CommunicationHandler.h

Go to the documentation of this file.

#pragma once
 
// Service header
#include "DataBaseInfo.h"
 
// OpenTwin header
#include "OTCore/JSON.h"
#include "OTCore/Flags.h"
#include "OTCore/OTClassHelper.h"
 
// Qt header
#include <QtNetwork/qlocalserver.h>
#include <mutex>
 
class SubprocessManager;
 
class CommunicationHandler : public QLocalServer {
    Q_OBJECT
    OT_DECL_NOCOPY(CommunicationHandler)
    OT_DECL_NODEFAULT(CommunicationHandler)
public:
    CommunicationHandler(SubprocessManager* _manager, const std::string& _serverName);
    ~CommunicationHandler();
 
    bool sendToClient(const ot::JsonDocument& _document, std::string& _response);
 
    void setModelUrl(const std::string& _url) { m_modelUrl = _url; m_modelUrlSet = false; };
    void setFrontendUrl(const std::string& _url) { m_frontendUrl = _url; m_frontendUrlSet = false; };
    void setDataBaseInfo(const DataBaseInfo& _info) { m_databaseInfo = _info; m_databaseInfoSet = false; };
 
    const std::string& getServerName(void) const { return m_serverName; };
 
    bool sendConfigToClient(void);
 
    void cleanupAfterCrash(void);
 
private Q_SLOTS:
    void slotNewConnection(void);
    void slotMessageReceived(void);
    void slotClientDisconnected(void);
    void slotProcessMessage(std::string _message);
 
private:
    enum class ClientState {
        Disconnected,
        WaitForPing,
        Ready,
        WaitForResponse,
        ReponseReceived
    };
 
    void processNextEvent(void);
 
    bool sendServiceInfoToClient(void);
    bool sendModelConfigToClient(void);
    bool sendFrontendConfigToClient(void);
    bool sendDataBaseConfigToClient(void);
 
    ClientState getClientState();
    void setClientState(ClientState _clientState);
 
    bool waitForClient(void);
    
    bool sendToClient(const QByteArray& _data, bool _expectResponse, std::string& _response);
 
    SubprocessManager* m_manager;
    std::string m_serverName;
 
    QLocalSocket* m_client;
    ClientState m_clientState; //State is accessed by two threads, use the threadsafe getter and setter
    std::mutex m_clientStateMutex;
 
    bool m_isInitializingClient;
 
    bool m_serviceAndSessionInfoSet;
 
    std::string m_frontendUrl;
    bool m_frontendUrlSet;
 
    std::string m_modelUrl;
    bool m_modelUrlSet;
 
    DataBaseInfo m_databaseInfo;
    bool m_databaseInfoSet;
 
    std::string m_response;
 
};