PicoScenesMessagingService.hxx

Go to the documentation of this file.

//
// Created by Zhiping Jiang on 7/17/22.
//
 
#ifndef PICOSCENES_PLATFORM_PICOSCENESMESSAGINGSERVICE_HXX
#define PICOSCENES_PLATFORM_PICOSCENESMESSAGINGSERVICE_HXX
 
#include <any>
#include "BoostHeaders.hxx"
#include "NICPortal.hxx"
 
using UniversalMessageType = std::tuple<std::any, std::string, std::string, std::string>;
 
class PicoScenesMessagingService {
public:
    static std::shared_ptr<PicoScenesMessagingService> getInstance(const std::string &messagingChannelId = "default");
 
    static UniversalMessageType makeMessage(const std::any &object, const std::string &destination, const std::string &source, const std::string &description);
 
    void append2MessageQueue(const UniversalMessageType &message);
 
    void clearMessageQueue();
 
    void send(const ModularPicoScenesRxFrame &rxFrame, const std::string &destination, const std::string &source, const std::string &description = "");
 
    void send(const ModularPicoScenesTxFrame &txFrame, const std::string &destination, const std::string &source, const std::string &description = "");
 
    void send(const std::string &textContent, const std::string &destination, const std::string &source, const std::string &description = "");
 
    void send(const pt::ptree &ptree, const std::string &destination, const std::string &source, const std::string &description = "");
 
    void send(const U8Vector &data, const std::string &destination, const std::string &source, const std::string &description = "");
 
    void send(const uint8_t *data, size_t bufferLength, const std::string &destination, const std::string &source, const std::string &description = "");
 
    void registerMessageHandler(const std::string &handlerName, std::function<void(const UniversalMessageType &)> handler);
 
    void unregisterHandler(const std::string &handlerName);
 
private:
    PicoScenesMessagingService();
 
    bool serviceState = true;                        
    std::deque<UniversalMessageType> appendingMessageQueue; 
    std::mutex queueMutex;                          
    std::mutex handleMutex;                         
    std::deque<UniversalMessageType> messageQueue;  
    std::map<std::string, std::function<void(const UniversalMessageType &)>> handlers; 
 
    std::mutex queueOperationMutex;                 
    std::condition_variable queueOperationCV;       
 
    void messagingServiceLoop();
};
 
 
#endif //PICOSCENES_PLATFORM_PICOSCENESMESSAGINGSERVICE_HXX