ecash

1 files changed, 95 insertions, 0 deletions

diff --git a/src/lib/parse.js b/src/lib/parse.js
new file mode 100644
index 00000000..fa4cb002
--- /dev/null
+++ b/src/lib/parse.js
@@ -0,0 +1,95 @@
+import { auth, get, isLiquid, post } from "$lib/utils";
+import bip21 from "bip21";
+import { validate } from "bitcoin-address-validation";
+import { PUBLIC_DOMAIN } from "$env/static/public";
+import { redirect } from "@sveltejs/kit";
+
+export default async (t, host, cookies) => {
+  if (!t) return;
+
+  if (t.startsWith("http")) redirect(307, t);
+  if (t.startsWith(host)) redirect(307, `http://${t}`);
+
+  let amount, id, user;
+
+  t = t.trim();
+  t.toLowerCase().startsWith("bitcoin:") &&
+    ({
+      address: t,
+      options: { amount },
+    } = bip21.decode(t));
+
+  if (t.startsWith("lightning:")) t = t.replace("lightning:", "");
+  if (t.endsWith(`@${PUBLIC_DOMAIN}`)) t = t.split("@")[0];
+  if (t.includes("@") && t.includes(".")) {
+    try {
+      t = await get(`/encode?address=${t}`);
+    } catch (e) {}
+  }
+
+  if (t.includes("/fund")) redirect(307, t.substring(t.indexOf("/fund")));
+
+  // lightning
+  if (t.toLowerCase().startsWith("lightning:"))
+    t = t.toLowerCase().replace("lightning:", "");
+  if (t.toLowerCase().startsWith("lnurl")) redirect(307, `/ln/${t}`);
+  if (t.includes(":")) t = t.split(":")[1];
+
+  if (t.toLowerCase().startsWith("ln")) {
+    try {
+      ({ id } = await get(`/invoice/${t}`));
+    } catch (e) {
+      redirect(307, `/send/lightning/${t}`);
+    }
+  }
+
+  // bitcoin
+  if (validate(t) || isLiquid(t)) {
+    try {
+      ({ id, user } = await get(`/invoice/${t}`));
+    } catch (e) {
+      let r = `/send/bitcoin/${t}`;
+      if (amount) r += "/" + amount;
+      redirect(307, r);
+    }
+
+    if (user) redirect(307, `/pay/${user.username}`);
+    else if (id) redirect(307, `/send/${id}`);
+  }
+
+  let claimed;
+  if (t.toLowerCase().startsWith("cashu")) {
+    try {
+      claimed = await post(`/claim`, { token: t }, auth(cookies));
+      claimed = { ok: true };
+    } catch (e) {
+      return e.message;
+    }
+    if (claimed.ok) {
+      redirect(307, `/${cookies.get("username")}/payments`);
+    }
+  }
+
+  // user
+  try {
+    user = await get(`/users/${t.split("/")[0]}`);
+    if (user.anon) user = null;
+  } catch (e) {}
+
+  if (user) redirect(307, `/pay/${t}`);
+
+  let fund;
+  try {
+    fund = await get(`/fund/${t}`);
+  } catch (e) {}
+
+  if (fund) redirect(307, `/send/fund/${t}`);
+
+  // invoice
+  let invoice;
+  try {
+    invoice = await get(`/invoice/${t}`);
+  } catch (e) {}
+
+  if (invoice) redirect(307, `/send/invoice/${invoice.id}`);
+};