ServiceRunStarter.h

Go to the documentation of this file.

#pragma once
 
// OT header
#include "OTCore/CoreTypes.h"
 
// std header
#include <mutex>
#include <list>
 
class Service;
class Session;
 
class ServiceRunStarter {
public:
    static ServiceRunStarter& instance();
 
    void addService(Session * _session, Service * _service);
    void sessionClosing(const std::string& _sessionId);
 
private:
    ServiceRunStarter();
    virtual ~ServiceRunStarter();
 
    bool queueEmpty(void);
    void worker(void);
    void sendRunMessageToService(std::string serviceURL, std::string messageOut, std::string serviceName, std::string serviceType, std::string serviceId);
 
    struct startupInformation {
        std::string sessionId;
 
        std::string serviceName;
        std::string serviceType;
        std::string serviceUrl;
        ot::serviceID_t serviceId;
 
        std::string credentialsUserName;
        std::string credentialsUserPassword;
        
        std::string databaseUserName;
        std::string databaseUserPassword;
 
        std::string userCollection;
        std::string sessionType;
    };
 
    std::mutex                      m_mutex;
    bool                            m_isStopping;
    bool                            m_isRunning;
    std::list<startupInformation>   m_queue;
};