dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-10-05 20:57:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

add trackers through torrent-set RPC request

Browse Source
This commit is contained in:
orignal
2026-09-19 21:28:05 -04:00
parent e5e816454f
commit a7bbfb566a
1 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd_client/TorrentsRPC.cpp
+22
View File
@@ -61,6 +61,7 @@ namespace torrents
std::string HandleTorrentStart (boost::json::object&& jsonRequest);
std::string HandleSessionGet (boost::json::object&& jsonRequest); // for transmission-rpc library
std::string HandleSessionStats (boost::json::object&& jsonRequest);
std::string HandleTorrentSet (boost::json::object&& jsonRequest);
private:
@@ -127,6 +128,8 @@ namespace torrents
return HandleSessionGet (std::move (jsonRequest));
else if (method == "session-stats")
return HandleSessionStats (std::move (jsonRequest));
else if (method == "torrent-set")
return HandleTorrentSet (std::move (jsonRequest));
else
{
LogPrint (eLogInfo, "TorrentsRPC: Method not found ", method);
@@ -627,6 +630,25 @@ namespace torrents
return SuccessResponse (GetTag (jsonRequest), std::move (response));
}
std::string JSONRPCHandler::HandleTorrentSet (boost::json::object&& jsonRequest)
{
auto arguments = jsonRequest.at ("arguments").as_object ();
if (arguments.contains ("trackerAdd"))
{
auto trackers = arguments.at ("trackerAdd").as_array ();
for (auto it: trackers)
{
boost::asio::post (m_Tunnel->GetService (),
boost::asio::use_future ([this, announce = it.as_string ()]()
{
m_Tunnel->AddTracker (announce, true);
})).wait ();
}
}
boost::json::object response; // always empty
return SuccessResponse (GetTag (jsonRequest), std::move (response));
}
#endif
TorrentsRPCSession::TorrentsRPCSession (TorrentsRPCServer& server, boost::asio::ip::tcp::socket&& s):