typescript

1 files changed, 127 insertions, 0 deletions

diff --git a/routes/ecash.ts b/routes/ecash.ts
new file mode 100644
index 00000000..8c2684b1
--- /dev/null
+++ b/routes/ecash.ts
@@ -0,0 +1,127 @@
+import { g, s, db } from "$lib/db";
+import { claim, mint, check } from "$lib/ecash";
+import { bail } from "$lib/utils";
+import { debit, credit, types } from "$lib/payments";
+import { v4 } from "uuid";
+import { l, err, warn } from "$lib/logging";
+import { emit } from "$lib/sockets";
+import store from "$lib/store";
+
+let { ecash: type } = types;
+
+export default {
+  async save({ body: { token } }, res) {
+    try {
+      let id = v4();
+      await s(`cash:${id}`, token);
+      res.send({ id });
+    } catch (e) {
+      err(e.message);
+      bail(res, e.message);
+    }
+  },
+
+  async get({ params: { id } }, res) {
+    try {
+      let token = await g(`cash:${id}`);
+      let status = await check(token);
+      res.send({ token, status });
+    } catch (e) {
+      err(e.message);
+      bail(res, e.message);
+    }
+  },
+
+  async claim({ body: { token }, user }, res) {
+    try {
+      let amount = await claim(token);
+
+      let memo;
+      let hash = v4();
+      let { currency, id: uid } = user;
+      let rates = await g("rates");
+      await s(`invoice:${hash}`, {
+        currency,
+        id: hash,
+        hash,
+        rate: rates[currency],
+        uid,
+        received: 0,
+      });
+
+      await credit(hash, amount, memo, user.id, type);
+
+      res.send({ ok: true });
+    } catch (e) {
+      err(e.message);
+      bail(res, e.message);
+    }
+  },
+
+  async mint({ body: { amount }, user }, res) {
+    try {
+      let id = v4();
+      let hash = v4();
+
+      let p = await debit({ hash, amount, user, type });
+      let token = await mint(amount);
+      p.memo = token;
+      await s(`payment:${p.id}`, p);
+      s(`cash:${id}`, token);
+
+      res.send({ id });
+    } catch (e) {
+      err(e.message);
+      bail(res, e.message);
+    }
+  },
+
+  async melt({ body: { amount, bolt11: hash, preimage }, user }, res) {
+    try {
+      amount = Math.round(amount / 1000);
+      let ref = preimage;
+      let { lightning: type } = types;
+      if (user.username !== "mint") fail("unauthorized");
+      let { id: uid, currency, username } = user;
+      let ourfee = await db.debit(
+        `balance:${uid}`,
+        `credit:${type}:${uid}`,
+        amount || 0,
+        0,
+        0,
+        0,
+      );
+
+      let rates = await g("rates");
+      let rate = rates[currency];
+
+      if (ourfee.err) fail(ourfee.err);
+
+      let id = v4();
+      let p = {
+        id,
+        amount: -amount,
+        hash,
+        ourfee,
+        uid,
+        confirmed: true,
+        rate,
+        currency,
+        type,
+        ref,
+        created: Date.now(),
+      };
+
+      await s(`payment:${hash}`, id);
+      await s(`payment:${id}`, p);
+      await db.lPush(`${uid}:payments`, id);
+
+      l(user.username, "sent", type, amount);
+      emit(user.id, "payment", p);
+
+      res.send(p);
+    } catch (e) {
+      bail(res, e.message);
+    }
+  },
+};