diff options
Diffstat (limited to 'routes/liquid/receive.js')
| -rw-r--r-- | routes/liquid/receive.js | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/routes/liquid/receive.js b/routes/liquid/receive.js index 380fe4f4..5f61bc73 100644 --- a/routes/liquid/receive.js +++ b/routes/liquid/receive.js @@ -1,14 +1,13 @@ -import { rates } from "../../lib/store.js"; -import { addresses } from "../../lib/store.js"; +import store from "../../lib/store.js"; import { sendLiquid } from "./send.js"; import { notify } from "../../lib/notifications.js"; import { callWebhook } from "../../lib/webhooks.js"; import reverse from 'buffer-reverse'; -import zmq from 'zeromq/v5-compat'; +import zmq from 'zeromq/v5-compat.js'; import { Op } from '@sequelize/core'; import { fromBase58 } from 'bip32'; import bitcoin from 'bitcoinjs-lib'; -// import { Block, networks, Transaction } from 'liquidjs-lib'; +import { Block, networks, Transaction } from 'liquidjs-lib'; const network = networks[ @@ -51,7 +50,7 @@ const getAccount = async (params, transaction) => { params.seed = nc.seed; } - const assets = app.get("assets"); + const assets = assets; if (assets[asset]) { ({ domain, ticker, precision, name } = assets[asset]); @@ -117,11 +116,11 @@ zmqRawTx.on("message", async (topic, message, sequence) => { const address = o.scriptPubKey.addresses[0]; if ( - Object.keys(addresses).includes(address) && + Object.keys(store.addresses).includes(address) && !change.includes(address) ) { await db.transaction(async transaction => { - let user = await getUser(addresses[address], transaction); + let user = await getUser(store.addresses[address], transaction); let invoice = await db.Invoice.findOne({ where: { @@ -172,7 +171,7 @@ zmqRawTx.on("message", async (topic, message, sequence) => { const currency = invoice ? invoice.currency : user.currency; const rate = invoice ? invoice.rate - : rates[user.currency]; + : store.rates[user.currency]; const tip = invoice ? invoice.tip : 0; const memo = invoice ? invoice.memo : ""; |