CscMessageReader.h

Go to the documentation of this file.

#ifndef CscMessageReader_H_
#define CscMessageReader_H_
 
#include "CscCommon.h"
#include "CscMessageEncryption.h"
#include "CscMessagingRequestContext.h"
#include <functional>
#include <mutex>
 
using std::mutex, std::function;
 
namespace conscience_core::communication {
 
typedef string CscMessageId;
typedef string CscMessageChunkId;
 
struct CscMessageMetaparams {
    optional<string> udpRemoteClientId = {};
    optional<CscMessagingPort> udpResponsePort = {};
};
 
static const string CONSCIENCE_COMMUNICATION_TIMEOUT_PREFIX = "__CSC_COM_SET_TIMEOUT";
 
class CscMessageReader {
public:
    CscMessageReader(const CscMessageEncryption *encryption,
                     function<void(const string &message, ptr<CscMessagingRequestContext> context)> onMessage);
    ~CscMessageReader();
 
    optional<string> pushMessageData(vector<unsigned char> *rawMessageData, ptr<CscMessagingRequestContext> context);
 
    static CscMessageMetaparams extractMetaParams(string &message);
 
private:
    const CscMessageEncryption *encryption;
    const function<void(const string &message, ptr<CscMessagingRequestContext> context)> onMessageReadComplete;
    static void extractMetaParams(string &message, CscMessagingRequestContext *context);
 
    mutex messagesReconstructionStartMutex;
    mutex messagesReconstructionMutex;
    bool messageReconstructionEnable = false;
    map<CscMessageId, map<string, string>> messagesChunksInReconstruction;
    map<CscMessageId, unsigned long long> messagesLastChunkTimestampMillis;
    map<CscMessageId, ptr<CscMessagingRequestContext>> messagesChunksContext;
    void startMessagesReconstruction();
    void stopMessagesReconstruction();
    void checkAllMessageChunkedReceivedAndReconstuctInOrder();
 
    string onMessageFull(const string &fullMessage, ptr<CscMessagingRequestContext> context);
 
    bool handleTimeoutPrefix(string &messageData, ptr<CscMessagingRequestContext> context);
    bool handleAutoClosePrefix(string &messageData, ptr<CscMessagingRequestContext> context);
 
    void extractMetaParams(string &message, ptr<CscMessagingRequestContext> context);
 
    void sanitizeMessage(string &message);
    bool processMessageChunk(string &message, ptr<CscMessagingRequestContext> context);
 
    unique_ptr<CscLogger> logger;
};
}
 
#endif