OrderBookDB.h

#ifndef XRPL_APP_LEDGER_ORDERBOOKDB_H_INCLUDED
#define XRPL_APP_LEDGER_ORDERBOOKDB_H_INCLUDED
 
#include <xrpld/app/ledger/AcceptedLedgerTx.h>
#include <xrpld/app/ledger/BookListeners.h>
#include <xrpld/app/main/Application.h>
 
#include <xrpl/protocol/MultiApiJson.h>
#include <xrpl/protocol/UintTypes.h>
 
#include <mutex>
#include <optional>
 
namespace ripple {
 
class OrderBookDB
{
public:
    explicit OrderBookDB(Application& app);
 
    void
    setup(std::shared_ptr<ReadView const> const& ledger);
    void
    update(std::shared_ptr<ReadView const> const& ledger);
 
    void
    addOrderBook(Book const&);
 
    std::vector<Book>
    getBooksByTakerPays(
        Issue const&,
        std::optional<Domain> const& domain = std::nullopt);
 
    int
    getBookSize(
        Issue const&,
        std::optional<Domain> const& domain = std::nullopt);
 
    bool
    isBookToXRP(Issue const&, std::optional<Domain> domain = std::nullopt);
 
    BookListeners::pointer
    getBookListeners(Book const&);
    BookListeners::pointer
    makeBookListeners(Book const&);
 
    // see if this txn effects any orderbook
    void
    processTxn(
        std::shared_ptr<ReadView const> const& ledger,
        AcceptedLedgerTx const& alTx,
        MultiApiJson const& jvObj);
 
private:
    Application& app_;
 
    // Maps order books by "issue in" to "issue out":
    hardened_hash_map<Issue, hardened_hash_set<Issue>> allBooks_;
 
    hardened_hash_map<std::pair<Issue, Domain>, hardened_hash_set<Issue>>
        domainBooks_;
 
    // does an order book to XRP exist
    hash_set<Issue> xrpBooks_;
 
    // does an order book to XRP exist
    hash_set<std::pair<Issue, Domain>> xrpDomainBooks_;
 
    std::recursive_mutex mLock;
 
    using BookToListenersMap = hash_map<Book, BookListeners::pointer>;
 
    BookToListenersMap mListeners;
 
    std::atomic<std::uint32_t> seq_;
 
    beast::Journal const j_;
};
 
}  // namespace ripple
 
#endif