ConnectionHub.h

#pragma once
 
#if !defined( EMSCRIPTEN )
 
#include "Connection.h"
#include "MessageHub.h"
 
namespace Cogs {
  namespace Network {
    class COGSFOUNDATION_API ConnectionHub : public ConnectionTCP, public MessageHub {
    public:
                            ConnectionHub(uint32_t id) : MessageHub(id) {}
                            ConnectionHub(Socket socket, const SockaddrIn& addr) : ConnectionTCP(socket, addr), MessageHub(0) {}
 
      virtual bool          processOutgoing() override;
      virtual bool          processIncoming() override;
 
    protected:
      virtual void          handleReceivedMessage(const Message::Ptr& message);
      virtual bool          disconnect() override;
 
    private:
              struct Header {
                uint32_t  id = 0;
                uint64_t  size = 0;
              };
 
              Message::Ptr  outgoingMessage;
              uint64_t      bytesSent = 0;
 
              Message::Ptr  incomingMessage;
              Header        incomingHeader;
    };
  }
}
 
#endif