vrfCurrentTaskManager.h

Go to the documentation of this file.

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



#pragma once

#include <vrfGuiCore/vrfGuiCore.h>

#include <vrvUtil/DtVirtualBaseClass.h>
#include <vrvCore/DtStateView.h>
#include <vrvCore/DtEntityState.h>

#include <vrftasks/simTask.h>
#include <vrftasks/currentTasksAdminContent.h>
#include <vrfutil/rwUUID.h>


#include <boost/function.hpp>

class DtVrfObjectMessage;

namespace makVrv
{
   class DtDe;
   class DtSimObjectEntry;
}

namespace makVrf
{

   class DT_DLL_VRFGUICORE DtVrfCurrentTaskManager : public makVrv::DtVirtualBaseClass
   {
   public:
      typedef DtBoost::shared_ptr<DtSimTask> DtSimTaskSharedPtr;
      typedef DtBoost::shared_ptr<DtSetDataRequest> DtSetDataRequestSharedPtr;
      typedef std::vector<DtSimTaskMessageType> Conflicting;

      struct TaskInformation
      {
         DtSimTaskSharedPtr task;
         DtSetDataRequestSharedPtr set;
         std::vector<TaskInformation> subtasks;
         int status;
         DtString controller;
         Conflicting conflictingTasks;
      };

      typedef std::vector<TaskInformation> EntityTaskInformation;

   public:
      DtVrfCurrentTaskManager(makVrv::DtDe&);
      virtual ~DtVrfCurrentTaskManager();

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

   public:
      boost::signals2::signal<void (const DtUUID&)> signal_currentTaskChanged;

      boost::signals2::signal<void ()> signal_allRequestsReceived;

      virtual void subscribeForTaskInformation(const makVrv::DtUniqueID& simId);
      virtual void unsubscribeForTaskInformation(const makVrv::DtUniqueID& simId, bool all = false);

      typedef boost::function<void (DtUUID, const EntityTaskInformation&)> DtRequestTaskCallbackFcn;

      virtual void requestCurrentTasksFor(const makVrv::DtUniqueID& simId, DtRequestTaskCallbackFcn);

      virtual void requestCurrentTasksFor(const std::vector<makVrv::DtUniqueID>& simIds);
      virtual void requestCurrentTasksFor(const std::vector<makVrv::DtSimEntry*>&);

      virtual void defaultReceivedTaskCallback(const DtUUID&, const EntityTaskInformation&);

      virtual const EntityTaskInformation* tasksFor(const makVrv::DtUniqueID& simId) const;

   protected:
      virtual void slot_simObjectEntryAboutToBeRemoved(makVrv::DtSimObjectEntry& entry);
      virtual void processEntityCurrentTaskCallback(const DtVrfObjectMessage* msg);

      virtual makVrv::DtUniqueID isMonitoring(const DtUUID&) const;
      virtual makVrv::DtUniqueID isRequesting(const DtUUID&) const;

      virtual void convertTaskList(const DtCurrentTasksAdminContent::DtTaskList&, EntityTaskInformation&) const;

      virtual void convertScriptedSetList(const DtCurrentTasksAdminContent::DtScriptedSetList&, EntityTaskInformation&) const;

      virtual TaskInformation convertDataToTaskInformation(const DtCurrentTaskData& data) const;

      virtual TaskInformation convertDataToScriptedSetInformation(const DtCurrentScriptedSetData& data) const;

      virtual void convertMessageToInformation(const DtCurrentTasksAdminContent*, EntityTaskInformation&) const;

   protected:
      makVrv::DtDe&  myDe;

      typedef std::pair<EntityTaskInformation, int> EntityTasks;

      typedef std::map<makVrv::DtUniqueID, EntityTasks>  DtEntityTaskMap;
      DtEntityTaskMap myTasks;

      typedef std::vector<DtRequestTaskCallbackFcn> DtRequestCallbackVector;
      typedef std::map<makVrv::DtUniqueID, DtRequestCallbackVector> DtRequestCallbackMap;

      DtRequestCallbackMap myTaskRequestCallbacks;
      bool myConnectedToReceiveTasks;
   };
}