tenaBroker/libTenaBroker/entityTrans.h

Go to the documentation of this file.

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


#pragma once

#include "objectTrans.h"

#include <portal/pReflectedObjectManagerTypes.h>
#include <portal/pObjectPublisherTypes.h>
#include <portal/pEntity.h>

#include <vl/reflEntList.h>
#include <vl/entityPub.h>

#include <map>

class DtReflectedEntity;
class DtEntityStateRepository;

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

      class DT_DLL_TENABROKER DtEntityTranslator : public DtObjectTranslator
      {
      public:

         typedef void (*callbackFunctionType)( DtReflectedEntity* object, void* userData );

         Dt_DEF_TRANSLATOR_NAME( "Entity State" );

         DtEntityTranslator( DtTenaBroker* tenaBroker );

         virtual ~DtEntityTranslator();

         virtual void tick();

         virtual void enableTranslator( bool enabled );

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

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

      protected:

         virtual void discoverTenaObject( DtReflectedEntity* obj );

         virtual void discoverPortalObject( const DtPortalReflectedEntity& obj );

         virtual void receiveTenaUpdate( DtReflectedEntity* obj );

         virtual void receivePortalUpdate( const DtPortalReflectedEntity& obj );

         virtual void createTenaPublisher( DtBrokerObject* brokerObject );

         virtual void createPortalPublisher( DtBrokerObject* brokerObject );

         virtual void deleteTenaPublisher( DtBrokerObject* brokerObject );

         virtual void deletePortalPublisher( DtBrokerObject* brokerObject );

         virtual bool isTenaPublishable( const DtBrokerObject* brokerObject ) const;

         virtual bool isPortalPublishable( const DtBrokerObject* brokerObject ) const;

         virtual void syncTenaDeadReconedValues( DtBrokerObject* brokerObject );
//         static void synchronizeDeadReconedValues( DtPortalEntity* destination,
//               const DtEntityStateRepository& source );

         virtual void syncPortalDeadReconedValues( DtBrokerObject* brokerObject );
//         static void synchronizeDeadReconedValues( DtEntityStateRepository* destination,
//               const DtPortalEntity& source );

      protected:

         static bool tenaDiscoveryCriteria( DtReflectedObject* obj, void* usr );

         static bool portalDiscoveryCriteria( const DtPortalReflectedEntity* obj, void* usr );

         static void tenaAdditionCallback( DtReflectedEntity* obj, void* usr );

         static void tenaUpdateCallback( DtReflectedEntity* obj, void* usr );

         static void tenaRemovalCallback( DtReflectedEntity* obj, void* usr );

         static void portalObjectAddedCb( const DtPortalReflectedEntity& obj, void* usr );

         static void portalObjectUpdatedCb( const DtPortalReflectedEntity& obj, void* usr );

         static void portalObjectDeletedCb( const DtPortalReflectedEntity& obj, void* usr );

      private:

         DtEntityTranslator( const DtEntityTranslator& other );

         DtEntityTranslator& operator = ( const DtEntityTranslator& other );

         int operator == ( const DtEntityTranslator& other ) const;

         int operator != ( const DtEntityTranslator& other ) const;

      protected:

         DtReflectedEntityList* myTenaReflectedList;
         DtPortalReflectedEntityManager* myPortalReflectedManager;

         size_t myPortalPublisherCount;
         size_t myTenaPublisherCount;

      };

   }
}