disBroker/disBroker/aggregateTranslator.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2016 MAK Technologies, Inc.
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <disBroker/disTranslator.h>
#include <vl/reflectedAggregateList.h>
#include <vl/aggregatePublisher.h>

#define AGGREGATE_TEMPLATE_ARGS \
   DtPortalAggregate, DtPortalReflectedAggregate, \
   DtReflectedAggregate, DtReflectedAggregateList, \
   DtAggregateStateRepository, DtAggregatePublisher

class DtAggregateStateRepository;

namespace MAKVrExchange
{

   namespace DtDisBroker
   {

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

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


      class DT_DLL_DISBROKER DtAggregateTranslator
         : public DtDisObjectTranslator<AGGREGATE_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Aggregate" );

         DtAggregateTranslator( DtBroker* broker );

         virtual ~DtAggregateTranslator();

      protected:

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

         virtual DtString disObjectName( const DtPortalReflectedAggregate* refObj ) const;

         virtual void createDisPublisher( DtBrokerObject* brokerObject );

         virtual DtString portalObjectName( const DtReflectedAggregate* refObj ) const;

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

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

         virtual void updateFilteredState( DtBrokerObject* brokerObj,
            DtPortalAggregatePublisher* publisher, DtReflectedAggregate* refObj );

         virtual void updateFilteredState(DtBrokerObject* brokerObj,
            const DtPortalReflectedAggregate* refObj);

         virtual DtPortalAggregate* translate( DtPortalAggregate* destination,
            const DtAggregateStateRepository& source,
            const DtReflectedAggregate& refObj );

         virtual DtAggregateStateRepository* translate(
            DtAggregateStateRepository* destination,
            const DtPortalAggregate& source,
            const DtPortalReflectedAggregate& refObj );

         virtual void syncPortalDeadReckonedValues( DtPortalAggregate& destination,
            const DtAggregateStateRepository& source );

         virtual void syncDisDeadReckonedValues( DtAggregateStateRepository& destination,
            const DtPortalAggregate& source );

      };

   }
}