mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
2c525b03c6
Start cleanup into ripple_data, split out some hash_value() instances Tidy up CBigNum into ripple_data, moving definitions to .cpp Split and clean up base58 stuff Remove unused files from VS2012 project Clean up some bignum stuff and remove unused files Partial cleanup of RFC1751 Enormous cleanup with RippleAddress and related, into ripple_data Remove unused VS project files Move ECIES stuff into CKey
82 lines
2.0 KiB
C++
82 lines
2.0 KiB
C++
#ifndef _PFREQUEST__H
|
|
#define _PFREQUEST__H
|
|
|
|
#include <set>
|
|
#include <vector>
|
|
|
|
#include <boost/thread/recursive_mutex.hpp>
|
|
#include <boost/enable_shared_from_this.hpp>
|
|
#include <boost/shared_ptr.hpp>
|
|
#include <boost/weak_ptr.hpp>
|
|
|
|
#include "SerializedTypes.h"
|
|
#include "Pathfinder.h"
|
|
|
|
// A pathfinding request submitted by a client
|
|
// The request issuer must maintain a strong pointer
|
|
|
|
class Ledger;
|
|
class InfoSub;
|
|
class STAmount;
|
|
class RLCache;
|
|
|
|
// Return values from parseJson <0 = invalid, >0 = valid
|
|
#define PFR_PJ_INVALID -1
|
|
#define PFR_PJ_NOCHANGE 0
|
|
#define PFR_PJ_CHANGE 1
|
|
|
|
class PFRequest : public boost::enable_shared_from_this<PFRequest>
|
|
{
|
|
public:
|
|
typedef boost::weak_ptr<PFRequest> wptr;
|
|
typedef boost::shared_ptr<PFRequest> pointer;
|
|
typedef const pointer& ref;
|
|
typedef const wptr& wref;
|
|
typedef std::pair<uint160, uint160> currIssuer_t;
|
|
|
|
|
|
protected:
|
|
boost::recursive_mutex mLock;
|
|
boost::weak_ptr<InfoSub> wpSubscriber; // Who this request came from
|
|
Json::Value jvId;
|
|
Json::Value jvStatus; // Last result
|
|
|
|
// Client request parameters
|
|
RippleAddress raSrcAccount;
|
|
RippleAddress raDstAccount;
|
|
STAmount saDstAmount;
|
|
std::set<currIssuer_t> sciSourceCurrencies;
|
|
std::vector<Json::Value> vjvBridges;
|
|
|
|
bool bValid;
|
|
bool bNew;
|
|
|
|
// Track all requests
|
|
static std::set<wptr> sRequests;
|
|
static boost::recursive_mutex sLock;
|
|
|
|
void setValid();
|
|
int parseJson(const Json::Value&, bool complete);
|
|
|
|
public:
|
|
|
|
PFRequest(const boost::shared_ptr<InfoSub>& subscriber);
|
|
|
|
bool isValid(const boost::shared_ptr<Ledger>&);
|
|
bool isValid();
|
|
bool isNew();
|
|
Json::Value getStatus();
|
|
|
|
Json::Value doCreate(const boost::shared_ptr<Ledger>&, const Json::Value&);
|
|
Json::Value doClose(const Json::Value&);
|
|
Json::Value doStatus(const Json::Value&);
|
|
|
|
bool doUpdate(const boost::shared_ptr<RLCache>&, bool fast); // update jvStatus
|
|
|
|
static void updateAll(const boost::shared_ptr<Ledger>& ledger, bool newOnly);
|
|
};
|
|
|
|
#endif
|
|
|
|
// vim:ts=4
|