diff options
| author | Adam Soltys <[email protected]> | 2022-09-02 14:47:08 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2022-09-02 14:47:14 -0700 |
| commit | 3161dd7ee95b6c7d70f8341298dd4fab84cda8b0 (patch) | |
| tree | 16cd6c55d5dc481331b1e8b640d179f193e7ea13 /routes/liquid/send.js | |
| parent | 7a8d64833de8873afb92982b3f5bfff59b30c542 (diff) | |
| download | coinos-server-3161dd7ee95b6c7d70f8341298dd4fab84cda8b0.tar.gz coinos-server-3161dd7ee95b6c7d70f8341298dd4fab84cda8b0.zip | |
es6 migration
Diffstat (limited to 'routes/liquid/send.js')
| -rw-r--r-- | routes/liquid/send.js | 42 |
1 files changed, 30 insertions, 12 deletions
diff --git a/routes/liquid/send.js b/routes/liquid/send.js index e5112468..9529a040 100644 --- a/routes/liquid/send.js +++ b/routes/liquid/send.js @@ -1,9 +1,13 @@ +import config from "../../config/index.js"; const btc = config.liquid.btcasset; const lcad = config.liquid.cadasset; -import { Transaction } from 'liquidjs-lib'; -import { computeConversionFee, conversionFeeReceiver } from './conversionFee.js'; +// import { Transaction } from 'liquidjs-lib'; +import { + computeConversionFee, + conversionFeeReceiver +} from "./conversionFee.js"; -sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { +export const sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { try { l.info("sending liquid", amount, address); if (!tx) { @@ -106,9 +110,15 @@ sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { }); // use user's credits to reduce fee, if available - let conversionFeeDeduction = Math.min(account.liquid_credits, conversionFee); + let conversionFeeDeduction = Math.min( + account.liquid_credits, + conversionFee + ); if (conversionFeeDeduction) { - await account.decrement({ liquid_credits: conversionFeeDeduction }, { transaction }); + await account.decrement( + { liquid_credits: conversionFeeDeduction }, + { transaction } + ); await account.reload({ transaction }); conversionFee -= conversionFeeDeduction; } @@ -140,7 +150,10 @@ sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { ); } - await account.decrement({ balance: (total + conversionFee)}, { transaction }); + await account.decrement( + { balance: total + conversionFee }, + { transaction } + ); await account.reload({ transaction }); let receiverAccount = await db.Account.findOne({ @@ -151,14 +164,17 @@ sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { { model: db.User, as: "user" - }, + } ], lock: transaction.LOCK.UPDATE, transaction }); if (conversionFee) { - await receiverAccount.increment({ balance: conversionFee }, { transaction }); + await receiverAccount.increment( + { balance: conversionFee }, + { transaction } + ); await receiverAccount.reload({ transaction }); fee_payment = { amount: conversionFee, @@ -173,7 +189,9 @@ sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { network: "COINOS" }; fee_payment.account = receiverAccount; - ({ id: fee_payment_id } = await db.Payment.create(fee_payment, { transaction })); + ({ id: fee_payment_id } = await db.Payment.create(fee_payment, { + transaction + })); } let payment = { @@ -188,7 +206,7 @@ sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { confirmed: true, received: false, network: "liquid", - fee_payment_id, + fee_payment_id }; payment.account = account; @@ -231,7 +249,7 @@ sendLiquid = async ({ asset, amount, user, address, memo, tx, limit }) => { } }; -export default ah(async (req, res) => { +export default async (req, res) => { let { user } = req; try { @@ -240,4 +258,4 @@ export default ah(async (req, res) => { l.error("problem sending liquid", user.username, e.message); return res.status(500).send(e); } -}); +}; |
