CscEntityClient.h

Go to the documentation of this file.

#ifndef CscEntityClient_h
#define CscEntityClient_h
 
#include "CscCommon.h"
 
namespace conscience_core::communication {
class CscMessagingManager;
}
 
using namespace conscience_core::communication;
 
namespace conscience_core::ai {
 
struct CSC_DLL_IMPORTEXPORT CscEntityProcessCommandOptions {
    bool canUseUdp = false;
 
    optional<unsigned int> commandTimeoutSeconds = 45;
 
    optional<fs::path> downloadBytesToPath = {};
    optional<function<void(float progress)>> onDownloadProgress = {};
 
    static CscEntityProcessCommandOptions udp(optional<unsigned int> commandTimeoutSeconds = {});
    static CscEntityProcessCommandOptions tcp(optional<unsigned int> commandTimeoutSeconds = {});
};
 
class CSC_DLL_IMPORTEXPORT CscEntityClient {
public:
    CscEntityClient(const string &serialNumber);
    virtual ~CscEntityClient() = default;
    virtual bool isSimulated() const = 0;
    virtual void connect() = 0;
    virtual void disconnect() = 0;
 
    virtual optional<string> processCommandString(const string &command, const CscEntityProcessCommandOptions &options = {}) = 0;
 
    static function<string(const string &command, const string &serialNumber)> &doProcessCommand();
 
protected:
    const string serialNumber;
};
 
class CSC_DLL_IMPORTEXPORT CscEntityClientSimulated : public CscEntityClient {
public:
    CscEntityClientSimulated(const string &serialNumber);
    ~CscEntityClientSimulated();
    bool isSimulated() const override;
    void connect() override;
    void disconnect() override;
    optional<string> processCommandString(const string &command, const CscEntityProcessCommandOptions &options = {}) override;
 
private:
    unique_ptr<CscLogger> logger = CscLogger::getForCategory("CscEntityClientSimulated");
};
 
class CSC_DLL_IMPORTEXPORT CscEntityClientReal : public CscEntityClient {
public:
    CscEntityClientReal(const string &serialNumber, CscMessagingManager *messagingManager, string ip, unsigned tcpPort, unsigned udpPort);
    ~CscEntityClientReal();
    bool isSimulated() const override;
    void connect() override;
    void disconnect() override;
    optional<string> processCommandString(const string &command, const CscEntityProcessCommandOptions &options = {}) override;
 
private:
    int TIME_TO_RECEIVE_FULLSTATUS_IN_MILLIS = 500;
 
    CscMessagingManager *messagingManager = nullptr;
    string ip = "";
    unsigned tcpPort;
    unsigned udpPort;
 
    void sendRegistrationToEntity(string commandPrefix);
 
    unique_ptr<CscLogger> logger = CscLogger::getForCategory("CscEntityClientReal");
};
 
}
 
#endif