UdpMessaging.h

Go to the documentation of this file.

#pragma once

#include "UdpMessagingTransaction.h"
#include "IDpaMessageForwarding.h"
#include "IDpaExclusiveAccess.h"
#include "UdpChannel.h"
#include "IMessaging.h"
#include "TaskQueue.h"
#include <string>
#include <atomic>

class DaemonController;

class UdpMessaging : public IMessaging, public IDpaMessageForwarding, public IDpaExclusiveAccess
{
public:
  enum class Mode {
    Operational,
    Service,
    Forwarding
  };

  UdpMessaging() = delete;
  UdpMessaging(const std::string& name);

  virtual ~UdpMessaging();

  void start() override;
  void stop() override;
  void update(const rapidjson::Value& cfg) override;
  const std::string& getName() const override { return m_name; }
  void registerMessageHandler(MessageHandlerFunc hndl) override;
  void unregisterMessageHandler() override;
  void sendMessage(const ustring& msg) override;

  // IDpaMessageForwarding overriden methods
  std::unique_ptr<DpaTransaction> getDpaTransactionForward(DpaTransaction* forwarded) override;

  // IDpaExclusiveAccess overriden methods
  void setExclusive(IChannel* chan) override;
  void resetExclusive() override;

  void sendDpaMessageToUdp(const DpaMessage&  dpaMessage);

  void setDaemon(IDaemon* d) { m_daemon = d; }

private:
  void getGwIdent(ustring& message);

  void getGwStatus(ustring& message);

  int handleMessageFromUdp(const ustring& udpMessage);
  
  void encodeMessageUdp(ustring& udpMessage, const ustring& message = ustring());

  void decodeMessageUdp(const ustring& udpMessage, ustring& message);

  IDaemon *m_daemon = nullptr;
  UdpMessagingTransaction* m_operationalTransaction = nullptr;

  IChannel* m_exclusiveChannel = nullptr;
  UdpChannel* m_udpChannel = nullptr;
  IMessaging::MessageHandlerFunc m_messageHandlerFunc;
  TaskQueue<ustring> *m_toUdpMessageQueue = nullptr;

  // configuration
  std::string m_name;
  unsigned m_remotePort = 55000;
  unsigned m_localPort = 55300;
};