typescript

1 files changed, 135 insertions, 0 deletions

diff --git a/routes/lnurl.ts b/routes/lnurl.ts
new file mode 100644
index 00000000..462127ac
--- /dev/null
+++ b/routes/lnurl.ts
@@ -0,0 +1,135 @@
+import migrate from "$lib/migrate";
+import { g, s } from "$lib/db";
+import { l, err, warn } from "$lib/logging";
+import { bail, getUser, fail } from "$lib/utils";
+import { v4 } from "uuid";
+import got from "got";
+import { generate } from "$lib/invoices";
+import { bech32 } from "bech32";
+import { fields, pick } from "$lib/utils";
+import { types } from "$lib/payments";
+import crypto from "crypto";
+import { COINOS_PUBKEY } from "$lib/nostr";
+
+import config from "$config";
+let { admin } = config;
+
+let { URL } = process.env;
+let host = URL.split("/").at(-1);
+
+export default {
+  async encode({ query: { address } }, res) {
+    let [name, domain] = address.split("@");
+    let url = `https://${domain}/.well-known/lnurlp/${name}`;
+
+    try {
+      let r = await got(url).json();
+      if (r.tag !== "payRequest") fail("not an ln address");
+    } catch (e) {
+      let m = `failed to lookup lightning address ${address}`;
+      warn(m);
+      return bail(res, m);
+    }
+
+    let enc = bech32.encode("lnurl", bech32.toWords(Buffer.from(url)), 20000);
+    res.send(enc);
+  },
+
+  async decode({ query: { text } }, res) {
+    try {
+      let url = Buffer.from(
+        bech32.fromWords(bech32.decode(text, 20000).words),
+      ).toString();
+
+      res.send(await got(url).json());
+    } catch (e) {
+      bail(res, e.message);
+    }
+  },
+
+  async lnurlp(
+    {
+      params: { username },
+      query: { minSendable = 1000, maxSendable = 100000000000 },
+    },
+    res,
+  ) {
+    try {
+      let { id: uid } = await getUser(username);
+
+      let metadata = JSON.stringify([
+        ["text/plain", `Paying ${username}@${host}`],
+        ["text/identifier", `${username}@${host}`],
+      ]);
+
+      let id = v4();
+      await s(`lnurl:${id}`, uid);
+
+      res.send({
+        allowsNostr: true,
+        minSendable,
+        maxSendable,
+        metadata,
+        nostrPubkey: COINOS_PUBKEY,
+        callback: `${URL}/api/lnurl/${id}`,
+        tag: "payRequest",
+      });
+    } catch (e) {
+      warn("problem generating lnurlp request", username, e.message);
+      bail(res, e.message);
+    }
+  },
+
+  async lnurlw({ params: { k1, pr } }, res) {},
+
+  async lnurl({ params: { id }, query: { amount, nostr } }, res) {
+    try {
+      let uid = await g(`lnurl:${id}`);
+      let user = await getUser(uid);
+      if (!user) fail("user not found");
+      let { username } = user;
+      username = username.replace(/\s/g, "").toLowerCase();
+
+      let memo = `Paying ${username}@${host}`;
+      let metadata = JSON.stringify([
+        ["text/plain", memo],
+        ["text/identifier", `${username}@${host}`],
+      ]);
+
+      if (nostr) {
+        try {
+          let event = JSON.parse(decodeURIComponent(nostr));
+          // TODO: validate the event
+          await s(`zap:${id}`, event);
+          metadata = nostr;
+        } catch (e) {
+          err("problem handling zap", e.message);
+        }
+      }
+
+      let { id: iid, text: pr } = await generate({
+        invoice: {
+          amount: Math.round(amount / 1000),
+          memo: metadata,
+          type: types.lightning,
+        },
+        user,
+      });
+
+      res.send({ pr, routes: [], verify: `${URL}/api/lnurl/verify/${iid}` });
+    } catch (e) {
+      bail(res, e.message);
+    }
+  },
+
+  async verify({ params: { id } }, res) {
+    let inv = await g(`invoice:${id}`);
+
+    if (!inv) return res.send({ status: "ERROR", reason: "Not found" });
+
+    let { received, amount, preimage } = inv;
+    let settled = received >= amount;
+
+    res.send({ status: "OK", settled, preimage });
+  },
+};