#ifndef __CLIENT_MANAGER_H__
#define __CLIENT_MANAGER_H__
#include <string>
#include <rapidjson/document.h>
#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>

#include "ServClient.h"
#include "redis_publisher.h"
#include "ThriftClient.h"


class CClientManager
{
public:
    typedef boost::function<bool(std::string&, const std::string&, const std::string&, const std::string&, bool)> Method;
    CClientManager();
    ~CClientManager();
public:
    static CClientManager* instance();
public:
    bool SendWSData(rapidjson::Document &document, rapidjson::Value &dataValue);
    bool IsOnLine(const std::string &openId);
    bool IsOnLines(const std::vector<std::string> &openIdVector, std::vector<int> &onLineVector);
    bool thriftMethod(rapidjson::Document& returnDocument, const std::string& method, const rapidjson::Value& reqArgsValue);
    bool thriftMethodSyn(rapidjson::Document& returnDocument, const std::string& method, rapidjson::Value& reqArgsValue, rapidjson::Document &document);

    bool thriftMethod(std::string& _return, const std::string &openId, const std::string& method, const std::string& reqArgs);
    bool thriftMethodSyn(std::string& _return, const std::string &openId, const std::string& method, const std::string& reqArgs);
    bool RegisterMethod(const char *methodName, Method method);
    void CleanStr(const std::string& srcStr, const std::string cleanChars, std::string& dstStr);
private:
    void ConnPoolInit();
    void RegisterMethods(const rapidjson::Value &methodsValue, boost::shared_ptr<CThriftClient> &thriftClient);
    bool Ping(std::string& _return, const std::string &openId, const std::string &method, const std::string &content, bool isSyn);
    bool Websocket(std::string& _return, const std::string& openId, const std::string& method, const std::string& content, bool isSyn);
    bool Webview(std::string& _return, const std::string& openId, const std::string& method, const std::string& content, bool isSyn);
    void InitPublisher();
    rapidjson::Value &CompressData(rapidjson::Document &document, rapidjson::Value &dataValue);
    std::string &Compress(const std::string &srcData, std::string &dstData);
private:	
    static	CClientManager* _instance;
    typedef std::map<std::string, Method> MethodMap;
    MethodMap m_methodMap;
    CRedisPublisher m_publisher;
    boost::mutex m_publisherMutex;
    int m_serialNumber;

    std::vector<boost::shared_ptr<CThriftClient>> m_thriftClientVector;
};
#endif