disBroker/disBroker/entityTranslator.h

Go to the documentation of this file.

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


#pragma once

#include <disBroker/disTranslator.h>
#include <vl/reflectedEntityList.h>
#include <vl/entityPublisher.h>

class DtEntityStateRepository;

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

namespace MAKVrExchange
{

   class DtPortalObject;

   namespace DtDisBroker
   {

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

      template <>
      DT_DLL_DISBROKER DtObjectPublisher*
         DtDisObjectTranslator<ENTITY_TEMPLATE_ARGS>::instantiateDisPublisher(
         const DtPortalReflectedEntity* refObj, const DtEntityIdentifier& name );


      class DT_DLL_DISBROKER DtEntityTranslator
         : public DtDisObjectTranslator<ENTITY_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Entity State" );

         DtEntityTranslator( DtBroker* broker );

         virtual ~DtEntityTranslator();

         virtual void tick();


         virtual void initializePortalCallbacks();
         virtual void removePortalCallbacks();


      protected:


         static bool portalDiGuyDiscoveryCriteria( const DtPortalReflectedObject* obj, void* usr );

         static void portalDiGuyAddedCb( const DtPortalReflectedDiGuy& obj, void* usr );

         static void portalDiGuyUpdatedCb( const DtPortalReflectedDiGuy& obj, void* usr );

         static void portalDiGuyDeletedCb( const DtPortalReflectedDiGuy& obj, void* usr );


         virtual void initializeDisCallbacks();


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

         virtual void discoverDisObject( DtReflectedEntity* obj );

         virtual void discoverPortalObject( const DtPortalReflectedEntity& obj );

         virtual void discoverPortalDiGuy( const DtPortalReflectedDiGuy& obj );

         virtual DtString disObjectName( const DtPortalReflectedEntity* refObj ) const;

         virtual void createDisPublisher( DtBrokerObject* brokerObject );

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

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

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

         virtual void receivePortalDiGuyUpdate( const DtPortalReflectedDiGuy& obj );

         virtual void removeDisObject( const DtReflectedObject& refObj );

         virtual void removePortalObject( const DtPortalReflectedEntity& refObj );

         virtual void removePortalDiGuy( const DtPortalReflectedDiGuy* diGuy );

         virtual void deleteDisPublisher( DtBrokerObject* brokerObj );



         virtual bool hasDiGuyAttributes( const DtEntityStateRepository& entity );

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

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

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

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

         virtual DtPortalDiGuy* translate( DtPortalDiGuy* destination,
            const DtEntityStateRepository& source );

         virtual DtEntityStateRepository* translate(
            DtEntityStateRepository* destination, const DtPortalDiGuy& source );


      private:

         DtEntityTranslator( const DtEntityTranslator& other );

         DtEntityTranslator& operator = ( const DtEntityTranslator& other );

      protected:

         typedef std::map<DtEntityIdentifier,DtBrokerObject*> EntityByEntityIdMap;
         EntityByEntityIdMap myPortalEntityByEntityIdMap;
         EntityByEntityIdMap myDisEntityByEntityIdMap;

         typedef std::map<DtEntityIdentifier,const DtPortalReflectedDiGuy*> DiGuyWaitList;
         DiGuyWaitList myDiGuyWaitList;

         typedef std::map<DtEntityIdentifier,DtPortalDiGuyPublisher*> PortalDiGuyPublisherMap;
         PortalDiGuyPublisherMap myPortalDiGuyPublisherMap;

         DtPortalReflectedDiGuyManager* myPortalReflectedDiGuyManager;

      };

   }
}