1 files changed, 33 insertions, 0 deletions
diff --git a/lib/db.js b/lib/db.js
new file mode 100644
index 00000000..86f8082e
--- /dev/null
+++ b/lib/db.js
@@ -0,0 +1,33 @@
+import config from "$config";
+import { sleep } from "$lib/utils";
+import { createClient } from "redis";
+
+export const db = createClient({ url: config.db });
+await db.connect();
+export default db;
+
+export let g = async k => JSON.parse(await db.get(k));
+export let s = (k, v) => db.set(k, JSON.stringify(v));
+
+let retries = {};
+export let t = async (k, f) => {
+  try {
+    await db.watch(k);
+    await f(await db.get(k), db);
+  } catch (err) {
+    if (!err.message.includes("watch")) throw err;
+
+    let r = retries[k] || 0;
+    retries[k] = r + 1;
+
+    if (r < 10) {
+      await sleep(100);
+      await t(k, f);
+    } else {
+      delete retries[k];
+      throw new Error("unable to obtain lock");
+    }
+  }
+
+  delete retries[k];
+};