1#include <xrpl/tx/transactors/lending/LoanManage.h>
3#include <xrpl/basics/Log.h>
4#include <xrpl/basics/Number.h>
5#include <xrpl/beast/utility/Zero.h>
6#include <xrpl/core/ServiceRegistry.h>
7#include <xrpl/ledger/ApplyView.h>
8#include <xrpl/ledger/View.h>
9#include <xrpl/ledger/helpers/LendingHelpers.h>
10#include <xrpl/ledger/helpers/TokenHelpers.h>
11#include <xrpl/protocol/Asset.h>
12#include <xrpl/protocol/Feature.h>
13#include <xrpl/protocol/Indexes.h>
14#include <xrpl/protocol/LedgerFormats.h>
15#include <xrpl/protocol/Protocol.h>
16#include <xrpl/protocol/SField.h>
17#include <xrpl/protocol/STAmount.h>
18#include <xrpl/protocol/STLedgerEntry.h>
19#include <xrpl/protocol/STTakesAsset.h>
20#include <xrpl/protocol/STTx.h>
21#include <xrpl/protocol/TER.h>
22#include <xrpl/protocol/TxFlags.h>
23#include <xrpl/protocol/Units.h>
24#include <xrpl/protocol/XRPAmount.h>
25#include <xrpl/tx/Transactor.h>
40 return tfLoanManageMask;
50 if (
auto const flagField = ctx.
tx[~sfFlags]; flagField && (*flagField != 0u))
53 if ((flags & (flags - 1)) != 0)
55 JLOG(ctx.
j.
warn()) <<
"LoanManage: Only one of tfLoanDefault, tfLoanImpair, or "
56 "tfLoanUnimpair can be set.";
67 auto const& tx = ctx.
tx;
69 auto const account = tx[sfAccount];
70 auto const loanID = tx[sfLoanID];
75 JLOG(ctx.
j.
warn()) <<
"Loan does not exist.";
84 if (loanSle->isFlag(lsfLoanDefault))
86 JLOG(ctx.
j.
warn()) <<
"Loan is in default. A defaulted loan can not be modified.";
89 if (loanSle->isFlag(lsfLoanImpaired) && tx.isFlag(tfLoanImpair))
91 JLOG(ctx.
j.
warn()) <<
"Loan is impaired. A loan can not be impaired twice.";
94 if (!(loanSle->isFlag(lsfLoanImpaired) || loanSle->isFlag(lsfLoanDefault)) &&
95 (tx.isFlag(tfLoanUnimpair)))
97 JLOG(ctx.
j.
warn()) <<
"Loan is unimpaired. Can not be unimpaired again.";
100 if (loanSle->at(sfPaymentRemaining) == 0)
102 JLOG(ctx.
j.
warn()) <<
"Loan is fully paid. A loan can not be modified "
103 "after it is fully paid.";
106 if (tx.isFlag(tfLoanDefault) &&
107 !
hasExpired(ctx.
view, loanSle->at(sfNextPaymentDueDate) + loanSle->at(sfGracePeriod)))
109 JLOG(ctx.
j.
warn()) <<
"A loan can not be defaulted before the next payment due date.";
113 auto const loanBrokerID = loanSle->at(sfLoanBrokerID);
120 if (loanBrokerSle->at(sfOwner) != account)
122 JLOG(ctx.
j.
warn()) <<
"LoanBroker for Loan does not belong to the account. LoanManage "
123 "can only be submitted by the Loan Broker.";
136 Asset const& vaultAsset,
141 std::int32_t const loanScale = loanSle->at(sfLoanScale);
142 auto brokerDebtTotalProxy = brokerSle->at(sfDebtTotal);
147 TenthBips32 const coverRateMinimum{brokerSle->at(sfCoverRateMinimum)};
148 TenthBips32 const coverRateLiquidation{brokerSle->at(sfCoverRateLiquidation)};
149 auto const defaultCovered = [&]() {
152 auto const minimumCover =
tenthBipsOfValue(brokerDebtTotalProxy.value(), coverRateMinimum);
163 auto const coverAvailable = *brokerSle->at(sfCoverAvailable);
165 return std::min(covered, coverAvailable);
168 auto const vaultDefaultAmount = totalDefaultAmount - defaultCovered;
179 auto vaultTotalProxy = vaultSle->at(sfAssetsTotal);
180 auto vaultAvailableProxy = vaultSle->at(sfAssetsAvailable);
182 if (vaultTotalProxy < vaultDefaultAmount)
185 JLOG(j.
warn()) <<
"Vault total assets is less than the vault default amount";
192 vaultTotalProxy -= vaultDefaultRounded;
195 vaultAvailableProxy += defaultCovered;
196 if (*vaultAvailableProxy > *vaultTotalProxy && !vaultAsset.
integral())
198 auto const difference = vaultAvailableProxy - vaultTotalProxy;
199 JLOG(j.
debug()) <<
"Vault assets available: " << *vaultAvailableProxy <<
"("
200 << vaultAvailableProxy.value().exponent()
201 <<
"), Total: " << *vaultTotalProxy <<
"("
202 << vaultTotalProxy.value().exponent() <<
"), Difference: " << difference
203 <<
"(" << difference.exponent() <<
")";
204 if (vaultAvailableProxy.value().exponent() - difference.exponent() > 13)
208 JLOG(j.
debug()) <<
"Difference between vault assets available and total is "
209 "dust. Set both to the larger value.";
210 vaultTotalProxy = vaultAvailableProxy;
213 if (*vaultAvailableProxy > *vaultTotalProxy)
216 JLOG(j.
fatal()) <<
"Vault assets available must not be greater "
217 "than assets outstanding. Available: "
218 << *vaultAvailableProxy <<
", Total: " << *vaultTotalProxy;
224 if (loanSle->isFlag(lsfLoanImpaired))
226 auto vaultLossUnrealizedProxy = vaultSle->at(sfLossUnrealized);
227 if (vaultLossUnrealizedProxy < totalDefaultAmount)
230 JLOG(j.
warn()) <<
"Vault unrealized loss is less than the default amount";
235 vaultLossUnrealizedProxy, -totalDefaultAmount, vaultAsset, vaultScale);
237 view.update(vaultSle);
246 auto coverAvailableProxy = brokerSle->at(sfCoverAvailable);
247 if (coverAvailableProxy < defaultCovered)
250 JLOG(j.
warn()) <<
"LoanBroker cover available is less than amount covered";
254 coverAvailableProxy -= defaultCovered;
255 view.update(brokerSle);
259 loanSle->setFlag(lsfLoanDefault);
261 loanSle->at(sfTotalValueOutstanding) = 0;
262 loanSle->at(sfPaymentRemaining) = 0;
263 loanSle->at(sfPrincipalOutstanding) = 0;
264 loanSle->at(sfManagementFeeOutstanding) = 0;
267 loanSle->at(sfNextPaymentDueDate) = 0;
268 view.update(loanSle);
274 brokerSle->at(sfAccount),
275 vaultSle->at(sfAccount),
276 STAmount{vaultAsset, defaultCovered},
287 Asset const& vaultAsset,
298 auto vaultLossUnrealizedProxy = vaultSle->at(sfLossUnrealized);
300 if (vaultLossUnrealizedProxy > vaultSle->at(sfAssetsTotal) - vaultSle->at(sfAssetsAvailable))
304 JLOG(j.
warn()) <<
"Vault unrealized loss is too large, and will "
305 "corrupt the vault.";
308 view.update(vaultSle);
311 loanSle->setFlag(lsfLoanImpaired);
312 auto loanNextDueProxy = loanSle->at(sfNextPaymentDueDate);
317 loanNextDueProxy =
view.parentCloseTime().time_since_epoch().count();
319 view.update(loanSle);
329 Asset const& vaultAsset,
338 auto vaultLossUnrealizedProxy = vaultSle->at(sfLossUnrealized);
340 if (vaultLossUnrealizedProxy < lossReversed)
343 JLOG(j.
warn()) <<
"Vault unrealized loss is less than the amount to be cleared";
350 view.update(vaultSle);
353 loanSle->clearFlag(lsfLoanImpaired);
354 auto const paymentInterval = loanSle->at(sfPaymentInterval);
355 auto const normalPaymentDueDate =
356 std::max(loanSle->at(sfPreviousPaymentDueDate), loanSle->at(sfStartDate)) + paymentInterval;
360 loanSle->at(sfNextPaymentDueDate) = normalPaymentDueDate;
365 loanSle->at(sfNextPaymentDueDate) =
366 view.parentCloseTime().time_since_epoch().count() + paymentInterval;
368 view.update(loanSle);
376 auto const& tx =
ctx_.tx;
379 auto const loanID = tx[sfLoanID];
384 auto const brokerID = loanSle->at(sfLoanBrokerID);
392 auto const vaultAsset = vaultSle->at(sfAsset);
394 auto const result = [&]() ->
TER {
397 if (tx.isFlag(tfLoanDefault))
399 if (tx.isFlag(tfLoanImpair))
401 if (tx.isFlag(tfLoanUnimpair))
A generic endpoint for log messages.
Writeable view to a ledger, for applying a transaction.
void visitInvariantEntry(bool isDelete, SLE::const_ref before, SLE::const_ref after) override
Inspect a single ledger entry modified by this transaction.
static TER defaultLoan(ApplyView &view, SLE::ref loanSle, SLE::ref brokerSle, SLE::ref vaultSle, Asset const &vaultAsset, beast::Journal j)
Helper function that might be needed by other transactors.
static TER preclaim(PreclaimContext const &ctx)
bool finalizeInvariants(STTx const &tx, TER result, XRPAmount fee, ReadView const &view, beast::Journal const &j) override
Check transaction-specific post-conditions after all entries have been visited.
static std::uint32_t getFlagsMask(PreflightContext const &ctx)
static TER unimpairLoan(ApplyView &view, SLE::ref loanSle, SLE::ref vaultSle, Asset const &vaultAsset, beast::Journal j)
Helper function that might be needed by other transactors.
static TER impairLoan(ApplyView &view, SLE::ref loanSle, SLE::ref vaultSle, Asset const &vaultAsset, beast::Journal j)
Helper function that might be needed by other transactors.
static NotTEC preflight(PreflightContext const &ctx)
static bool checkExtraFeatures(PreflightContext const &ctx)
Number is a floating point type that can represent a wide range of values.
virtual SLE::const_pointer read(Keylet const &k) const =0
Return the state item associated with a key.
std::shared_ptr< STLedgerEntry > const & ref
std::shared_ptr< STLedgerEntry const > const & const_ref
Keylet loan(uint256 const &loanBrokerID, SeqProxy const &loanSeq) noexcept
Keylet vault(AccountID const &owner, SeqProxy const &seq) noexcept
Keylet loanBroker(AccountID const &owner, SeqProxy const &seq) noexcept
Use hash_* containers for keys that do not need a cryptographically secure hashing algorithm.
bool hasExpired(ReadView const &view, std::optional< std::uint32_t > const &exp, ExpiryComparison comparison=ExpiryComparison::Inclusive)
Determines whether the given expiration time has passed.
TER accountSend(ApplyView &view, AccountID const &from, AccountID const &to, STAmount const &saAmount, beast::Journal j, SLE::ref sponsorSle={}, WaiveTransferFee waiveFee=WaiveTransferFee::No, AllowMPTOverflow allowOverflow=AllowMPTOverflow::No)
Calls static accountSendIOU if saAmount represents Issue.
constexpr T tenthBipsOfValue(T value, TenthBips< TBips > bips)
int getAssetsTotalScale(SLE::const_ref vaultSle)
void adjustImpreciseNumber(NumberProxy value, Number const &adjustment, Asset const &asset, int vaultScale)
TenthBips< std::uint32_t > TenthBips32
TERSubset< CanCvtToNotTEC > NotTEC
void roundToAsset(A const &asset, Number &value)
Round an arbitrary precision Number IN PLACE to the precision of a given Asset.
bool isTesSuccess(TER x) noexcept
TERSubset< CanCvtToTER > TER
Number loanVaultExposure(SLE::const_ref vaultSle, SLE::const_ref loanSle)
void associateAsset(STLedgerEntry &sle, Asset const &asset)
Associate an Asset with all sMD_NeedsAsset fields in a ledger entry.
constexpr FlagValue tfUniversalMask
bool checkLendingProtocolDependencies(Rules const &rules, STTx const &tx)
State information when determining if a tx is likely to claim a fee.
State information when preflighting a tx.