From f3282182f4cd9035a57f099c34b235d6509010b1 Mon Sep 17 00:00:00 2001
From: Vincent Koc <vincentkoc@ieee.org>
Date: Wed, 11 Mar 2026 19:50:39 -0400
Subject: [PATCH] Tests: cover shared inbound dedupe state

---
 src/auto-reply/reply/inbound-dedupe.test.ts | 43 +++++++++++++++++++++
 1 file changed, 43 insertions(+)
 create mode 100644 src/auto-reply/reply/inbound-dedupe.test.ts

diff --git a/src/auto-reply/reply/inbound-dedupe.test.ts b/src/auto-reply/reply/inbound-dedupe.test.ts
new file mode 100644
index 00000000000..c71aeb598dd
--- /dev/null
+++ b/src/auto-reply/reply/inbound-dedupe.test.ts
@@ -0,0 +1,43 @@
+import { afterEach, describe, expect, it } from "vitest";
+import { importFreshModule } from "../../../test/helpers/import-fresh.js";
+import type { MsgContext } from "../templating.js";
+import { resetInboundDedupe } from "./inbound-dedupe.js";
+
+const sharedInboundContext: MsgContext = {
+  Provider: "discord",
+  Surface: "discord",
+  From: "discord:user-1",
+  To: "channel:c1",
+  OriginatingChannel: "discord",
+  OriginatingTo: "channel:c1",
+  SessionKey: "agent:main:discord:channel:c1",
+  MessageSid: "msg-1",
+};
+
+describe("inbound dedupe", () => {
+  afterEach(() => {
+    resetInboundDedupe();
+  });
+
+  it("shares dedupe state across distinct module instances", async () => {
+    const inboundA = await importFreshModule<typeof import("./inbound-dedupe.js")>(
+      import.meta.url,
+      "./inbound-dedupe.js?scope=shared-a",
+    );
+    const inboundB = await importFreshModule<typeof import("./inbound-dedupe.js")>(
+      import.meta.url,
+      "./inbound-dedupe.js?scope=shared-b",
+    );
+
+    inboundA.resetInboundDedupe();
+    inboundB.resetInboundDedupe();
+
+    try {
+      expect(inboundA.shouldSkipDuplicateInbound(sharedInboundContext)).toBe(false);
+      expect(inboundB.shouldSkipDuplicateInbound(sharedInboundContext)).toBe(true);
+    } finally {
+      inboundA.resetInboundDedupe();
+      inboundB.resetInboundDedupe();
+    }
+  });
+});