vrfSyncMatrixManager.h

Go to the documentation of this file.

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



#pragma once

#if !defined(Q_MOC_RUN)
#include <vrfGuiCoreQt/vrfGuiCoreQt.h>
#include <vrfutil/rwUUID.h>
#include <vrvCore/DtEntityState.h>
#include <vrvCore/DtStateView.h>
#include <vrvUtil/DtVirtualBaseClass.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrfGuiCore/aggregateState.h>

#include <vrfplan/rwSyncMatrixObjectList.h>
#include <vrfplan/rwSyncMatrixPhaseList.h>
#include <vrfplan/rwSyncMatrixPlanList.h>

#include <vrvUtil/signalslib.h>

#include <vlpi/simulationAddress.h>
#endif
#include <boost/signals2.hpp>

#include <QtCore/QObject>

namespace makVrv
{
   class DtDe;
}

class QWidget;
class DtSimMessage;
class DtSimulationAddress;
class DtVrfObjectMessage;

namespace makVrf
{
   class DtSyncMatrixDialogInterface;
   class DtVrfBackendState;

   class DT_DLL_VRFGUICOREQT DtVrfSyncMatrixManager : public QObject, public makVrv::DtVirtualBaseClass
   {
      Q_OBJECT

   public:

      struct SyncMatrixWithPhases
      {
         SyncMatrixWithPhases(const DtString name = ""):myName(name) {}
         SyncMatrixWithPhases(const SyncMatrixWithPhases& orig):myName(orig.myName), myPhases(orig.myPhases), myPlansStatus(orig.myPlansStatus) {}
         
         DtString myName;
         DtString myCurrentPhase;
         DtRwSyncMatrixObjectList myObjects;
         DtRwSyncMatrixPhaseList myPhases;
         DtRwSyncMatrixPlanList myPlansStatus;
      };

      typedef std::map<DtUUID, SyncMatrixWithPhases> SyncMatrices;

      struct ObjectUpdateMonitor
      {
         ObjectUpdateMonitor(const DtUUID& uuid = DtUUID::nullUUID()):
            myUUID(uuid), myUpdateUUID(uuid), mySubEntitiesCount(0), mySubAggregatesCount(0){}
         DtUUID myUUID;
         DtUUID myUpdateUUID;
         int mySubEntitiesCount;
         int mySubAggregatesCount;
         std::string myMarkingText;
      };

      typedef std::map<makVrv::DtUniqueID, ObjectUpdateMonitor> ObjectUpdateMonitorsMap;

      DtVrfSyncMatrixManager(makVrv::DtDe& de);

      virtual ~DtVrfSyncMatrixManager();

      static DtVrfSyncMatrixManager& instance(makVrv::DtDe& de);

      virtual void show(QWidget* parent, const DtUUID& forUUID = DtUUID::nullUUID());

      virtual void requestSyncMatrices();

      virtual const SyncMatrices& syncMatrices() const;

      virtual void setSelectedSyncMatrix(const DtUUID& uuid);
      virtual const DtUUID& selectedSyncMatrix();

      virtual void requestNewSyncMatrix(const QString& name ="");
      virtual void requestSyncMatrixRename(const DtUUID& uuid, const QString& name);
      virtual void requestSyncMatrixRemove(const DtUUID& uuid);

      virtual void requestSyncMatrixPhaseRemove(const DtUUID& uuid, const QString& phaseName);

      virtual void requestNewSyncMatrixObjects(const DtUUID& syncMatrix, const std::vector<DtUUID>& objects);
      virtual void requestSyncMatrixObjectRemove(const DtUUID& syncMatrix, const DtUUID& object);

      virtual void requestSyncMatrixPlan(const DtUUID& syncMatrix, const DtUUID& object,
         const QString& phaseName);

      virtual void removeSyncMatrixPlan(const DtUUID& syncMatrix, const DtUUID& object,
         const QString& phaseName);

      virtual void activateSyncMatrixPlan(const DtUUID& syncMatrix, const DtUUID& object,
         const QString& phaseName, bool activate);

      virtual void setSyncMatrixPhaseInfo(const DtUUID& syncMatrix,
         const QString& currentName, int phaseIndex, 
         const QString& requestedName, bool endConditionSpecified,
         const DtSimCondExpr* endCondition = NULL);

      virtual bool objectExistsInMatrix(const SyncMatrixWithPhases& syncMatrix, const DtUUID& object) const;
      virtual bool objectExistsInMatrix(const DtUUID& syncMatrix, const DtUUID& object) const;

