liquid

1 files changed, 8 insertions, 5 deletions

diff --git a/lib/payments.js b/lib/payments.js
index e0aff192..03daf93e 100644
--- a/lib/payments.js
+++ b/lib/payments.js
@@ -5,7 +5,7 @@ import { v4 } from "uuid";
 import { notify } from "$lib/notifications";
 import { db, g, s, t } from "$lib/db";
 import { l, err, warn } from "$lib/logging";
-import { fail, wait, SATS } from "$lib/utils";
+import { fail, sleep, wait, SATS } from "$lib/utils";
 import { callWebhook } from "$lib/webhooks";
 import got from "got";
 import { spawn } from "child_process";
@@ -61,7 +61,7 @@ export let debit = async ({
 
   if (!amount || amount < 0) fail("Amount must be greater than zero");
 
-  let ourfee = [types.bitcoin, types.lightning].includes(type)
+  let ourfee = [types.bitcoin, types.liquid, types.lightning].includes(type)
     ? Math.round(amount * config.fee)
     : 0;
 
@@ -128,6 +128,9 @@ export let credit = async (hash, amount, memo, ref, type = types.internal) => {
 
   let rate = store.rates[currency];
 
+  if (!rate) await sleep(1000);
+  rate = store.rates[currency];
+
   let equivalentRate =
     invoice.rate * (store.rates[currency] / store.rates[invoice.currency]);
 
@@ -153,11 +156,11 @@ export let credit = async (hash, amount, memo, ref, type = types.internal) => {
     created: Date.now(),
   };
 
-  if (type === types.bitcoin) invoice.pending += amount;
+  if ([types.bitcoin, types.liquid].includes(type)) invoice.pending += amount;
   else invoice.received += amount;
 
   let balance = "balance";
-  if (type === types.bitcoin) {
+  if ([types.bitcoin, types.liquid].includes(type)) {
     let [txid, vout] = ref.split(":").slice(-2);
     p.confirmed = false;
     balance = "pending";
@@ -168,7 +171,7 @@ export let credit = async (hash, amount, memo, ref, type = types.internal) => {
 
   let m = await db.multi();
 
-  if ([types.bitcoin, types.lightning].includes(type))
+  if ([types.bitcoin, types.liquid, types.lightning].includes(type))
     m.incrBy(`credit:${type}:${uid}`, Math.round(amount * config.fee));
 
   m.set(`invoice:${iid}`, JSON.stringify(invoice))