objectConsoleMessageHandler.h

Go to the documentation of this file.

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



#pragma once


#include <vrfGuiCore/vrfGuiCore.h>
#include <vrvCore/DtUniqueID.h>
#include <vrvUtil/DtVirtualBaseClass.h>
#include <vrvUtil/DtUnicode.h>
#include <vlutil/vlPrint.h>
#include <vrfmsgs/ifAskUserQuestion.h>
#include <vrfutil/rwUUID.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrvCore/DtStateView.h>
#include <vrvCore/DtEntityState.h>

#include <map>
#include <vector>

namespace makVrv
{
   class DtDe;
   class DtSimObjectEntry;
}

class DtEntityIdentifier;
class DtString;
class DtSimMessage;

namespace makVrf
{
   static DtNotifyLevelType DtNlQuestion = DtNotifyLevelType(DtNlDebug + 10);

   class DtNetworkMessageInterface;
   class DtCommentInteractionInterface;

   class DT_DLL_VRFGUICORE DtObjectConsoleMessageHandler : public makVrv::DtVirtualBaseClass
   {
   public:
      typedef std::vector<std::pair<makVrv::DtUnicode, int> > DtConsoleMessageList;

      DtObjectConsoleMessageHandler(makVrv::DtDe&);
      virtual ~DtObjectConsoleMessageHandler();

      static DtObjectConsoleMessageHandler& instance(makVrv::DtDe& de);
      static void registerInstance(makVrv::DtDe& de, DtObjectConsoleMessageHandler*);

      virtual void setEnabled(bool);
      bool enabled() const
      {
         return myEnabled;
      }

      boost::signals2::signal<void (const DtUUID&, int notifyLevel, const makVrv::DtUnicode&)> signal_consoleMessageReceived;
      boost::signals2::signal<void (int)> signal_messageQueueSizeChanged;
      boost::signals2::signal<void (makVrv::DtElementID, int, int)> signal_questionStatusChanged;

      virtual void setMessageQueueSize(int);
      int messageQueueSize() const
      {
         return myMessageQueueSize;
      }

      virtual bool questionFor(makVrv::DtElementID id, int questionId, DtIfAskUserQuestion&) const;

      virtual std::vector<int> pendingQuestionsFor(makVrv::DtElementID) const;

      virtual bool hasOutstandingQuestions(makVrv::DtElementID) const;

      virtual bool hasAwaitingMessage(makVrv::DtElementID id);

      virtual DtConsoleMessageList messagesFor(const DtUUID& entityId) const;

      virtual void setReceivingMessagesFor(makVrv::DtElementID, bool);

      virtual bool receivingMessagesFor(makVrv::DtElementID) const;

      virtual void clearAllMessages(const DtUUID& entityId);

      virtual void userQuestionAnswered(makVrv::DtElementID id, int questionId);

   protected:
      virtual void processObjectConsoleMessageCallback(DtNetworkMessageInterface*);
      virtual void slot_simObjectEntryAboutToBeRemoved(const makVrv::DtStateView<makVrv::DtVrlinkSimulatedBaseState>* state);

      virtual void processUserQuestion(DtSimMessage*);
      virtual bool processQuestion(const DtIfAskUserQuestion&);
      virtual void processUserQuestionOperation(DtSimMessage*);

      virtual void messagesToResolve();
      virtual void questionsToResolve();

      virtual makVrv::DtUnicode translateComment(DtCommentInteractionInterface* comment) const;
      virtual void messagesToResolve(makVrv::DtElementID);
      virtual void checkIfNeedsToNotifyForNewMessage(makVrv::DtElementID, int notifyLevel);

   protected:
      typedef std::map<DtUUID, DtConsoleMessageList> ConsoleMessageMap;

      makVrv::DtDe&        myDe;
      bool                 myEnabled;
      int                  myMessageQueueSize;
      ConsoleMessageMap    myConsoleMessageMap;

      std::map<makVrv::DtElementID, int> myReceivingMessagesFor;

      std::map<DtUUID, int> myHasAwaitingMessages;
      std::map<std::string, DtIfAskUserQuestion> myHasAwaitingQuestions;

      std::map<makVrv::DtElementID, int> mySetAwaiting;

      typedef std::map<DtUUID, std::vector<DtIfAskUserQuestion> > PendingQuestions;
      PendingQuestions myPendingQuestions;

      makVrv::DtSignalConnectionManager myConnections;
   };
}