1 files changed, 50 insertions, 0 deletions
diff --git a/packages/core/tests/config/watcher.test.ts b/packages/core/tests/config/watcher.test.ts
new file mode 100644
index 0000000..9388c8a
--- /dev/null
+++ b/packages/core/tests/config/watcher.test.ts
@@ -0,0 +1,50 @@
+import { mkdirSync, rmSync, writeFileSync } from "node:fs";
+import { join } from "node:path";
+import { afterEach, beforeEach, describe, expect, it } from "vitest";
+import { watchDirConfig } from "../../src/config/watcher.js";
+
+const TMP = join("/tmp/opencode", "dispatch-watchdir-test");
+
+beforeEach(() => {
+	mkdirSync(TMP, { recursive: true });
+});
+
+afterEach(() => {
+	rmSync(TMP, { recursive: true, force: true });
+});
+
+function wait(ms: number): Promise<void> {
+	return new Promise((resolve) => setTimeout(resolve, ms));
+}
+
+describe("watchDirConfig", () => {
+	it("fires onChange (debounced) when <dir>/dispatch.toml changes", async () => {
+		let calls = 0;
+		const handle = watchDirConfig(TMP, () => {
+			calls++;
+		});
+		// Let chokidar finish its initial scan before mutating the file.
+		await wait(200);
+
+		writeFileSync(join(TMP, "dispatch.toml"), `[permissions]\nread = "allow"\n`, "utf-8");
+		// 300ms debounce + chokidar latency.
+		await wait(700);
+
+		handle.close();
+		expect(calls).toBeGreaterThanOrEqual(1);
+	});
+
+	it("does not fire after close()", async () => {
+		let calls = 0;
+		const handle = watchDirConfig(TMP, () => {
+			calls++;
+		});
+		await wait(200);
+		handle.close();
+
+		writeFileSync(join(TMP, "dispatch.toml"), `[permissions]\nedit = "deny"\n`, "utf-8");
+		await wait(700);
+
+		expect(calls).toBe(0);
+	});
+});