puter/paseo
1
0
Fork 0
mirror of https://github.com/getpaseo/paseo.git synced 2026-07-29 12:01:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(lint): reduce max-depth in opencode-agent foreground loop

Browse Source
This commit is contained in:
Mohamed Boudra
2026-04-24 02:10:41 +07:00
parent 5f6ebe2065
commit d78dff3572
1 changed files with 22 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
packages/server/src/server/agent/providers/opencode-agent.ts
View File

@@ -241,6 +241,25 @@ function normalizeTurnFailureError(error: unknown): string {
return normalized.length > 0 ? normalized : "Unknown error";
}
type TerminalTurnEvent = Extract<
AgentStreamEvent,
{ type: "turn_completed" | "turn_failed" | "turn_canceled" }
>;
function toTerminalTurnEvent(event: AgentStreamEvent): TerminalTurnEvent | null {
if (event.type === "turn_failed") {
return {
type: "turn_failed",
provider: "opencode",
error: normalizeTurnFailureError(event.error),
};
}
if (event.type === "turn_completed" || event.type === "turn_canceled") {
return event;
}
return null;
}
function isOpenCodeNotFoundError(error: unknown): boolean {
return (
typeof error === "object" &&
@@ -2132,23 +2151,9 @@ class OpenCodeAgentSession implements AgentSession {
if (e.type === "timeline" && e.item.type === "tool_call") {
this.trackToolCall(e.item);
}
if (
e.type === "turn_completed" ||
e.type === "turn_failed" ||
e.type === "turn_canceled"
) {
if (e.type === "turn_failed") {
this.finishForegroundTurn(
{
type: "turn_failed",
provider: "opencode",
error: normalizeTurnFailureError(e.error),
},
turnId,
);
} else {
this.finishForegroundTurn(e, turnId);
}
const terminalEvent = toTerminalTurnEvent(e);
if (terminalEvent) {
this.finishForegroundTurn(terminalEvent, turnId);
return;
}
this.notifySubscribers(e, turnId);