Compare commits

...

1 Commits

Author SHA1 Message Date
Kit Langton a83e989ffa feat: unwrap session namespaces to flat exports + barrel 2026-04-15 23:14:55 -04:00
54 changed files with 5025 additions and 5039 deletions
+2 -2
View File
@@ -42,9 +42,9 @@ import { ModelID, ProviderID } from "../provider/schema"
import { Agent as AgentModule } from "../agent/agent" import { Agent as AgentModule } from "../agent/agent"
import { AppRuntime } from "@/effect/app-runtime" import { AppRuntime } from "@/effect/app-runtime"
import { Installation } from "@/installation" import { Installation } from "@/installation"
import { MessageV2 } from "@/session/message-v2" import { MessageV2 } from "@/session"
import { Config } from "@/config" import { Config } from "@/config"
import { Todo } from "@/session/todo" import { Todo } from "@/session"
import { z } from "zod" import { z } from "zod"
import { LoadAPIKeyError } from "ai" import { LoadAPIKeyError } from "ai"
import type { AssistantMessage, Event, OpencodeClient, SessionMessageResponse, ToolPart } from "@opencode-ai/sdk/v2" import type { AssistantMessage, Event, OpencodeClient, SessionMessageResponse, ToolPart } from "@opencode-ai/sdk/v2"
+1 -1
View File
@@ -4,7 +4,7 @@ import { Effect } from "effect"
import { Agent } from "../../../agent/agent" import { Agent } from "../../../agent/agent"
import { Provider } from "../../../provider" import { Provider } from "../../../provider"
import { Session } from "../../../session" import { Session } from "../../../session"
import type { MessageV2 } from "../../../session/message-v2" import type { MessageV2 } from "../../../session"
import { MessageID, PartID } from "../../../session/schema" import { MessageID, PartID } from "../../../session/schema"
import { ToolRegistry } from "../../../tool/registry" import { ToolRegistry } from "../../../tool/registry"
import { Instance } from "../../../project/instance" import { Instance } from "../../../project/instance"
+1 -1
View File
@@ -1,6 +1,6 @@
import type { Argv } from "yargs" import type { Argv } from "yargs"
import { Session } from "../../session" import { Session } from "../../session"
import { MessageV2 } from "../../session/message-v2" import { MessageV2 } from "../../session"
import { SessionID } from "../../session/schema" import { SessionID } from "../../session/schema"
import { cmd } from "./cmd" import { cmd } from "./cmd"
import { bootstrap } from "../bootstrap" import { bootstrap } from "../bootstrap"
+2 -2
View File
@@ -27,8 +27,8 @@ import type { SessionID } from "../../session/schema"
import { MessageID, PartID } from "../../session/schema" import { MessageID, PartID } from "../../session/schema"
import { Provider } from "../../provider" import { Provider } from "../../provider"
import { Bus } from "../../bus" import { Bus } from "../../bus"
import { MessageV2 } from "../../session/message-v2" import { MessageV2 } from "../../session"
import { SessionPrompt } from "@/session/prompt" import { SessionPrompt } from "@/session"
import { AppRuntime } from "@/effect/app-runtime" import { AppRuntime } from "@/effect/app-runtime"
import { Git } from "@/git" import { Git } from "@/git"
import { setTimeout as sleep } from "node:timers/promises" import { setTimeout as sleep } from "node:timers/promises"
+1 -1
View File
@@ -1,7 +1,7 @@
import type { Argv } from "yargs" import type { Argv } from "yargs"
import type { Session as SDKSession, Message, Part } from "@opencode-ai/sdk/v2" import type { Session as SDKSession, Message, Part } from "@opencode-ai/sdk/v2"
import { Session } from "../../session" import { Session } from "../../session"
import { MessageV2 } from "../../session/message-v2" import { MessageV2 } from "../../session"
import { cmd } from "./cmd" import { cmd } from "./cmd"
import { bootstrap } from "../bootstrap" import { bootstrap } from "../bootstrap"
import { Database } from "../../storage/db" import { Database } from "../../storage/db"
@@ -85,7 +85,7 @@ import { useTuiConfig } from "../../context/tui-config"
import { getScrollAcceleration } from "../../util/scroll" import { getScrollAcceleration } from "../../util/scroll"
import { TuiPluginRuntime } from "../../plugin" import { TuiPluginRuntime } from "../../plugin"
import { DialogGoUpsell } from "../../component/dialog-go-upsell" import { DialogGoUpsell } from "../../component/dialog-go-upsell"
import { SessionRetry } from "@/session/retry" import { SessionRetry } from "@/session"
addDefaultParsers(parsers.parsers) addDefaultParsers(parsers.parsers)
+10 -10
View File
@@ -22,17 +22,17 @@ import { Skill } from "@/skill"
import { Discovery } from "@/skill/discovery" import { Discovery } from "@/skill/discovery"
import { Question } from "@/question" import { Question } from "@/question"
import { Permission } from "@/permission" import { Permission } from "@/permission"
import { Todo } from "@/session/todo" import { Todo } from "@/session"
import { Session } from "@/session" import { Session } from "@/session"
import { SessionStatus } from "@/session/status" import { SessionStatus } from "@/session"
import { SessionRunState } from "@/session/run-state" import { SessionRunState } from "@/session"
import { SessionProcessor } from "@/session/processor" import { SessionProcessor } from "@/session"
import { SessionCompaction } from "@/session/compaction" import { SessionCompaction } from "@/session"
import { SessionRevert } from "@/session/revert" import { SessionRevert } from "@/session"
import { SessionSummary } from "@/session/summary" import { SessionSummary } from "@/session"
import { SessionPrompt } from "@/session/prompt" import { SessionPrompt } from "@/session"
import { Instruction } from "@/session/instruction" import { Instruction } from "@/session"
import { LLM } from "@/session/llm" import { LLM } from "@/session"
import { LSP } from "@/lsp" import { LSP } from "@/lsp"
import { MCP } from "@/mcp" import { MCP } from "@/mcp"
import { McpAuth } from "@/mcp/auth" import { McpAuth } from "@/mcp/auth"
@@ -5,7 +5,7 @@ import { iife } from "@/util/iife"
import { Log } from "../../util/log" import { Log } from "../../util/log"
import { setTimeout as sleep } from "node:timers/promises" import { setTimeout as sleep } from "node:timers/promises"
import { CopilotModels } from "./models" import { CopilotModels } from "./models"
import { MessageV2 } from "@/session/message-v2" import { MessageV2 } from "@/session"
const log = Log.create({ service: "plugin.copilot" }) const log = Log.create({ service: "plugin.copilot" })
@@ -4,15 +4,15 @@ import { describeRoute, validator, resolver } from "hono-openapi"
import { SessionID, MessageID, PartID } from "@/session/schema" import { SessionID, MessageID, PartID } from "@/session/schema"
import z from "zod" import z from "zod"
import { Session } from "../../session" import { Session } from "../../session"
import { MessageV2 } from "../../session/message-v2" import { MessageV2 } from "../../session"
import { SessionPrompt } from "../../session/prompt" import { SessionPrompt } from "../../session"
import { SessionRunState } from "@/session/run-state" import { SessionRunState } from "@/session"
import { SessionCompaction } from "../../session/compaction" import { SessionCompaction } from "../../session"
import { SessionRevert } from "../../session/revert" import { SessionRevert } from "../../session"
import { SessionShare } from "@/share/session" import { SessionShare } from "@/share/session"
import { SessionStatus } from "@/session/status" import { SessionStatus } from "@/session"
import { SessionSummary } from "@/session/summary" import { SessionSummary } from "@/session"
import { Todo } from "../../session/todo" import { Todo } from "../../session"
import { Effect } from "effect" import { Effect } from "effect"
import { AppRuntime } from "../../effect/app-runtime" import { AppRuntime } from "../../effect/app-runtime"
import { Agent } from "../../agent/agent" import { Agent } from "../../agent/agent"
+2 -4
View File
@@ -3,11 +3,11 @@ import { Bus } from "@/bus"
import { Session } from "." import { Session } from "."
import { SessionID, MessageID, PartID } from "./schema" import { SessionID, MessageID, PartID } from "./schema"
import { Provider } from "../provider" import { Provider } from "../provider"
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import z from "zod" import z from "zod"
import { Token } from "../util/token" import { Token } from "../util/token"
import { Log } from "../util/log" import { Log } from "../util/log"
import { SessionProcessor } from "./processor" import { SessionProcessor } from "."
import { Agent } from "@/agent/agent" import { Agent } from "@/agent/agent"
import { Plugin } from "@/plugin" import { Plugin } from "@/plugin"
import { Config } from "@/config" import { Config } from "@/config"
@@ -17,7 +17,6 @@ import { Effect, Layer, Context } from "effect"
import { InstanceState } from "@/effect" import { InstanceState } from "@/effect"
import { isOverflow as overflow } from "./overflow" import { isOverflow as overflow } from "./overflow"
export namespace SessionCompaction {
const log = Log.create({ service: "session.compaction" }) const log = Log.create({ service: "session.compaction" })
export const Event = { export const Event = {
@@ -409,4 +408,3 @@ When constructing the summary, try to stick to this template:
Layer.provide(Config.defaultLayer), Layer.provide(Config.defaultLayer),
), ),
) )
}
+14
View File
@@ -1 +1,15 @@
export * as Session from "./session" export * as Session from "./session"
export * as SessionRunState from "./run-state"
export * as SystemPrompt from "./system"
export * as Message from "./message"
export * as SessionRetry from "./retry"
export * as SessionProcessor from "./processor"
export * as SessionRevert from "./revert"
export * as Instruction from "./instruction"
export * as SessionSummary from "./summary"
export * as Todo from "./todo"
export * as LLM from "./llm"
export * as SessionStatus from "./status"
export * as SessionCompaction from "./compaction"
export * as SessionPrompt from "./prompt"
export * as MessageV2 from "./message-v2"
+1 -3
View File
@@ -10,7 +10,7 @@ import { withTransientReadRetry } from "@/util/effect-http-client"
import { Global } from "../global" import { Global } from "../global"
import { Instance } from "../project/instance" import { Instance } from "../project/instance"
import { Log } from "../util/log" import { Log } from "../util/log"
import type { MessageV2 } from "./message-v2" import type { MessageV2 } from "."
import type { MessageID } from "./schema" import type { MessageID } from "./schema"
const log = Log.create({ service: "instruction" }) const log = Log.create({ service: "instruction" })
@@ -50,7 +50,6 @@ function extract(messages: MessageV2.WithParts[]) {
return paths return paths
} }
export namespace Instruction {
export interface Interface { export interface Interface {
readonly clear: (messageID: MessageID) => Effect.Effect<void> readonly clear: (messageID: MessageID) => Effect.Effect<void>
readonly systemPaths: () => Effect.Effect<Set<string>, AppFileSystem.Error> readonly systemPaths: () => Effect.Effect<Set<string>, AppFileSystem.Error>
@@ -240,4 +239,3 @@ export namespace Instruction {
export function loaded(messages: MessageV2.WithParts[]) { export function loaded(messages: MessageV2.WithParts[]) {
return extract(messages) return extract(messages)
} }
}
+2 -4
View File
@@ -9,9 +9,9 @@ import { ProviderTransform } from "@/provider/transform"
import { Config } from "@/config" import { Config } from "@/config"
import { Instance } from "@/project/instance" import { Instance } from "@/project/instance"
import type { Agent } from "@/agent/agent" import type { Agent } from "@/agent/agent"
import type { MessageV2 } from "./message-v2" import type { MessageV2 } from "."
import { Plugin } from "@/plugin" import { Plugin } from "@/plugin"
import { SystemPrompt } from "./system" import { SystemPrompt } from "."
import { Flag } from "@/flag/flag" import { Flag } from "@/flag/flag"
import { Permission } from "@/permission" import { Permission } from "@/permission"
import { PermissionID } from "@/permission/schema" import { PermissionID } from "@/permission/schema"
@@ -24,7 +24,6 @@ import { EffectBridge } from "@/effect"
import * as Option from "effect/Option" import * as Option from "effect/Option"
import * as OtelTracer from "@effect/opentelemetry/Tracer" import * as OtelTracer from "@effect/opentelemetry/Tracer"
export namespace LLM {
const log = Log.create({ service: "llm" }) const log = Log.create({ service: "llm" })
export const OUTPUT_TOKEN_MAX = ProviderTransform.OUTPUT_TOKEN_MAX export const OUTPUT_TOKEN_MAX = ProviderTransform.OUTPUT_TOKEN_MAX
type Result = Awaited<ReturnType<typeof streamText>> type Result = Awaited<ReturnType<typeof streamText>>
@@ -450,4 +449,3 @@ export namespace LLM {
} }
return false return false
} }
}
+18 -20
View File
@@ -24,7 +24,6 @@ interface FetchDecompressionError extends Error {
path: string path: string
} }
export namespace MessageV2 {
export const SYNTHETIC_ATTACHMENT_PROMPT = "Attached image(s) from tool result:" export const SYNTHETIC_ATTACHMENT_PROMPT = "Attached image(s) from tool result:"
export function isMedia(mime: string) { export function isMedia(mime: string) {
@@ -534,7 +533,7 @@ export namespace MessageV2 {
...row.data, ...row.data,
id: row.id, id: row.id,
sessionID: row.session_id, sessionID: row.session_id,
}) as MessageV2.Info }) as Info
const part = (row: typeof PartTable.$inferSelect) => const part = (row: typeof PartTable.$inferSelect) =>
({ ({
@@ -542,7 +541,7 @@ export namespace MessageV2 {
id: row.id, id: row.id,
sessionID: row.session_id, sessionID: row.session_id,
messageID: row.message_id, messageID: row.message_id,
}) as MessageV2.Part }) as Part
const older = (row: Cursor) => const older = (row: Cursor) =>
or( or(
@@ -552,7 +551,7 @@ export namespace MessageV2 {
function hydrate(rows: (typeof MessageTable.$inferSelect)[]) { function hydrate(rows: (typeof MessageTable.$inferSelect)[]) {
const ids = rows.map((row) => row.id) const ids = rows.map((row) => row.id)
const partByMessage = new Map<string, MessageV2.Part[]>() const partByMessage = new Map<string, Part[]>()
if (ids.length > 0) { if (ids.length > 0) {
const partRows = Database.use((db) => const partRows = Database.use((db) =>
db db
@@ -699,7 +698,7 @@ export namespace MessageV2 {
if ( if (
msg.info.error && msg.info.error &&
!( !(
MessageV2.AbortedError.isInstance(msg.info.error) && AbortedError.isInstance(msg.info.error) &&
msg.parts.some((part) => part.type !== "step-start" && part.type !== "reasoning") msg.parts.some((part) => part.type !== "step-start" && part.type !== "reasoning")
) )
) { ) {
@@ -865,7 +864,7 @@ export namespace MessageV2 {
) )
if (!row) throw new NotFoundError({ message: `Session not found: ${input.sessionID}` }) if (!row) throw new NotFoundError({ message: `Session not found: ${input.sessionID}` })
return { return {
items: [] as MessageV2.WithParts[], items: [] as WithParts[],
more: false, more: false,
} }
} }
@@ -907,7 +906,7 @@ export namespace MessageV2 {
id: row.id, id: row.id,
sessionID: row.session_id, sessionID: row.session_id,
messageID: row.message_id, messageID: row.message_id,
}) as MessageV2.Part, }) as Part,
) )
} }
@@ -926,8 +925,8 @@ export namespace MessageV2 {
} }
} }
export function filterCompacted(msgs: Iterable<MessageV2.WithParts>) { export function filterCompacted(msgs: Iterable<WithParts>) {
const result = [] as MessageV2.WithParts[] const result = [] as WithParts[]
const completed = new Set<string>() const completed = new Set<string>()
for (const msg of msgs) { for (const msg of msgs) {
result.push(msg) result.push(msg)
@@ -954,16 +953,16 @@ export namespace MessageV2 {
): NonNullable<Assistant["error"]> { ): NonNullable<Assistant["error"]> {
switch (true) { switch (true) {
case e instanceof DOMException && e.name === "AbortError": case e instanceof DOMException && e.name === "AbortError":
return new MessageV2.AbortedError( return new AbortedError(
{ message: e.message }, { message: e.message },
{ {
cause: e, cause: e,
}, },
).toObject() ).toObject()
case MessageV2.OutputLengthError.isInstance(e): case OutputLengthError.isInstance(e):
return e return e
case LoadAPIKeyError.isInstance(e): case LoadAPIKeyError.isInstance(e):
return new MessageV2.AuthError( return new AuthError(
{ {
providerID: ctx.providerID, providerID: ctx.providerID,
message: e.message, message: e.message,
@@ -971,7 +970,7 @@ export namespace MessageV2 {
{ cause: e }, { cause: e },
).toObject() ).toObject()
case (e as SystemError)?.code === "ECONNRESET": case (e as SystemError)?.code === "ECONNRESET":
return new MessageV2.APIError( return new APIError(
{ {
message: "Connection reset by server", message: "Connection reset by server",
isRetryable: true, isRetryable: true,
@@ -985,9 +984,9 @@ export namespace MessageV2 {
).toObject() ).toObject()
case e instanceof Error && (e as FetchDecompressionError).code === "ZlibError": case e instanceof Error && (e as FetchDecompressionError).code === "ZlibError":
if (ctx.aborted) { if (ctx.aborted) {
return new MessageV2.AbortedError({ message: e.message }, { cause: e }).toObject() return new AbortedError({ message: e.message }, { cause: e }).toObject()
} }
return new MessageV2.APIError( return new APIError(
{ {
message: "Response decompression failed", message: "Response decompression failed",
isRetryable: true, isRetryable: true,
@@ -1004,7 +1003,7 @@ export namespace MessageV2 {
error: e, error: e,
}) })
if (parsed.type === "context_overflow") { if (parsed.type === "context_overflow") {
return new MessageV2.ContextOverflowError( return new ContextOverflowError(
{ {
message: parsed.message, message: parsed.message,
responseBody: parsed.responseBody, responseBody: parsed.responseBody,
@@ -1013,7 +1012,7 @@ export namespace MessageV2 {
).toObject() ).toObject()
} }
return new MessageV2.APIError( return new APIError(
{ {
message: parsed.message, message: parsed.message,
statusCode: parsed.statusCode, statusCode: parsed.statusCode,
@@ -1031,7 +1030,7 @@ export namespace MessageV2 {
const parsed = ProviderError.parseStreamError(e) const parsed = ProviderError.parseStreamError(e)
if (parsed) { if (parsed) {
if (parsed.type === "context_overflow") { if (parsed.type === "context_overflow") {
return new MessageV2.ContextOverflowError( return new ContextOverflowError(
{ {
message: parsed.message, message: parsed.message,
responseBody: parsed.responseBody, responseBody: parsed.responseBody,
@@ -1039,7 +1038,7 @@ export namespace MessageV2 {
{ cause: e }, { cause: e },
).toObject() ).toObject()
} }
return new MessageV2.APIError( return new APIError(
{ {
message: parsed.message, message: parsed.message,
isRetryable: parsed.isRetryable, isRetryable: parsed.isRetryable,
@@ -1054,4 +1053,3 @@ export namespace MessageV2 {
return new NamedError.Unknown({ message: JSON.stringify(e) }, { cause: e }).toObject() return new NamedError.Unknown({ message: JSON.stringify(e) }, { cause: e }).toObject()
} }
} }
}
-2
View File
@@ -3,7 +3,6 @@ import { SessionID } from "./schema"
import { ModelID, ProviderID } from "../provider/schema" import { ModelID, ProviderID } from "../provider/schema"
import { NamedError } from "@opencode-ai/shared/util/error" import { NamedError } from "@opencode-ai/shared/util/error"
export namespace Message {
export const OutputLengthError = NamedError.create("MessageOutputLengthError", z.object({})) export const OutputLengthError = NamedError.create("MessageOutputLengthError", z.object({}))
export const AuthError = NamedError.create( export const AuthError = NamedError.create(
"ProviderAuthError", "ProviderAuthError",
@@ -188,4 +187,3 @@ export namespace Message {
ref: "Message", ref: "Message",
}) })
export type Info = z.infer<typeof Info> export type Info = z.infer<typeof Info>
}
+1 -1
View File
@@ -1,7 +1,7 @@
import type { Config } from "@/config" import type { Config } from "@/config"
import type { Provider } from "@/provider" import type { Provider } from "@/provider"
import { ProviderTransform } from "@/provider/transform" import { ProviderTransform } from "@/provider/transform"
import type { MessageV2 } from "./message-v2" import type { MessageV2 } from "."
const COMPACTION_BUFFER = 20_000 const COMPACTION_BUFFER = 20_000
+5 -7
View File
@@ -7,21 +7,20 @@ import { Permission } from "@/permission"
import { Plugin } from "@/plugin" import { Plugin } from "@/plugin"
import { Snapshot } from "@/snapshot" import { Snapshot } from "@/snapshot"
import { Session } from "." import { Session } from "."
import { LLM } from "./llm" import { LLM } from "."
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { isOverflow } from "./overflow" import { isOverflow } from "./overflow"
import { PartID } from "./schema" import { PartID } from "./schema"
import type { SessionID } from "./schema" import type { SessionID } from "./schema"
import { SessionRetry } from "./retry" import { SessionRetry } from "."
import { SessionStatus } from "./status" import { SessionStatus } from "."
import { SessionSummary } from "./summary" import { SessionSummary } from "."
import type { Provider } from "@/provider" import type { Provider } from "@/provider"
import { Question } from "@/question" import { Question } from "@/question"
import { errorMessage } from "@/util/error" import { errorMessage } from "@/util/error"
import { Log } from "@/util/log" import { Log } from "@/util/log"
import { isRecord } from "@/util/record" import { isRecord } from "@/util/record"
export namespace SessionProcessor {
const DOOM_LOOP_THRESHOLD = 3 const DOOM_LOOP_THRESHOLD = 3
const log = Log.create({ service: "session.processor" }) const log = Log.create({ service: "session.processor" })
@@ -616,4 +615,3 @@ export namespace SessionProcessor {
Layer.provide(Config.defaultLayer), Layer.provide(Config.defaultLayer),
), ),
) )
}
+1 -1
View File
@@ -1,7 +1,7 @@
import { NotFoundError, eq, and } from "../storage/db" import { NotFoundError, eq, and } from "../storage/db"
import { SyncEvent } from "@/sync" import { SyncEvent } from "@/sync"
import { Session } from "." import { Session } from "."
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { SessionTable, MessageTable, PartTable } from "./session.sql" import { SessionTable, MessageTable, PartTable } from "./session.sql"
import { Log } from "../util/log" import { Log } from "../util/log"
+10 -12
View File
@@ -2,19 +2,19 @@ import path from "path"
import os from "os" import os from "os"
import z from "zod" import z from "zod"
import { SessionID, MessageID, PartID } from "./schema" import { SessionID, MessageID, PartID } from "./schema"
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { Log } from "../util/log" import { Log } from "../util/log"
import { SessionRevert } from "./revert" import { SessionRevert } from "."
import { Session } from "." import { Session } from "."
import { Agent } from "../agent/agent" import { Agent } from "../agent/agent"
import { Provider } from "../provider" import { Provider } from "../provider"
import { ModelID, ProviderID } from "../provider/schema" import { ModelID, ProviderID } from "../provider/schema"
import { type Tool as AITool, tool, jsonSchema, type ToolExecutionOptions, asSchema } from "ai" import { type Tool as AITool, tool, jsonSchema, type ToolExecutionOptions, asSchema } from "ai"
import { SessionCompaction } from "./compaction" import { SessionCompaction } from "."
import { Bus } from "../bus" import { Bus } from "../bus"
import { ProviderTransform } from "../provider/transform" import { ProviderTransform } from "../provider/transform"
import { SystemPrompt } from "./system" import { SystemPrompt } from "."
import { Instruction } from "./instruction" import { Instruction } from "."
import { Plugin } from "../plugin" import { Plugin } from "../plugin"
import PROMPT_PLAN from "../session/prompt/plan.txt" import PROMPT_PLAN from "../session/prompt/plan.txt"
import BUILD_SWITCH from "../session/prompt/build-switch.txt" import BUILD_SWITCH from "../session/prompt/build-switch.txt"
@@ -31,13 +31,13 @@ import * as Stream from "effect/Stream"
import { Command } from "../command" import { Command } from "../command"
import { pathToFileURL, fileURLToPath } from "url" import { pathToFileURL, fileURLToPath } from "url"
import { ConfigMarkdown } from "../config/markdown" import { ConfigMarkdown } from "../config/markdown"
import { SessionSummary } from "./summary" import { SessionSummary } from "."
import { NamedError } from "@opencode-ai/shared/util/error" import { NamedError } from "@opencode-ai/shared/util/error"
import { SessionProcessor } from "./processor" import { SessionProcessor } from "."
import { Tool } from "@/tool/tool" import { Tool } from "@/tool/tool"
import { Permission } from "@/permission" import { Permission } from "@/permission"
import { SessionStatus } from "./status" import { SessionStatus } from "."
import { LLM } from "./llm" import { LLM } from "."
import { Shell } from "@/shell/shell" import { Shell } from "@/shell/shell"
import { AppFileSystem } from "@opencode-ai/shared/filesystem" import { AppFileSystem } from "@opencode-ai/shared/filesystem"
import { Truncate } from "@/tool/truncate" import { Truncate } from "@/tool/truncate"
@@ -47,7 +47,7 @@ import { Cause, Effect, Exit, Layer, Option, Scope, Context } from "effect"
import { EffectLogger } from "@/effect/logger" import { EffectLogger } from "@/effect/logger"
import { InstanceState } from "@/effect" import { InstanceState } from "@/effect"
import { TaskTool, type TaskPromptOps } from "@/tool/task" import { TaskTool, type TaskPromptOps } from "@/tool/task"
import { SessionRunState } from "./run-state" import { SessionRunState } from "."
import { EffectBridge } from "@/effect" import { EffectBridge } from "@/effect"
// @ts-ignore // @ts-ignore
@@ -63,7 +63,6 @@ IMPORTANT:
const STRUCTURED_OUTPUT_SYSTEM_PROMPT = `IMPORTANT: The user has requested structured output. You MUST use the StructuredOutput tool to provide your final response. Do NOT respond with plain text - you MUST call the StructuredOutput tool with your answer formatted according to the schema.` const STRUCTURED_OUTPUT_SYSTEM_PROMPT = `IMPORTANT: The user has requested structured output. You MUST use the StructuredOutput tool to provide your final response. Do NOT respond with plain text - you MUST call the StructuredOutput tool with your answer formatted according to the schema.`
export namespace SessionPrompt {
const log = Log.create({ service: "session.prompt" }) const log = Log.create({ service: "session.prompt" })
const elog = EffectLogger.create({ service: "session.prompt" }) const elog = EffectLogger.create({ service: "session.prompt" })
@@ -1852,4 +1851,3 @@ NOTE: At any point in time through this workflow you should feel free to ask the
const argsRegex = /(?:\[Image\s+\d+\]|"[^"]*"|'[^']*'|[^\s"']+)/gi const argsRegex = /(?:\[Image\s+\d+\]|"[^"]*"|'[^']*'|[^\s"']+)/gi
const placeholderRegex = /\$(\d+)/g const placeholderRegex = /\$(\d+)/g
const quoteTrimRegex = /^["']|["']$/g const quoteTrimRegex = /^["']|["']$/g
}
+1 -3
View File
@@ -1,9 +1,8 @@
import type { NamedError } from "@opencode-ai/shared/util/error" import type { NamedError } from "@opencode-ai/shared/util/error"
import { Cause, Clock, Duration, Effect, Schedule } from "effect" import { Cause, Clock, Duration, Effect, Schedule } from "effect"
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { iife } from "@/util/iife" import { iife } from "@/util/iife"
export namespace SessionRetry {
export type Err = ReturnType<NamedError["toObject"]> export type Err = ReturnType<NamedError["toObject"]>
// This exported message is shared with the TUI upsell detector. Matching on a // This exported message is shared with the TUI upsell detector. Matching on a
@@ -122,4 +121,3 @@ export namespace SessionRetry {
}), }),
) )
} }
}
+3 -5
View File
@@ -6,12 +6,11 @@ import { Storage } from "@/storage/storage"
import { SyncEvent } from "../sync" import { SyncEvent } from "../sync"
import { Log } from "../util/log" import { Log } from "../util/log"
import { Session } from "." import { Session } from "."
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { SessionID, MessageID, PartID } from "./schema" import { SessionID, MessageID, PartID } from "./schema"
import { SessionRunState } from "./run-state" import { SessionRunState } from "."
import { SessionSummary } from "./summary" import { SessionSummary } from "."
export namespace SessionRevert {
const log = Log.create({ service: "session.revert" }) const log = Log.create({ service: "session.revert" })
export const RevertInput = z.object({ export const RevertInput = z.object({
@@ -158,4 +157,3 @@ export namespace SessionRevert {
Layer.provide(SessionSummary.defaultLayer), Layer.provide(SessionSummary.defaultLayer),
), ),
) )
}
+2 -4
View File
@@ -2,11 +2,10 @@ import { InstanceState } from "@/effect"
import { Runner } from "@/effect/runner" import { Runner } from "@/effect/runner"
import { Effect, Layer, Scope, Context } from "effect" import { Effect, Layer, Scope, Context } from "effect"
import { Session } from "." import { Session } from "."
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { SessionID } from "./schema" import { SessionID } from "./schema"
import { SessionStatus } from "./status" import { SessionStatus } from "."
export namespace SessionRunState {
export interface Interface { export interface Interface {
readonly assertNotBusy: (sessionID: SessionID) => Effect.Effect<void> readonly assertNotBusy: (sessionID: SessionID) => Effect.Effect<void>
readonly cancel: (sessionID: SessionID) => Effect.Effect<void> readonly cancel: (sessionID: SessionID) => Effect.Effect<void>
@@ -105,4 +104,3 @@ export namespace SessionRunState {
) )
export const defaultLayer = layer.pipe(Layer.provide(SessionStatus.defaultLayer)) export const defaultLayer = layer.pipe(Layer.provide(SessionStatus.defaultLayer))
}
+1 -1
View File
@@ -1,6 +1,6 @@
import { sqliteTable, text, integer, index, primaryKey } from "drizzle-orm/sqlite-core" import { sqliteTable, text, integer, index, primaryKey } from "drizzle-orm/sqlite-core"
import { ProjectTable } from "../project/project.sql" import { ProjectTable } from "../project/project.sql"
import type { MessageV2 } from "./message-v2" import type { MessageV2 } from "."
import type { SessionEntry } from "../v2/session-entry" import type { SessionEntry } from "../v2/session-entry"
import type { Snapshot } from "../snapshot" import type { Snapshot } from "../snapshot"
import type { Permission } from "../permission" import type { Permission } from "../permission"
+1 -1
View File
@@ -16,7 +16,7 @@ import { ProjectTable } from "../project/project.sql"
import { Storage } from "@/storage/storage" import { Storage } from "@/storage/storage"
import { Log } from "../util/log" import { Log } from "../util/log"
import { updateSchema } from "../util/update-schema" import { updateSchema } from "../util/update-schema"
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { Instance } from "../project/instance" import { Instance } from "../project/instance"
import { InstanceState } from "@/effect" import { InstanceState } from "@/effect"
import { Snapshot } from "@/snapshot" import { Snapshot } from "@/snapshot"
-2
View File
@@ -5,7 +5,6 @@ import { SessionID } from "./schema"
import { Effect, Layer, Context } from "effect" import { Effect, Layer, Context } from "effect"
import z from "zod" import z from "zod"
export namespace SessionStatus {
export const Info = z export const Info = z
.union([ .union([
z.object({ z.object({
@@ -85,4 +84,3 @@ export namespace SessionStatus {
) )
export const defaultLayer = layer.pipe(Layer.provide(Bus.layer)) export const defaultLayer = layer.pipe(Layer.provide(Bus.layer))
}
+1 -3
View File
@@ -4,10 +4,9 @@ import { Bus } from "@/bus"
import { Snapshot } from "@/snapshot" import { Snapshot } from "@/snapshot"
import { Storage } from "@/storage/storage" import { Storage } from "@/storage/storage"
import { Session } from "." import { Session } from "."
import { MessageV2 } from "./message-v2" import { MessageV2 } from "."
import { SessionID, MessageID } from "./schema" import { SessionID, MessageID } from "./schema"
export namespace SessionSummary {
function unquoteGitPath(input: string) { function unquoteGitPath(input: string) {
if (!input.startsWith('"')) return input if (!input.startsWith('"')) return input
if (!input.endsWith('"')) return input if (!input.endsWith('"')) return input
@@ -162,4 +161,3 @@ export namespace SessionSummary {
sessionID: SessionID.zod, sessionID: SessionID.zod,
messageID: MessageID.zod.optional(), messageID: MessageID.zod.optional(),
}) })
}
-2
View File
@@ -16,7 +16,6 @@ import type { Agent } from "@/agent/agent"
import { Permission } from "@/permission" import { Permission } from "@/permission"
import { Skill } from "@/skill" import { Skill } from "@/skill"
export namespace SystemPrompt {
export function provider(model: Provider.Model) { export function provider(model: Provider.Model) {
if (model.api.id.includes("gpt-4") || model.api.id.includes("o1") || model.api.id.includes("o3")) if (model.api.id.includes("gpt-4") || model.api.id.includes("o1") || model.api.id.includes("o3"))
return [PROMPT_BEAST] return [PROMPT_BEAST]
@@ -81,4 +80,3 @@ export namespace SystemPrompt {
) )
export const defaultLayer = layer.pipe(Layer.provide(Skill.defaultLayer)) export const defaultLayer = layer.pipe(Layer.provide(Skill.defaultLayer))
}
-2
View File
@@ -6,7 +6,6 @@ import z from "zod"
import { Database, eq, asc } from "../storage/db" import { Database, eq, asc } from "../storage/db"
import { TodoTable } from "./session.sql" import { TodoTable } from "./session.sql"
export namespace Todo {
export const Info = z export const Info = z
.object({ .object({
content: z.string().describe("Brief description of the task"), content: z.string().describe("Brief description of the task"),
@@ -82,4 +81,3 @@ export namespace Todo {
) )
export const defaultLayer = layer.pipe(Layer.provide(Bus.layer)) export const defaultLayer = layer.pipe(Layer.provide(Bus.layer))
}
+1 -1
View File
@@ -7,7 +7,7 @@ import { InstanceState } from "@/effect"
import { Provider } from "@/provider" import { Provider } from "@/provider"
import { ModelID, ProviderID } from "@/provider/schema" import { ModelID, ProviderID } from "@/provider/schema"
import { Session } from "@/session" import { Session } from "@/session"
import { MessageV2 } from "@/session/message-v2" import { MessageV2 } from "@/session"
import type { SessionID } from "@/session/schema" import type { SessionID } from "@/session/schema"
import { Database, eq } from "@/storage/db" import { Database, eq } from "@/storage/db"
import { Config } from "@/config" import { Config } from "@/config"
+1 -1
View File
@@ -4,7 +4,7 @@ import { Effect } from "effect"
import { Tool } from "./tool" import { Tool } from "./tool"
import { Question } from "../question" import { Question } from "../question"
import { Session } from "../session" import { Session } from "../session"
import { MessageV2 } from "../session/message-v2" import { MessageV2 } from "../session"
import { Provider } from "../provider" import { Provider } from "../provider"
import { Instance } from "../project/instance" import { Instance } from "../project/instance"
import { type SessionID, MessageID, PartID } from "../session/schema" import { type SessionID, MessageID, PartID } from "../session/schema"
+1 -1
View File
@@ -11,7 +11,7 @@ import { FileTime } from "../file/time"
import DESCRIPTION from "./read.txt" import DESCRIPTION from "./read.txt"
import { Instance } from "../project/instance" import { Instance } from "../project/instance"
import { assertExternalDirectoryEffect } from "./external-directory" import { assertExternalDirectoryEffect } from "./external-directory"
import { Instruction } from "../session/instruction" import { Instruction } from "../session"
const DEFAULT_READ_LIMIT = 2000 const DEFAULT_READ_LIMIT = 2000
const MAX_LINE_LENGTH = 2000 const MAX_LINE_LENGTH = 2000
+2 -2
View File
@@ -37,10 +37,10 @@ import { Ripgrep } from "../file/ripgrep"
import { Format } from "../format" import { Format } from "../format"
import { InstanceState } from "@/effect" import { InstanceState } from "@/effect"
import { Question } from "../question" import { Question } from "../question"
import { Todo } from "../session/todo" import { Todo } from "../session"
import { LSP } from "../lsp" import { LSP } from "../lsp"
import { FileTime } from "../file/time" import { FileTime } from "../file/time"
import { Instruction } from "../session/instruction" import { Instruction } from "../session"
import { AppFileSystem } from "@opencode-ai/shared/filesystem" import { AppFileSystem } from "@opencode-ai/shared/filesystem"
import { Bus } from "../bus" import { Bus } from "../bus"
import { Agent } from "../agent/agent" import { Agent } from "../agent/agent"
+2 -2
View File
@@ -3,9 +3,9 @@ import DESCRIPTION from "./task.txt"
import z from "zod" import z from "zod"
import { Session } from "../session" import { Session } from "../session"
import { SessionID, MessageID } from "../session/schema" import { SessionID, MessageID } from "../session/schema"
import { MessageV2 } from "../session/message-v2" import { MessageV2 } from "../session"
import { Agent } from "../agent/agent" import { Agent } from "../agent/agent"
import type { SessionPrompt } from "../session/prompt" import type { SessionPrompt } from "../session"
import { Config } from "../config" import { Config } from "../config"
import { Effect } from "effect" import { Effect } from "effect"
+1 -1
View File
@@ -2,7 +2,7 @@ import z from "zod"
import { Effect } from "effect" import { Effect } from "effect"
import { Tool } from "./tool" import { Tool } from "./tool"
import DESCRIPTION_WRITE from "./todowrite.txt" import DESCRIPTION_WRITE from "./todowrite.txt"
import { Todo } from "../session/todo" import { Todo } from "../session"
const parameters = z.object({ const parameters = z.object({
todos: z.array(z.object(Todo.Info.shape)).describe("The updated todo list"), todos: z.array(z.object(Todo.Info.shape)).describe("The updated todo list"),
+1 -1
View File
@@ -1,6 +1,6 @@
import z from "zod" import z from "zod"
import { Effect } from "effect" import { Effect } from "effect"
import type { MessageV2 } from "../session/message-v2" import type { MessageV2 } from "../session"
import type { Permission } from "../permission" import type { Permission } from "../permission"
import type { SessionID, MessageID } from "../session/schema" import type { SessionID, MessageID } from "../session/schema"
import { Truncate } from "./truncate" import { Truncate } from "./truncate"
@@ -1,6 +1,6 @@
import { test, expect, describe } from "bun:test" import { test, expect, describe } from "bun:test"
import { extractResponseText, formatPromptTooLargeError } from "../../src/cli/cmd/github" import { extractResponseText, formatPromptTooLargeError } from "../../src/cli/cmd/github"
import type { MessageV2 } from "../../src/session/message-v2" import type { MessageV2 } from "../../src/session"
import { SessionID, MessageID, PartID } from "../../src/session/schema" import { SessionID, MessageID, PartID } from "../../src/session/schema"
// Helper to create minimal valid parts // Helper to create minimal valid parts
@@ -3,7 +3,7 @@ import { Effect } from "effect"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { Server } from "../../src/server/server" import { Server } from "../../src/server/server"
import { Session as SessionNs } from "../../src/session" import { Session as SessionNs } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { MessageID, PartID, type SessionID } from "../../src/session/schema" import { MessageID, PartID, type SessionID } from "../../src/session/schema"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import { tmpdir } from "../fixture/fixture" import { tmpdir } from "../fixture/fixture"
@@ -6,8 +6,8 @@ import z from "zod"
import { Bus } from "../../src/bus" import { Bus } from "../../src/bus"
import { Config } from "../../src/config" import { Config } from "../../src/config"
import { Agent } from "../../src/agent/agent" import { Agent } from "../../src/agent/agent"
import { LLM } from "../../src/session/llm" import { LLM } from "../../src/session"
import { SessionCompaction } from "../../src/session/compaction" import { SessionCompaction } from "../../src/session"
import { Token } from "../../src/util/token" import { Token } from "../../src/util/token"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
@@ -15,13 +15,13 @@ import { Permission } from "../../src/permission"
import { Plugin } from "../../src/plugin" import { Plugin } from "../../src/plugin"
import { provideTmpdirInstance, tmpdir } from "../fixture/fixture" import { provideTmpdirInstance, tmpdir } from "../fixture/fixture"
import { Session as SessionNs } from "../../src/session" import { Session as SessionNs } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { MessageID, PartID, SessionID } from "../../src/session/schema" import { MessageID, PartID, SessionID } from "../../src/session/schema"
import { SessionStatus } from "../../src/session/status" import { SessionStatus } from "../../src/session"
import { SessionSummary } from "../../src/session/summary" import { SessionSummary } from "../../src/session"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import type { Provider } from "../../src/provider" import type { Provider } from "../../src/provider"
import * as SessionProcessorModule from "../../src/session/processor" import * as SessionProcessorModule from "../../src/session"
import { Snapshot } from "../../src/snapshot" import { Snapshot } from "../../src/snapshot"
import { ProviderTest } from "../fake/provider" import { ProviderTest } from "../fake/provider"
import { testEffect } from "../lib/effect" import { testEffect } from "../lib/effect"
@@ -2,8 +2,8 @@ import { afterEach, beforeEach, describe, expect, test } from "bun:test"
import path from "path" import path from "path"
import { Effect } from "effect" import { Effect } from "effect"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { Instruction } from "../../src/session/instruction" import { Instruction } from "../../src/session"
import type { MessageV2 } from "../../src/session/message-v2" import type { MessageV2 } from "../../src/session"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { MessageID, PartID, SessionID } from "../../src/session/schema" import { MessageID, PartID, SessionID } from "../../src/session/schema"
import { Global } from "../../src/global" import { Global } from "../../src/global"
+2 -2
View File
@@ -4,7 +4,7 @@ import { tool, type ModelMessage } from "ai"
import { Cause, Effect, Exit, Stream } from "effect" import { Cause, Effect, Exit, Stream } from "effect"
import z from "zod" import z from "zod"
import { makeRuntime } from "../../src/effect/run-service" import { makeRuntime } from "../../src/effect/run-service"
import { LLM } from "../../src/session/llm" import { LLM } from "../../src/session"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { Provider } from "../../src/provider" import { Provider } from "../../src/provider"
import { ProviderTransform } from "../../src/provider/transform" import { ProviderTransform } from "../../src/provider/transform"
@@ -13,7 +13,7 @@ import { ProviderID, ModelID } from "../../src/provider/schema"
import { Filesystem } from "../../src/util/filesystem" import { Filesystem } from "../../src/util/filesystem"
import { tmpdir } from "../fixture/fixture" import { tmpdir } from "../fixture/fixture"
import type { Agent } from "../../src/agent/agent" import type { Agent } from "../../src/agent/agent"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { SessionID, MessageID } from "../../src/session/schema" import { SessionID, MessageID } from "../../src/session/schema"
import { AppRuntime } from "../../src/effect/app-runtime" import { AppRuntime } from "../../src/effect/app-runtime"
@@ -1,6 +1,6 @@
import { describe, expect, test } from "bun:test" import { describe, expect, test } from "bun:test"
import { APICallError } from "ai" import { APICallError } from "ai"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import type { Provider } from "../../src/provider" import type { Provider } from "../../src/provider"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { SessionID, MessageID, PartID } from "../../src/session/schema" import { SessionID, MessageID, PartID } from "../../src/session/schema"
@@ -3,7 +3,7 @@ import { Effect } from "effect"
import path from "path" import path from "path"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { Session as SessionNs } from "../../src/session" import { Session as SessionNs } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { MessageID, PartID, type SessionID } from "../../src/session/schema" import { MessageID, PartID, type SessionID } from "../../src/session/schema"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
@@ -11,12 +11,12 @@ import { Plugin } from "../../src/plugin"
import { Provider } from "../../src/provider" import { Provider } from "../../src/provider"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { LLM } from "../../src/session/llm" import { LLM } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { SessionProcessor } from "../../src/session/processor" import { SessionProcessor } from "../../src/session"
import { MessageID, PartID, SessionID } from "../../src/session/schema" import { MessageID, PartID, SessionID } from "../../src/session/schema"
import { SessionStatus } from "../../src/session/status" import { SessionStatus } from "../../src/session"
import { SessionSummary } from "../../src/session/summary" import { SessionSummary } from "../../src/session"
import { Snapshot } from "../../src/snapshot" import { Snapshot } from "../../src/snapshot"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import * as CrossSpawnSpawner from "../../src/effect/cross-spawn-spawner" import * as CrossSpawnSpawner from "../../src/effect/cross-spawn-spawner"
@@ -16,22 +16,22 @@ import { Provider as ProviderSvc } from "../../src/provider"
import { Env } from "../../src/env" import { Env } from "../../src/env"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { Question } from "../../src/question" import { Question } from "../../src/question"
import { Todo } from "../../src/session/todo" import { Todo } from "../../src/session"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { LLM } from "../../src/session/llm" import { LLM } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { AppFileSystem } from "@opencode-ai/shared/filesystem" import { AppFileSystem } from "@opencode-ai/shared/filesystem"
import { SessionCompaction } from "../../src/session/compaction" import { SessionCompaction } from "../../src/session"
import { SessionSummary } from "../../src/session/summary" import { SessionSummary } from "../../src/session"
import { Instruction } from "../../src/session/instruction" import { Instruction } from "../../src/session"
import { SessionProcessor } from "../../src/session/processor" import { SessionProcessor } from "../../src/session"
import { SessionPrompt } from "../../src/session/prompt" import { SessionPrompt } from "../../src/session"
import { SessionRevert } from "../../src/session/revert" import { SessionRevert } from "../../src/session"
import { SessionRunState } from "../../src/session/run-state" import { SessionRunState } from "../../src/session"
import { MessageID, PartID, SessionID } from "../../src/session/schema" import { MessageID, PartID, SessionID } from "../../src/session/schema"
import { SessionStatus } from "../../src/session/status" import { SessionStatus } from "../../src/session"
import { Skill } from "../../src/skill" import { Skill } from "../../src/skill"
import { SystemPrompt } from "../../src/session/system" import { SystemPrompt } from "../../src/session"
import { Shell } from "../../src/shell/shell" import { Shell } from "../../src/shell/shell"
import { Snapshot } from "../../src/snapshot" import { Snapshot } from "../../src/snapshot"
import { ToolRegistry } from "../../src/tool/registry" import { ToolRegistry } from "../../src/tool/registry"
@@ -6,8 +6,8 @@ import { Effect, Layer } from "effect"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { SessionPrompt } from "../../src/session/prompt" import { SessionPrompt } from "../../src/session"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import { tmpdir } from "../fixture/fixture" import { tmpdir } from "../fixture/fixture"
+3 -3
View File
@@ -3,12 +3,12 @@ import type { NamedError } from "@opencode-ai/shared/util/error"
import { APICallError } from "ai" import { APICallError } from "ai"
import { setTimeout as sleep } from "node:timers/promises" import { setTimeout as sleep } from "node:timers/promises"
import { Effect, Schedule } from "effect" import { Effect, Schedule } from "effect"
import { SessionRetry } from "../../src/session/retry" import { SessionRetry } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { ProviderID } from "../../src/provider/schema" import { ProviderID } from "../../src/provider/schema"
import { AppRuntime } from "../../src/effect/app-runtime" import { AppRuntime } from "../../src/effect/app-runtime"
import { SessionID } from "../../src/session/schema" import { SessionID } from "../../src/session/schema"
import { SessionStatus } from "../../src/session/status" import { SessionStatus } from "../../src/session"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { tmpdir } from "../fixture/fixture" import { tmpdir } from "../fixture/fixture"
@@ -4,8 +4,8 @@ import path from "path"
import { Effect, Layer } from "effect" import { Effect, Layer } from "effect"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { SessionRevert } from "../../src/session/revert" import { SessionRevert } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { Snapshot } from "../../src/snapshot" import { Snapshot } from "../../src/snapshot"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import { MessageID, PartID, SessionID } from "../../src/session/schema" import { MessageID, PartID, SessionID } from "../../src/session/schema"
@@ -4,7 +4,7 @@ import { Session as SessionNs } from "../../src/session"
import { Bus } from "../../src/bus" import { Bus } from "../../src/bus"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { MessageID, PartID, type SessionID } from "../../src/session/schema" import { MessageID, PartID, type SessionID } from "../../src/session/schema"
import { AppRuntime } from "../../src/effect/app-runtime" import { AppRuntime } from "../../src/effect/app-runtime"
import { tmpdir } from "../fixture/fixture" import { tmpdir } from "../fixture/fixture"
@@ -17,11 +17,11 @@ import { FetchHttpClient } from "effect/unstable/http"
import fs from "fs/promises" import fs from "fs/promises"
import path from "path" import path from "path"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { LLM } from "../../src/session/llm" import { LLM } from "../../src/session"
import { SessionPrompt } from "../../src/session/prompt" import { SessionPrompt } from "../../src/session"
import { SessionRevert } from "../../src/session/revert" import { SessionRevert } from "../../src/session"
import { SessionSummary } from "../../src/session/summary" import { SessionSummary } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import { provideTmpdirServer } from "../fixture/fixture" import { provideTmpdirServer } from "../fixture/fixture"
import { testEffect } from "../lib/effect" import { testEffect } from "../lib/effect"
@@ -42,13 +42,13 @@ import { Provider as ProviderSvc } from "../../src/provider"
import { Env } from "../../src/env" import { Env } from "../../src/env"
import { Question } from "../../src/question" import { Question } from "../../src/question"
import { Skill } from "../../src/skill" import { Skill } from "../../src/skill"
import { SystemPrompt } from "../../src/session/system" import { SystemPrompt } from "../../src/session"
import { Todo } from "../../src/session/todo" import { Todo } from "../../src/session"
import { SessionCompaction } from "../../src/session/compaction" import { SessionCompaction } from "../../src/session"
import { Instruction } from "../../src/session/instruction" import { Instruction } from "../../src/session"
import { SessionProcessor } from "../../src/session/processor" import { SessionProcessor } from "../../src/session"
import { SessionRunState } from "../../src/session/run-state" import { SessionRunState } from "../../src/session"
import { SessionStatus } from "../../src/session/status" import { SessionStatus } from "../../src/session"
import { Snapshot } from "../../src/snapshot" import { Snapshot } from "../../src/snapshot"
import { ToolRegistry } from "../../src/tool/registry" import { ToolRegistry } from "../../src/tool/registry"
import { Truncate } from "../../src/tool/truncate" import { Truncate } from "../../src/tool/truncate"
@@ -2,10 +2,10 @@ import { describe, expect, test } from "bun:test"
import path from "path" import path from "path"
import { Effect, Layer } from "effect" import { Effect, Layer } from "effect"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { SessionPrompt } from "../../src/session/prompt" import { SessionPrompt } from "../../src/session"
import { Log } from "../../src/util/log" import { Log } from "../../src/util/log"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
const projectRoot = path.join(__dirname, "../..") const projectRoot = path.join(__dirname, "../..")
Log.init({ print: false }) Log.init({ print: false })
@@ -1,6 +1,6 @@
import { describe, expect, test } from "bun:test" import { describe, expect, test } from "bun:test"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import { SessionPrompt } from "../../src/session/prompt" import { SessionPrompt } from "../../src/session"
import { SessionID, MessageID } from "../../src/session/schema" import { SessionID, MessageID } from "../../src/session/schema"
describe("structured-output.OutputFormat", () => { describe("structured-output.OutputFormat", () => {
@@ -3,7 +3,7 @@ import path from "path"
import { Effect } from "effect" import { Effect } from "effect"
import { Agent } from "../../src/agent/agent" import { Agent } from "../../src/agent/agent"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { SystemPrompt } from "../../src/session/system" import { SystemPrompt } from "../../src/session"
import { provideInstance, tmpdir } from "../fixture/fixture" import { provideInstance, tmpdir } from "../fixture/fixture"
function load<A>(dir: string, fn: (svc: Agent.Interface) => Effect.Effect<A>) { function load<A>(dir: string, fn: (svc: Agent.Interface) => Effect.Effect<A>) {
+1 -1
View File
@@ -9,7 +9,7 @@ import { LSP } from "../../src/lsp"
import { Permission } from "../../src/permission" import { Permission } from "../../src/permission"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { SessionID, MessageID } from "../../src/session/schema" import { SessionID, MessageID } from "../../src/session/schema"
import { Instruction } from "../../src/session/instruction" import { Instruction } from "../../src/session"
import { ReadTool } from "../../src/tool/read" import { ReadTool } from "../../src/tool/read"
import { Truncate } from "../../src/tool/truncate" import { Truncate } from "../../src/tool/truncate"
import { Tool } from "../../src/tool/tool" import { Tool } from "../../src/tool/tool"
+2 -2
View File
@@ -5,8 +5,8 @@ import { Config } from "../../src/config"
import * as CrossSpawnSpawner from "../../src/effect/cross-spawn-spawner" import * as CrossSpawnSpawner from "../../src/effect/cross-spawn-spawner"
import { Instance } from "../../src/project/instance" import { Instance } from "../../src/project/instance"
import { Session } from "../../src/session" import { Session } from "../../src/session"
import { MessageV2 } from "../../src/session/message-v2" import { MessageV2 } from "../../src/session"
import type { SessionPrompt } from "../../src/session/prompt" import type { SessionPrompt } from "../../src/session"
import { MessageID, PartID } from "../../src/session/schema" import { MessageID, PartID } from "../../src/session/schema"
import { ModelID, ProviderID } from "../../src/provider/schema" import { ModelID, ProviderID } from "../../src/provider/schema"
import { TaskTool, type TaskPromptOps } from "../../src/tool/task" import { TaskTool, type TaskPromptOps } from "../../src/tool/task"