tenaBroker/tenaBroker/entityTranslator.h

Go to the documentation of this file.

/*****************************************************************************
 * Copyright (c) 2016 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <tenaBroker/baseEntityTranslator.h>

#include <vlTena/reflectedEntityList.h>
#include <vlTena/entityPublisher.h>

#include <vl/entityStateRepository.h>

class DtReflectedEntity;

#define ENTITY_TEMPLATE_ARGS \
   DtPortalEntity, DtPortalReflectedEntity, \
   DtReflectedEntity, DtReflectedEntityList, \
   DtEntityStateRepository, DtEntityPublisher

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

      template <>
      DT_DLL_TENABROKER DtEntityIdentifier
         DtTenaObjectTranslator<ENTITY_TEMPLATE_ARGS>::mapIdentifier(
         const DtPortalReflectedEntity* refObj, const DtString& identifier );

      template <>
      DT_DLL_TENABROKER DtObjectPublisher*
         DtTenaObjectTranslator<ENTITY_TEMPLATE_ARGS>::instantiateTenaPublisher(
         const DtPortalReflectedEntity* refObj, const DtEntityIdentifier& name );


      class DT_DLL_TENABROKER DtEntityTranslator
         : public DtBaseEntityTranslator<ENTITY_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Entity State" );

         DtEntityTranslator( DtBroker* broker );

         virtual ~DtEntityTranslator();

      protected:

         virtual bool isThrottlingRateOk( DtEntityPublisher* publisher,
            DtBrokerObject* brokerObj );

         virtual bool isTenaPublishable( DtBrokerObject* brokerObj,
            const DtPortalReflectedEntity* refObj );

         virtual DtString tenaObjectName( const DtPortalReflectedEntity* refObj ) const;

         virtual void createTenaPublisher( DtBrokerObject* brokerObj );

         virtual void updateTenaBrokerObject( DtBrokerObject* brokerObj,
            const DtEntityStateRepository& sr );

         virtual void updatePortalBrokerObject( DtBrokerObject* brokerObj,
            const DtPortalEntity& sr );

         virtual void updateFilteredState( DtBrokerObject* brokerObj,
            DtPortalEntityPublisher* publisher, DtReflectedEntity* refObj );

         virtual DtPortalEntity* translate( DtPortalEntity* destination,
            const DtEntityStateRepository& source, const DtReflectedEntity& refObj );

         virtual void syncPortalDeadReckonedValues( DtPortalEntity& destination,
            const DtEntityStateRepository& source );

         virtual DtEntityStateRepository* translate( DtEntityStateRepository* destination,
            const DtPortalEntity& source, const DtPortalReflectedEntity& refObj );

         virtual void syncTenaDeadReckonedValues( DtEntityStateRepository& destination,
            const DtPortalEntity& source );

      };

   }
}