CscRealEntitiesCollector.h

Go to the documentation of this file.

#ifndef CscRealEntitiesCollector_h
#define CscRealEntitiesCollector_h
 
#include "CscCommon.h"
#include "Axiomes/Csc3dTypes.h"
namespace conscience_core::communication {
class CscMessagingManager;
}
using namespace conscience_core::communication;
using namespace conscience_core::axiomes;
 
namespace conscience_core::core_objects::entities {
struct CscNetworkEntityData {
public:
    CscNetworkEntityData(
        string name,
        string osVersion,
        string modelId,
        string owner,
        string serialNumber,
        string birthday,
        string provider,
        string engineIp,
        string enginePort,
        string rtspLink,
        string ip,
        bool useGnssPositioning = false,
        optional<PositionFormat> simulatedInputsType = {},
        optional<string> localProjection = {});
 
    const string name;
    const string osVersion;
    const string modelId;
    const string owner;
    const string serialNumber;
    const string birthday;
    const string provider;
    const string engineIp;
    const string enginePort;
    const string rtspLink;
    const string ip;
    const bool useGnssPositioning;
    const optional<PositionFormat> simulatedInputsType;
    const optional<string> localProjection;
 
    static CscNetworkEntityData *fromProfile(const string &entityIp, const vector<string> &profileArgs);
};
 
class CscRealEntitiesCollector;
 
struct EntitiesCollectAutoStop {
public:
    EntitiesCollectAutoStop(CscRealEntitiesCollector *realEntityCollector, int delayInSeconds);
    void setShouldStopCollecting(bool shouldStopCollecting);
    bool getShouldStopCollecting() const;
    bool isStopped() const;
 
private:
    bool stopped = false;
    bool shouldStopCollecting = false;
    CscRealEntitiesCollector *realEntityCollector = nullptr;
};
 
class CscRealEntitiesCollectorMessagingHandler;
 
class CscRealEntitiesCollector {
public:
    CscRealEntitiesCollector(optional<function<void(bool)>> onCollectStartAndStop = {});
    ~CscRealEntitiesCollector();
    void collectAvailableEntities(function<void(CscNetworkEntityData *)> callback, optional<int> autoStopAfterSeconds = {});
    void stop();
private:
    optional<function<void(bool)>> onCollectStartAndStop;
    CscMessagingManager *messagingManager = nullptr;
    CscRealEntitiesCollectorMessagingHandler *messageHandler = nullptr;
    EntitiesCollectAutoStop *currentCollectAutoStop = nullptr;
    const unsigned udpServerPort = 1903;
    const unsigned tcpServerPort = 2003;
 
    bool scanSendRequestsInProgress = false;
 
    void sendProfileRequestToNetworkEntities();
    void initCommunicationsComponent(function<void(CscNetworkEntityData *)> listener);
    void stopWithNoLock();
 
    unique_ptr<CscLogger> logger = CscLogger::getForCategory("CscRealEntitiesCollector");
    mutex stopMutex;
    mutex collectEntitiesMutex;
};
 
}
 
#endif