baseObjectTranslator.h

Go to the documentation of this file.

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


#pragma once

#include <broker/translator.h>
#include <portal/pReflectedObject.h>
#include <portal/pReflectedObjectManager.h>

namespace MAKVrExchange
{

   class DtBrokerObject;

   class DT_DLL_BROKER DtObjectTranslator : public DtTranslator
   {
   public:

      typedef void (*BrokerObjectCbPtr)( const DtBrokerObject* brokerObj, void* usr );

   public:

      DtObjectTranslator( DtBroker* broker, const DtString& name, DtPortalMessageKind kind );

      virtual ~DtObjectTranslator();


      virtual void initializePortalCallbacks() = 0;
      virtual void removePortalCallbacks() = 0;


      virtual void shutdown() = 0;

      virtual void forceUpdateAll() {};

      virtual unsigned int numObjects() const = 0;


      virtual void addObjectDiscoveredCallback( BrokerObjectCbPtr funcPtr, void* usr );
      virtual void addObjectUpdatedCallback( BrokerObjectCbPtr funcPtr, void* usr );
      virtual void addObjectRemovedCallback( BrokerObjectCbPtr funcPtr, void* usr );



      virtual void callObjectDiscoverCallbacks( const DtBrokerObject* obj );
      virtual void callObjectUpdateCallbacks( const DtBrokerObject* obj );
      virtual void callObjectRemoveCallbacks( const DtBrokerObject* obj );



      virtual bool isPortalDiscoverable( const DtPortalReflectedObject* obj );

      virtual bool isPortalPublishable( const DtBrokerObject* obj );


   protected:

      struct CallbackPair { BrokerObjectCbPtr fcn; void* userData; };
      typedef std::list<CallbackPair> CallbackPairList;

      CallbackPairList myDiscoverCallbacks;
      CallbackPairList myUpdateCallbacks;
      CallbackPairList myRemoveCallbacks;

   };


   template <class T_PortalObject,class T_PortalReflectedObject,class T_ParentClass=DtObjectTranslator>
   class DtBaseObjectTranslator : public T_ParentClass
   {
   public:

      typedef DtBaseObjectTranslator<T_PortalObject,T_PortalReflectedObject,T_ParentClass> ParentClass;

   public:

      DtBaseObjectTranslator( DtBroker* broker, const DtString& name, DtPortalMessageKind kind );

      virtual ~DtBaseObjectTranslator();

      virtual void enablePublishTranslator( bool enabled );


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



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

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

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

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


      virtual void shutdown();

   protected:


      virtual void discoverPortalObject( const T_PortalReflectedObject& obj );
      virtual void receivePortalUpdate( const T_PortalReflectedObject& obj );
      virtual void removePortalObject( const T_PortalReflectedObject& obj );


   protected:

      DtPortalReflectedObjectManager<T_PortalReflectedObject>* myPortalReflectedManager;

   };
}

#define _baseObjectTranslator_INL_
#include "baseObjectTranslator.inl"
#undef _baseObjectTranslator_INL_