Reset smoke harness idempotence state

test/smoke/harness/backdoor.ts

@@ -1,5 +1,6 @@
 import type { Federation } from "@fedify/fedify/federation";
 import { Create, Follow, Note, Undo } from "@fedify/vocab";
+import { resetFederationTestState } from "./federation.ts";
 import { store } from "./store.ts";
 
 function json(data: unknown, status = 200): Response {
@@ -80,6 +81,7 @@ export async function handleBackdoor(
   if (url.pathname === "/_test/reset" && request.method === "POST") {
     store.clear();
     recipientCache.clear();
+    await resetFederationTestState();
     return json({ ok: true });
   }
 

test/smoke/harness/federation.ts

@@ -7,14 +7,21 @@ const ORIGIN = Deno.env.get("HARNESS_ORIGIN") ??
   "http://fedify-harness:3001";
 
 const rsaKeyPair = await generateCryptoKeyPair("RSASSA-PKCS1-v1_5");
+const kv = new MemoryKvStore();
 
 const federation = createFederation<void>({
-  kv: new MemoryKvStore(),
+  kv,
   origin: ORIGIN,
   allowPrivateAddress: true,
   skipSignatureVerification: !Deno.env.get("STRICT_MODE"),
 });
 
+export async function resetFederationTestState(): Promise<void> {
+  for await (const entry of kv.list()) {
+    await kv.delete(entry.key);
+  }
+}
+
 federation
   .setActorDispatcher("/users/{identifier}", async (ctx, identifier) => {
     if (identifier !== "testuser") return null;