mirror of
https://github.com/XRPLF/rippled.git
synced 2025-12-06 17:27:55 +00:00
e8b17ef082
Conflicts: src/cpp/ripple/OrderBookDB.cpp src/cpp/ripple/OrderBookDB.h src/cpp/ripple/Pathfinder.cpp
60 lines
1.9 KiB
C++
60 lines
1.9 KiB
C++
#include "Ledger.h"
|
|
#include "OrderBook.h"
|
|
#include <boost/shared_ptr.hpp>
|
|
|
|
|
|
//
|
|
// XXX Eventually make this cached and just update it as transactions come in.
|
|
// But, for now it is probably faster to just generate it each time.
|
|
//
|
|
|
|
class BookListeners
|
|
{
|
|
boost::unordered_set<InfoSub*> mListeners;
|
|
public:
|
|
typedef boost::shared_ptr<BookListeners> pointer;
|
|
|
|
void addSubscriber(InfoSub* sub);
|
|
void removeSubscriber(InfoSub* sub);
|
|
void publish(Json::Value& jvObj);
|
|
};
|
|
|
|
class OrderBookDB
|
|
{
|
|
std::vector<OrderBook::pointer> mEmptyVector;
|
|
std::vector<OrderBook::pointer> mXRPOrders;
|
|
std::map<uint160, std::vector<OrderBook::pointer> > mIssuerMap;
|
|
//std::vector<OrderBook::pointer> mAllOrderBooks;
|
|
|
|
// issuerIn, issuerOut, currencyIn, currencyOut
|
|
std::map<uint160, std::map<uint160, std::map<uint160, std::map<uint160, BookListeners::pointer> > > > mListeners;
|
|
|
|
std::map<uint256, bool > mKnownMap;
|
|
|
|
public:
|
|
OrderBookDB();
|
|
void setup(Ledger::pointer ledger);
|
|
|
|
// return list of all orderbooks that want XRP
|
|
std::vector<OrderBook::pointer>& getXRPInBooks(){ return mXRPOrders; }
|
|
|
|
// return list of all orderbooks that want IssuerID
|
|
std::vector<OrderBook::pointer>& getBooks(const uint160& issuerID);
|
|
|
|
// return list of all orderbooks that want this issuerID and currencyID
|
|
void getBooks(const uint160& issuerID, const uint160& currencyID, std::vector<OrderBook::pointer>& bookRet);
|
|
|
|
// returns the best rate we can find
|
|
float getPrice(uint160& currencyIn,uint160& currencyOut);
|
|
|
|
|
|
BookListeners::pointer getBookListeners(uint160 currencyIn, uint160 currencyOut, uint160 issuerIn, uint160 issuerOut);
|
|
BookListeners::pointer makeBookListeners(uint160 currencyIn, uint160 currencyOut, uint160 issuerIn, uint160 issuerOut);
|
|
|
|
// see if this txn effects any orderbook
|
|
void processTxn(const SerializedTransaction& stTxn, TER terResult,TransactionMetaSet::pointer& meta,Json::Value& jvObj);
|
|
|
|
};
|
|
|
|
// vim:ts=4
|