diff --git a/packages/opencode/src/acp-next/service.ts b/packages/opencode/src/acp-next/service.ts index 96d0c005d1..e1b7d7a2d6 100644 --- a/packages/opencode/src/acp-next/service.ts +++ b/packages/opencode/src/acp-next/service.ts @@ -39,7 +39,10 @@ export type Interface = { export class Service extends Context.Service()("@opencode/ACPNext/Service") {} -export function make(input: { sdk: OpencodeClient; connection?: Pick }): Interface { +export function make(input: { + sdk: OpencodeClient + connection?: Pick +}): Interface { const sessions = new Map() const directories = new Map>() const registeredMcp = new Map>() @@ -401,7 +404,10 @@ function registerMcpServers( { throwOnError: true }, ), "mcp", - ).pipe(Effect.tap(() => Effect.sync(() => current.add(server.name))), Effect.ignore), + ).pipe( + Effect.tap(() => Effect.sync(() => current.add(server.name))), + Effect.ignore, + ), ), { concurrency: "unbounded" }, ).pipe(Effect.asVoid) diff --git a/packages/opencode/test/acp-next/service-session.test.ts b/packages/opencode/test/acp-next/service-session.test.ts index 44a5acb1f3..8b13203c8b 100644 --- a/packages/opencode/test/acp-next/service-session.test.ts +++ b/packages/opencode/test/acp-next/service-session.test.ts @@ -215,7 +215,6 @@ describe("ACP next service sessions", () => { expect(result.configOptions?.find((option) => option.id === "mode")?.currentValue).toBe("plan") }) - it("maps provider auth failures to auth-required request errors", async () => { const service = ACPNextService.make({ sdk: { @@ -244,15 +243,15 @@ describe("ACP next service sessions", () => { it("does not cache failed directory snapshots", async () => { let providersCalls = 0 const sdk = { - config: { - providers: () => { + config: { + providers: () => { providersCalls++ if (providersCalls === 1) { return Promise.reject({ name: "ProviderAuthError", data: { providerID: "test" } }) } return Promise.resolve({ data: { providers: [provider], default: { test: modelID } } }) - }, - get: () => Promise.resolve({ data: {} }), + }, + get: () => Promise.resolve({ data: {} }), }, app: { agents: () => Promise.resolve({ data: [{ name: "build", mode: "primary", permission: [], options: {} }] }), diff --git a/packages/opencode/test/cli/acp-next/acp-next-process.test.ts b/packages/opencode/test/cli/acp-next/acp-next-process.test.ts index 8f9e148118..426f8225bf 100644 --- a/packages/opencode/test/cli/acp-next/acp-next-process.test.ts +++ b/packages/opencode/test/cli/acp-next/acp-next-process.test.ts @@ -69,17 +69,14 @@ describe("opencode acp-next (subprocess)", () => { ) yield* acp.request("initialize", { protocolVersion: 1 }) - const session = expectOk( - yield* acp.request("session/new", { cwd: home, mcpServers: [] }), - ) + const session = expectOk(yield* acp.request("session/new", { cwd: home, mcpServers: [] })) expect(typeof session.sessionId).toBe("string") expect(selectConfigOption(session.configOptions, "model")?.category).toBe("model") const update = yield* acp.waitForNotification( "session/update", (params) => - params.sessionId === session.sessionId && - params.update.sessionUpdate === "available_commands_update", + params.sessionId === session.sessionId && params.update.sessionUpdate === "available_commands_update", ) expect(update.params?.sessionId).toBe(session.sessionId)