entityInterface.h

Go to the documentation of this file.

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


#if DtTENA

#pragma once

#include <coLromMapper/coLromMapExport.h>

#include <vlTena/objectInterface.h>
#include <vlTena/reflectedEntity.h>
#include <vl/globalObjectDesignator.h>

#include <vl/entityStateRepository.h>
#include <vlpi/entityType.h>

#include <TENA/GeocentricSpatialReferenceFrame/Pointer.h>
#include <TENA/PlatformDetails/ServantPtr.h>
#include <TENA/PlatformDetails/ProxyPtr.h>
#include <TENA/PlatformDetails/Servant.h>
#include <TENA/PlatformDetails/Proxy.h>
#include <TENA/PlatformType/Includes.h>
#include <TENA/Platform/ServantPtr.h>
#include <TENA/Platform/ProxyPtr.h>
#include <TENA/Platform/Servant.h>
#include <TENA/Platform/Proxy.h>
#include <TENA/UniqueID/Includes.h>
#include <TENA/Time/Pointer.h>

#include <list>
#include <map>

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

      class DT_DLL_COMMONLROM DtEntityInterface: public DtObjectInterface
      {
      protected:

         class DtEntityServantObject : public DtTenaServantObject
         {
         public:
            DtEntityServantObject( TENA::Platform::ServantPtr sp,
               TENA::PlatformDetails::ServantPtr dp):
                  myServantPtr(sp),
                  myDetailsServantPtr(dp){}

            virtual ~DtEntityServantObject() {}

            virtual const TENA::Platform::ServantPtr servant() const { return myServantPtr;}

            virtual TENA::Platform::ServantPtr servant() { return myServantPtr;}

            virtual const TENA::PlatformDetails::ServantPtr detailsServant() const
            { return myDetailsServantPtr; }

            virtual TENA::PlatformDetails::ServantPtr detailsServant()
            { return myDetailsServantPtr;}

         protected:
            TENA::Platform::ServantPtr myServantPtr;
            TENA::PlatformDetails::ServantPtr myDetailsServantPtr;
         };


         public:

         DtEntityInterface(DtExerciseConn* exConn);

         virtual ~DtEntityInterface();

         public:

         virtual DtTenaServantObject* createServantObject(DtExerciseConn* exConn);

         virtual void processServantCleanup(DtTenaServantObject* servant);

         virtual void subscribe();

         virtual bool needUpdate(const DtStateRepository& stateRep,
            const DtStateRepository& asSeenByRemote,
            bool useThresholding = true);


         virtual void decode(const DtTenaServantObject* servant,
            DtStateRepository* stateRep)const;

         virtual void encode(DtTenaServantObject* servant,
            const DtStateRepository* stateRep,
            TENA::Time::Pointer timeForStamping,
            bool forceUpdate = false);

         virtual DtReflectedObject *createReflectedObject()const;

         virtual void processAddition(TENA::Platform::ProxyPtr const &proxy);

         virtual void processUpdate(TENA::Platform::ProxyPtr const &proxy);

         virtual void processRemoval(TENA::Platform::ProxyPtr const &proxy);

         virtual void processAddition(TENA::PlatformDetails::ProxyPtr const &proxy);

         virtual void processUpdate(TENA::PlatformDetails::ProxyPtr const &proxy);

         virtual void processRemoval(TENA::PlatformDetails::ProxyPtr const &proxy);

         protected:

         virtual void decode( const TENA::Platform::ImmutablePublicationStatePtr pubStatePtr,
            DtStateRepository* stateRep ) const;

         virtual void decodeDetails( const TENA::PlatformDetails::ImmutablePublicationStatePtr pubStatePtr,
            DtStateRepository* stateRep ) const;

         virtual bool needDetailsUpdate( const DtEntityStateRepository& stateRep,
            const DtEntityStateRepository& asSeenByRemote );

         virtual void encodeDetails(DtTenaServantObject* servant,
            const DtEntityStateRepository* esr, TENA::Time::Pointer timeForStamping ) const;

         virtual void checkForWaitingDetails( TENA::Platform::ProxyPtr const& proxy );

         virtual DtForceType tenaForceToVrlinkForce( TENA::Force tenaForce ) const;
         virtual TENA::Force vrlinkForceToTenaForce( DtForceType vrlinkForce ) const;

         private:

         DtEntityInterface(const DtEntityInterface &other);

         DtEntityInterface& operator=(const DtEntityInterface &other);

         protected:

         TENA::GeocentricSpatialReferenceFrame::Pointer myGeocSRF;

         TENA::Platform::SubscriptionInfoPtr mySubscriptionInfoPtr;
         TENA::PlatformDetails::SubscriptionInfoPtr myDetailsSubscriptionInfoPtr;

         typedef std::map<TENA::Platform::ProxyPtr, DtReflectedObject *> PlatProxyToRefObjMap;
         typedef std::map<TENA::PlatformDetails::ProxyPtr, DtReflectedObject*> DetailsProxyToRefObjMap;
         PlatProxyToRefObjMap myRefEntMap;
         DetailsProxyToRefObjMap myRefDetailsMap;

         PlatProxyToRefObjMap myEntityWaitList;
         std::list<TENA::PlatformDetails::ProxyPtr> myDetailsWaitList;
         bool myNeedPlatformUpdate;
         bool myNeedDetailsUpdate;

      };

   }
}

#endif // DtTENA