ProjectSynchronization.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_PROJECTSYNCHRONIZATION_HPP
#define IV_SRC_COMMS_PROJECTSYNCHRONIZATION_HPP
 
#include "comms/ip/IPCommunicationDriver.hpp"
#include "comms/redundancy/messages/RedundancyMessageProjectRequest.hpp"
#include "comms/redundancy/messages/RedundancyMessageProjectResponse.hpp"
#include "comms/redundancy/messages/messages.hpp"
#include "comms/socket/CNetPort.hpp"
 
#include <memory>
 
namespace iv::comms
{
 
class ProjectSynchronization
{
public:
    // Singleton
    static std::unique_ptr<iv::comms::ProjectSynchronization> &create();
 
    ProjectSynchronization(const ProjectSynchronization &other) = delete;
    ProjectSynchronization(ProjectSynchronization &&other) = delete;
    ~ProjectSynchronization() = default;
 
    ProjectSynchronization &operator=(const ProjectSynchronization &other) = delete;
    ProjectSynchronization &operator=(ProjectSynchronization &&other) = delete;
 
    static bool sendProjectInfoMessage();
    static bool sendProjectRequestMessage(const iv::types::stationId &station);
    static bool sendProject(const iv::types::stationId &station,
                            iv::comms::redundancy::eProjectSyncronizationFile fileType);
 
    static bool
    processProjectInfoMessage(const std::shared_ptr<iv::comms::redundancy::RedundancyMessageProjectInfo> &message);
    static bool processProjectRequestMessage(
            const std::shared_ptr<iv::comms::redundancy::RedundancyMessageProjectRequest> &message);
    static bool processProjectResponseMessage(
            const std::shared_ptr<iv::comms::redundancy::RedundancyMessageProjectResponse> &message);
 
private:
    ProjectSynchronization();
 
    static bool prvSendMessage(const std::vector<std::byte> &message,
                               const iv::model::comms::net::IpSettings &ipSettings);
    static bool prvSendFile(std::string_view projectFolder, std::string_view filePath,
                            iv::comms::redundancy::eProjectSyncronizationFile fileType,
                            const iv::model::comms::net::IpSettings &ipSettings);
 
    static std::unique_ptr<iv::comms::ProjectSynchronization> instance;
 
    struct SyncStationsInfo
    {
        iv::types::stationId station;
        iv::types::timestamp lastUpdateTime;
        std::string reference;
        std::string lastVersion;
    };
 
    std::vector<std::weak_ptr<iv::comms::ip::IPCommunicationDriver>> m_redundancyDrivers;
    std::map<iv::types::stationId, iv::model::comms::net::IpSettings> m_peerStationsIps;
 
    std::map<iv::types::stationId, SyncStationsInfo> m_stationsSyncInfo;
    iv::types::stationId m_station;
 
    struct Constants
    {
        static constexpr iv::types::timestamp lastUpdateDifference {15 * iv::constants::time::MillisecondsInSeconds};
    };
};
 
}// namespace iv::comms
 
#endif//IV_SRC_COMMS_PROJECTSYNCHRONIZATION_HPP