summaryrefslogtreecommitdiffhomepage
path: root/packages
diff options
context:
space:
mode:
Diffstat (limited to 'packages')
-rw-r--r--packages/opencode/src/effect/cross-spawn-spawner.ts3
-rw-r--r--packages/opencode/src/session/message-v2.ts1
-rw-r--r--packages/opencode/src/tool/bash.ts32
-rw-r--r--packages/opencode/test/session/messages-pagination.test.ts5
4 files changed, 18 insertions, 23 deletions
diff --git a/packages/opencode/src/effect/cross-spawn-spawner.ts b/packages/opencode/src/effect/cross-spawn-spawner.ts
index 30b4dde42..39e50d13d 100644
--- a/packages/opencode/src/effect/cross-spawn-spawner.ts
+++ b/packages/opencode/src/effect/cross-spawn-spawner.ts
@@ -497,5 +497,6 @@ const rt = lazy(() => {
return makeRuntime(ChildProcessSpawner, defaultLayer)
})
-export const runPromiseExit: ReturnType<typeof rt>["runPromiseExit"] = (...args) => rt().runPromiseExit(...(args as [any]))
+export const runPromiseExit: ReturnType<typeof rt>["runPromiseExit"] = (...args) =>
+ rt().runPromiseExit(...(args as [any]))
export const runPromise: ReturnType<typeof rt>["runPromise"] = (...args) => rt().runPromise(...(args as [any]))
diff --git a/packages/opencode/src/session/message-v2.ts b/packages/opencode/src/session/message-v2.ts
index 0bcdb7aeb..eb3951985 100644
--- a/packages/opencode/src/session/message-v2.ts
+++ b/packages/opencode/src/session/message-v2.ts
@@ -900,7 +900,6 @@ export namespace MessageV2 {
}
}
-
export function filterCompacted(msgs: Iterable<MessageV2.WithParts>) {
const result = [] as MessageV2.WithParts[]
const completed = new Set<string>()
diff --git a/packages/opencode/src/tool/bash.ts b/packages/opencode/src/tool/bash.ts
index 119cbadfa..e50f09cc3 100644
--- a/packages/opencode/src/tool/bash.ts
+++ b/packages/opencode/src/tool/bash.ts
@@ -314,7 +314,6 @@ function cmd(shell: string, name: string, command: string, cwd: string, env: Nod
})
}
-
async function run(
input: {
shell: string
@@ -340,23 +339,19 @@ async function run(
const exit = await CrossSpawnSpawner.runPromiseExit((spawner) =>
Effect.gen(function* () {
- const handle = yield* spawner.spawn(
- cmd(input.shell, input.name, input.command, input.cwd, input.env),
- )
+ const handle = yield* spawner.spawn(cmd(input.shell, input.name, input.command, input.cwd, input.env))
yield* Effect.forkScoped(
- Stream.runForEach(
- Stream.decodeText(handle.all),
- (chunk) =>
- Effect.sync(() => {
- output += chunk
- ctx.metadata({
- metadata: {
- output: preview(output),
- description: input.description,
- },
- })
- }),
+ Stream.runForEach(Stream.decodeText(handle.all), (chunk) =>
+ Effect.sync(() => {
+ output += chunk
+ ctx.metadata({
+ metadata: {
+ output: preview(output),
+ description: input.description,
+ },
+ })
+ }),
),
)
@@ -385,10 +380,7 @@ async function run(
}
return exit.kind === "exit" ? exit.code : null
- }).pipe(
- Effect.scoped,
- Effect.orDie,
- ),
+ }).pipe(Effect.scoped, Effect.orDie),
)
let code: number | null = null
diff --git a/packages/opencode/test/session/messages-pagination.test.ts b/packages/opencode/test/session/messages-pagination.test.ts
index ea7a0727c..bb9df6aea 100644
--- a/packages/opencode/test/session/messages-pagination.test.ts
+++ b/packages/opencode/test/session/messages-pagination.test.ts
@@ -722,7 +722,10 @@ describe("MessageV2.filterCompacted", () => {
const u1 = await addUser(session.id, "hello")
await addCompactionPart(session.id, u1)
- const error = new MessageV2.APIError({ message: "boom", isRetryable: true }).toObject() as MessageV2.Assistant["error"]
+ const error = new MessageV2.APIError({
+ message: "boom",
+ isRetryable: true,
+ }).toObject() as MessageV2.Assistant["error"]
await addAssistant(session.id, u1, { summary: true, finish: "end_turn", error })
const u2 = await addUser(session.id, "retry")