/*
 * =====================================================================================
 *
 *       Filename:  center.h
 *
 *    Description:  
 *
 *        Version:  1.0
 *        Created:  2021年03月30日 16时22分24秒
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  Li Chao (), 
 *   Organization:  
 *
 * =====================================================================================
 */
#ifndef CENTER_TM9OUQTG
#define CENTER_TM9OUQTG

#include "shm_socket.h"
#include <functional>
#include <map>
#include <memory>
class CenterTopicNode;
class TcpServer;
class TcpProxy;
class IoService;

class BHCenter
{
	typedef ShmSocket Socket;

public:
	typedef Socket::PartialRecvCB MsgHandler;
	typedef Socket::RawRecvCB RawHandler;
	typedef Socket::IdleCB IdleHandler;
	static bool Install(const std::string &name, MsgHandler handler, RawHandler raw_handler, IdleHandler idle, const MQInfo &mq, const int mq_len);

	BHCenter(Socket::Shm &shm);
	~BHCenter();
	bool Start();
	bool Stop();

private:
	struct CenterInfo {
		std::string name_;
		MsgHandler handler_;
		RawHandler raw_handler_;
		IdleHandler idle_;
		MQInfo mq_;
		int mq_len_ = 0;
	};
	typedef std::map<std::string, CenterInfo> CenterRecords;
	static CenterRecords &Centers();

	std::map<std::string, std::shared_ptr<ShmSocket>> sockets_;
	std::unique_ptr<CenterTopicNode> topic_node_;

	std::unique_ptr<IoService> io_service_;
	std::unique_ptr<TcpServer> tcp_server_;
	std::unique_ptr<TcpProxy> tcp_proxy_;
};

#endif // end of include guard: CENTER_TM9OUQTG