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

print base64 nodeid to log

Browse Source
This commit is contained in:
orignal committed 2026-10-05 13:31:53 -04:00
1 parent 0d833e4f13
commit 9f23dada45
2 files changed
+11 -7
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

libi2pd_client/TorrentsDHT.cpp
+6 -7
View File
@@ -696,7 +696,7 @@ namespace torrents
auto node = std::make_shared<Node> (id, from.GetIdentHash (), fromPort);
if (!node->VerifyID ())
{
LogPrint (eLogInfo, "TorrentsDHT: Query received from node with invalid ID ", node->peer.ToBase64 ());
LogPrint (eLogInfo, "TorrentsDHT: Query received from node with invalid ID ", node->id.ToBase64 ());
return;
}
node = UpdateNode (node);
@@ -716,14 +716,14 @@ namespace torrents
void TorrentsDHT::HandlePingQuery (const i2p::data::IdentHash& fromIdent, uint16_t fromPort,
std::string_view transactionID, const NodeID& nodeID)
{
LogPrint (eLogDebug, "TorrentsDHT: Ping query msg received from ", fromIdent.ToBase64 ());
LogPrint (eLogDebug, "TorrentsDHT: Ping query msg received from ", nodeID.ToBase64 ());
SendPingResponse (transactionID, fromIdent, fromPort + 1); // to rport
}
void TorrentsDHT::HandleGetPeersQuery (const i2p::data::IdentHash& fromIdent, uint16_t fromPort,
std::string_view transactionID, std::shared_ptr<Node> from, const Torrent::InfoHash& infoHash)
{
LogPrint (eLogDebug, "TorrentsDHT: Get peers query msg received from ", fromIdent.ToBase64 ());
LogPrint (eLogDebug, "TorrentsDHT: Get peers query msg received from ", from->id.ToBase64 ());
std::shared_ptr<DHTTorrent> torrent;
auto it = m_Torrents.find (infoHash);
if (it != m_Torrents.end ())
@@ -791,7 +791,6 @@ namespace torrents
void TorrentsDHT::HandleResponse (std::string_view transactionID, const NodeID& nodeID,
uint64_t token, const std::vector<std::string_view>& values, const NodeInfo& nodeInfo)
{
LogPrint (eLogDebug, "TorrentsDHT: Response msg received");
uint16_t t = 0;
if (transactionID.size () >= 2)
memcpy (&t, transactionID.data (), 2);
@@ -811,7 +810,7 @@ namespace torrents
}
case eKRPCQueryGetPeers:
{
LogPrint (eLogDebug, "TorrentsDHT: get_peers response received from ", ident.ToBase64 ());
LogPrint (eLogDebug, "TorrentsDHT: get_peers response received from peer ", ident.ToBase64 ());
if (!values.empty () && values[0].empty ()) // nodes
HandleGetPeersResponseNode (info, nodeID, token, nodeInfo);
else //values
@@ -821,7 +820,7 @@ namespace torrents
case eKRPCQueryFindNode:
{
auto node = UpdateNode (std::make_shared<Node>(nodeInfo));
LogPrint (eLogDebug, "TorrentsDHT: find_node response received ", node->peer.ToBase64 ());
LogPrint (eLogDebug, "TorrentsDHT: find_node response received ", node->id.ToBase64 ());
break;
}
case eKRPCQueryAnnouncePeer:
@@ -1036,7 +1035,7 @@ namespace torrents
if (!node) return nullptr;
auto [it, inserted] = m_Nodes.emplace (node->id, node);
if (inserted)
LogPrint (eLogDebug, "TorrentsDHT: Node ", node->peer.ToBase64 (), ":", node->port, " added");
LogPrint (eLogDebug, "TorrentsDHT: Node ", node->id.ToBase64 (), " added");
it->second->lastUpdateTime = i2p::util::GetMonotonicSeconds ();
if (m_RoutingTable) m_RoutingTable->AddNode (it->second);
return it->second;
libi2pd_client/TorrentsDHT.h
+5
View File
@@ -27,6 +27,7 @@
#include <optional>
#include <filesystem>
#include <boost/asio.hpp>
#include "Base.h"
#include "Identity.h"
#include "I2PService.h"
#include "util.h"
@@ -78,6 +79,10 @@ namespace torrents
}
return -1;
}
std::string ToBase64 () const
{
return i2p::data::ByteStreamToBase64 (data (), size ());
}
};
using NodeInfo = std::array<uint8_t, NodeID::len + i2p::data::IdentHash::len + 2>;