mirror of https://github.com/oxen-io/lokinet
Compare commits
94 Commits
c693569c00
...
a4bd7806b3
Author | SHA1 | Date |
---|---|---|
dr7ana | a4bd7806b3 | 4 months ago |
dr7ana | 7421d59009 | 4 months ago |
dr7ana | a5b7a7e35b | 4 months ago |
dr7ana | e331f0b31f | 5 months ago |
dr7ana | 5469c9beb0 | 5 months ago |
dr7ana | 4c336c9ea1 | 5 months ago |
dr7ana | eaa853d04f | 5 months ago |
dr7ana | 0d8017d61d | 5 months ago |
Jason Rhinelander | f6a660ae1e | 5 months ago |
dr7ana | 3fb9ba57e5 | 5 months ago |
dr7ana | 30f62d2689 | 5 months ago |
dr7ana | 5be09563fa | 5 months ago |
dr7ana | 4437d0b373 | 5 months ago |
dr7ana | 3451a30d0e | 5 months ago |
dr7ana | ea3c3e30e0 | 5 months ago |
dr7ana | 9e31300d0f | 5 months ago |
Jason Rhinelander | 6fdfb4cef6 | 5 months ago |
dr7ana | 47be3cefe1 | 5 months ago |
Jason Rhinelander | 7417c59286 | 5 months ago |
dr7ana | f41bcd00c6 | 5 months ago |
dr7ana | 2a090b6e42 | 5 months ago |
dr7ana | 87ae0686d0 | 5 months ago |
dr7ana | b63733381f | 5 months ago |
dr7ana | 49794295b1 | 5 months ago |
Jason Rhinelander | 5c13a0e7b4 | 5 months ago |
dr7ana | c71e767511 | 5 months ago |
dr7ana | 42aa92ab95 | 5 months ago |
dr7ana | ef1897c25a | 5 months ago |
dr7ana | 13305f703f | 5 months ago |
dr7ana | 575494c3da | 5 months ago |
dr7ana | 2c3763b61c | 5 months ago |
dr7ana | 08c2c26c29 | 5 months ago |
dr7ana | d6e5aca572 | 5 months ago |
dr7ana | fd21eb3a00 | 5 months ago |
dr7ana | d016951d2f | 5 months ago |
dr7ana | fbc71847ef | 5 months ago |
dr7ana | ea614ed141 | 5 months ago |
dr7ana | 49dbdf1062 | 5 months ago |
Jason Rhinelander | 2f1917040c | 5 months ago |
dr7ana | 63c9bd6e63 | 5 months ago |
dr7ana | eb971265c7 | 5 months ago |
Jason Rhinelander | b0d6d0cc2b | 5 months ago |
Jason Rhinelander | 4c7f9d080f | 5 months ago |
dr7ana | 6cb2f57abd | 5 months ago |
dr7ana | b69f754599 | 5 months ago |
dr7ana | 94f307283f | 5 months ago |
dr7ana | 7544436f6a | 5 months ago |
Jason Rhinelander | cece742cf3 | 5 months ago |
Jason Rhinelander | 6c58f07a41 | 5 months ago |
Jason Rhinelander | a6da88cbbe | 5 months ago |
dr7ana | 88b9d9f976 | 5 months ago |
dr7ana | f812d5471b | 5 months ago |
dr7ana | 3c521c4923 | 5 months ago |
Jason Rhinelander | 3509693c49 | 5 months ago |
Jason Rhinelander | febcd44ea1 | 5 months ago |
Jason Rhinelander | 636de93b1a | 5 months ago |
dr7ana | daa3a6fd94 | 5 months ago |
Jason Rhinelander | 5e2c18ff19 | 5 months ago |
dr7ana | f5d959c65a | 5 months ago |
Jason Rhinelander | 1a7f47f5cd | 5 months ago |
Jason Rhinelander | 4c1f6112a7 | 5 months ago |
dr7ana | f725c07f2d | 5 months ago |
dr7ana | e0c1069790 | 5 months ago |
dr7ana | efe5fd3b5b | 5 months ago |
dr7ana | 0bf3a3323a | 5 months ago |
dr7ana | 22edd63284 | 5 months ago |
dr7ana | 238cc3d0da | 5 months ago |
dr7ana | 5f430a392b | 5 months ago |
dr7ana | 63644d3d84 | 5 months ago |
dr7ana | f2feea74ee | 5 months ago |
Jason Rhinelander | 412ce44139 | 5 months ago |
Jason Rhinelander | daeff3ee7e | 5 months ago |
Jason Rhinelander | 0e6a2941bd | 5 months ago |
Jason Rhinelander | b82b4c7fe6 | 5 months ago |
Jason Rhinelander | b3dc23e1bf | 5 months ago |
Jason Rhinelander | 30d58911fa | 5 months ago |
dr7ana | 9084d39e5a | 5 months ago |
Jason Rhinelander | bc2cb46d9c | 5 months ago |
dr7ana | 8af38d3d44 | 5 months ago |
dr7ana | d00257b9f0 | 5 months ago |
dr7ana | aaf284b39f | 5 months ago |
dr7ana | cef2ff7782 | 5 months ago |
dr7ana | ed6bd28a35 | 5 months ago |
dr7ana | c9268dceba | 5 months ago |
dr7ana | 62c37825b0 | 5 months ago |
dr7ana | 70e9c1ae25 | 5 months ago |
dr7ana | 3508dee8d8 | 5 months ago |
dr7ana | 91121ea22b | 5 months ago |
dr7ana | f6e651caea | 5 months ago |
dr7ana | ba3fffb765 | 5 months ago |
dr7ana | b6cc86e25b | 5 months ago |
dr7ana | 3fc7980691 | 5 months ago |
dr7ana | 6559617816 | 5 months ago |
dr7ana | 5fa3c2be87 | 5 months ago |
Binary file not shown.
@ -1 +1 @@
|
||||
Subproject commit f6172d58d3358473a4c98d96270058a32e166d5f
|
||||
Subproject commit 24fbdb794ef26bf5324d1b56d48d1da8de8a140c
|
@ -1 +1 @@
|
||||
Subproject commit 3ced484e8cc543b90c5fc554ccc0ea2e54ec8d37
|
||||
Subproject commit 73d4b6f940c0790e6f7c3ec46e03c014f51be1fa
|
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,123 @@
|
||||
#pragma once
|
||||
|
||||
#include "common.hpp"
|
||||
|
||||
#include <llarp/util/logging/buffer.hpp>
|
||||
|
||||
namespace llarp
|
||||
{
|
||||
namespace GossipRCMessage
|
||||
{
|
||||
inline static std::string
|
||||
serialize(const RouterID& last_sender, const RemoteRC& rc)
|
||||
{
|
||||
oxenc::bt_dict_producer btdp;
|
||||
|
||||
try
|
||||
{
|
||||
btdp.append_encoded("rc", rc.view());
|
||||
btdp.append("sender", last_sender.ToView());
|
||||
}
|
||||
catch (...)
|
||||
{
|
||||
log::error(link_cat, "Error: GossipRCMessage failed to bt encode contents");
|
||||
}
|
||||
|
||||
return std::move(btdp).str();
|
||||
}
|
||||
} // namespace GossipRCMessage
|
||||
|
||||
namespace FetchRCMessage
|
||||
{
|
||||
inline const auto INVALID_REQUEST =
|
||||
messages::serialize_response({{messages::STATUS_KEY, "Invalid relay ID requested"}});
|
||||
|
||||
inline static std::string
|
||||
serialize(
|
||||
std::chrono::system_clock::time_point since, const std::vector<RouterID>& explicit_ids)
|
||||
{
|
||||
oxenc::bt_dict_producer btdp;
|
||||
|
||||
try
|
||||
{
|
||||
{
|
||||
auto sublist = btdp.append_list("explicit_ids");
|
||||
|
||||
for (const auto& rid : explicit_ids)
|
||||
sublist.append(rid.ToView());
|
||||
}
|
||||
|
||||
btdp.append("since", since.time_since_epoch() / 1s);
|
||||
}
|
||||
catch (...)
|
||||
{
|
||||
log::error(link_cat, "Error: RCFetchMessage failed to bt encode contents!");
|
||||
}
|
||||
|
||||
return std::move(btdp).str();
|
||||
}
|
||||
} // namespace FetchRCMessage
|
||||
|
||||
namespace BootstrapFetchMessage
|
||||
{
|
||||
// the LocalRC is converted to a RemoteRC type to send to the bootstrap seed
|
||||
inline static std::string
|
||||
serialize(std::optional<LocalRC> local_rc, size_t quantity)
|
||||
{
|
||||
oxenc::bt_dict_producer btdp;
|
||||
|
||||
if (local_rc)
|
||||
{
|
||||
log::critical(logcat, "Serializing localRC: {}", oxenc::to_hex(local_rc->view()));
|
||||
btdp.append_encoded("local", oxen::quic::to_sv(local_rc->view()));
|
||||
}
|
||||
|
||||
btdp.append("quantity", quantity);
|
||||
|
||||
return std::move(btdp).str();
|
||||
}
|
||||
|
||||
inline static std::string
|
||||
serialize_response(const std::vector<RouterID>& explicit_ids)
|
||||
{
|
||||
oxenc::bt_dict_producer btdp;
|
||||
|
||||
try
|
||||
{
|
||||
auto sublist = btdp.append_list("explicit_ids");
|
||||
|
||||
for (const auto& rid : explicit_ids)
|
||||
sublist.append(rid.ToView());
|
||||
}
|
||||
catch (...)
|
||||
{
|
||||
log::error(link_cat, "Error: BootstrapFetchMessage failed to bt encode contents!");
|
||||
}
|
||||
|
||||
return std::move(btdp).str();
|
||||
}
|
||||
} // namespace BootstrapFetchMessage
|
||||
|
||||
namespace FetchRIDMessage
|
||||
{
|
||||
inline constexpr auto INVALID_REQUEST = "Invalid relay ID requested to relay response from."sv;
|
||||
|
||||
inline static std::string
|
||||
serialize(const RouterID& source)
|
||||
{
|
||||
oxenc::bt_dict_producer btdp;
|
||||
|
||||
try
|
||||
{
|
||||
btdp.append("source", source.ToView());
|
||||
}
|
||||
catch (...)
|
||||
{
|
||||
log::error(link_cat, "Error: FetchRIDMessage failed to bt encode contents!");
|
||||
}
|
||||
|
||||
return std::move(btdp).str();
|
||||
}
|
||||
} // namespace FetchRIDMessage
|
||||
|
||||
} // namespace llarp
|
@ -1,30 +0,0 @@
|
||||
#pragma once
|
||||
|
||||
#include "common.hpp"
|
||||
|
||||
namespace llarp::RCFetchMessage
|
||||
{
|
||||
inline constexpr auto INVALID_REQUEST = "Invalid relay ID requested."sv;
|
||||
|
||||
inline static std::string
|
||||
serialize(std::chrono::system_clock::time_point since, const std::vector<RouterID>& explicit_ids)
|
||||
{
|
||||
oxenc::bt_dict_producer btdp;
|
||||
|
||||
try
|
||||
{
|
||||
btdp.append("since", since.time_since_epoch() / 1s);
|
||||
{
|
||||
auto id_list = btdp.append_list("explicit_ids");
|
||||
for (const auto& rid : explicit_ids)
|
||||
id_list.append(rid.ToView());
|
||||
}
|
||||
}
|
||||
catch (...)
|
||||
{
|
||||
log::error(link_cat, "Error: RCFetchMessage failed to bt encode contents!");
|
||||
}
|
||||
|
||||
return std::move(btdp).str();
|
||||
}
|
||||
} // namespace llarp::RCFetchMessage
|
@ -1,17 +0,0 @@
|
||||
#pragma once
|
||||
|
||||
#include "common.hpp"
|
||||
|
||||
namespace llarp::RouterIDFetch
|
||||
{
|
||||
inline constexpr auto INVALID_REQUEST = "Invalid relay ID requested to relay response from."sv;
|
||||
|
||||
inline static std::string
|
||||
serialize(const RouterID& source)
|
||||
{
|
||||
// serialize_response is a bit weird here, and perhaps could have a sister function
|
||||
// with the same purpose but as a request, but...it works.
|
||||
return messages::serialize_response({{"source", source.ToView()}});
|
||||
}
|
||||
|
||||
} // namespace llarp::RouterIDFetch
|
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
Loading…
Reference in New Issue