baseObjectTranslator.h

Go to the documentation of this file.

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

#pragma once

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

#define OBJECT_TRANSLATOR_TEMPLATE_LIST \
   template \
   < class T_DtBrokerObject \
   , class T_DtPortalObject \
   , class T_ParentClass >

   
namespace MAKVrExchange
{
   class DtBaseObjectTranslator : public DtTranslator
   {
   public:

      DtBaseObjectTranslator( DtBroker* broker, const DtString& name, DtPortalMessageKind kind );
      
      virtual void enableTranslator( bool enabled );
      virtual void initializePortalCallbacks() = 0;
      virtual void removePortalCallbacks() = 0;
      
      typedef void (*BrokerObjectCbPtr) ( const void *brokerObjectPointer, void *userData);
      virtual void addObjectDiscoveredCallback(BrokerObjectCbPtr funcPtr, void *userData);
      virtual void addObjectUpdatedCallback(BrokerObjectCbPtr funcPtr, void *userData);
      virtual void addObjectRemovedCallback(BrokerObjectCbPtr funcPtr, void *userData);

   protected:

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

      CallbackPairList myDiscoverCallbacks;
      CallbackPairList myUpdateCallbacks;
      CallbackPairList myRemoveCallbacks;
   };

   OBJECT_TRANSLATOR_TEMPLATE_LIST
   class DtObjectTranslator : public T_ParentClass
   {
   public:

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

      virtual ~DtObjectTranslator();

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

      virtual void discoverPortalObject(const DtPortalReflectedObjectTemplate< T_DtPortalObject > &obj) = 0; 
      virtual void receivePortalUpdate(const DtPortalReflectedObjectTemplate< T_DtPortalObject > &obj) = 0; 
      virtual void removePortalObject(const DtPortalReflectedObjectTemplate< T_DtPortalObject > &obj) = 0; 
      

         virtual void callObjectDiscoverCallbacks(const T_DtBrokerObject* brokerObject);

         virtual void callObjectUpdateCallbacks(const T_DtBrokerObject* brokerObject);

         virtual void callObjectRemoveCallbacks(const T_DtBrokerObject* brokerObject);

      virtual bool isPortalPublishable(const T_DtBrokerObject* brokerObject) const;

      virtual bool isPortalDiscoverable(const DtPortalReflectedObject* brokerObject) const;

      static void portalObjectAddedCb(const DtPortalReflectedObjectTemplate< T_DtPortalObject > &obj, void *ud); 

      static void portalObjectUpdatedCb(const DtPortalReflectedObjectTemplate< T_DtPortalObject > &obj, void *ud); 

      static void portalObjectDeletedCb(const DtPortalReflectedObjectTemplate< T_DtPortalObject > &obj, void *ud); 

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

   protected:
      DtPortalReflectedObjectManager< DtPortalReflectedObjectTemplate< T_DtPortalObject > > *myPortalReflectedManager;
   };
};