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 <vrfGuiCore/entityStateListenerExtensions.h>
#include <vrfGuiCore/tacticalGraphicListenerExtensions.h>

#include <vrvCore/DtEntityState.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 
{
   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();

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

         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();

         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 reflectedEntityPostUpdate();

         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 );
         virtual void executeCharacterAction(const std::string&);
         virtual void setAppearanceBits( unsigned int mask, unsigned int newValue, bool force = false );
          virtual void executeSetColor(DtRwColor color);
          virtual void executeGesture(const std::string& gestureName, int reps, float overallDuration, float channel_A_weight);

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

      protected:
         bool myBlockAnimationChange;
         double myTime;
         unsigned int myNewAppearance;
         unsigned int myNewAppearanceMask;
         bool myResetToFrozen;
         bool myBlockGestureChange;
         std::string myGesture;
         DtString myLastExtendedLabels;
      };

      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();

         virtual void setNetVelocity(const DtVector32&, double pduTime);
         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
         {
            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) {}

         virtual ~DtVrfVrlinkTacticalGraphicStateListener() {}

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

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

         virtual ~DtVrfVrlinkEntityStateListenerCreator();

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

   #ifdef DtDIS
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener* create(const DtEntityIdentifier& id, 
            const DtEntityType& type);
   #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, bool localWeather);

         virtual ~DtVrfWeatherStateListener();

         DtVrfWeatherStateListener() = delete;

         DtVrfWeatherStateListener(const DtVrfWeatherStateListener &) = delete;

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

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

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

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

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

         DtVrfWeatherStateListenerCreator(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection&, bool localWeather);
      };
      
      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();

         virtual void updateSubordinates();

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

      protected:
         virtual void slot_subordinateAdded(const DtUUID&, const DtUUID&);
         virtual void slot_subordinateRemoved(const DtUUID&, const DtUUID&);
         virtual void setAlgorithm();
         virtual void postUpdate(DtReflectedAggregate*) override;

      protected:
         makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& mySimulation;
         makVrv::DtSignalConnectionManager myConnections;
      };

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

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

         virtual ~DtVrfVrlinkAggregateStateListenerCreator();

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

   #ifdef DtDIS
         virtual makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener* create(const DtEntityIdentifier& id, 
            const DtEntityType& type);
   #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&);

      #if DtHLA
         virtual DtReflectedExtAggregateList* create(makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateExistenceListener&, const DtDDMRegionSet*);
      #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() {};

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

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

     class VRF_PROTOCOL_EXPORT DtVrfVrvExtReflectedEntityList : public DtReflectedExtEntityList
      {
      public:
         DtVrfVrvExtReflectedEntityList(makVrv::DT_PROTOCOL_NAMESPACE::DtEntityElementProcessor& listener);

   #if DtHLA
         DtVrfVrvExtReflectedEntityList(makVrv::DT_PROTOCOL_NAMESPACE::DtEntityElementProcessor& listener, 
            const DtDDMRegionSet& regionsToUse);
   #endif

         virtual ~DtVrfVrvExtReflectedEntityList();
#if DtHLA
         virtual DtReflectedEntity* newReflectedObject(DtHlaObject* obj) const;

         virtual void removeAndDelete(DtReflectedObject* entity, char* msg = NULL);
         virtual void resolveOrphans();
#endif

   #if DtDIS

         //Hacked class which allows setting the esr of an newly created reflected
         //Entity
         class DtVrfVrvReflectedEntity : public DtReflectedExtEntity
         {
         public:
            DtVrfVrvReflectedEntity(DtExerciseConn* conn,
               const DtEntityIdentifier& id,
               const DtEntityType& type,
               DtEntityStateRepository* esr)
               : DtReflectedExtEntity(conn,id,type)
            {
               delete myEntityStateRep;
               myEntityStateRep = esr;
               myEntityStateRep->setClock(conn->clock());
               myEntityStateRep->setGlobalId(id);
               myEntityStateRep->setDisObjectManager( conn->disObjectManager() );
            }

         };

         virtual DtReflectedEntity* newReflectedEntity( 
            const DtEntityIdentifier& id,
            const DtEntityType& type) const;

         virtual void removeAndDelete(DtReflectedObject* obj, char* msg = NULL);
   #endif

         //Whenever an entity is added.
         virtual void objectAdded(DtReflectedObject* ent);

      protected:

         typedef std::map<DtReflectedExtEntity*,makVrv::DtEntityStateListener*> 
            ReflectedEntityListenerMap;


         makVrv::DT_PROTOCOL_NAMESPACE::DtEntityElementProcessor& myListener;
         mutable ReflectedEntityListenerMap myReflectedEntityListenerMap;
      };

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

         virtual ~DtVrfEntityStateInterceptorCreator();

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

         DtVrfEntityStateInterceptorCreator();
      };
   }
}