aboutsummaryrefslogtreecommitdiffstats
path: root/lib/utils.js
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2022-12-28 07:01:06 +0000
committerAdam Soltys <[email protected]>2022-12-28 07:01:06 +0000
commitd45fb3d4b40096aa4f3650c73bad873eea5a885f (patch)
tree40576a091d4923a5ac949d9dc6311ba4116042d6 /lib/utils.js
parent2d2c991645f3b0ac7fb3ad88afdad0bb67c28b74 (diff)
downloadcoinos-server-d45fb3d4b40096aa4f3650c73bad873eea5a885f.tar.gz
coinos-server-d45fb3d4b40096aa4f3650c73bad873eea5a885f.zip
missing imports
Diffstat (limited to 'lib/utils.js')
-rw-r--r--lib/utils.js18
1 files changed, 11 insertions, 7 deletions
diff --git a/lib/utils.js b/lib/utils.js
index 2854fefc..49f95a00 100644
--- a/lib/utils.js
+++ b/lib/utils.js
@@ -1,4 +1,5 @@
import store from "$lib/store";
+import redis from "$lib/redis";
import config from "$config";
import db from "$db";
import sequelize from "@sequelize/core";
@@ -7,9 +8,18 @@ import { payments as bcPayments, networks as bcNetworks } from "bitcoinjs-lib";
import { payments as lqPayments, networks as lqNetworks } from "liquidjs-lib";
import lnd from "$lib/lnd";
import ln from "$lib/ln";
+import { coinos } from "$lib/nostr";
const { Op } = sequelize;
+export const sleep = n => new Promise(r => setTimeout(r, n));
+export const wait = async (f, s = 300, n = 1000) => {
+ let i = 0;
+ while (!(await f()) && i < s) (await sleep(n)) && i++;
+ if (i >= s) throw new Error("timeout");
+ return f();
+};
+
export const requirePin = async ({ body, user }) => {
if (!user || (user.pin && user.pin !== body.pin))
throw new Error("Invalid pin");
@@ -47,6 +57,7 @@ export const getUser = async (username, transaction) => {
500
);
+ await wait(() => !!coinos, 100, 10);
coinos.subscribe(`${pubkey}:follows`, {
limit: 1,
kinds: [3],
@@ -193,10 +204,3 @@ export const derivePayRequest = async ({ amount, memo, tip }) => {
).bolt11;
};
-export const sleep = n => new Promise(r => setTimeout(r, n));
-export const wait = async (f, s = 300, n = 1000) => {
- let i = 0;
- while (!(await f()) && i < s) (await sleep(n)) && i++;
- if (i >= s) throw new Error("timeout");
- return f();
-};