72e2d19433
* Inject wallet logger interface * Include method in NWC logs * Fix wrong page total * Poll for new logs every second * Fix overlapping pagination * Remove unused total * Better logs for incoming payments * Use _setLogs instead of wrapper * Remove inconsistent receive log * Remove console.log from wallet logger on server * Fix missing 'wallet detached' log * Fix confirm_withdrawl code * Remove duplicate autowithdrawal log * Add context to log * Add more context * Better table styling * Move CSS for wallet logs into one file * remove unused logNav class * rename classes * Align key with second column * Fix TypeError if context empty * Check content-type header before calling res.json() * Fix duplicate 'failed to create invoice' * Parse details from LND error * Fix invalid DOM property 'colspan' * P2P zap logs with context * Remove unnecessary withdrawal error log * the code assignment was broken anyway * we already log withdrawal errors using .catch on payViaPaymentRequest * Don't show outgoing fee to receiver to avoid confusion * Fix typo in comment * Log if invoice was canceled by payer * Automatically populate context from bolt11 * Fix missing context * Fix wrap errors not logged * Only log cancel if client canceled * Remove unused imports * Log withdrawal/forward success/error in payment flow * Fix boss not passed to checkInvoice * Fix TypeError * Fix database timeouts caused by logger The logger shares the same connection pool with any currently running transaction. This means that we enter a classic deadlock when we await logger calls: the logger call is waiting for a connection but the currently running transaction is waiting for the logger call to finish before it can release a connection. * Fix cache returning undefined * Fix typo in comment * Add padding-right to key in log context * Always use 'incoming payment failed:' --------- Co-authored-by: Keyan <34140557+huumn@users.noreply.github.com>
56 lines
1.9 KiB
JavaScript
56 lines
1.9 KiB
JavaScript
import { msatsSatsFloor, msatsToSats, satsToMsats } from '@/lib/format'
|
|
import { createWithdrawal } from '@/api/resolvers/wallet'
|
|
import { createInvoice } from 'wallets/server'
|
|
|
|
export async function autoWithdraw ({ data: { id }, models, lnd }) {
|
|
const user = await models.user.findUnique({ where: { id } })
|
|
if (
|
|
user.autoWithdrawThreshold === null ||
|
|
user.autoWithdrawMaxFeePercent === null ||
|
|
user.autoWithdrawMaxFeeTotal === null) return
|
|
|
|
const threshold = satsToMsats(user.autoWithdrawThreshold)
|
|
const excess = Number(user.msats - threshold)
|
|
|
|
// excess must be greater than 10% of threshold
|
|
if (excess < Number(threshold) * 0.1) return
|
|
|
|
// floor fee to nearest sat but still denominated in msats
|
|
const maxFeeMsats = msatsSatsFloor(Math.max(
|
|
Math.ceil(excess * (user.autoWithdrawMaxFeePercent / 100.0)),
|
|
Number(satsToMsats(user.autoWithdrawMaxFeeTotal))
|
|
))
|
|
// msats will be floored by createInvoice if it needs to be
|
|
const msats = BigInt(excess) - maxFeeMsats
|
|
|
|
// must be >= 1 sat
|
|
if (msats < 1000n) return
|
|
|
|
// check that
|
|
// 1. the user doesn't have an autowithdraw pending
|
|
// 2. we have not already attempted to autowithdraw this fee recently
|
|
const [pendingOrFailed] = await models.$queryRaw`
|
|
SELECT EXISTS(
|
|
SELECT *
|
|
FROM "Withdrawl"
|
|
WHERE "userId" = ${id}
|
|
AND "autoWithdraw"
|
|
AND status IS DISTINCT FROM 'CONFIRMED'
|
|
AND now() < created_at + interval '1 hour'
|
|
AND "msatsFeePaying" >= ${maxFeeMsats}
|
|
)`
|
|
|
|
if (pendingOrFailed.exists) return
|
|
|
|
const { invoice, wallet, logger } = await createInvoice(id, { msats, description: 'SN: autowithdrawal', expiry: 360 }, { models })
|
|
|
|
try {
|
|
return await createWithdrawal(null,
|
|
{ invoice, maxFee: msatsToSats(maxFeeMsats) },
|
|
{ me: { id }, models, lnd, wallet, logger })
|
|
} catch (err) {
|
|
logger.error(`incoming payment failed: ${err}`, { bolt11: invoice })
|
|
throw err
|
|
}
|
|
}
|