vrfAggregatePublisher.h

Go to the documentation of this file.

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


#pragma once

#include <vrfExtObjects/dllExport.h>
#include <vrfExtObjects/extendedAttributesInitializer.h>
#include <vrfExtObjects/vrfAggregatePublisher.h>
#include <vrfExtObjects/vrfObjectIdGenerator.h>
#include <vl/aggregatePublisher.h>
#include <vlutil/vlSmartPointers.h>
#include <readerWriter/rwProperties.h>

#ifdef DtDIS
typedef DtAggregateStateEncoder DtAggPublisherEncoder;
typedef DtAggregateStateDecoder DtAggPublisherDecoder;
#else // DtHLA
typedef DtHlaStateEncoder DtAggPublisherEncoder;
typedef DtHlaStateDecoder DtAggPublisherDecoder;
#endif

class DtExtAggregateStateRepository;
class DtBaseEntityStateRepository;
class DtEntityType;
class DtObjectClassChooser;

namespace makVrfVrlinkExtToolkit
{
   class DtExtendedAttributesObjectPublisher;
}

class DT_DLL_vrfExtObjects DtVrfAggregatePublisher
{
public:

   typedef DtAggregateStateRepository* (*MyStateRepCreator)();
   
   DtVrfAggregatePublisher(
      const DtEntityType& type, DtExerciseConn* conn,
#if DtHLA
      const DtGlobalObjectDesignator& glId = DtVrfObjectIdGenerator::nullId(),
#endif
      const DtEntityIdentifier& entId = DtEntityIdentifier::nullId(),
      DtRwProperties* stateProps = 0, DtRwProperties* paramProps = 0);

   DtVrfAggregatePublisher(
      const DtEntityType& type, DtExerciseConn* conn,
#if DtHLA
      const DtGlobalObjectDesignator& glId = DtVrfObjectIdGenerator::nullId(),
#endif
      const DtEntityIdentifier& entId = DtEntityIdentifier::nullId(),
      const DtRwProperties& stateProps = DtRwProperties::emptyProperties(), 
      const DtRwProperties& paramProps = DtRwProperties::emptyProperties());

   virtual ~DtVrfAggregatePublisher();
   
   virtual void addEntity(const DtBaseEntityStateRepository*);
   virtual void removeEntity(const DtBaseEntityStateRepository*);

   virtual void addAggregate(const DtBaseEntityStateRepository*);
   virtual void removeAggregate(const DtBaseEntityStateRepository*);

   virtual void setExtendedData(const DtString& key, const DtString& value);
   virtual void clearExtendedData();
   virtual void removeExtendedData(const DtString& key);
   virtual DtString extendedData(const DtString& key) const;

   virtual bool tick(
#ifdef DtHLA
   bool& extAttrPublisherTick
#endif
   );

   virtual DtExtAggregateStateRepository* aggregateProcessStateRep();
   virtual DtExtAggregateStateRepository* aggregateStateRep();
   virtual DtExtAggregateStateRepository* agsr();

#ifdef DtHLA
   virtual DtAggPublisherDecoder* decoder();

   virtual DtAggPublisherEncoder* encoder();
#endif

   DtStateRepository* sr()
   {
      return myPublisher->sr();
   }

#ifdef DtHLA
   const DtString& name() const
   {
      return myPublisher->name();
   }
#endif

   virtual const DtObjectId& id() const;

   virtual const DtObjectId& localId() const;

   virtual const DtGlobalObjectDesignator& globalId() const;

   virtual void forceUpdate();

   virtual DtAggregatePublisher* aggregatePublisher();

   virtual void setSendVrfObjectDataRecord(bool shouldSend);

   static void setInitializer(DtExtendedAttributesInitializerPtr init);
   
   static DtExtendedAttributesInitializerPtr initializer();

#if DtHLA
   static void setObjectClassChooser(DtObjectClassChooserPtr chooser);

   static DtObjectClassChooserPtr objectClassChooser();
#endif

protected:

   DtVrfAggregatePublisher();

   void initialize(const DtEntityType& type, DtExerciseConn* conn,
#if DtHLA
      const DtGlobalObjectDesignator& glId,
#endif
      const DtEntityIdentifier& entId);

#ifdef DtDIS
   virtual void sendFinalPdu();
#endif

private:

   DtVrfAggregatePublisher(const DtVrfAggregatePublisher&);
   
   DtVrfAggregatePublisher& operator=(const DtVrfAggregatePublisher&);

protected:

   DtAggregatePublisher*   myPublisher;

#if DtHLA
   makVrfVrlinkExtToolkit::DtExtendedAttributesObjectPublisher* myExtAttrPublisher;

   static DtObjectClassChooserPtr theObjectClassChooser;
#endif

   static DtExtendedAttributesInitializerPtr theInitializer;
};