mirror of
https://github.com/dashpay/dash.git
synced 2024-12-28 13:32:47 +01:00
cb1d4766f5
* refactor: coinjoin/coinjoin-*[cpp/h] --> coinjoin/*.[cpp/h] * refactor: governance/governance-*[cpp/h] --> governance/*.[cpp/h] * refactor: masternode/masternode-*[cpp/h] --> masternode/*.[cpp/h] * fix linter Co-authored-by: UdjinM6 <UdjinM6@users.noreply.github.com>
91 lines
3.7 KiB
C++
91 lines
3.7 KiB
C++
// Copyright (c) 2014-2021 The Dash Core developers
|
|
// Distributed under the MIT/X11 software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#ifndef BITCOIN_COINJOIN_SERVER_H
|
|
#define BITCOIN_COINJOIN_SERVER_H
|
|
|
|
#include <coinjoin/coinjoin.h>
|
|
#include <net.h>
|
|
|
|
class CCoinJoinServer;
|
|
class UniValue;
|
|
|
|
// The main object for accessing mixing
|
|
extern CCoinJoinServer coinJoinServer;
|
|
|
|
/** Used to keep track of current status of mixing pool
|
|
*/
|
|
class CCoinJoinServer : public CCoinJoinBaseSession, public CCoinJoinBaseManager
|
|
{
|
|
private:
|
|
// Mixing uses collateral transactions to trust parties entering the pool
|
|
// to behave honestly. If they don't it takes their money.
|
|
std::vector<CTransactionRef> vecSessionCollaterals;
|
|
|
|
bool fUnitTest;
|
|
|
|
/// Add a clients entry to the pool
|
|
bool AddEntry(CConnman& connman, const CCoinJoinEntry& entry, PoolMessage& nMessageIDRet);
|
|
/// Add signature to a txin
|
|
bool AddScriptSig(const CTxIn& txin);
|
|
|
|
/// Charge fees to bad actors (Charge clients a fee if they're abusive)
|
|
void ChargeFees(CConnman& connman) const;
|
|
/// Rarely charge fees to pay miners
|
|
void ChargeRandomFees(CConnman& connman) const;
|
|
/// Consume collateral in cases when peer misbehaved
|
|
void ConsumeCollateral(CConnman& connman, const CTransactionRef& txref) const;
|
|
|
|
/// Check for process
|
|
void CheckPool(CConnman& connman);
|
|
|
|
void CreateFinalTransaction(CConnman& connman);
|
|
void CommitFinalTransaction(CConnman& connman);
|
|
|
|
/// Is this nDenom and txCollateral acceptable?
|
|
bool IsAcceptableDSA(const CCoinJoinAccept& dsa, PoolMessage& nMessageIDRet) const;
|
|
bool CreateNewSession(const CCoinJoinAccept& dsa, PoolMessage& nMessageIDRet, CConnman& connman);
|
|
bool AddUserToExistingSession(const CCoinJoinAccept& dsa, PoolMessage& nMessageIDRet);
|
|
/// Do we have enough users to take entries?
|
|
bool IsSessionReady() const;
|
|
|
|
/// Check that all inputs are signed. (Are all inputs signed?)
|
|
bool IsSignaturesComplete() const;
|
|
/// Check to make sure a given input matches an input in the pool and its scriptSig is valid
|
|
bool IsInputScriptSigValid(const CTxIn& txin) const;
|
|
|
|
// Set the 'state' value, with some logging and capturing when the state changed
|
|
void SetState(PoolState nStateNew);
|
|
|
|
/// Relay mixing Messages
|
|
void RelayFinalTransaction(const CTransaction& txFinal, CConnman& connman);
|
|
void PushStatus(CNode* pnode, PoolStatusUpdate nStatusUpdate, PoolMessage nMessageID, CConnman& connman) const;
|
|
void RelayStatus(PoolStatusUpdate nStatusUpdate, CConnman& connman, PoolMessage nMessageID = MSG_NOERR);
|
|
void RelayCompletedTransaction(PoolMessage nMessageID, CConnman& connman);
|
|
|
|
void ProcessDSACCEPT(CNode* pfrom, const std::string& strCommand, CDataStream& vRecv, CConnman& connman, bool enable_bip61);
|
|
void ProcessDSQUEUE(CNode* pfrom, const std::string& strCommand, CDataStream& vRecv, CConnman& connman, bool enable_bip61);
|
|
void ProcessDSVIN(CNode* pfrom, const std::string& strCommand, CDataStream& vRecv, CConnman& connman, bool enable_bip61);
|
|
void ProcessDSSIGNFINALTX(CNode* pfrom, const std::string& strCommand, CDataStream& vRecv, CConnman& connman, bool enable_bip61);
|
|
|
|
void SetNull();
|
|
|
|
public:
|
|
CCoinJoinServer() :
|
|
vecSessionCollaterals(),
|
|
fUnitTest(false) {}
|
|
|
|
void ProcessMessage(CNode* pfrom, const std::string& strCommand, CDataStream& vRecv, CConnman& connman, bool enable_bip61);
|
|
|
|
bool HasTimedOut() const;
|
|
void CheckTimeout(CConnman& connman);
|
|
void CheckForCompleteQueue(CConnman& connman);
|
|
|
|
void DoMaintenance(CConnman& connman) const;
|
|
|
|
void GetJsonInfo(UniValue& obj) const;
|
|
};
|
|
|
|
#endif // BITCOIN_COINJOIN_SERVER_H
|