#include "localtaglookup.hpp" #include "context.hpp" #include #include #include #include namespace llarp::dht { LocalTagLookup::LocalTagLookup( const PathID_t& path, uint64_t txid, const service::Tag& _target, AbstractDHTMessageHandler* ctx) : TagLookup(TXOwner{ctx->OurKey(), txid}, _target, ctx, 0), localPath(path) {} void LocalTagLookup::SendReply() { auto path = parent->GetRouter()->path_context().GetByUpstream(parent->OurKey().as_array(), localPath); if (!path) { llarp::LogWarn( "did not send reply for relayed dht request, no such local path " "for pathid=", localPath); return; } routing::PathDHTMessage msg; msg.dht_msgs.emplace_back(new GotIntroMessage(valuesFound, whoasked.txid)); if (!path->SendRoutingMessage(msg, parent->GetRouter())) { llarp::LogWarn( "failed to send routing message when informing result of dht " "request, pathid=", localPath); } } } // namespace llarp::dht