WeArtClient.h

Go to the documentation of this file.

 
#pragma once
#include "WeArtCommon.h"
#include "WeArtMessageListener.h"
#include "WeArtMessages.h"
#include "WeArtMessageSerializer.h"
#include "WeArtThimbleTrackingObject.h"
#include "WeArtTrackingRawData.h"
#include "WeArtAnalogSensorData.h"
#include <winsock2.h>
#include <future>
#include <forward_list>
 
class WeArtClient {
public:
    using MessageCallback = std::function<void(WeArtMessage*)>;
 
    WeArtClient(PCSTR ip_address, PCSTR port);
 
    void Start(TrackingType trackType = TrackingType::WEART_HAND);
 
    void Stop();
 
    void Run();
 
    bool IsConnected();
 
    void Close();
 
    void StartCalibration();
 
    void StopCalibration();
 
    void StartRawData();
 
    void StopRawData();
 
    void SendMessage(WeArtMessage* message);
 
    void AddThimbleTracking(WeArtThimbleTrackingObject* trackingObjects);
 
    void AddThimbleRawSensors(WeArtTrackingRawData* rawSensorData);
 
    void AddThimbleAnalogRawSensor(WeArtAnalogSensorData *analogRawSensorData);
 
    int SizeThimbles();
 
    void AddMessageListener(WeArtMessageListener* listener);
 
    void AddMessageCallback(MessageCallback callback);
 
    void RemoveMessageListener(WeArtMessageListener* listener);
 
    void RemoveMessageCallback(MessageCallback callback);
 
    void AddConnectionStatusCallback(std::function<void(bool)> callback);
 
    enum ErrorType {
        ConnectionError,
        SendMessageError,
        ReceiveMessageError
    };
 
    void AddErrorCallback(std::function<void(WeArtClient::ErrorType)> callback);
 
protected:
    WeArtMessageSerializer messageSerializer;
 
    void OnReceive();
 
private:
    bool Connected = false;
 
    SOCKET ConnectSocket;
 
    std::vector<WeArtThimbleTrackingObject*> thimbleTrackingObjects;
    std::vector<WeArtMessageListener*> messageListeners;
    std::vector<MessageCallback> messageCallbacks;
 
    void ForwardingMessages(std::vector<WeArtMessage*> messages);
 
    // Connection status and errors callbacks management
    std::vector<std::function<void(bool)>> connectionStatusCallbacks;
    std::vector<std::function<void(ErrorType)>> errorCallbacks;
    std::forward_list<std::future<void>> pendingCallbacks;
 
    void NotifyConnectionStatus(bool connected);
    void NotifyError(ErrorType errorType);
    void ClearProcessedCallbacks();
    
    PCSTR IP_ADDESS;
    PCSTR PORT;
};