myvtm/Module/mod_chromium/EntitySessionManager.h

#ifndef __ENTITY_SESSION_MANAGER_H
#define __ENTITY_SESSION_MANAGER_H

#include <map>
#include <vector>
#include <string>
#include "CMessage.h"
// #include "CSocketClient.h"
// #include "CWSCodec.h"

namespace Chromium {

	enum RequestProcessType {
		PROCESS_NOTHING,
		PROCESS_SEND,
		PROCESS_STARTSESSION,
		PROCESS_FINDSESSION,
		PROCESS_RECORDMSG
	};

	enum AckProcessType {
		ACKPROCESS_NOTHING,
		ACKPROCESS_SEND
	};

	typedef struct WSClientReqInfoStruct {
		int transID;
		unsigned int hdlID;
		struct WSClientReqInfoStruct* next;
	}WSClientReqInfo;

	class EntitySessionManager {
	public:
		//	EntitySessionManager(CSocketClient* pSocket, CWSCodec* serializer);
		EntitySessionManager();
		~EntitySessionManager();

		std::pair<int, std::string> GetStartSessionRequest(std::string entityname, std::string className);	//返回分配的transId和生成的beginSession串
		std::pair<int, std::string> GetAllSessionRequest(int transId, bool isInitCfg);
		RequestProcessType RequestProcess(CMessage* msg, std::string entityName,
			unsigned int hdlID);
		AckProcessType AckProcess(CMessage* msg, unsigned int& hdlID);
		AckProcessType AskProcessEvent(CMessage* msg, std::vector<std::pair<int, int>>& transIdandHdlIDArr);
		std::pair<AckProcessType, std::string> AskProcessSession(CMessage* msg, unsigned int& hdlID);
		std::string GetStartSessionAck(CMessage* msg, std::string entityname);
		std::pair<bool, std::string> DoSessionRemove(unsigned int session);
		EntitySessionManager& DoSessionUpdate(std::string entityname, int session);

		int MakeNewTransID(CMessage* msg, unsigned int hdlID);
		std::pair<bool, int> getSrcTransID(int newTransID);
		WSClientReqInfo* ReduceOriginTransID(CMessage* msg);

		void updateBeginSessionTime(std::string entityName, bool doCleanSessionTime = false);
		bool checkBeginSession(std::string entityName);
		void StoreSessionReq(int transid, std::string entityname);
		std::vector<std::string> queryUnLinkSession();
		static std::map<std::string, int> queryAllSessionInfo();
		void doWithErrorCode(int errorCode, int transId);
	private:

		static std::map<std::string, int> m_session_map;	// entity name -> session id
		std::map<int, WSClientReqInfo> m_trans_map;	// real trans id -> client trans id & client ws connection handler	
		std::map<int, std::string> m_session_ack_map;	// trans id -> entity name	
		std::map<std::string, int> m_broadcast_map;	// broadcast list
		std::map<std::string, time_t> t_BeginSessionTime;

		
		//	CSocketClient* m_socket;
		//	CWSCodec* m_serializer;
	private:
		std::pair<bool, int> GetSessionIDByEntityName(std::string entityname);

		void RemoveAckListNode(int transid);
		std::string UpdateSessionMap(int transid, int sessionId);	//更新session表并返回更新的实体名

		// process with requests
		RequestProcessType ProcessWithInfo(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithBeginSession(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithEndSession(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithRequest(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithRegister(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithUnregister(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithSetVarReq(CMessage* msg, std::string entityName, unsigned int hdlID);
		RequestProcessType ProcessWithGetVarReq(CMessage* msg, std::string entityName, unsigned int hdlID);

		AckProcessType ProcessWithAck(CMessage* msg, unsigned int& hdlID);
		AckProcessType ProcessWithRecvEvent(CMessage* msg, unsigned int& hdlID);
	};

}

#endif