rprBroker/rprBroker/aggregateTranslator.h

Go to the documentation of this file.

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


#pragma once

#include <rprBroker/rprTranslator.h>
#include <vl/aggregatePublisher.h>
#include <vl/reflectedAggregateList.h>

class DtReflectedAggregate;
class DtAggregateStateRepository;

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

namespace MAKVrExchange
{

   class DtPortalAggregate;

   namespace DtRprBroker
   {

      template <>
      DT_DLL_RPRBROKER DtAggregatePublisher*
         DtRprObjectTranslator<AGGREGATE_TEMPLATE_ARGS>::instantiateRprPublisher(
            const DtPortalReflectedAggregate* refObj, const DtString& name );


      class DT_DLL_RPRBROKER DtAggregateTranslator
         : public DtRprObjectTranslator<AGGREGATE_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Aggregate" );

         DtAggregateTranslator( DtBroker* broker );

         virtual ~DtAggregateTranslator();

      protected:

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

         virtual void createRprPublisher( DtBrokerObject* brokerObj );

         virtual DtString rprObjectName( const DtPortalReflectedAggregate* refObj ) const;

         virtual void fillOutgoingIds( DtAggregatePublisher* publisher,
            const DtString& objectName );

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

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

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

         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 syncRprDeadReckonedValues( DtAggregateStateRepository& destination,
            const DtPortalAggregate& source );

      };

   }
}