Unverified Commit 1bd31544 authored by Hong Minhee's avatar Hong Minhee
Browse files

Deno KV adapters

parent c1aa2003

.vscode/settings.json

+1 −0
Original line number Diff line number Diff line
@@ -37,6 +37,7 @@ 
    "cfworker",

    "codegen",

    "Deno",

    "denokv",

    "dereferenceable",

    "discoverability",

    "docloader",

CHANGES.md

+7 −1
Original line number Diff line number Diff line
@@ -20,7 +20,7 @@ To be released. 
     -  Added `KvStore` interface.

     -  Added `KvStoreSetOptions` interface.

     -  Added `KvKey` type.

     -  Added `MemoryKvStore` class.

     -  Added `DenoKvStore` class.

     -  `KvCacheParameters.kv` option now accepts a `KvStore` instead of

        `Deno.Kv`.

     -  `KvCacheParameters.prefix` option now accepts a `KvKey` instead of
@@ -39,6 +39,12 @@ To be released. 
     -  Added `InProcessMessageQueue` class.

     -  Added `FederationParameters.queue` option.



 -  Added `@fedify/fedify/x/denokv` module for adapting `Deno.Kv` to `KvStore`

    and `MessageQueue`.  It is only available in Deno runtime.



     -  Added `DenoKvStore` class.

     -  Added `DenoKvMessageQueue` class.



 -  Removed dependency on *jose*.



     -  Added `exportSpki()` function.

deno.json

+1 −0
Original line number Diff line number Diff line
@@ -9,6 +9,7 @@ 
    "./runtime": "./runtime/mod.ts",

    "./vocab": "./vocab/mod.ts",

    "./webfinger": "./webfinger/mod.ts",

    "./x/denokv": "./x/denokv.ts",

    "./x/fresh": "./x/fresh.ts"

  },

  "imports": {

dnt.ts

+2 −1
Original line number Diff line number Diff line
@@ -36,7 +36,8 @@ await build({ 
  },

  outDir: "./npm",

  entryPoints: Object.entries(metadata.exports as Record<string, string>)

    .map(([name, path]) => ({ name, path })),

    .map(([name, path]) => ({ name, path }))

    .filter(({ name }) => !name.startsWith("./x/")),

  importMap: denoJson,

  scriptModule: false,

  shims: {

x/denokv.test.ts

0 → 100644
+77 −0
Original line number Diff line number Diff line 
import { Temporal } from "@js-temporal/polyfill";

import { assertEquals, assertGreater } from "@std/assert";

import { delay } from "@std/async/delay";

import { DenoKvMessageQueue, DenoKvStore } from "./denokv.ts";



Deno.test("DenoKvStore", async (t) => {

  const kv = await Deno.openKv(":memory:");

  const store = new DenoKvStore(kv);



  await t.step("get()", async () => {

    await kv.set(["foo", "bar"], "foobar");

    assertEquals(await store.get(["foo", "bar"]), "foobar");

  });



  await t.step("set()", async () => {

    await store.set(["foo", "baz"], "baz");

    assertEquals((await kv.get<string>(["foo", "baz"])).value, "baz");

  });



  await t.step("delete()", async () => {

    await store.delete(["foo", "baz"]);

    assertEquals((await kv.get<string>(["foo", "baz"])).value, null);

  });



  kv.close();

});



Deno.test("DenoKvMessageQueue", async (t) => {

  const kv = await Deno.openKv(":memory:");

  const mq = new DenoKvMessageQueue(kv);



  const messages: string[] = [];

  mq.listen((message: string) => {

    messages.push(message);

  });



  await t.step("enqueue()", async () => {

    await mq.enqueue("Hello, world!");

  });



  await waitFor(() => messages.length > 0, 15_000);



  await t.step("listen()", () => {

    assertEquals(messages, ["Hello, world!"]);

  });



  let started = 0;

  await t.step("enqueue() with delay", async () => {

    started = Date.now();

    await mq.enqueue(

      "Delayed message",

      { delay: Temporal.Duration.from({ seconds: 3 }) },

    );

  });



  await waitFor(() => messages.length > 1, 15_000);



  await t.step("listen() with delay", () => {

    assertEquals(messages, ["Hello, world!", "Delayed message"]);

    assertGreater(Date.now() - started, 3_000);

  });



  kv.close();

});



async function waitFor(

  predicate: () => boolean,

  timeoutMs: number,

): Promise<void> {

  const started = Date.now();

  while (!predicate()) {

    await delay(500);

    if (Date.now() - started > timeoutMs) {

      throw new Error("Timeout");

    }

  }

}