vrfVrvExtensions.h

Go to the documentation of this file.

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



#pragma once

#include <vrfVrlSharedSource/vrfProtocol.h>

#include <vrvVrl/DtVrlinkConnection.h>


class DtDIGuyObjectStateRepository;

#include <vrvCore/DtSharedEntityDisplaySettings.h>
#include <vl/diGuyObjectStateRepository.h>
#include <vrvVrl/DtEntityStateInterceptor.h>
#include <vrvVrl/DtEntityKinStateListener.h>
#include <vrvVrl/DtWeatherStateListener.h>
#include <vrvVrl/DtVrlinkEntityStateListener.h>
#include <vrvVrl/DtVrlinkAggregateStateListener.h>
#include <vrvVrl/DtVrlinkTacticalGraphicStateListener.h>
#include <vrvVrl/DtEntityElementProcessor.h>
#include <vrvVrl/DtAggregateExistenceListener.h>
#include <vrvVrl/DtVrlinkReflectedAerodromeList.h>
#include <vrvVrl/DtEntityStateInterceptorCreator.h>
#include <vrvVrl/DtAggregateStateInterceptorCreator.h>
#include <vrvVrl/DtEntityStateInterceptorCreator.h>
#include <vrvVrl/DtTimeAndDateProcessor.h>

#include <vrfGuiCore/entityStateListenerExtensions.h>
#include <vrfGuiCore/tacticalGraphicListenerExtensions.h>


#include <vrvCore/DtAgentManagerInterface.h>
#include <vrfExtObjects/reflectedExtEntity.h>
#include <vrfExtObjects/reflectedExtEntityList.h>
#include <vrvUtil/DtSignalConnectionManager.h>

#include <vrfutil/rwUUID.h>

#include <vlpi/entityType.h>
#include <matrix/vlVector.h>

#if DtHLA
#include <vrfExtObjects/stateRepositoryWithExtendedAttributesHLA.h>
#else
#include <vrfExtObjects/stateRepositoryWithExtendedAttributesDIS.h>
#endif
#include "vrfutil/rwColor.h"

class DtReflectedAerodromeList;

namespace makVrv
{
   class DtVrlinkElement;
   class DtEmbarkationUpdaterAgent;

   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtEntitySimDataProcessor;
      class DtVrlinkAggregateElement;
      class DtVrlinkTacticalGraphicStateListener;
      class DtVrlinkEntityStateListener;
   }
}

