teleport/client/tp_assist_win/ts_http_rpc.h

#ifndef __TS_HTTP_RPC_H__
#define __TS_HTTP_RPC_H__

#include "../../external/mongoose/mongoose.h"

#include "ts_const.h"

#include <vector>
#include <string>
#include <map>

#include <ex.h>
#include <json/json.h>


/*
//=================================================================
<EFBFBD>ӿ<EFBFBD>ʹ<EFBFBD><EFBFBD>˵<EFBFBD><EFBFBD><EFBFBD><EFBFBD>

<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>󣬼<EFBFBD><EFBFBD><EFBFBD> localhost:50022<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>http<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʽҪ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>£<EFBFBD>

GET <EFBFBD><EFBFBD>ʽ
http://localhost:50022/method/json_param
<EFBFBD><EFBFBD><EFBFBD><EFBFBD>json_param<EFBFBD><EFBFBD>ʹ<EFBFBD><EFBFBD>url_encode<EFBFBD><EFBFBD><EFBFBD>б<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>json<EFBFBD><EFBFBD>ʽ<EFBFBD>ַ<EFBFBD><EFBFBD><EFBFBD>

POST <EFBFBD><EFBFBD>ʽ
http://localhost:50022/method
post<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>json_param

<EFBFBD><EFBFBD><EFBFBD>У<EFBFBD>URI<EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>֣<EFBFBD>
method			<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ִ<EFBFBD>е<EFBFBD><EFBFBD><EFBFBD><EFBFBD>񷽷<EFBFBD><EFBFBD><EFBFBD>
json_param		<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>񷽷<EFBFBD><EFBFBD>ĸ<EFBFBD><EFBFBD>Ӳ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>û<EFBFBD>и<EFBFBD><EFBFBD>Ӳ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ⲿ<EFBFBD>ֿ<EFBFBD><EFBFBD><EFBFBD>ʡ<EFBFBD>ԡ<EFBFBD>

<EFBFBD><EFBFBD><EFBFBD>ظ<EFBFBD>ʽ<EFBFBD><EFBFBD>ִ<EFBFBD>н<EFBFBD><EFBFBD><EFBFBD><EFBFBD>󣬷<EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD>json<EFBFBD><EFBFBD>ʽ<EFBFBD><EFBFBD><EFBFBD>ַ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ߣ<EFBFBD><EFBFBD><EFBFBD>ʽ<EFBFBD><EFBFBD><EFBFBD>£<EFBFBD>

{"code":0,"data":varb}

<EFBFBD><EFBFBD><EFBFBD>У<EFBFBD>code<EFBFBD>DZ<EFBFBD><EFBFBD>еģ<EFBFBD><EFBFBD><EFBFBD>ֵ<EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>룬0<EFBFBD><EFBFBD>ʾ<EFBFBD>ɹ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD>ܣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>û<EFBFBD><EFBFBD>data<EFBFBD>򡣲<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD>ʱ<EFBFBD><EFBFBD>data<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ķ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʽ<EFBFBD><EFBFBD><EFBFBD>ݾ<EFBFBD><EFBFBD><EFBFBD>ִ<EFBFBD>е<EFBFBD><EFBFBD><EFBFBD><EFBFBD>񷽷<EFBFBD><EFBFBD><EFBFBD>ͬ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͬ<EFBFBD><EFBFBD>

*/

void http_rpc_main_loop(bool is_https);
void http_rpc_stop(bool is_https);

typedef std::map<ex_astr, ex_astr> content_type_map;

// for https server, see
// http://www.xiaovdiy.cn/?post=284

class TsHttpRpc {
public:
    TsHttpRpc();
    ~TsHttpRpc();

    bool init_http();
    bool init_https();
    void run(void);
    void stop(void);
    void _rpc_func_url_protocol(const ex_astr& func_args, ex_astr& buf);

    ex_astr get_content_type(ex_astr file_suffix) {
        content_type_map::iterator it=m_content_type_map.find(file_suffix);
        if (it != m_content_type_map.end()) {
            return it->second;
        } else {
            return "application/octet-stream";
        }
    };

private:
    bool _on_init();
    int _parse_request(struct http_message* req, ex_astr& func_cmd, ex_astr& func_args);
    void _process_js_request(const ex_astr& func_cmd, const ex_astr& func_args, ex_astr& buf);
    void _create_json_ret(ex_astr& buf, int errcode);
    void _create_json_ret(ex_astr& buf, Json::Value& jr_root);

    void _rpc_func_run_client(const ex_astr& func_args, ex_astr& buf);
    // 	void _rpc_func_check(const ex_astr& func_args, ex_astr& buf);
    void _rpc_func_rdp_play(const ex_astr& func_args, ex_astr& buf);
    void _rpc_func_get_config(const ex_astr& func_args, ex_astr& buf);
    void _rpc_func_set_config(const ex_astr& func_args, ex_astr& buf);
    void _rpc_func_file_action(const ex_astr& func_args, ex_astr& buf);
    void _rpc_func_get_version(const ex_astr& func_args, ex_astr& buf);

    static void _mg_event_handler(struct mg_connection *nc, int ev, void *ev_data);

private:
    content_type_map m_content_type_map;
    struct mg_mgr m_mg_mgr;
    bool m_stop;
};

#endif // __TS_HTTP_RPC_H__