#ifndef LLARP_SERVICE_INTROSET_HPP #define LLARP_SERVICE_INTROSET_HPP #include #include #include #include #include #include #include #include #include #include #include #include namespace llarp { struct Crypto; namespace service { constexpr std::size_t MAX_INTROSET_SIZE = 4096; // 10 seconds clock skew permitted for introset expiration constexpr llarp_time_t MAX_INTROSET_TIME_DELTA = (10 * 1000); struct IntroSet final : public llarp::IBEncodeMessage, public util::IStateful { util::StatusObject ExtractStatus() const override; ServiceInfo A; std::vector< Introduction > I; PQPubKey K; Tag topic; llarp_time_t T = 0; llarp::PoW* W = nullptr; llarp::Signature Z; IntroSet() = default; IntroSet(IntroSet&& other) : IBEncodeMessage(other.version) { A = std::move(other.A); I = std::move(other.I); K = std::move(other.K); T = std::move(other.T); version = std::move(other.version); topic = std::move(other.topic); W = std::move(other.W); Z = std::move(other.Z); } IntroSet(const IntroSet& other) : IBEncodeMessage(other.version) { A = other.A; I = other.I; K = other.K; T = other.T; version = other.version; topic = other.topic; if(other.W) W = new llarp::PoW(*other.W); Z = other.Z; } ~IntroSet(); IntroSet& operator=(const IntroSet& other) { I.clear(); A = other.A; I = other.I; K = other.K; T = other.T; version = other.version; topic = other.topic; if(W) { delete W; W = nullptr; } if(other.W) W = new llarp::PoW(*other.W); Z = other.Z; return *this; } bool operator<(const IntroSet& other) const { return A < other.A; } bool operator==(const IntroSet& other) const { return A == other.A && I == other.I && K == other.K && T == other.T && version == other.version && topic == other.topic && W == other.W && Z == other.Z; } bool operator!=(const IntroSet& other) const { return !(*this == other); } bool OtherIsNewer(const IntroSet& other) const { return T < other.T; } std::ostream& print(std::ostream& stream, int level, int spaces) const; llarp_time_t GetNewestIntroExpiration() const; bool HasExpiredIntros(llarp_time_t now) const; bool IsExpired(llarp_time_t now) const; bool BEncode(llarp_buffer_t* buf) const override; bool DecodeKey(const llarp_buffer_t& key, llarp_buffer_t* buf) override; bool Verify(llarp::Crypto* crypto, llarp_time_t now) const; }; inline std::ostream& operator<<(std::ostream& out, const IntroSet& i) { return i.print(out, -1, -1); } using IntroSetLookupHandler = std::function< void(const std::vector< IntroSet >&) >; } // namespace service } // namespace llarp #endif