OrderBookDBImpl.h

#pragma once
 
#include <xrpl/basics/UnorderedContainers.h>
#include <xrpl/beast/utility/Journal.h>
#include <xrpl/core/ServiceRegistry.h>
#include <xrpl/ledger/OrderBookDB.h>
#include <xrpl/ledger/ReadView.h>
#include <xrpl/protocol/Asset.h>
#include <xrpl/protocol/Book.h>
#include <xrpl/protocol/UintTypes.h>
 
#include <atomic>
#include <cstdint>
#include <functional>
#include <memory>
#include <mutex>
#include <optional>
#include <utility>
#include <vector>
 
namespace xrpl {

struct OrderBookDBConfig
{
    int pathSearchMax;
    bool standalone;
};

std::unique_ptr<OrderBookDB>
makeOrderBookDb(ServiceRegistry& registry, OrderBookDBConfig const& config);
 
class OrderBookDBImpl final : public OrderBookDB
{
public:
    OrderBookDBImpl(ServiceRegistry& registry, OrderBookDBConfig const& config);
 
    // OrderBookDB interface implementation
    void
    setup(std::shared_ptr<ReadView const> const& ledger) override;
 
    void
    addOrderBook(Book const& book) override;
 
    std::vector<Book>
    getBooksByTakerPays(Asset const& asset, std::optional<Domain> const& domain = std::nullopt)
        override;
 
    int
    getBookSize(Asset const& asset, std::optional<Domain> const& domain = std::nullopt) override;
 
    bool
    isBookToXRP(Asset const& asset, std::optional<Domain> const& domain = std::nullopt) override;
 
    // OrderBookDBImpl-specific methods
    void
    update(std::shared_ptr<ReadView const> const& ledger);
 
private:
    std::reference_wrapper<ServiceRegistry> registry_;
    int const pathSearchMax_;
    bool const standalone_;
 
    // Maps order books by "asset in" to "asset out":
    HardenedHashMap<Asset, HardenedHashSet<Asset>> allBooks_;
 
    HardenedHashMap<std::pair<Asset, Domain>, HardenedHashSet<Asset>> domainBooks_;
 
    // does an order book to XRP exist
    HashSet<Asset> xrpBooks_;
 
    // does an order book to XRP exist
    HashSet<std::pair<Asset, Domain>> xrpDomainBooks_;
 
    std::recursive_mutex lock_;
 
    std::atomic<std::uint32_t> seq_;
 
    beast::Journal const j_;
};
 
}  // namespace xrpl