mirror of
https://github.com/oxen-io/lokinet
synced 2023-12-14 06:53:00 +01:00
95cd275cdd
* add lokinet_add_bootstrap_rc function for adding an rc from memory * prevent stack overflow on error closing connection in quic * add in memory nodedb * refactor how convotags are set as active * add initial stubs for endpoint statistics * refactor time stuff to be a bit cleaner * update lnproxy script with more arguments
88 lines
2.3 KiB
C++
88 lines
2.3 KiB
C++
#pragma once
|
|
|
|
#include <llarp/crypto/types.hpp>
|
|
#include <llarp/path/path.hpp>
|
|
#include "intro_set.hpp"
|
|
#include "convotag.hpp"
|
|
|
|
#include <memory>
|
|
#include <set>
|
|
|
|
namespace llarp
|
|
{
|
|
namespace service
|
|
{
|
|
struct ProtocolMessage;
|
|
|
|
struct RecvDataEvent
|
|
{
|
|
path::Path_ptr fromPath;
|
|
PathID_t pathid;
|
|
std::shared_ptr<ProtocolMessage> msg;
|
|
};
|
|
|
|
struct ProtocolMessage;
|
|
struct IDataHandler
|
|
{
|
|
virtual bool
|
|
HandleDataMessage(
|
|
path::Path_ptr path, const PathID_t from, std::shared_ptr<ProtocolMessage> msg) = 0;
|
|
|
|
virtual bool
|
|
GetCachedSessionKeyFor(const ConvoTag& remote, SharedSecret& secret) const = 0;
|
|
virtual void
|
|
PutCachedSessionKeyFor(const ConvoTag& remote, const SharedSecret& secret) = 0;
|
|
|
|
/// called when we send data to remote on a convotag
|
|
virtual void
|
|
ConvoTagTX(const ConvoTag& tag) = 0;
|
|
|
|
/// called when we got data from remote on a convotag
|
|
virtual void
|
|
ConvoTagRX(const ConvoTag& tag) = 0;
|
|
|
|
virtual void
|
|
RemoveConvoTag(const ConvoTag& remote) = 0;
|
|
|
|
virtual bool
|
|
HasConvoTag(const ConvoTag& remote) const = 0;
|
|
|
|
virtual void
|
|
PutSenderFor(const ConvoTag& remote, const ServiceInfo& si, bool inbound) = 0;
|
|
|
|
virtual bool
|
|
GetSenderFor(const ConvoTag& remote, ServiceInfo& si) const = 0;
|
|
|
|
virtual void
|
|
PutIntroFor(const ConvoTag& remote, const Introduction& intro) = 0;
|
|
|
|
virtual bool
|
|
GetIntroFor(const ConvoTag& remote, Introduction& intro) const = 0;
|
|
|
|
virtual void
|
|
PutReplyIntroFor(const ConvoTag& remote, const Introduction& intro) = 0;
|
|
|
|
virtual bool
|
|
GetReplyIntroFor(const ConvoTag& remote, Introduction& intro) const = 0;
|
|
|
|
virtual bool
|
|
GetConvoTagsForService(const Address& si, std::set<ConvoTag>& tag) const = 0;
|
|
|
|
virtual bool
|
|
HasInboundConvo(const Address& addr) const = 0;
|
|
|
|
virtual bool
|
|
HasOutboundConvo(const Address& addr) const = 0;
|
|
|
|
/// do we want a session outbound to addr
|
|
virtual bool
|
|
WantsOutboundSession(const Address& addr) const = 0;
|
|
|
|
virtual void
|
|
MarkAddressOutbound(const Address& addr) = 0;
|
|
|
|
virtual void
|
|
QueueRecvData(RecvDataEvent ev) = 0;
|
|
};
|
|
} // namespace service
|
|
} // namespace llarp
|