strategies/entityState.h

Go to the documentation of this file.

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

#pragma once

#include "strategies/export.h"
#include "managedInterface/linkStrategy.h"
#include "managedInterface/managedInterface.h"
#include "managedInterface/publisherList.h"
#include "messages/entityState.h"

#include <string>
#include <map>

#include <matrix/vlVector.h>

class DtMessage;
class DtManagedInterface;
class DtReflectedEntity;
class DtReflectedEntityList;
class DtEntityPublisher;
class DtReflectedEmitterSystem;
class DtReflectedEmitterSystemList;
class DtEmitterSystemPublisher;

class MANAGEDINTERFACE_MODULE_DLL DtEntityStateStrategy : public DtLinkStrategy
{
public:
   virtual ~DtEntityStateStrategy();

   std::string name();
   static std::string theName();

   virtual bool init();
   virtual void tick();
   virtual void shutdown();

   static DtLinkStrategy* create(DtManagedInterface* gl);

protected:
   DtEntityStateStrategy(DtManagedInterface* link);

   void handleCSharpEntityDiscovered(DtMessage* msg);
   static void vrlEntityDiscovered(DtReflectedEntity* ent, void* usr);
   void handleVrlEntityDiscovered(DtReflectedEntity* ent);

   void handleCSharpEntityState(DtMessage* msg);
   static void vrlEntityState(DtReflectedEntity* ent, void* usr);
   void handleVrlEntityState(DtReflectedEntity* ent);

   void handleCSharpEntityRemoved(DtMessage* msg);
   static void vrlEntityRemoved(DtReflectedEntity* ent, void* usr);
   void handleVrlEntityRemoved(DtReflectedEntity* ent);

   void handleCSharpHeartbeatRate(DtMessage* msg);
   void handleCSharpThresholdRate(DtMessage* msg);
   void handleCSharpReflectedHeartbeatThreshold(DtMessage* msg);
   void handleCSharpReflectedSmoothingPeriod(DtMessage* msg);
   void handleEntitySubscriptionChange(DtMessage* msg);

   EntityStateMessage createStateMessage(DtReflectedEntity* ent);
   bool isEqual(EntityStateMessage& lhs, EntityStateMessage& rhs);

   DtReflectedEntityList* myRel;
   DtPublisherList<DtEntityPublisher>* myPubs;

   DtReflectedEmitterSystemList* myRml;
   DtPublisherList<DtEmitterSystemPublisher>* myEmitterPubs;

   static std::string theStrategyName;

   bool myPublishInit;
   bool myReflectInit;

   DtMessageDelegate* myDiscoveredHandler;
   DtMessageDelegate* myRemovedHandler;
   DtMessageDelegate* myStateHandler;
   DtMessageDelegate* myHeartbeatHandler;
   DtMessageDelegate* myThresholdHandler;
   DtMessageDelegate* myReflectedHeartbeatHandler;
   DtMessageDelegate* myReflectedSmoothingHandler;
   DtMessageDelegate* mySubscriptionChangeHandler;
};