namespace makVrf 
{
   class DtRangeItemsStateComponent;
   class DtStateData;

   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtVrfAggregateStateInterceptorCreator : public makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateStateInterceptorCreator
      {
      public:
         static DtAggregateStateInterceptorCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual ~DtVrfAggregateStateInterceptorCreator() override;

         virtual DtAggregateStateRepository* create(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* listener) override;

         DtVrfAggregateStateInterceptorCreator();
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkEntityStateListener : public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener,
         public DtEntityStateListenerExtensions
      {
      public:
         DtVrfVrlinkEntityStateListener(makVrv::DtUniqueID id, makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection&);

         virtual ~DtVrfVrlinkEntityStateListener() override;

         bool animationChangeBlocked() const
         {
            return myBlockAnimationChange;
         }

         bool gestureChangeBlocked() const
         {
            return myBlockGestureChange;
         }

         virtual void setBlockAnimationChange(bool b, double speed = 0.);
         virtual void setBlockGestureChange(bool b);
         virtual void setFrozen(bool);
        virtual void queueRangeItemsModified(const DtStateData* sd);

         virtual void reflectedEntityPostUpdate() override;

         bool blockAnimationChange(bool b, double speed = 0.)
         {
            bool old = myBlockAnimationChange;

            setBlockAnimationChange(b, speed);

            return old;
         }

         virtual void setCharacterAction(const std::string& action, bool paused, float speed, bool usePositioning,
            const DtVector&, int autoChooseTransitionBehavior, float transitionSpeed) override;
         virtual void executeCharacterAction(const std::string&);
         virtual void setAppearanceBits(unsigned int mask, unsigned int newValue, bool force = false) override;
          virtual void executeSetColor(DtRwColor color) override;
          virtual void executeGesture(
            const std::string& gestureName, int reps, float overallDuration, float channel_A_weight) override;
         virtual void rangeItemsModified(const DtStateData*);
         virtual bool rangeItemsFrom(const DtStateData* sd,
            const std::vector<DtRangeItem>& sourceItems, std::vector<DtRangeItem>& items);

         boost::signals2::signal<void(DtRwColor)> signal_setIconColor;
         virtual void setupAdditionalItems();

      protected:
         bool myBlockAnimationChange;
         double myTime;
         unsigned int myNewAppearance;
         unsigned int myNewAppearanceMask;
         bool myResetToFrozen;
         bool myBlockGestureChange;
         std::string myGesture;
         DtString myLastExtendedLabels;
         makVrv::DtSignalConnectionManager myRangeItemsUpdateConnections;
         boost::signals2::connection mySetupConnection;
         boost::signals2::connection myRangeItemsModifiedConnection;
      };

      class VRF_PROTOCOL_EXPORT DtVrfEntityKinStateListener : public makVrv::DT_PROTOCOL_NAMESPACE::DtEntityKinStateListener
      {
      public:
         DtVrfEntityKinStateListener(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener&, makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn);

         virtual ~DtVrfEntityKinStateListener() override;

         virtual void setNetVelocity(const DtVector32&, double pduTime) override;
         virtual void setUseTemporaryVelocity(bool b, double speed);

      protected:
         DtVector32 myCurrentVelocity;
         UpdateStruct32 myCopyVelocityValue;
         bool myUseTemporaryVelocity;
         DtVector32 myTemporaryVelocity;
      };

      class VRF_PROTOCOL_EXPORT DtVrfEntityKinStateListenerCreator : public makVrv::DT_PROTOCOL_NAMESPACE::DtEntityKinStateListenerCreator
      {
      public:
         DtVrfEntityKinStateListenerCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& connection)
         : makVrv::DT_PROTOCOL_NAMESPACE::DtEntityKinStateListenerCreator(connection)
         {
         }

         //functionality.
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtEntityKinStateListener* create(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& stateListener) const override
         {
            return new DtVrfEntityKinStateListener(stateListener, myConnection);
         }
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkTacticalGraphicStateListener : public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkTacticalGraphicStateListener,
         public DtTacticalGraphicListenerExtensions
      {
      public:
         DtVrfVrlinkTacticalGraphicStateListener(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& connection, makVrv::DtUniqueID id)
            : DtVrlinkTacticalGraphicStateListener(connection, id),
            DtTacticalGraphicListenerExtensions(id, connection) {}

         virtual ~DtVrfVrlinkTacticalGraphicStateListener() override {}

      protected:
         virtual void postUpdate(DtReflectedControlObject* cObj) override;
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkEntityStateListenerCreator : public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListenerCreator
      {
      public:
         static DtVrfVrlinkEntityStateListenerCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual ~DtVrfVrlinkEntityStateListenerCreator() override;

   #ifdef DtHLA
         //functionality.
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener* create(DtHlaObject* object) override;
   #endif

   #ifdef DtDIS
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener* create(
            const DtEntityIdentifier& id, const DtEntityType& type) override;
   #endif

         DtVrfVrlinkEntityStateListenerCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection&);
      };

      class VRF_PROTOCOL_EXPORT DtVrfWeatherStateListener : public makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener,
         public DtTacticalGraphicListenerExtensions
      {
      public:
         DtVrfWeatherStateListener(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim, makVrv::DtUniqueID id);

         virtual ~DtVrfWeatherStateListener() override;

         DtVrfWeatherStateListener() = delete;

         DtVrfWeatherStateListener(const DtVrfWeatherStateListener &) = delete;

         DtVrfWeatherStateListener &operator=(const DtVrfWeatherStateListener &) = delete;

      protected:
         virtual void postUpdate( DtReflectedControlObject* cObj ) override;

      protected:
         DtString myCanSetScenarioPreStartTime;
         DtString myTimeSetToLocalOnFirstPlacement;
      };

      class VRF_PROTOCOL_EXPORT DtVrfWeatherStateListenerCreator : public makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListenerCreator
      {
      public:
         virtual ~DtVrfWeatherStateListenerCreator() override;

   #ifdef DtHLA
         //functionality.
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener* create(DtHlaObject* object) override;
   #endif

   #ifdef DtDIS
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtWeatherStateListener* create(
            const DtEntityIdentifier& id, const DtEntityType& type) override;
   #endif

         DtVrfWeatherStateListenerCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection&);
      };
      
