CscMessagingRequestContext.h

Go to the documentation of this file.

#ifndef CscMessagingRequestContext_H_
#define CscMessagingRequestContext_H_
 
#include "CscCommon.h"
#include "TcpClient.h"
 
#define ENTITY_PORT_UDP_DEFAULT 1705
#define ENTITY_PORT_TCP_DEFAULT 1805
#define ENGINE_PORT_UDP_DEFAULT 1707
#define ENGINE_PORT_TCP_DEFAULT 1807
#define MESSAGE_META_PARAM_UDP_RESPONSE_PORT "udpP"
#define MESSAGE_META_PARAMS_SEPARATOR ":|:"
 
namespace conscience_core::communication {
    typedef unsigned int CscMessagingPort;
 
    enum CscMessagingProtocol {
        UDP = 0,
        TCP = 1
    };
 
    class CscMessagingRequestContext {
    public:
        string getRemoteIp() const;
        CscMessagingProtocol getProtocol() const;
        
        CscMessagingPort getRemotePort() const;
        void setRemotePortForUdp(CscMessagingPort remotePort);
        
        optional<string> getRemoteUdpClientId() const;
        void setRemoteUdpClientId(optional<string> remoteUdpClientId);
        
        TcpClient *getTcpClient() const;
        
        static ptr<CscMessagingRequestContext> forUdp(const string &remoteIp, CscMessagingPort remotePort);
        static ptr<CscMessagingRequestContext> forTcp(TcpClient *tcpClient);
        static ptr<CscMessagingRequestContext> forTcp(const string &remoteIpAddress, CscMessagingPort remotePort);
 
        ~CscMessagingRequestContext();
 
        operator string() const;
        string toString() const;
 
        bool shouldAutoCloseAfterResponse() const;
 
        void setAutoCloseAfterResponse(bool enabled);
 
        optional<string> lastCommandResponse = {};
 
        optional<unsigned> sendTimoutSeconds = {};
 
        ptr<bool> destroyed = nullptr;
 
    private:
        CscMessagingRequestContext(const string &remoteIp, CscMessagingPort remotePort, CscMessagingProtocol protocol, TcpClient *tcpClient);
        
        bool autoCloseAfterResponse = true;
        string remoteIp;
        CscMessagingProtocol protocol = CscMessagingProtocol::UDP;
        CscMessagingPort remotePort;
        optional<string> remoteUdpClientId = {};
        TcpClient *tcpClient = nullptr;
    };
}
 
#endif