diff options
| author | Adam Soltys <[email protected]> | 2024-10-23 08:27:25 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2024-10-23 10:10:21 -0700 |
| commit | 11a7c49eec78f088c83c5a2ff467d7afe0e55f29 (patch) | |
| tree | 262b33d634639ed402064a74394b67d2bfacd241 | |
| parent | 4a8fab2201253c53483ef33e6418967129c99463 (diff) | |
| download | coinos-server-11a7c49eec78f088c83c5a2ff467d7afe0e55f29.tar.gz coinos-server-11a7c49eec78f088c83c5a2ff467d7afe0e55f29.zip | |
lint
| -rw-r--r-- | lib/payments.ts | 233 | ||||
| -rw-r--r-- | lib/utils.ts | 81 | ||||
| -rw-r--r-- | routes/payments.ts | 178 |
3 files changed, 247 insertions, 245 deletions
diff --git a/lib/payments.ts b/lib/payments.ts index cb66bd48..1b865046 100644 --- a/lib/payments.ts +++ b/lib/payments.ts @@ -1,36 +1,36 @@ import config from "$config"; +import api from "$lib/api"; +import { db, g, s } from "$lib/db"; import { generate } from "$lib/invoices"; -import { v4 } from "uuid"; +import ln from "$lib/ln"; +import { err, l, warn } from "$lib/logging"; import { notify } from "$lib/notifications"; -import { db, g, s } from "$lib/db"; -import { l, err, warn } from "$lib/logging"; import { + SATS, btc, fail, fmt, - link, + formatReceipt, getInvoice, getPayment, getUser, - sleep, - SATS, + link, sats, - formatReceipt, + sleep, t, } from "$lib/utils"; import { callWebhook } from "$lib/webhooks"; -import got from "got"; -import api from "$lib/api"; -import { bech32 } from "bech32"; import rpc from "@coinos/rpc"; -import ln from "$lib/ln"; +import { bech32 } from "bech32"; +import got from "got"; +import { v4 } from "uuid"; -let bc = rpc(config.bitcoin); -let lq = rpc(config.liquid); +const bc = rpc(config.bitcoin); +const lq = rpc(config.liquid); -let dust = 547; +const dust = 547; -export let types = { +export const types = { internal: "internal", bitcoin: "bitcoin", lightning: "lightning", @@ -40,7 +40,7 @@ export let types = { reconcile: "reconcile", }; -export let debit = async ({ +export const debit = async ({ aid = undefined, hash, amount, @@ -56,12 +56,12 @@ export let debit = async ({ // if (!user.unlimited && amount > 1000000) // fail(`⚡️${amount} exceeds max withdrawal of ⚡️1,000,000`); let ref; - let { id: uid, currency } = user; + const { id: uid, currency } = user; - let rates = await g("rates"); + const rates = await g("rates"); if (!rate) rate = rates[currency]; - let invoice = await getInvoice(hash); + const invoice = await getInvoice(hash); let iid; if (invoice) { @@ -70,7 +70,7 @@ export let debit = async ({ ref = invoice.uid; - let equivalentRate = + const equivalentRate = invoice.rate * (rates[currency] / rates[invoice.currency]); if (Math.abs(invoice.rate / rates[invoice.currency] - 1) < 0.01) { @@ -80,7 +80,7 @@ export let debit = async ({ } } - let tip = parseInt(invoice?.tip) || null; + const tip = parseInt(invoice?.tip) || null; if (tip < 0) fail("Invalid tip"); if (!amount || amount < 0) fail("Amount must be greater than zero"); @@ -104,8 +104,8 @@ export let debit = async ({ if (ourfee.err) fail(ourfee.err); - let id = v4(); - let p = { + const id = v4(); + const p = { id, aid, amount: -amount, @@ -135,7 +135,7 @@ export let debit = async ({ return p; }; -export let credit = async ({ +export const credit = async ({ hash, amount, memo = "", @@ -145,7 +145,7 @@ export let credit = async ({ }) => { amount = parseInt(amount) || 0; - let inv = await getInvoice(hash); + const inv = await getInvoice(hash); if (!inv) { await db.sAdd("missing", ref.split(":")[0]); return; @@ -159,16 +159,16 @@ export let credit = async ({ if (amount < 0 || tip < 0) fail("Invalid amount"); if (type === types.internal) amount += tip; - let user = await getUser(inv.uid); - let { id: uid, currency, username } = user; + const user = await getUser(inv.uid); + const { id: uid, currency, username } = user; - let rates = await g("rates"); + const rates = await g("rates"); let rate = rates[currency]; if (!rate) await sleep(1000); rate = rates[currency]; - let equivalentRate = inv.rate * (rates[currency] / rates[inv.currency]); + const equivalentRate = inv.rate * (rates[currency] / rates[inv.currency]); if (Math.abs(inv.rate / rates[inv.currency] - 1) < 0.01) { rate = equivalentRate; @@ -176,8 +176,8 @@ export let credit = async ({ // warn("rate slipped", hash, invoice.rate, equivalentRate); } - let id = v4(); - let p = { + const id = v4(); + const p = { aid, id, iid: inv.id, @@ -204,7 +204,7 @@ export let credit = async ({ let balanceKey = "balance"; if ([types.bitcoin, types.liquid].includes(type)) { - let [txid, vout] = ref.split(":").slice(-2); + const [txid, vout] = ref.split(":").slice(-2); p.confirmed = false; balanceKey = "pending"; await s(`payment:${txid}:${vout}`, id); @@ -212,7 +212,7 @@ export let credit = async ({ await s(`payment:${hash}`, id); } - let m = await db.multi(); + const m = await db.multi(); if ([types.bitcoin, types.liquid, types.lightning].includes(type)) m.incrBy(`credit:${type}:${uid}`, Math.round(amount * config.fee)); @@ -223,7 +223,7 @@ export let credit = async ({ .incrBy(`${balanceKey}:${aid || uid}`, amount) .exec(); - if (inv.items && inv.items.length) { + if (inv.items?.length) { formatReceipt(inv.items, inv.currency); p.items = inv.items; } @@ -233,18 +233,18 @@ export let credit = async ({ return p; }; -export let completePayment = async (inv, p, user) => { - let { id, autowithdraw, threshold, reserve, destination, username } = user; +export const completePayment = async (inv, p, user) => { + const { id, autowithdraw, threshold, reserve, destination, username } = user; let withdrawal; if (p.confirmed) { if (autowithdraw) { try { - let to = destination.trim(); - let balance = await g(`balance:${id}`); - let amount = balance - reserve; + const to = destination.trim(); + const balance = await g(`balance:${id}`); + const amount = balance - reserve; if (balance > threshold) { l("initiating autowithdrawal", amount, to, balance, threshold); - let w = await pay({ amount, to, user }); + const w = await pay({ amount, to, user }); withdrawal = { amount: fmt(-w.amount), link: link(w.id), @@ -255,7 +255,6 @@ export let completePayment = async (inv, p, user) => { warn(username, "autowithdraw failed", e.message); } } - } notify(p, user, withdrawal); @@ -263,12 +262,13 @@ export let completePayment = async (inv, p, user) => { callWebhook(inv, p); }; -let pay = async ({ aid = undefined, amount, to, user }) => { +const pay = async ({ aid = undefined, amount, to, user }) => { if (!aid) aid = user.id; amount = parseInt(amount) || 0; - let lnurl, pr; + let lnurl; + let pr; if (to.includes("@") && to.includes(".")) { - let [name, domain] = to.split("@"); + const [name, domain] = to.split("@"); lnurl = `https://${domain}/.well-known/lnurlp/${name}`; } else if (to.startsWith("lnurl")) { lnurl = Buffer.from( @@ -276,10 +276,10 @@ let pay = async ({ aid = undefined, amount, to, user }) => { ).toString(); } - let maxfee = getMaxFee(amount); + const maxfee = getMaxFee(amount); if (lnurl) { amount -= maxfee; - let { callback } = (await got(lnurl).json()) as any; + const { callback } = (await got(lnurl).json()) as any; ({ pr } = (await got(`${callback}?amount=${amount * 1000}`).json()) as any); } else if (to.startsWith("ln")) { amount -= maxfee; @@ -291,8 +291,9 @@ let pay = async ({ aid = undefined, amount, to, user }) => { : await sendOnchain({ aid, amount, address: to, user, subtract: true }); }; -export let decode = async (hex) => { - let type, tx; +export const decode = async (hex) => { + let type; + let tx; try { tx = await bc.decodeRawTransaction(hex); type = types.bitcoin; @@ -309,14 +310,14 @@ export let decode = async (hex) => { return { tx, type }; }; -let inflight = {}; -export let sendOnchain = async (params) => { +const inflight = {}; +export const sendOnchain = async (params) => { let { aid, hex, rate, user, signed } = params; if (!aid) aid = user.id; if (!hex) ({ hex } = await build(params)); - let { tx, type } = await decode(hex); - let node = + const { tx, type } = await decode(hex); + const node = aid === user.id ? rpc(config[type]) : rpc({ ...config[type], wallet: aid }); let { txid } = tx; @@ -335,7 +336,7 @@ export let sendOnchain = async (params) => { ({ txid } = await node.decodeRawTransaction(hex)); - let r = await node.testMempoolAccept([hex]); + const r = await node.testMempoolAccept([hex]); if (!r[0].allowed) fail("transaction rejected"); let total = 0; @@ -343,7 +344,7 @@ export let sendOnchain = async (params) => { let change = 0; if (type === types.liquid) { - for (let { + for (const { asset, scriptPubKey: { address, type }, value, @@ -362,18 +363,18 @@ export let sendOnchain = async (params) => { } } else { let totalIn = 0; - for await (let { txid, vout } of tx.vin) { - let hex = await node.getRawTransaction(txid); - let tx = await node.decodeRawTransaction(hex); + for await (const { txid, vout } of tx.vin) { + const hex = await node.getRawTransaction(txid); + const tx = await node.decodeRawTransaction(hex); totalIn += sats(tx.vout[vout].value); } - for (let { + for (const { scriptPubKey: { address }, value, } of tx.vout) { total += sats(value); - let invoice = await g(`invoice:${address}`); + const invoice = await g(`invoice:${address}`); if (invoice?.aid === aid) fail("Cannot send to internal address"); if ((await node.getAddressInfo(address)).ismine) { @@ -384,9 +385,9 @@ export let sendOnchain = async (params) => { fee = totalIn - total; } - let amount = total - change; + const amount = total - change; - let p = await debit({ + const p = await debit({ aid, hash: txid, amount, @@ -409,7 +410,7 @@ export let sendOnchain = async (params) => { } }; -let getMaxFee = (n) => +const getMaxFee = (n) => Math.round( n < 100 ? n * 5 @@ -424,7 +425,7 @@ let getMaxFee = (n) => : n * 0.01, ); -export let sendLightning = async ({ +export const sendLightning = async ({ user, pr, amount, @@ -439,15 +440,15 @@ export let sendLightning = async ({ } let total = amount; - let decoded = await ln.decode(pr); - let { amount_msat } = decoded; + const decoded = await ln.decode(pr); + const { amount_msat } = decoded; if (amount_msat) total = Math.round(amount_msat / 1000); maxfee = parseInt(maxfee) || getMaxFee(total); if (maxfee < 0) fail("Max fee cannot be negative"); - let { pays } = await ln.listpays(pr); + const { pays } = await ln.listpays(pr); if (pays.find((p) => p.status === "complete")) fail("Invoice has already been paid"); @@ -490,7 +491,7 @@ export let sendLightning = async ({ return p; }; -export let sendInternal = async ({ +export const sendInternal = async ({ amount, invoice = undefined, recipient, @@ -502,15 +503,15 @@ export let sendInternal = async ({ user: recipient, }); - let { hash } = invoice; + const { hash } = invoice; let memo; - let p = await debit({ hash, amount, memo, user: sender }); + const p = await debit({ hash, amount, memo, user: sender }); await credit({ hash, amount, memo, ref: sender.id }); return p; }; -let getAddressType = async (a) => { +const getAddressType = async (a) => { try { await bc.getAddressInfo(a); return types.bitcoin; @@ -524,7 +525,7 @@ let getAddressType = async (a) => { } }; -export let build = async ({ +export const build = async ({ aid, amount, address, @@ -532,15 +533,15 @@ export let build = async ({ subtract, user, }) => { - let type = await getAddressType(address); + const type = await getAddressType(address); if (!aid) aid = user.id; - let node = + const node = aid === user.id ? rpc(config[type]) : rpc({ ...config[type], wallet: aid }); amount = parseInt(amount); if (amount < 0) fail("invalid amount"); - let fees: any = await fetch(`${api[type]}/fees/recommended`).then((r) => + const fees: any = await fetch(`${api[type]}/fees/recommended`).then((r) => r.json(), ); @@ -550,7 +551,7 @@ export let build = async ({ if (feeRate < fees.economyFee) fail("fee rate too low"); - let replaceable = false; + const replaceable = false; let outs = [{ [address]: btc(amount) }]; @@ -575,10 +576,10 @@ export let build = async ({ else throw e; } - let balance = await g(`balance:${aid}`); + const balance = await g(`balance:${aid}`); let ourfee = Math.round(amount * config.fee); - let credit = await g(`credit:${type}:${aid}`); - let covered = Math.min(credit, ourfee); + const credit = await g(`credit:${type}:${aid}`); + const covered = Math.min(credit, ourfee); ourfee -= covered; if (aid) ourfee = 0; @@ -600,16 +601,16 @@ export let build = async ({ fee = sats(tx.fee); } - let inputs = []; - let { vin } = await node.decodeRawTransaction(tx.hex); + const inputs = []; + const { vin } = await node.decodeRawTransaction(tx.hex); - for (let { txid, vout } of vin) { - let rawTx = await node.getRawTransaction(txid); - let tx = await node.decodeRawTransaction(rawTx); - let prevOutput = tx.vout[vout]; - let { address } = prevOutput.scriptPubKey; - let { hdkeypath: path } = await node.getAddressInfo(address); - let witnessUtxo = { + for (const { txid, vout } of vin) { + const rawTx = await node.getRawTransaction(txid); + const tx = await node.decodeRawTransaction(rawTx); + const prevOutput = tx.vout[vout]; + const { address } = prevOutput.scriptPubKey; + const { hdkeypath: path } = await node.getAddressInfo(address); + const witnessUtxo = { amount: Math.round(prevOutput.value * SATS), script: prevOutput.scriptPubKey.hex, }; @@ -619,10 +620,10 @@ export let build = async ({ return { feeRate, ourfee, fee, fees, hex: tx.hex, inputs }; }; -export let catchUp = async () => { +export const catchUp = async () => { try { - let txns = []; - for (let [type, n] of Object.entries({ bitcoin: bc, liquid: lq })) { + const txns = []; + for (const [type, n] of Object.entries({ bitcoin: bc, liquid: lq })) { txns.push( ...(await n.listTransactions("*", 10)).filter((tx) => { tx.type = type; @@ -631,7 +632,7 @@ export let catchUp = async () => { ); } - for (let { txid, type } of txns) { + for (const { txid, type } of txns) { try { if (await db.zScore("seen", txid)) continue; await got.post(`http://localhost:${process.env.PORT || 3119}/confirm`, { @@ -652,33 +653,33 @@ export let catchUp = async () => { setTimeout(catchUp, 10000); }; -export let reconcile = async (account, initial = false) => { +export const reconcile = async (account, initial = false) => { try { - let { descriptors, id, uid, type } = account; - let user = await getUser(uid); - let node = rpc({ ...config[type], wallet: id }); + const { descriptors, id, uid, type } = account; + const user = await getUser(uid); + const node = rpc({ ...config[type], wallet: id }); let total; if (initial) { - let progress = await node.scanTxOutSet("status"); + const progress = await node.scanTxOutSet("status"); if (progress) return setTimeout(() => reconcile(account, initial), 1000); - let { total_amount } = await node.scanTxOutSet("start", descriptors); + const { total_amount } = await node.scanTxOutSet("start", descriptors); total = Math.round(total_amount * SATS); } else { total = Math.round((await node.getBalance({ minconf: 1 })) * SATS); } - let { balanceAdjustment: memo } = t(user); + const { balanceAdjustment: memo } = t(user); - let balance = await g(`balance:${id}`); + const balance = await g(`balance:${id}`); - let amount = Math.abs(total - balance); - let hash = v4(); + const amount = Math.abs(total - balance); + const hash = v4(); if (total > balance) { - let inv = { + const inv = { memo, type: types.reconcile, hash, @@ -711,17 +712,17 @@ export let reconcile = async (account, initial = false) => { } }; -export let check = async () => { +export const check = async () => { try { - let payments = await db.sMembers("pending"); + const payments = await db.sMembers("pending"); - for (let pr of payments) { - let p = await getPayment(pr); + for (const pr of payments) { + const p = await getPayment(pr); if (!p) continue; - let { pays } = await ln.listpays(pr); + const { pays } = await ln.listpays(pr); - let failed = !pays.length || pays.every((p) => p.status === "failed"); - let completed = pays.find((p) => p.status === "complete"); + const failed = !pays.length || pays.every((p) => p.status === "failed"); + const completed = pays.find((p) => p.status === "complete"); if (completed) await finalize(completed, p); else if (failed) await reverse(p); @@ -733,11 +734,11 @@ export let check = async () => { setTimeout(check, 2000); }; -let finalize = async (r, p) => { +const finalize = async (r, p) => { await db.sRem("pending", p.hash); l("payment completed", p.id, r.payment_preimage); - let maxfee = p.fee; + const maxfee = p.fee; p.fee = Math.round((r.amount_sent_msat - r.amount_msat) / 1000); p.ref = r.payment_preimage; @@ -749,12 +750,12 @@ let finalize = async (r, p) => { return p; }; -let reverse = async (p) => { - let total = Math.abs(p.amount) + p.fee; - let ourfee = p.ourfee || 0; - let credit = Math.round(total * config.fee) - ourfee; +const reverse = async (p) => { + const total = Math.abs(p.amount) + p.fee; + const ourfee = p.ourfee || 0; + const credit = Math.round(total * config.fee) - ourfee; - let k = await db.reverse( + const k = await db.reverse( `payment:${p.id}`, `balance:${p.uid}`, `credit:${types.lightning}:${p.uid}`, diff --git a/lib/utils.ts b/lib/utils.ts index fa10fb81..b1ff862b 100644 --- a/lib/utils.ts +++ b/lib/utils.ts @@ -1,44 +1,44 @@ +import config from "$config"; +import { g, s } from "$lib/db"; import locales from "$lib/locales/index"; -import { randomBytes, bytesToHex } from "@noble/hashes/utils"; import migrate from "$lib/migrate"; -import { g, s } from "$lib/db"; -import config from "$config"; +import { bytesToHex, randomBytes } from "@noble/hashes/utils"; import { getPublicKey } from "nostr"; - let { URL } = process.env; +const { URL } = process.env; -export let fail = (msg) => { +export const fail = (msg) => { throw new Error(msg); }; -export let nada = () => {}; +export const nada = () => {}; -export let sleep = (n) => new Promise((r) => setTimeout(r, n)); -export let wait = async (f, s = 300, n = 50) => { +export const sleep = (n) => new Promise((r) => setTimeout(r, n)); +export const wait = async (f, s = 300, n = 50) => { let i = 0; while (!(await f()) && i < s) (await sleep(n)) && i++; if (i >= s) fail("timeout"); return f(); }; -export let prod = process.env.NODE_ENV === "production"; +export const prod = process.env.NODE_ENV === "production"; -export let bail = (res, msg) => res.code(500).send(msg); +export const bail = (res, msg) => res.code(500).send(msg); -export let SATS = 100000000; -export let sats = (n) => Math.round(n * SATS); -export let btc = (n) => parseFloat((n / SATS).toFixed(8)); -export let fiat = (n, r) => (n * r) / SATS; +export const SATS = 100000000; +export const sats = (n) => Math.round(n * SATS); +export const btc = (n) => parseFloat((n / SATS).toFixed(8)); +export const fiat = (n, r) => (n * r) / SATS; -export let uniq = (a, k) => [...new Map(a.map((x) => [k(x), x])).values()]; -export let pick = (O, K) => +export const uniq = (a, k) => [...new Map(a.map((x) => [k(x), x])).values()]; +export const pick = (O, K) => K.reduce((o, k) => (typeof O[k] !== "undefined" && (o[k] = O[k]), o), {}); -export let bip21 = (address, { amount, memo, tip, type }) => { +export const bip21 = (address, { amount, memo, tip, type }) => { if (!(amount || memo)) return address; - let network = { liquid: "liquidnetwork", bitcoin: "bitcoin" }[type]; - let url = new URLSearchParams(); + const network = { liquid: "liquidnetwork", bitcoin: "bitcoin" }[type]; + const url = new URLSearchParams(); if (amount) { url.append("amount", btc(amount + tip).toFixed(8)); @@ -50,7 +50,7 @@ export let bip21 = (address, { amount, memo, tip, type }) => { return `${network}:${address}?${url.toString()}`; }; -export let fields = [ +export const fields = [ "cipher", "pubkey", "password", @@ -70,9 +70,9 @@ export let fields = [ "banner", ]; -export let getUser = async (username) => { +export const getUser = async (username) => { if (username === "undefined") fail("invalid user"); - let user = await migrate(username); + const user = await migrate(username); if (user && !user.anon && !user.nwc) { user.nwc = bytesToHex(randomBytes(32)); await s(getPublicKey(user.nwc), user.id); @@ -82,20 +82,20 @@ export let getUser = async (username) => { return user; }; -export let getInvoice = async (hash) => { +export const getInvoice = async (hash) => { let iid = await g(`invoice:${hash}`); - if (iid && iid.id) iid = iid.id; - else if (iid && iid.hash) iid = iid.hash; + if (iid?.id) iid = iid.id; + else if (iid?.hash) iid = iid.hash; return await g(`invoice:${iid}`); }; -export let getPayment = async (id) => { +export const getPayment = async (id) => { let p = await g(`payment:${id}`); if (typeof p === "string") p = await g(`payment:${p}`); return p; }; -export let f = (s, currency) => +export const f = (s, currency) => new Intl.NumberFormat("en-US", { style: "currency", currency, @@ -108,14 +108,14 @@ export function formatReceipt(items, currency) { const words = text.split(" "); const lines = []; let currentLine = ""; - words.forEach((word) => { + for (const word of words) { if (currentLine.length + word.length + 1 > maxWidth) { lines.push(currentLine); currentLine = word; } else { currentLine += (currentLine.length > 0 ? " " : "") + word; } - }); + } if (currentLine) lines.push(currentLine); return lines; } @@ -124,7 +124,7 @@ export function formatReceipt(items, currency) { let maxQuantityLength = 0; let maxPriceLength = 0; - items.forEach((item) => { + for (const item of items) { const quantityLength = String(item.quantity).length; if (quantityLength > maxQuantityLength) { maxQuantityLength = quantityLength; @@ -134,7 +134,7 @@ export function formatReceipt(items, currency) { if (priceLength > maxPriceLength) { maxPriceLength = priceLength; } - }); + } // Add padding to the widths for aesthetic spacing return { @@ -156,7 +156,7 @@ export function formatReceipt(items, currency) { const nameLines = wrapText(item.name, nameColumnWidth); // Construct the full line(s) with the first line including the price - let fullLines = [ + const fullLines = [ `${quantityStr}${nameLines[0].padEnd(nameColumnWidth)}${priceStr}`, ]; // Add any additional name lines, properly indented @@ -169,11 +169,11 @@ export function formatReceipt(items, currency) { .join("\n"); } -export let t = ({ language = "en" }) => locales[language]; +export const t = ({ language = "en" }) => locales[language]; -export let time = (() => { - let count = 0, - started = false; +export const time = (() => { + let count = 0; + let started = false; return (s = "") => { if (!started) { console.time(""); @@ -183,8 +183,9 @@ export let time = (() => { }; })(); -export let fmt = (sats) => - "⚡️" + - new Intl.NumberFormat("en-US", { maximumFractionDigits: 0 }).format(sats); +export const fmt = (sats) => + `⚡️${new Intl.NumberFormat("en-US", { maximumFractionDigits: 0 }).format( + sats, + )}`; -export let link = (id) => `${URL}/payment/${id}`; +export const link = (id) => `${URL}/payment/${id}`; diff --git a/routes/payments.ts b/routes/payments.ts index f69123ac..4573ac4f 100644 --- a/routes/payments.ts +++ b/routes/payments.ts @@ -1,33 +1,33 @@ import config from "$config"; -import { emit } from "$lib/sockets"; -import { v4 } from "uuid"; +import api from "$lib/api"; +import { requirePin } from "$lib/auth"; import { db, g, s, t } from "$lib/db"; -import { l, err, warn } from "$lib/logging"; +import { err, l, warn } from "$lib/logging"; +import mqtt from "$lib/mqtt"; +import { + build, + completePayment, + credit, + debit, + decode, + sendInternal, + sendLightning, + sendOnchain, + types, +} from "$lib/payments"; +import { emit } from "$lib/sockets"; import { + SATS, bail, fail, getInvoice, getPayment, getUser, sats, - SATS, } from "$lib/utils"; -import { requirePin } from "$lib/auth"; -import { - completePayment, - decode, - debit, - credit, - types, - build, - sendInternal, - sendLightning, - sendOnchain, -} from "$lib/payments"; -import mqtt from "$lib/mqtt"; -import got from "got"; -import api from "$lib/api"; import rpc from "@coinos/rpc"; +import got from "got"; +import { v4 } from "uuid"; import ln from "$lib/ln"; @@ -37,16 +37,16 @@ export default { }, async create(req, res) { - let { body, user } = req; + const { body, user } = req; let { amount, hash, maxfee, fund, memo, payreq } = body; - let balance = await g(`balance:${user.id}`); + const balance = await g(`balance:${user.id}`); try { if (await g("freeze")) fail("Problem sending payment"); if (typeof amount !== "undefined") { amount = parseInt(amount); - if (amount < 0 || amount > SATS || isNaN(amount)) + if (amount < 0 || amount > SATS || Number.isNaN(amount)) fail("Invalid amount"); } @@ -92,7 +92,7 @@ export default { payments = ( await Promise.all( payments.map(async (pid) => { - let p = await g(`payment:${pid}`); + const p = await g(`payment:${pid}`); if (!p) { warn("user", id, "missing payment", pid); await db.lRem(`${aid || id}:payments`, 0, pid); @@ -107,9 +107,9 @@ export default { .filter((p) => p) .sort((a, b) => b.created - a.created); - let count = payments.length; + const count = payments.length; - let fn = (a, b) => ({ + const fn = (a, b) => ({ ...a, [b.currency]: { tips: (a[b.currency] ? a[b.currency].tips : 0) + (b.tip || 0), @@ -135,8 +135,8 @@ export default { }, }); - let incoming = payments.filter((p: any) => p.amount > 0).reduce(fn, {}); - let outgoing = payments.filter((p: any) => p.amount < 0).reduce(fn, {}); + const incoming = payments.filter((p: any) => p.amount > 0).reduce(fn, {}); + const outgoing = payments.filter((p: any) => p.amount < 0).reduce(fn, {}); if (limit) payments = payments.slice(offset, offset + limit); @@ -145,10 +145,10 @@ export default { async get(req, res) { try { - let { + const { params: { hash }, } = req; - let p = await getPayment(hash); + const p = await getPayment(hash); if (p.type === types.internal) p.with = await g(`user:${p.ref}`); res.send(p); } catch (e) { @@ -158,14 +158,14 @@ export default { }, async parse(req, res) { - let { + const { body: { payreq }, user, } = req; try { - let hour = 1000 * 60 * 60; + const hour = 1000 * 60 * 60; let nodes = await g("nodes"); - let { last } = nodes || {}; + const { last } = nodes || {}; if (!last || last > Date.now() - hour) { ({ nodes } = await ln.listnodes()); @@ -173,15 +173,15 @@ export default { await s("nodes", nodes); } - let decoded = await ln.decodepay(payreq); - let { amount_msat, payee } = decoded; - let node = nodes.find((n) => n.nodeid === payee); - let alias = node ? node.alias : payee.substr(0, 12); + const decoded = await ln.decodepay(payreq); + const { amount_msat, payee } = decoded; + const node = nodes.find((n) => n.nodeid === payee); + const alias = node ? node.alias : payee.substr(0, 12); - let amount = Math.round(amount_msat / 1000); + const amount = Math.round(amount_msat / 1000); let ourfee = Math.round(amount * config.fee); - let credit = await g(`credit:lightning:${user.id}`); - let covered = Math.min(credit, ourfee) || 0; + const credit = await g(`credit:lightning:${user.id}`); + const covered = Math.min(credit, ourfee) || 0; ourfee -= covered; res.send({ alias, amount, ourfee }); @@ -191,10 +191,10 @@ export default { }, async fund(req, res) { - let { + const { params: { name }, } = req; - let amount = await g(`fund:${name}`); + const amount = await g(`fund:${name}`); if (typeof amount === "undefined" || amount === null) return bail(res, "fund not found"); let payments = (await db.lRange(`fund:${name}:payments`, 0, -1)) || []; @@ -209,10 +209,10 @@ export default { }, async withdraw(req, res) { - let { + const { params: { name }, } = req; - let maxWithdrawable = await g(`fund:${name}`); + const maxWithdrawable = await g(`fund:${name}`); res.send({ tag: "withdrawRequest", callback: `${URL}/lnurlw/${name}`, @@ -239,8 +239,8 @@ export default { if (!iid) { iid = v4(); - let rates = await g("rates"); - let { currency } = user; + const rates = await g("rates"); + const { currency } = user; await s(`invoice:${iid}`, { currency, id: iid, @@ -251,7 +251,7 @@ export default { }); } - let payment = await credit({ + const payment = await credit({ hash: iid, amount, memo: id, @@ -268,23 +268,23 @@ export default { }, async confirm(req, res) { - let { + const { body: { txid, wallet, type }, } = req; try { - let node = rpc({ ...config[type], wallet }); - let { confirmations, details } = await node.getTransaction(txid); - let hot = wallet === config[type].wallet; + const node = rpc({ ...config[type], wallet }); + const { confirmations, details } = await node.getTransaction(txid); + const hot = wallet === config[type].wallet; let aid; if (!hot) aid = wallet; - for (let { address, amount, asset, category, vout } of details) { + for (const { address, amount, asset, category, vout } of details) { if (!address) continue; if (type === types.liquid && asset !== config.liquid.btc) continue; if (category === "send") { - let p = await getPayment(txid); + const p = await getPayment(txid); if (!p) continue; if (confirmations) { @@ -299,10 +299,10 @@ export default { continue; } - let p = await getPayment(`${txid}:${vout}`); + const p = await getPayment(`${txid}:${vout}`); if (!p) { - let invoice = await getInvoice(address); + const invoice = await getInvoice(address); if (!hot && aid !== invoice?.aid) continue; await credit({ hash: address, @@ -312,13 +312,13 @@ export default { aid, }); } else if (confirmations >= 1) { - let id = `payment:${txid}:${vout}`; - let p = await getPayment(`${txid}:${vout}`); + const id = `payment:${txid}:${vout}`; + const p = await getPayment(`${txid}:${vout}`); if (!p) return db.sAdd("missed", id); if (p.confirmed) return; - let invoice = await getInvoice(address); - let { id: iid } = invoice; + const invoice = await getInvoice(address); + const { id: iid } = invoice; p.confirmed = true; invoice.received += parseInt(invoice.pending); @@ -334,7 +334,7 @@ export default { .incrBy(`balance:${p.aid || p.uid}`, p.amount) .exec(); - let user = await g(`user:${p.uid}`); + const user = await g(`user:${p.uid}`); await completePayment(invoice, p, user); } } @@ -347,7 +347,7 @@ export default { }, async fee(req, res) { - let { body, user } = req; + const { body, user } = req; try { res.send(await build({ ...body, user })); } catch (e) { @@ -365,12 +365,12 @@ export default { }, async send(req, res) { - let { body, user } = req; + const { body, user } = req; try { await requirePin({ body, user }); - let { hash: txid } = await sendOnchain({ ...body, user }); - let pid = await g(`payment:${txid}`); - let p = await g(`payment:${pid}`); + const { hash: txid } = await sendOnchain({ ...body, user }); + const pid = await g(`payment:${txid}`); + const p = await g(`payment:${pid}`); res.send(p); } catch (e) { @@ -381,7 +381,7 @@ export default { }, async freeze(req, res) { - let { + const { body: { secret }, } = req; try { @@ -395,16 +395,16 @@ export default { }, async print(req, res) { - let { + const { body: { id }, user, } = req; try { - let p = await g(`payment:${id}`); + const p = await g(`payment:${id}`); if (p.uid !== user.id) fail("unauthorized"); emit(user.id, "payment", p); - let { username } = user; + const { username } = user; mqtt.publish( username, @@ -427,21 +427,21 @@ export default { lnaddress = decodeURIComponent(lnaddress); await requirePin({ body, user }); - let [username, domain] = lnaddress.split("@"); - let { minSendable, maxSendable, callback, metadata } = (await got( + const [username, domain] = lnaddress.split("@"); + const { minSendable, maxSendable, callback, metadata } = (await got( `https://${domain}/.well-known/lnurlp/${username}`, ).json()) as any; - let memo = metadata["text/plain"] || ""; + const memo = metadata["text/plain"] || ""; if (amount * 1000 < minSendable || amount * 1000 > maxSendable) fail("amount out of range"); - let r: any = await got(`${callback}?amount=${amount * 1000}`).json(); + const r: any = await got(`${callback}?amount=${amount * 1000}`).json(); if (r.reason) fail(r.reason); - let { pr } = r; + const { pr } = r; - let { payee } = await ln.decode(pr); - let { id } = await ln.getinfo(); + const { payee } = await ln.decode(pr); + const { id } = await ln.getinfo(); let p; if (payee === id) { @@ -457,7 +457,7 @@ export default { }, async gateway(req, res) { - let { + const { body: { short_channel_id, webhook }, } = req; @@ -466,24 +466,24 @@ export default { }, async replace(req, res) { - let { + const { body: { id }, user, } = req; try { - let p = await g(`payment:${id}`); + const p = await g(`payment:${id}`); if (!p) fail("Payment not found"); if (p.uid !== user.id) fail("unauthorized"); - let { tx, type } = await decode(p.hex); - let node = rpc(config[type]); + const { tx, type } = await decode(p.hex); + const node = rpc(config[type]); - let fees: any = await fetch(`${api[type]}/fees/recommended`).then((r) => + const fees: any = await fetch(`${api[type]}/fees/recommended`).then((r) => r.json(), ); - let outputs = []; - for (let { + const outputs = []; + for (const { scriptPubKey: { address }, value, } of tx.vout) { @@ -491,21 +491,21 @@ export default { outputs.push({ [address]: value }); } - let raw = await node.createRawTransaction(tx.vin, outputs); + const raw = await node.createRawTransaction(tx.vin, outputs); - let newTx = await node.fundRawTransaction(raw, { + const newTx = await node.fundRawTransaction(raw, { fee_rate: fees.fastestFee + 50, replaceable: true, subtractFeeFromOutputs: [], }); - let diff = sats(newTx.fee) - p.fee; + const diff = sats(newTx.fee) - p.fee; if (diff < 0) fail("fee must increase"); if (config[type].walletpass) await node.walletPassphrase(config[type].walletpass, 300); p.hex = (await node.signRawTransactionWithWallet(newTx.hex)).hex; - let r = await node.testMempoolAccept([p.hex]); + const r = await node.testMempoolAccept([p.hex]); if (!r[0].allowed) fail(`transaction rejected ${p.hex}`); warn("bump", user.username, p.hex); @@ -517,12 +517,12 @@ export default { }, async internal(req, res) { - let { + const { body: { username, amount }, user: sender, } = req; - let recipient = await getUser(username); + const recipient = await getUser(username); res.send(await sendInternal({ amount, sender, recipient })); }, }; |
