tenaBroker/tenaBroker/aggregateTranslator.h

Go to the documentation of this file.

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


#pragma once

#include <tenaBroker/baseEntityTranslator.h>

#include <vlTena/reflectedAggregateList.h>
#include <vlTena/aggregatePublisher.h>

#include <vl/aggregateStateRepository.h>

class DtReflectedAggregate;

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

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

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


      class DT_DLL_TENABROKER DtAggregateTranslator
         : public DtBaseEntityTranslator<AGGREGATE_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Aggregate" );

         DtAggregateTranslator( DtBroker* broker );

         virtual ~DtAggregateTranslator();

      protected:

         virtual bool isThrottlingRateOk( DtAggregatePublisher* publisher,
            DtBrokerObject* brokerObj );

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

         virtual DtString tenaObjectName( const DtPortalReflectedAggregate* refObj ) const;

         virtual DtObjectPublisher* instantiateTenaPublisher(
            const DtPortalReflectedAggregate* refObj,
            const DtEntityIdentifier& objectName );

         virtual void createTenaPublisher( DtBrokerObject* brokerObject );

         virtual DtString portalObjectName( const DtReflectedAggregate* refObj ) const;

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

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

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

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

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

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

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

      };

   }
}