forwarderWebManager.h

Go to the documentation of this file.

/*********************************************************************
 ** Copyright (c) 2006 MaK Technologies, Inc.
 ** All rights reserved.
 *********************************************************************/
/*******************************************************************************
 ** $RCSfile: forwarderWebManager.h,v $ $Revision: 1.2 $ $State: Exp $
 *******************************************************************************/

#ifndef DtForwarderWebManager_H_
#define DtForwarderWebManager_H_

#include <rtiMsConfig.h>
#include <spyXmlDocument.h>
#include <wwwSpyAdapter.h>
#include <wwwRequestXmlBlock.h>
#include <netMapForwarderXmlBlock.h>
#include <vlutil/vlThreadSafe.h>
#include <rtiMsg.h>
#include <vlutil/vlTime.h>
#include <deque>

class DtForwarderNode;
class DtNetworkMapProcessor;
class DtWwwControlRspMsg;
class DtNetworkMapRspMsg;

class DT_DLL_FORWARDER DtForwarderWebManager
{
public:
      
   typedef bool (DtForwarderWebManager::* NetworkMapMsgRspHandlerMemberCb)(
      MAKRti::DtInetAddr src, const DtNetworkMapRspMsg& msg  );

public:
   
   DtForwarderWebManager( DtBoost::shared_ptr<DtForwarderNode> parent );
   virtual ~DtForwarderWebManager();

   virtual MAKRti::DtString printableNetworkMap( bool drawTree = true ) const;

   virtual DtSpyXmlDocumentSP getNetworkMap() const;

   virtual bool tick( double maxTime );

public:
   
   static void requestComplete( DtNetworkMapRspMsg& msg, void* usr );

protected:

   typedef void ( DtForwarderWebManager::*MessageHandlerFn)( const DtRtiMsg* );
   typedef std::list< MessageHandlerFn > MessageHandlerList;
   typedef std::map< DtRtiMsgKind, MessageHandlerList > MessageHandlersByKind;

   void requestComplete( DtNetworkMapRspMsg& msg );
   
   virtual void registerMsgHandler( DtRtiMsgKind kind, MessageHandlerFn func );
   virtual void unRegisterMsgHandler( DtRtiMsgKind kind, MessageHandlerFn func );

   virtual const MessageHandlerList& messageHandlersForKind( DtRtiMsgKind kind );

   virtual void handleWwwCommandMsg( const DtRtiMsg* );
   virtual void handleStateRequestMsg( const DtRtiMsg* msg );


   virtual DtWwwControlRspMsg* buildWwwCommandResponse(
      DtWebSpyUtils::WwwControlMsgCommandId commandType, const MAKRti::DtString& commandString );
   virtual std::auto_ptr<MAKRti::DtString> buildWwwStateResponse( 
      DtWebSpyUtils::StateComponentType requestType );


   virtual void issueNetworkMapRequest() const;

   void printForwarder( DtNetMapForwarderXmlBlockSP forwarderSP, MAKRti::DtString& target,
      MAKRti::DtString indentLevel, bool drawTree = true ) const;
   
protected:

   DtClock myClock;
   unsigned long myConnId;
   DtBoost::shared_ptr<DtForwarderNode> myParent;
   DtNetworkMapProcessor* myNetworkMapProcessor;
   std::auto_ptr<DtWwwSpyAdapter> myWebAdapter;
   MessageHandlersByKind myMessageHandlers;

   DtSpyXmlDocumentSP myXmlNetworkMapDoc;
};


#endif //! DtForwarderWebManager_H_