TCPServer.h

#ifndef __TCPServer_h__
#define __TCPServer_h__
 
#include "Socket.h"
#include "TCPSocket.h"
#include "IPAddressList.h"
#include "Command.h"
#include "CommandList.h"
#include "SubscriptionManager.h"
 
namespace core {
 
 
   class TCPServer : public TCPSocket, public Command {
 
    public:
 
 
      TCPServer(EPoll &ePoll, IPAddress address, std::string delimiter = " ", int depth = 10, std::string text = "");
 
 
      virtual ~TCPServer();
 
      virtual void sessionErrorHandler(std::string errorString, std::stringstream &out);
 
 
      virtual TCPSession * getSocketAccept(EPoll &epoll);
 
 
      std::vector<TCPSession *> sessions;
 
 
      CommandList commands;
 
 
      IPAddressList *blackList;
 
 
      IPAddressList *whiteList;
 
      void removeFromSessionList(TCPSession *session);
 
      void output(std::stringstream &out); 
 
 
      void sendToAll(std::stringstream &out);
 
 
      void sendToAll(std::stringstream &out, TCPSession &sender, SessionFilter filter);
 
 
      void sendToAll(std::stringstream &out, TCPSession &sender);
 
 
      SubscriptionManager subscriptions;
 
    protected:
 
 
      void onDataReceived(std::string data) override;
 
 
      int processCommand(coreutils::ZString &request, TCPSession &session) override;
 
    private:
 
      TCPSession * accept();
      std::mutex lock;
 
   };
 
}
 
#endif