rexy712/matrix_thing
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Update to new rjp api

Browse Source
This commit is contained in:
rexy712 2020-04-09 13:20:53 -07:00
parent ec3901b904
commit 76431079c6
7 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/matrix/client.cpp
View File

@ -67,7 +67,7 @@ namespace matrix{
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<std::vector<raii::rjp_string>> retval = _create_netreturn(root, http_status()); netreturn<std::vector<raii::rjp_string>> retval = _create_netreturn(root, http_status());
if(!root) if(!root)
return retval; return retval;
@ -180,7 +180,7 @@ namespace matrix{
if(!reply) if(!reply)
return netreturn<sync::client_response>(rexy::string(), rexy::string(), http_status(), {nullptr}); return netreturn<sync::client_response>(rexy::string(), rexy::string(), http_status(), {nullptr});
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<sync::client_response> retval = _create_netreturn(root, http_status()); netreturn<sync::client_response> retval = _create_netreturn(root, http_status());
if(!root) if(!root)
return retval; return retval;
@ -227,7 +227,7 @@ namespace matrix{
if(!succ || !fileurl) if(!succ || !fileurl)
return _create_netreturn(fileurl, http_status()); return _create_netreturn(fileurl, http_status());
raii::rjp_ptr root(rjp_parse(fileurl, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(fileurl, RJP_PARSE_ALL_EXT, NULL));
netreturn<uploaded_file> retval = _create_netreturn(root, http_status()); netreturn<uploaded_file> retval = _create_netreturn(root, http_status());
if(!root) if(!root)
return retval; return retval;

10
src/matrix/connection.cpp
View File

@ -161,7 +161,7 @@ namespace matrix{
rexy::string reply = _post_curl(data, url, header); rexy::string reply = _post_curl(data, url, header);
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status()); netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status());
retval.value() = _curl_reply_search(reply, target); retval.value() = _curl_reply_search(reply, target);
return retval; return retval;
@ -172,7 +172,7 @@ namespace matrix{
rexy::string reply = _put_curl(data, url, header); rexy::string reply = _put_curl(data, url, header);
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status()); netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status());
retval.value() = _curl_reply_search(reply, target); retval.value() = _curl_reply_search(reply, target);
return retval; return retval;
@ -181,13 +181,13 @@ namespace matrix{
rexy::string reply = _get_curl(url); rexy::string reply = _get_curl(url);
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status()); netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status());
retval.value() = _curl_reply_search(reply, target); retval.value() = _curl_reply_search(reply, target);
return retval; return retval;
} }
raii::rjp_string connection::_curl_reply_search(const rexy::string_base& reply, const rexy::string_base& target)const{ raii::rjp_string connection::_curl_reply_search(const rexy::string_base& reply, const rexy::string_base& target)const{
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
return _curl_reply_search(root, target); return _curl_reply_search(root, target);
} }
raii::rjp_string connection::_curl_reply_search(const raii::rjp_ptr& root, const rexy::string_base& target)const{ raii::rjp_string connection::_curl_reply_search(const raii::rjp_ptr& root, const rexy::string_base& target)const{
@ -218,7 +218,7 @@ namespace matrix{
netreturn_base connection::_create_netreturn(const rexy::string_base& mxjson, int httpstatus){ netreturn_base connection::_create_netreturn(const rexy::string_base& mxjson, int httpstatus){
if(!mxjson) if(!mxjson)
return netreturn_base(""_ss, ""_ss, httpstatus); return netreturn_base(""_ss, ""_ss, httpstatus);
raii::rjp_ptr root(rjp_parse(mxjson.get(), RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(mxjson.get(), RJP_PARSE_ALL_EXT, NULL));
return _create_netreturn(root, httpstatus); return _create_netreturn(root, httpstatus);
} }
netreturn_base connection::_create_netreturn(const raii::rjp_ptr& root, int httpstatus){ netreturn_base connection::_create_netreturn(const raii::rjp_ptr& root, int httpstatus){

8
src/matrix/roomcxn.cpp
View File

@ -57,7 +57,7 @@ namespace matrix{
rexy::string resp = _get_curl(m_urls.room_members()); rexy::string resp = _get_curl(m_urls.room_members());
if(!resp) return _create_netreturn(resp, http_status()); if(!resp) return _create_netreturn(resp, http_status());
raii::rjp_ptr root(rjp_parse(resp.get(), RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(resp.get(), RJP_PARSE_ALL_EXT, NULL));
if(!root) return _create_netreturn(root, http_status()); if(!root) return _create_netreturn(root, http_status());
RJP_value* res = rjp_search_member(root.get(), json::keys::joined()); RJP_value* res = rjp_search_member(root.get(), json::keys::joined());
if(!res) return _create_netreturn(root, http_status()); if(!res) return _create_netreturn(root, http_status());
@ -107,7 +107,7 @@ namespace matrix{
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status()); netreturn<raii::rjp_string> retval = _create_netreturn(root, http_status());
retval.value() = _curl_reply_search(root, json::keys::event::eventid()); retval.value() = _curl_reply_search(root, json::keys::event::eventid());
return retval; return retval;
@ -144,7 +144,7 @@ namespace matrix{
netreturn<sync::roomcxn_message_event_list> roomcxn::get_event(const rexy::string_base& eventid)const{ netreturn<sync::roomcxn_message_event_list> roomcxn::get_event(const rexy::string_base& eventid)const{
rexy::string reply = _get_curl(m_urls.event(*m_ses, m_curl.encode(m_roomid), eventid)); rexy::string reply = _get_curl(m_urls.event(*m_ses, m_curl.encode(m_roomid), eventid));
if(!reply) return _create_netreturn(reply, http_status()); if(!reply) return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply.get(), RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply.get(), RJP_PARSE_ALL_EXT, NULL));
if(!root.get()) _create_netreturn(root, http_status()); if(!root.get()) _create_netreturn(root, http_status());
netreturn<sync::roomcxn_message_event_list> retval = _create_netreturn(root, http_status()); netreturn<sync::roomcxn_message_event_list> retval = _create_netreturn(root, http_status());
@ -160,7 +160,7 @@ namespace matrix{
netreturn<sync::roomcxn_message_event_list> roomcxn::_get_events(int amount, rexy::static_string direction, const rexy::string_base& from, const rexy::string_base& to){ netreturn<sync::roomcxn_message_event_list> roomcxn::_get_events(int amount, rexy::static_string direction, const rexy::string_base& from, const rexy::string_base& to){
rexy::string reply = _get_curl(m_urls.messages(*m_ses, m_curl.encode(m_roomid), from, to, direction, amount)); rexy::string reply = _get_curl(m_urls.messages(*m_ses, m_curl.encode(m_roomid), from, to, direction, amount));
if(!reply) return _create_netreturn(reply, http_status()); if(!reply) return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply.get(), RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply.get(), RJP_PARSE_ALL_EXT, NULL));
if(!root.get()) _create_netreturn(root, http_status()); if(!root.get()) _create_netreturn(root, http_status());
netreturn<sync::roomcxn_message_event_list> retval = _create_netreturn(root, http_status()); netreturn<sync::roomcxn_message_event_list> retval = _create_netreturn(root, http_status());

4
src/matrix/session.cpp
View File

@ -82,7 +82,7 @@ namespace matrix{
rexy::string reply = _post_curl(json::_empty(), rest::session_urls::password(*m_ses), raii::curl_llist()); rexy::string reply = _post_curl(json::_empty(), rest::session_urls::password(*m_ses), raii::curl_llist());
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<void> retval = _create_netreturn(root, http_status()); netreturn<void> retval = _create_netreturn(root, http_status());
if(!root) if(!root)
return retval; return retval;
@ -155,7 +155,7 @@ namespace matrix{
rexy::string reply = _request_access_token(name, pass, loginurl); rexy::string reply = _request_access_token(name, pass, loginurl);
if(!reply) if(!reply)
return _create_netreturn(reply, http_status()); return _create_netreturn(reply, http_status());
raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(reply, RJP_PARSE_ALL_EXT, NULL));
netreturn<std::pair<raii::rjp_string,raii::rjp_string>> retval = _create_netreturn(root, http_status()); netreturn<std::pair<raii::rjp_string,raii::rjp_string>> retval = _create_netreturn(root, http_status());
if(!root) if(!root)
return retval; return retval;

2
src/matrix/sync_response.cpp
View File

@ -51,7 +51,7 @@ namespace matrix::sync{
//Sync response //Sync response
client_response::client_response(const rexy::string_base& s): client_response::client_response(const rexy::string_base& s):
m_root(rjp_parse(s, RJP_PARSE_ALL_EXT)){} m_root(rjp_parse(s, RJP_PARSE_ALL_EXT, NULL)){}
client_response::client_response(RJP_value* root): client_response::client_response(RJP_value* root):
m_root(root){} m_root(root){}
room_list client_response::room_join_events(void)const{ room_list client_response::room_join_events(void)const{

2
src/test.cpp
View File

@ -37,7 +37,7 @@ matrix::auth_data read_auth_file(const char* filename){
if(!fp){ if(!fp){
return {}; return {};
} }
raii::rjp_ptr root(rjp_parse(fp.read(fp.length()), RJP_PARSE_ALL_EXT)); raii::rjp_ptr root(rjp_parse(fp.read(fp.length()), RJP_PARSE_ALL_EXT, NULL));
if(!root.get()) if(!root.get())
return {}; return {};

2
util/matrix-send.cpp
View File

@ -55,7 +55,7 @@ matrix::auth_data read_auth_file(const char* filename){
if(!fp){ if(!fp){
return {}; return {};
} }
raii::rjp_ptr root(rjp_parse(fp.read(fp.length()))); raii::rjp_ptr root(rjp_parse(fp.read(fp.length()), RJP_PARSE_ALL_EXT, NULL));
if(!root.get()) if(!root.get())
return {}; return {};