twisterarmy/twister-core
1
0
Fork 0
mirror of https://github.com/twisterarmy/twister-core.git synced 2025-01-11 07:17:53 +00:00
Code Issues Projects Releases Wiki Activity

new dhtput to keep track of RTs

Browse Source
This commit is contained in:
Miguel Freitas 2013-09-19 17:35:22 -03:00
parent cbb5a524ce
commit 875aa4095f
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/twister.cpp
View File

@ -1041,10 +1041,12 @@ Value newrtmsg(const Array& params, bool fHelp)
int k = params[1].get_int(); int k = params[1].get_int();
string strK = boost::lexical_cast<std::string>(k); string strK = boost::lexical_cast<std::string>(k);
entry vrt = jsonToEntry(params[2].get_obj()); entry vrt = jsonToEntry(params[2].get_obj());
entry const *rt = vrt.find_key("userpost");
entry const *sig_rt= vrt.find_key("sig_userpost");
entry v; entry v;
if( !createSignedUserpost(v, strUsername, k, "", if( !createSignedUserpost(v, strUsername, k, "",
vrt.find_key("userpost"), vrt.find_key("sig_userpost"), NULL, rt, sig_rt, NULL,
std::string(""), 0) ) std::string(""), 0) )
throw JSONRPCError(RPC_INTERNAL_ERROR,"error signing post with private key of user"); throw JSONRPCError(RPC_INTERNAL_ERROR,"error signing post with private key of user");
@ -1069,6 +1071,14 @@ Value newrtmsg(const Array& params, bool fHelp)
ses->dht_putData(strUsername, string("post")+strK, false, ses->dht_putData(strUsername, string("post")+strK, false,
v, strUsername, GetAdjustedTime(), k); v, strUsername, GetAdjustedTime(), k);
// notification to keep track of RTs of the original post
if( rt ) {
string rt_user = rt->find_key("n")->string();
string rt_k = boost::lexical_cast<std::string>(rt->find_key("k")->integer());
ses->dht_putData(rt_user, string("rts")+rt_k, true,
v, strUsername, GetAdjustedTime(), k);
}
return entryToJson(v); return entryToJson(v);
} }