BittyBuzzMessageService.h

Go to the documentation of this file.

#ifndef __BITTYBUZZMESSAGESERVICE_H_
#define __BITTYBUZZMESSAGESERVICE_H_
 
#include "IBittyBuzzMessageService.h"
#include <bbzmsg.h>
#include <bsp/IBSP.h>
#include <cpp-common/ICircularQueue.h>
#include <logger/ILogger.h>
 
class BittyBuzzMessageService : public IBittyBuzzMessageService {
  public:
    BittyBuzzMessageService(ICircularQueue<MessageDTO>& hostQueue,
                            ICircularQueue<MessageDTO>& remoteQueue,
                            ICircularQueue<MessageDTO>& buzzQueue,
                            IBSP& bsp,
                            ILogger& logger);
 
    ~BittyBuzzMessageService() override = default;
 
    bool callHostFunction(uint16_t agentId,
                          const char* functionName,
                          const FunctionCallArgumentDTO* args,
                          uint16_t argsLength) override;
 
    bool callBuzzFunction(uint16_t agentId,
                          const char* functionName,
                          const FunctionCallArgumentDTO* args,
                          uint16_t argsLength) override;
 
    bool queueBuzzMessages() override;
 
  private:
    std::optional<std::reference_wrapper<BuzzMessageDTO>> getNextMessage();
    bool flush();
 
    ICircularQueue<MessageDTO>& m_hostQueue;
    ICircularQueue<MessageDTO>& m_remoteQueue;
    ICircularQueue<MessageDTO>& m_buzzQueue;
    BuzzMessagesDTO m_messages;
    IBSP& m_bsp;
    ILogger& m_logger;
};
 
#endif // __BITTYBUZZMESSAGESERVICE_H_