rprBroker/rprBroker/entityTranslator.h

Go to the documentation of this file.

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


#pragma once

#include <rprBroker/rprTranslator.h>
#include <vl/reflectedEntityList.h>
#include <vl/entityPublisher.h>
#include <map>

class DtReflectedEntity;
class DtReflectedEntityList;
class DtReflectedDIGuyObject;
class DtEntityStateRepository;
class DtReflectedDIGuyObjectList;
class DtDIGuyObjectStateRepository;

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

namespace MAKVrExchange
{

   class DtPortalEntity;

   namespace DtRprBroker
   {

      template <>
      DT_DLL_RPRBROKER DtEntityPublisher*
         DtRprObjectTranslator<ENTITY_TEMPLATE_ARGS>::instantiateRprPublisher(
            const DtPortalReflectedEntity* refObj, const DtString& name );


      class DT_DLL_RPRBROKER DtEntityTranslator
         : public DtRprObjectTranslator<ENTITY_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Entity State" );

         DtEntityTranslator( DtBroker* broker );

         virtual ~DtEntityTranslator();


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


         virtual void tick();

      protected:


         static bool portalDiGuyDiscoveryCriteria( const DtPortalReflectedObject* object, 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 bool isPortalPublishable( const DtBrokerObject* brokerObj ) const;



         virtual void discoverRprObject( DtReflectedEntity& refObj );

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

         virtual void discoverPortalObject( const DtPortalReflectedEntity& refObj );

         virtual void discoverPortalDiGuy( const DtPortalReflectedDiGuy& obj );

         virtual void receivePortalDiGuyUpdate( const DtPortalReflectedDiGuy& obj );

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

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

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

         virtual DtString rprObjectName( const DtPortalReflectedEntity* refObj ) const;

         virtual void fillOutgoingIds( DtEntityPublisher* publisher,
            const DtString& name );

         virtual void createRprPublisher( DtBrokerObject* brokerObject );

         virtual void removeRprObject( const DtReflectedObject& refObj );

         virtual void removePortalObject( const DtPortalReflectedObject& reflectedObj );

         virtual void removePortalDiGuy( const DtPortalReflectedDiGuy& obj );



         virtual bool hasDiGuyAttributes( const DtEntityStateRepository& entity );

         virtual void syncRprArtParts( DtBrokerObject* brokerObject );

         virtual void syncRprDeadReckonedValues( DtBrokerObject* brokerObject );

         virtual void syncPortalDeadReconedValues( DtBrokerObject* brokerObject );

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

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

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

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


      protected:

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

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

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

         DtPortalReflectedDiGuyManager* myPortalReflectedDiGuyManager;

      };

   }
}