Add a 10ms delay after events.

Trustroots · Aug 10, 2024 · 8fde5ac · 8fde5ac
1 parent 32b7d5e
commit 8fde5ac
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 1 deletion.
diff --git a/common/constants.ts b/common/constants.ts
@@ -22,7 +22,9 @@ export const MINIMUM_TRUSTROOTS_USERNAME_LENGTH = 3;
 export const WAIT_FOR_KIND_ZERO_TIMEOUT_SECONDS = 5;
 
 export const DEV_PUBKEY =
-  "80789235a71a388074abfa5c482e270456d2357425266270f82071cf2b1de74a" as const
+  "80789235a71a388074abfa5c482e270456d2357425266270f82071cf2b1de74a" as const;
 
 export const HITCHMAPS_AUTHOR_PUBLIC_KEY =
   "53055ee011e96a00a705b38253b9cbc6614ccbd37df4dad42ec69bbe608c4209" as const;
+
+export const DELAY_AFTER_PROCESSING_EVENT_MS = 10;
diff --git a/deno.lock b/deno.lock
diff --git a/deps.ts b/deps.ts
@@ -7,3 +7,4 @@ export const newQueue = newQueueImport;
 // import * as logImport from "jsr:@std/[email protected]";
 // export const log = logImport.getLogger("nostroots-server");
 export * as logPackage from "jsr:@std/[email protected]";
+export * as async from "jsr:@std/[email protected]";
diff --git a/validation/repost.ts b/validation/repost.ts
@@ -13,6 +13,8 @@ import { validateEvent } from "./validate.ts";
 import { newQueue } from "../deps.ts";
 import { nostrTools } from "../deps.ts";
 import { log } from "../log.ts";
+import { async } from "../deps.ts";
+import { DELAY_AFTER_PROCESSING_EVENT_MS } from "../common/constants.ts";
 
 async function getRelayPool(isDev: true | undefined) {
   const relays = isDev ? DEV_RELAYS : DEFAULT_RELAYS;
@@ -120,6 +122,8 @@ function processEventFactoryFactory(
       }
       const repostedEvent = await generateRepostedEvent(event, privateKey);
       publishEvent(relayPool, repostedEvent);
+
+      await async.delay(DELAY_AFTER_PROCESSING_EVENT_MS);
     };
   };
 }