#ifndef __Session_h__
#define __Session_h__

#include "TCPSocket.h"
#include "SessionFilter.h"

namespace core {

   class Command;
   
   class TCPServer;
   
   ///
   /// TCPSession
   ///
   /// TCPSession defines the nature of the interaction with the client
   /// and stores persistent data for a defined session. TCPSession objects
   /// are not sockets but instead provide a communications control 
   /// mechanism. Protocol conversations are provided through extensions
   /// from this object.  
   /// 
   /// 
   ///
   
   class TCPSession : public TCPSocket {
      
    public:

      ///
      ///
      ///
      
      TCPSession(EPoll &ePoll, TCPServer &server, std::string text = "");

      ///
      ///
      ///
      
      ~TCPSession(); 
      
      Command *grab = NULL;
      
      virtual void output(std::stringstream &data);

      ///
      /// Use out to send data to the session socket or other session sockets.
      ///
      
      std::stringstream out;
      
      /// 
      /// The send method is used to output the contents of the out stream
      /// to the session containing the stream.
      ///
      
      void send();
      
      ///
      /// Use this sendToAll method to output the contents of the out stream
      /// to all the connections on the server excluding the sender session. 
      ///
      
      void sendToAll();
      
      ///
      /// Use this sendToAll method to output the contents of the out stream
      /// to all the connections on the server excluding the sender session
      /// and the entries identified by the passed in filter object.
      ///
      
      void sendToAll(SessionFilter filter);

      ///
      /// Use this method to terminate this TCPSession. 
      ///
      
      void terminate();
      
      ///
      /// 
      ///
      
      TCPServer &server;

      enum Mode {LINE, BLOCK};
      
    protected:
 
      ///
      ///
      ///

      virtual void onRegistered() override;    

      ///
      /// Override this method to receive data directly from the socket as data is
      /// received. If you need data split by line termination characters then
      /// override the onLineReceived method instead.
      ///
      
      virtual void onDataReceived(char *data, int len) override;      
      
      ///
      /// Override the onLineReceived method to receive a string of characters that 
      /// represents a single line of data terminated by a LF or CRLF. If onDataReceived 
      /// was overriden this method will not be called unless the onDataReceived calls
      /// this method explicitly using the class and member name.
      ///
      
      virtual void onLineReceived(std::string line); 
      
      ///
      /// Override the onBlockReceived method to receive a string of characters that 
      /// represents a single block of data of length determined by the block length value. If 
      /// onDataReceived was overriden this method will not be called unless the onDataReceived 
      /// calls this method explicitly using the class and member name.
      ///
      
      virtual void onBlockReceived(std::string block); 

      ///
      /// This method is called from within the protocol method when protocol is called
      /// on the initial connection where the data is an empty string. Use this method
      /// to deliver a message to the connection upon connection.
      ///
      
      virtual void onConnected();
      
      ///
      /// Override the protocol method to manage and control the session communications
      /// in your inherited session. If you do not override this method then the Session
      /// default will process the 'commands' added to the server object using the 
      /// processRequest method on the session input. 
      ///
      /// When data is received within the session two modes are available to pass the 
      /// data through the protocol method: LINE or BLOCK.
      ///
      
      virtual void protocol(std::string data); 

      ///
      /// Use the setMode method to set the receiving mode for the data on this socket. 
      /// Data can be received in LINE mode, which will receive data from the socket one 
      /// line at a time, or BLOCK mode where a certain specified data block is received
      /// before calling the onBlockReceived method.
      ///
      
      void setMode(Mode mode, int size = 0); 
      
    private:
      char *lineBuffer = NULL;
      int lineBufferSize = 0;
      std::mutex mtx;
      bool term = false;
      enum Mode mode = LINE;
      int blockSize;
      
   };
   
}

#endif