chore: add utils folder

Author: ynwd

core/map/mod.ts

@@ -1,4 +1,4 @@
-import { kv } from "../../utils/db.ts";
+import { kv } from "../utils/kv.ts";
 import { createTaskQueue } from "../../utils/queue.ts";
 
 type StoreOptions = {

core/utils/kv.ts

@@ -0,0 +1,39 @@
+/**
+ * Inspired by Deno Saaskit
+ * See: https://github.com/denoland/saaskit/blob/main/utils/db.ts
+ */
+const DENO_KV_PATH_KEY = "DENO_KV_PATH";
+let path = undefined;
+if (
+  /**
+   * Resolves to the current status of a permission.
+   */
+  (await Deno.permissions.query({ name: "env", variable: DENO_KV_PATH_KEY }))
+    .state === "granted"
+) {
+  path = Deno.env.get(DENO_KV_PATH_KEY);
+}
+
+/**
+ * Create Deno.Kv Singleton
+ */
+let instance: Deno.Kv;
+async function getKvInstance(path?: string): Promise<Deno.Kv> {
+  if (!instance) {
+    instance = await Deno.openKv(path);
+  }
+  return instance;
+}
+
+export const kv = await getKvInstance(path);
+
+export async function collectValues<T>(iter: Deno.KvListIterator<T>) {
+  return await Array.fromAsync(iter, ({ value }) => value);
+}
+
+export async function reset() {
+  const iter = kv.list({ prefix: [] });
+  const promises = [];
+  for await (const res of iter) promises.push(kv.delete(res.key));
+  await Promise.all(promises);
+}

core/utils/queue.test.ts

@@ -0,0 +1,21 @@
+import { assertEquals } from "../../core/server/deps.ts";
+import { createTaskQueue } from "../../utils/queue.ts";
+
+Deno.test("Queue: create message", async () => {
+  const q = createTaskQueue();
+  const x = await q.process(() => "x");
+  const y = await q.process(() => 1);
+  const z = await q.process(() => true);
+  const o = await q.process(() => ({}));
+  const v = await q.process(() => {});
+  const p = await q.process(async () => {
+    const r = new Promise<string>((resolve) => resolve("hello"));
+    return await r;
+  });
+  assertEquals(x, "x");
+  assertEquals(y, 1);
+  assertEquals(z, true);
+  assertEquals(o, {});
+  assertEquals(v, undefined);
+  assertEquals(p, "hello");
+});

core/utils/queue.ts

@@ -0,0 +1,34 @@
+export function createTaskQueue() {
+  // deno-lint-ignore no-explicit-any
+  const array: any = [];
+
+  let isExecuting = false;
+  async function exec() {
+    while (array.length > 0) {
+      const { fn, args, resolve } = array.shift();
+      try {
+        const result = await fn(...args);
+        resolve(result);
+      } catch (error) {
+        console.error("Error executing function:", error);
+      }
+    }
+    isExecuting = false;
+  }
+
+  // deno-lint-ignore no-explicit-any
+  function process<T extends any[], R>(
+    fn: (...args: T) => Promise<R> | R,
+    ...args: T
+  ): Promise<R> {
+    return new Promise((resolve) => {
+      array.push({ fn, args, resolve });
+      if (!isExecuting) {
+        isExecuting = true;
+        exec();
+      }
+    });
+  }
+
+  return { process };
+}