      virtual bool objectExistsInMatrix(const DtUUID& object) const;

      virtual QString findFirstSyncMatrixFor(const DtUUID&) const;

      virtual void copyPlanToClipboard(const DtUUID& syncMatrix, const DtUUID& object, const QString& phaseName);
      virtual void copyPlanFromClipboard(const DtUUID& syncMatrix, const DtUUID& object, const QString& phaseName);

      boost::signals2::signal<void()> signal_clearSyncMatrices;
      boost::signals2::signal<void()> signal_syncMatrixManagerChanged;
      boost::signals2::signal<void(const DtUUID&, const DtString&)> signal_receivedRenameSyncMatrix;
      boost::signals2::signal<void(const DtUUID&)> signal_receivedRemoveSyncMatrix;
      boost::signals2::signal<void(bool)> signal_enableAddAndRenameSyncMatrix;
      boost::signals2::signal<void(const DtUUID&)> signal_syncMatrixPhaseUpdate;
      boost::signals2::signal<void(const DtUUID&)> signal_receivedSyncMatrixInfo;
      boost::signals2::signal<void(const DtUUID&)> signal_receivedSyncMatrixObjectsList;
      boost::signals2::signal<void(const DtUUID&, const DtString&, const DtString&, bool)> signal_receivedMoveToPhase;
      boost::signals2::signal<void(const DtUUID&, const DtString&, const DtString&, bool, bool)> signal_receivedPlanStatus;

      boost::signals2::signal<void(const DtUUID&, const DtUUID&)> signal_syncMatrixObjectUpdated;
      boost::signals2::signal<void(const DtUUID&, const DtString&)> signal_syncMatrixObjectRenamed;

   protected:
      virtual DtSyncMatrixDialogInterface* createSyncMatrixDialog(QWidget* parent);

      virtual void sessionStatusChanged(bool status);
      virtual void backendUpdated(int flags);

      virtual void clearAllSyncMatrices();

      virtual makVrv::DtUniqueID registerToObjectUpdate(makVrv::DtUniqueID id);
      virtual void unregisterToObjectUpdate(makVrv::DtUniqueID id);

      virtual void registerListToObjectUpdates(const DtRwSyncMatrixObjectList& objectList);
      virtual void registerToObjectUpdateInHierarchy(makVrv::DtUniqueID id);
      virtual void resetObjectUpdateMonitors();

      virtual void processSyncMatrixListResponse(DtSimMessage* msg);
      virtual void processSyncMatrixRenameResponse(DtSimMessage* msg);
      virtual void processSyncMatrixRemoveResponse(DtSimMessage* msg);
      virtual void processSyncMatrixRemovePhaseResponse(DtSimMessage* msg);
      virtual void processSyncMatrixInfoResponse(DtSimMessage* msg);
      virtual void processSyncMatrixObjectsListResponse(DtSimMessage* msg);
      virtual void processSyncMatrixPhaseInfoResponse(DtSimMessage* msg);
      virtual void processSyncMatrixCurrentPhase(DtSimMessage* msg);
      virtual void processSyncMatrixPlansStatus(DtSimMessage* msg);
      virtual void receivedPlanCallbackForCopy(DtSimMessage* msg);

      virtual void slot_onObjectAboutToBeRemoved(const makVrv::DtStateView<makVrv::DtVrlinkSimulatedBaseState>* s);
      virtual void slot_onObjectAdded(const makVrv::DtStateView<makVrv::DtVrlinkSimulatedBaseState>* s);
      virtual void slot_onObjectNameChanged(const makVrv::DtStateView<makVrv::DtVrlinkSimulatedBaseState>* s, const std::string& newName);

      virtual void slot_onAggregateStateViewUpdated(makVrv::DtStateView<DtVrlinkSimulatedAggregateState>* s);

   protected:

      makVrv::DtDe&                       myDe;
      DtSyncMatrixDialogInterface*        mySyncMatrixDialog;
      SyncMatrices                        mySyncMatrices;
      makVrv::DtSignalConnectionManager   myConnections;
      DtUUID                              mySelectedSyncMatrix;
      ObjectUpdateMonitorsMap             myObjectsMonitor;

      DtUUID                              myWaitingForCopyObject;
      DtUUID                              myWaitingForCopyMatrix;
      QString                             myWaitingForCopyPhase;
   };
}