DtVrlinkAggregateElementManager.h

Go to the documentation of this file.

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


#pragma once

#include <vrvVrl/vrvVrl.h>

#include <vrvCore/DtAggregateElementManager.h>
#include <vrvCore/DtElementIDHierarchy.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrvUtil/DtVirtualBaseClass.h>

#include <vlutil/vlSmartPointers.h>
#include <vl/globalObjectDesignator.h>

#include <boost/unordered_map.hpp>

namespace makVrv
{

   class DtAggregateEchelonManager;
   class DtAggregateElement;
   class DtAggregateStateListener;

   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtVrlinkAggregateStateListener;
      class DtVrlinkAggregateElement;
      class DtVrlinkConnection;
      class DL_DLL_IGCONVRLINK DtVrlinkAggregateElementManager : public DtAggregateElementManager
      {
      public:
         DtVrlinkAggregateElementManager(DtBaseConnection& conn);

         virtual ~DtVrlinkAggregateElementManager();

         DtVrlinkAggregateElementManager() = delete;

         DtVrlinkAggregateElementManager(const DtVrlinkAggregateElementManager&) = delete;

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

         DtVrlinkAggregateElement* findElementFromGlobalId(const DtGlobalObjectDesignator& id);

      public:

         virtual void addElement(DtAggregateElement* element) override;

         virtual void destroyElement(DtElementID elementID) override;

         virtual void createElement(DtAggregateStateListener&) override;
         typedef boost::unordered_map<std::string, DtVrlinkAggregateElement*>
           GlobalIdToAggregateElementMap;

         const GlobalIdToAggregateElementMap& globalIdToElementMap() const;
         GlobalIdToAggregateElementMap& globalIdToElementMap();

         virtual void slot_subordinatesChanged(DtVrlinkAggregateElement*);

     protected:
        virtual void watchForGlobalIdDiscovery(DtElementID parent, const std::string& globalId);

        virtual void slot_entityElementCreated(DtEntityElement*);

        virtual void aggregateElementCreated(DtVrlinkAggregateStateListener&, DtVrlinkAggregateElement*);

        virtual void removeFromWatchList(DtElementID id);

        virtual void connectToElementProcessor();
        virtual void disconnectFromElementProcessor();

        virtual void mapGlobalIdsToElementIds(DtElementID parent,
           const std::set<std::string>& globalIds, DtElementIDHierarchy::ElementIDs& children);

        virtual void slot_hierarchyItemToBeRemoved(DtElementIDHierarchyNode* node);

        virtual  DtVrlinkConnection& vrlinkConnection();
        virtual  const DtVrlinkConnection& vrlinkConnection() const;

      protected:

         typedef boost::unordered_map<std::string, DtElementID>   WatchList;

         WatchList myWatchList;
         GlobalIdToAggregateElementMap myGlobalIdToElementMap;
         DtVrlinkConnection* myVrlinkConnection;
      };    

      class DL_DLL_IGCONVRLINK DtVrlinkAggregateElementManagerCreator : public DtAggregateElementManagerCreator
      {

      public:
 
         virtual DtAggregateElementManager* create(DtBaseConnection& conn);
      };
   }
}