CscMessageSender.h

Go to the documentation of this file.

#ifndef CscMessageSender_H_
#define CscMessageSender_H_
 
#include "CscCommon.h"
#include "CscMessageEncryption.h"
#include "CscMessagingRequestContext.h"
#include "TcpClient.h"
#include <mutex>
 
using std::mutex, std::function;;
 
namespace conscience_core::communication {
 
    typedef string CscMessageId;
    typedef string CscMessageChunkId;
 
    class CannotSendMessageException : public exception {
    public:
        CannotSendMessageException(const string &errorMessage) noexcept : errorMessage(errorMessage) {}
        ~CannotSendMessageException() noexcept override = default;
        const char *what() const noexcept override {
            return errorMessage.c_str();
        }
    private:
        const string errorMessage;
    };
 
    class CscMessageSender {
    public:
        CscMessageSender(const CscMessageEncryption *encryption, const CscMessagingPort udpResponsePort);
        ~CscMessageSender() {
        }
 
        void sendAndDownloadResponseBytes(vector<unsigned char> *data, fs::path downloadResponseToPath, ptr<CscMessagingRequestContext> context, optional<function<void(float progress)>> onDownloadProgress = {});
        optional<vector<unsigned char>*> send(vector<unsigned char> *data, ptr<CscMessagingRequestContext> context);
        optional<vector<unsigned char>*> send(vector<unsigned char> *data, const string ip, CscMessagingPort port, CscMessagingProtocol protocol);
        optional<vector<unsigned char>*> sendTcp(vector<unsigned char> *data, const string ip, const int port);
        optional<vector<unsigned char>*> sendTcpWithClient(TcpClient *tcpClient, vector<unsigned char> *data, bool noResponseExpected, bool closeClient);
        
        optional<vector<unsigned char>*> sendMessage(const string &message, ptr<CscMessagingRequestContext> context);
        optional<vector<unsigned char>*> sendMessage(const string &message, const string ip, CscMessagingPort port, CscMessagingProtocol protocol);
 
        optional<vector<unsigned char>*> sendUdp(const string &message, const string ip, CscMessagingPort port) const;
        optional<vector<unsigned char>*> sendUdp(vector<unsigned char> *data, const string ip, CscMessagingPort port) const;
        optional<vector<unsigned char>*> sendTcpWithClient(TcpClient *tcpClient, const string &message, bool noResponseExpected, bool closeClient);
 
    private:
        const CscMessageEncryption *encryption;
 
        inline static unsigned long long chunkedMessageCounter = 0;
        string requestIdPrefix;
        inline static mutex chunkedMessageCounterMutex;
        const CscMessagingPort udpResponsePort;
 
        unique_ptr<CscLogger> logger;
    };
}
 
#endif