      class VRF_PROTOCOL_EXPORT DtVrfVrlinkAggregateStateListener : public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener,
         public DtEntityStateListenerExtensions
      {
      public:
         DtVrfVrlinkAggregateStateListener(makVrv::DtUniqueID id, makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection&);

         virtual ~DtVrfVrlinkAggregateStateListener() override;

         virtual void updateSubordinates() override;

         virtual void executeSetColor(DtRwColor color) override;
        virtual void queueRangeItemsModified(const DtStateData* sd);
        virtual void rangeItemsModified(const DtStateData* sd);
        virtual bool updateAggregateSpecificData(const DtStateData* sd);
         boost::signals2::signal<void(DtRwColor)> signal_setIconColor;
         virtual bool rangeItemsFrom(const DtStateData* sd,
            const std::vector<DtRangeItem>& sourceItems, std::vector<DtRangeItem>& items);

      protected:
         virtual void setAlgorithm() override;
         virtual void postUpdate(DtReflectedAggregate*) override;
         virtual void setupAdditionalItems();

      protected:
         makVrv::DtSignalConnectionManager myRangeItemsUpdateConnections;
         DtString myLastExtendedLabels;
         boost::signals2::connection mySetupConnection;
         boost::signals2::connection myRangeItemsModifiedConnection;
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkAggregateStateListenerCreator : public makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateStateListenerCreator
      {
      public:

         static DtVrfVrlinkAggregateStateListenerCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual ~DtVrfVrlinkAggregateStateListenerCreator() override;

   #ifdef DtHLA
         //functionality.
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* create(DtHlaObject* object) override;
   #endif

   #ifdef DtDIS
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* create(
            const DtEntityIdentifier& id, const DtEntityType& type) override;
   #endif

         DtVrfVrlinkAggregateStateListenerCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection&);
      };

      class VRF_PROTOCOL_EXPORT DtVrfAggregateReflectedListCreator :
         public makVrv::DT_PROTOCOL_NAMESPACE::DtVrvAggregateReflectedListCreator
      {
      public:

         static makVrv::DT_PROTOCOL_NAMESPACE::DtVrvAggregateReflectedListCreator&
            instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual DtReflectedExtAggregateList* create(
            makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateExistenceListener&) override;

      #if DtHLA
         virtual DtReflectedExtAggregateList* create(
            makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateExistenceListener&, const DtDDMRegionSet*) override;
      #endif

      protected:
         DtVrfAggregateReflectedListCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkReflectedAerodromeListCreator :
         public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkReflectedAerodromeListCreator
      {
      public:

         static makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkReflectedAerodromeListCreator&
            instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual DtReflectedAerodromeList* create(makVrv::DT_PROTOCOL_NAMESPACE::DtAerodromeExistenceListener&) override;
#if DtHLA
         virtual DtReflectedAerodromeList* create(makVrv::DT_PROTOCOL_NAMESPACE::DtAerodromeExistenceListener&, const DtDDMRegionSet*) override;
#endif

      protected:
         DtVrfVrlinkReflectedAerodromeListCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkTacticalGraphicStateListenerCreator
      : public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkTacticalGraphicStateListenerCreator
      {
      public:

         DtVrfVrlinkTacticalGraphicStateListenerCreator(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& c) : DtVrlinkTacticalGraphicStateListenerCreator(c) {};

         virtual ~DtVrfVrlinkTacticalGraphicStateListenerCreator() override {};

   #ifdef DtHLA
         //functionality.
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEnvironmentalStateListenerInterface* create(
            DtHlaObject* object) override
         {
            return new DtVrfVrlinkTacticalGraphicStateListener(mySim, mySim.sceneInterface().createNewUniqueId());
         }
   #endif

   #if DtDIS
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEnvironmentalStateListenerInterface* create(
            const DtEntityIdentifier& id, const DtEntityType& type) override
         {
            return new DtVrfVrlinkTacticalGraphicStateListener(mySim, mySim.sceneInterface().createNewUniqueId());
         }
   #endif
      };

      class VRF_PROTOCOL_EXPORT DtVrfEntityStateInterceptorCreator : public makVrv::DT_PROTOCOL_NAMESPACE::DtEntityStateInterceptorCreator
      {
      public:
         static DtEntityStateInterceptorCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual ~DtVrfEntityStateInterceptorCreator() override;

         virtual DtEntityStateRepository* create(
            makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener* listener) override;

         DtVrfEntityStateInterceptorCreator();
      };

      class VRF_PROTOCOL_EXPORT DtVrfTimeAndDateProcessor : public makVrv::DT_PROTOCOL_NAMESPACE::DtTimeAndDateProcessor
      {
      public:
         DtVrfTimeAndDateProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn);

         virtual ~DtVrfTimeAndDateProcessor() override;
        
         virtual void onTimeAndDateDiscovered(DtTimeAndDateStateRepository* timeAndDateSR) override;
         virtual void onTimeAndDateToBeDestroyed(const DtGlobalObjectDesignator& id) override;

         boost::signals2::signal<void (DtTimeAndDateStateRepository*)> signal_timeAndDateDiscovered;
      };
   }
}