vrlinkSignalInteractionTranslator.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2020 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/


#pragma once

#include <vrlinkNetworkInterface/vrlinkNetworkInterfaceDefines.h>
#include <vrlinkNetworkInterface/vrlinkEventTranslator.h>
#include <vrlinkNetworkInterface/splitMessageCollector.h>
#include <vrfMsgTransport/rawSignalEvent.h>
#include <vrfMsgTransport/vrfSignalEvent.h>
#include <vl/signalInteraction.h>

namespace makVrf
{
   class DtVrlinkNetworkInterface;

   class DT_DLL_vrlinkNetworkInterface DtVrlinkSignalInteractionTranslator : public DtVrlinkEventTranslator
   {
   public:
      struct SignalInfoHeader
      {
         SignalInfoHeader()
         {
            strcpy(&vrfver[0], "VRF5OH");
         }

   #if DtDIS
         unsigned int protocolId;
   #endif
         char vrfver[6];
         int siteId;
         int appId;
         int vrfMessageVersionSupported;
         int userDataLength;
         int commModelNameLength;
      };

   public:
      DtVrlinkSignalInteractionTranslator();
      virtual ~DtVrlinkSignalInteractionTranslator() override;

      virtual void init(DtVrlinkNetworkInterface*) override;

      static void netMessageCallback(::DtSignalInteraction* interaction, void * usr);
      virtual void processNetMessage(::DtSignalInteraction* interaction);

   protected:
      virtual int protocolId(::DtSignalInteraction* interaction) const;
      virtual bool processEvent(const makVrfEvents::DtEvent&) override;
      virtual bool processEvent(const makVrfEvents::DtRawSignalEvent*);
      virtual bool processEvent(const makVrfEvents::DtVrfSignalEvent*);
      virtual void sendInteraction(const SignalInfoHeader&, const DtSplitMessageCollector::SplitInfo&, 
         const char* pBuffer, const DtGlobalObjectDesignator& entityId, double sampleRate, int encodingClass,
         int encodingType, int numSamples = 1, int radioIndex = 0, unsigned int streamTagUpper = 0,
         unsigned int streamTagLower = 0);

      virtual void processVoiceMessage(::DtSignalInteraction* interaction);
      virtual void processVrfMessage(::DtSignalInteraction* interaction);

   protected:
      DtSplitMessageCollector* mySplitMessageCollector;
   };

   DT_DLL_vrlinkNetworkInterface unsigned long long  DtCreateStreamTag(int site, int host, int entityNum, int radioId);
   DT_DLL_vrlinkNetworkInterface void DtDecodeStreamTag(unsigned long long tag, int& site, int& host, int& entityNum, int& radioId);
   DT_DLL_vrlinkNetworkInterface unsigned long long DtCreateStreamTag(const DtEntityIdentifier& entityId, int radioId);
   DT_DLL_vrlinkNetworkInterface void DtDecodeStreamTag(unsigned long long tag, DtEntityIdentifier& entityId, int& radioId);
   DT_DLL_vrlinkNetworkInterface void DtDecodeRadioName(const std::string& name, DtEntityIdentifier& entityId, int& radioId);
}