fix(delegate-task): route sync prompts by directory

src/tools/delegate-task/sync-prompt-route.test.ts

@@ -0,0 +1,92 @@
+import { describe, expect, mock, test } from "bun:test"
+
+import { unsafeTestValue } from "../../../test-support/unsafe-test-value"
+import type { OpencodeClient } from "./types"
+import { sendSyncPrompt } from "./sync-prompt-sender"
+import {
+  promptSyncWithModelSuggestionRetry,
+  promptWithModelSuggestionRetry,
+} from "../../shared/model-suggestion-retry"
+
+type PromptRetryClient = Parameters<typeof promptWithModelSuggestionRetry>[0]
+type PromptRetryArgs = Parameters<typeof promptWithModelSuggestionRetry>[1]
+type PromptSyncRetryClient = Parameters<typeof promptSyncWithModelSuggestionRetry>[0]
+type PromptSyncRetryArgs = Parameters<typeof promptSyncWithModelSuggestionRetry>[1]
+
+describe("sendSyncPrompt session routing", () => {
+  test("#given a sync child session directory #when sending the prompt #then promptAsync uses that OpenCode directory route", async () => {
+    // given
+    const promptCalls: PromptRetryArgs[] = []
+    const promptWithRetry = mock(async (_client: PromptRetryClient, input: PromptRetryArgs) => {
+      promptCalls.push(input)
+    })
+
+    // when
+    await sendSyncPrompt(
+      unsafeTestValue<OpencodeClient>({ session: {} }),
+      {
+        sessionID: "ses_child",
+        agentToUse: "sisyphus-junior",
+        args: {
+          description: "test task",
+          prompt: "test prompt",
+          run_in_background: false,
+          load_skills: [],
+        },
+        systemContent: undefined,
+        categoryModel: undefined,
+        directory: "/parent/project",
+        toastManager: null,
+        taskId: undefined,
+      },
+      {
+        promptWithModelSuggestionRetry: promptWithRetry,
+        promptSyncWithModelSuggestionRetry: mock(async () => {}),
+      },
+    )
+
+    // then
+    expect(promptCalls).toHaveLength(1)
+    expect(promptCalls[0]?.query).toEqual({ directory: "/parent/project" })
+  })
+
+  test("#given oracle falls back to promptSync #when async prompt returns unexpected EOF #then the sync retry keeps the same directory route", async () => {
+    // given
+    const promptSyncCalls: PromptSyncRetryArgs[] = []
+    const promptWithRetry = mock(async () => {
+      throw new Error("JSON Parse error: Unexpected EOF")
+    })
+    const promptSyncWithRetry = mock(async (_client: PromptSyncRetryClient, input: PromptSyncRetryArgs) => {
+      promptSyncCalls.push(input)
+    })
+
+    // when
+    const result = await sendSyncPrompt(
+      unsafeTestValue<OpencodeClient>({ session: {} }),
+      {
+        sessionID: "ses_child",
+        agentToUse: "oracle",
+        args: {
+          description: "test task",
+          prompt: "test prompt",
+          run_in_background: false,
+          load_skills: [],
+        },
+        systemContent: undefined,
+        categoryModel: undefined,
+        directory: "/parent/project",
+        toastManager: null,
+        taskId: undefined,
+      },
+      {
+        promptWithModelSuggestionRetry: promptWithRetry,
+        promptSyncWithModelSuggestionRetry: promptSyncWithRetry,
+      },
+    )
+
+    // then
+    expect(result).toBeNull()
+    expect(promptSyncCalls).toHaveLength(1)
+    expect(promptSyncCalls[0]?.query).toEqual({ directory: "/parent/project" })
+  })
+})

src/tools/delegate-task/sync-prompt-sender.ts

@@ -6,6 +6,7 @@ import {
   promptSyncWithModelSuggestionRetry,
   promptWithModelSuggestionRetry,
 } from "../../shared/model-suggestion-retry"
+import { routePromptRetry, routePromptSyncRetry } from "../../shared/session-route"
 import { formatDetailedError } from "./error-formatting"
 import { getAgentToolRestrictions } from "../../shared/agent-tool-restrictions"
 import { stripInvisibleAgentCharacters } from "../../shared/agent-display-names"
@@ -59,6 +60,7 @@ export async function sendSyncPrompt(
     args: DelegateTaskArgs
     systemContent: string | undefined
     categoryModel: DelegatedModelConfig | undefined
+    directory: string
     toastManager: { removeTask: (id: string) => void } | null | undefined
     taskId: string | undefined
     sisyphusAgentConfig?: SisyphusAgentConfig
@@ -99,11 +101,12 @@ export async function sendSyncPrompt(
   }
 
   try {
-    await deps.promptWithModelSuggestionRetry(client, promptArgs)
+    const routedPromptArgs = routePromptRetry(promptArgs, input.directory)
+    await deps.promptWithModelSuggestionRetry(client, routedPromptArgs)
   } catch (promptError) {
     if (isOracleAgent(input.agentToUse) && isUnexpectedEofError(promptError)) {
       try {
-        await deps.promptSyncWithModelSuggestionRetry(client, promptArgs)
+        await deps.promptSyncWithModelSuggestionRetry(client, routePromptSyncRetry(promptArgs, input.directory))
         return null
       } catch (oracleRetryError) {
         promptError = oracleRetryError

src/tools/delegate-task/sync-task.ts

@@ -177,6 +177,7 @@ export async function executeSyncTask(
       agentToUse,
       args,
       systemContent,
+      directory: createSessionResult.parentDirectory,
       toastManager,
       taskId,
       sisyphusAgentConfig: executorCtx.sisyphusAgentConfig,