test(release): clear beta validation blockers

vincentkoc · vincentkoc · commit 4b55a0e04d41 · 2026-06-09T01:02:23.000+02:00
diff --git a/extensions/codex/src/app-server/native-subagent-monitor.test.ts b/extensions/codex/src/app-server/native-subagent-monitor.test.ts
@@ -380,7 +380,7 @@ describe("CodexNativeSubagentMonitor", () => {
       const runtime = createRuntime();
       const monitor = new CodexNativeSubagentMonitor(client, runtime, {
         codexHome,
-        transcriptPollDelaysMs: [10],
+        transcriptPollDelaysMs: [10, 1],
       });
       monitor.registerParent({
         parentThreadId: "parent-thread",
@@ -400,7 +400,11 @@ describe("CodexNativeSubagentMonitor", () => {
 
       expect(runtime.deliverAgentHarnessTaskCompletion).not.toHaveBeenCalled();
 
-      await vi.advanceTimersByTimeAsync(20);
+      await vi.advanceTimersByTimeAsync(10);
+      expect(runtime.deliverAgentHarnessTaskCompletion).not.toHaveBeenCalled();
+
+      await vi.advanceTimersByTimeAsync(1);
+      await Promise.resolve();
 
       expect(runtime.deliverAgentHarnessTaskCompletion).toHaveBeenCalledWith(
         expect.objectContaining({
diff --git a/src/agents/acp-spawn.test.ts b/src/agents/acp-spawn.test.ts
@@ -1676,7 +1676,7 @@ describe("spawnAcpDirect", () => {
             channel: "matrix",
             accountId: input.conversation.accountId,
             conversationId: "child-thread",
-            parentConversationId: input.conversation.parentConversationId ?? "!room:example",
+            parentConversationId: input.conversation.parentConversationId ?? "!room:example.org",
           },
           metadata: {
             boundBy:
@@ -1695,10 +1695,11 @@ describe("spawnAcpDirect", () => {
         thread: true,
       },
       {
-        agentSessionKey: "agent:main:matrix:channel:!room:example",
+        agentSessionKey: "agent:main:matrix:channel:!room:example.org",
         agentChannel: "matrix",
         agentAccountId: "default",
-        agentTo: "channel:!room:example",
+        agentTo: "room:!room:example.org",
+        agentGroupId: "!room:example.org",
       },
     );
     expect(result.status, JSON.stringify(result)).toBe("accepted");
@@ -1707,13 +1708,13 @@ describe("spawnAcpDirect", () => {
       conversation: {
         channel: "matrix",
         accountId: "default",
-        conversationId: "!room:example",
+        conversationId: "!room:example.org",
       },
     });
     expectAgentGatewayCall({
       deliver: true,
       channel: "matrix",
-      to: "room:!room:example",
+      to: "room:!room:example.org",
       threadId: "child-thread",
     });
   });
diff --git a/src/commands/tasks.test.ts b/src/commands/tasks.test.ts
@@ -7,6 +7,7 @@ import { resolveSqliteSessionStoreDatabasePath } from "../config/sessions/store-
 import { loadSessionStore, saveSessionStore } from "../config/sessions/store.js";
 import { saveCronStore } from "../cron/store.js";
 import type { RuntimeEnv } from "../runtime.js";
+import { closeOpenClawAgentDatabasesForTest } from "../state/openclaw-agent-db.js";
 import { resetDetachedTaskLifecycleRuntimeForTests } from "../tasks/detached-task-runtime.js";
 import {
   createManagedTaskFlow as createManagedTaskFlowOrNull,
@@ -67,6 +68,7 @@ async function writeTaskSessionStore(
 ) {
   await fs.mkdir(path.dirname(storePath), { recursive: true });
   await saveSessionStore(storePath, store as never, { skipMaintenance: true });
+  closeOpenClawAgentDatabasesForTest();
 }
 
 function readTaskSessionStore(storePath: string): Record<string, unknown> {
@@ -94,6 +96,7 @@ async function withTaskCommandStateDir(
       resetTaskRegistryDeliveryRuntimeForTests();
       resetTaskRegistryForTests({ persist: false });
       resetTaskFlowRegistryForTests({ persist: false });
+      closeOpenClawAgentDatabasesForTest();
       try {
         await run(state);
       } finally {
@@ -103,6 +106,7 @@ async function withTaskCommandStateDir(
         resetTaskRegistryDeliveryRuntimeForTests();
         resetTaskRegistryForTests({ persist: false });
         resetTaskFlowRegistryForTests({ persist: false });
+        closeOpenClawAgentDatabasesForTest();
       }
     },
   );
@@ -121,6 +125,7 @@ describe("tasks commands", () => {
     resetTaskRegistryDeliveryRuntimeForTests();
     resetTaskRegistryForTests({ persist: false });
     resetTaskFlowRegistryForTests({ persist: false });
+    closeOpenClawAgentDatabasesForTest();
   });
 
   it("keeps audit JSON stable and sorts combined findings before limiting", async () => {
