From 9e7f7bf8e434646c568319fc44969777ab41b621 Mon Sep 17 00:00:00 2001 From: "opencode-agent[bot]" Date: Fri, 8 May 2026 17:46:57 +0000 Subject: [PATCH] chore: generate --- .../src/cli/cmd/run/stream.transport.ts | 63 ++++++++++--------- .../test/cli/run/stream.transport.test.ts | 7 ++- 2 files changed, 38 insertions(+), 32 deletions(-) diff --git a/packages/opencode/src/cli/cmd/run/stream.transport.ts b/packages/opencode/src/cli/cmd/run/stream.transport.ts index c528c3d374..22240ebf56 100644 --- a/packages/opencode/src/cli/cmd/run/stream.transport.ts +++ b/packages/opencode/src/cli/cmd/run/stream.transport.ts @@ -561,37 +561,37 @@ function createLayer(input: StreamInput) { Effect.orElseSucceed(() => []), ) - const bootstrapSubagentHistory = Effect.fn("RunStreamTransport.bootstrapSubagentHistory")( - function* (sessions: string[]) { - yield* Effect.forEach( - sessions, - (sessionID) => - messages(sessionID, SUBAGENT_CALL_BOOTSTRAP_LIMIT).pipe( - Effect.tap((messagesList) => - Effect.sync(() => { - if ( - !bootstrapSubagentCalls({ - data: state.subagent, - sessionID, - messages: messagesList, - thinking: input.thinking, - limits: input.limits(), - }) - ) { - return - } + const bootstrapSubagentHistory = Effect.fn("RunStreamTransport.bootstrapSubagentHistory")(function* ( + sessions: string[], + ) { + yield* Effect.forEach( + sessions, + (sessionID) => + messages(sessionID, SUBAGENT_CALL_BOOTSTRAP_LIMIT).pipe( + Effect.tap((messagesList) => + Effect.sync(() => { + if ( + !bootstrapSubagentCalls({ + data: state.subagent, + sessionID, + messages: messagesList, + thinking: input.thinking, + limits: input.limits(), + }) + ) { + return + } - syncFooter([], undefined, currentSubagentState()) - }), - ), + syncFooter([], undefined, currentSubagentState()) + }), ), - { - concurrency: 4, - discard: true, - }, - ) - }, - ) + ), + { + concurrency: 4, + discard: true, + }, + ) + }) const bootstrap = Effect.fn("RunStreamTransport.bootstrap")(function* () { const [messagesList, children, permissions, questions] = yield* Effect.all( @@ -651,7 +651,10 @@ function createLayer(input: StreamInput) { return } - yield* bootstrapSubagentHistory(sessions).pipe(Effect.forkIn(scope, { startImmediately: true }), Effect.asVoid) + yield* bootstrapSubagentHistory(sessions).pipe( + Effect.forkIn(scope, { startImmediately: true }), + Effect.asVoid, + ) }) const idle = Effect.fn("RunStreamTransport.idle")((fallback: boolean) => diff --git a/packages/opencode/test/cli/run/stream.transport.test.ts b/packages/opencode/test/cli/run/stream.transport.test.ts index 9d832d1e34..3358ae774d 100644 --- a/packages/opencode/test/cli/run/stream.transport.test.ts +++ b/packages/opencode/test/cli/run/stream.transport.test.ts @@ -477,7 +477,8 @@ describe("run stream transport", () => { const boot = await waitFor(() => { const item = ui.events.findLast((event) => event.type === "stream.subagent") const state = item?.type === "stream.subagent" ? item.state : undefined - return state?.tabs.some((tab) => tab.sessionID === "child-1") && state.permissions.some((req) => req.id === "perm-1") + return state?.tabs.some((tab) => tab.sessionID === "child-1") && + state.permissions.some((req) => req.id === "perm-1") ? state : undefined }) @@ -509,7 +510,9 @@ describe("run stream transport", () => { const item = ui.events.findLast((event) => event.type === "stream.subagent") const state = item?.type === "stream.subagent" ? item.state : undefined const detail = state?.details["child-1"] - return detail?.commits.some((commit) => commit.kind === "tool" && commit.tool === "edit" && commit.phase === "start") + return detail?.commits.some( + (commit) => commit.kind === "tool" && commit.tool === "edit" && commit.phase === "start", + ) ? state : undefined })