refactor(core): route openai-compatible natively

2026-08-08 10:09:52 -04:00 · 2026-08-07 17:06:21 +00:00
44 changed files with 779 additions and 1294 deletions
@@ -25,20 +25,8 @@ import { ToolSchemaProjection } from "./utils/tool-schema"

 const ADAPTER = "gemini"
 const MEDIA_MIMES = new Set<string>(ProviderShared.MEDIA_MIMES)
-// Google documents this sentinel for replaying Gemini 3 function calls after their original signature was lost.
-const SKIP_THOUGHT_SIGNATURE_VALIDATOR = "skip_thought_signature_validator"
 export const DEFAULT_BASE_URL = "https://generativelanguage.googleapis.com/v1beta"

-// Gemini 3 rejects replayed function calls without a thought signature. Google's SDKs avoid that in normal chats by
-// retaining complete model responses, but OpenCode reconstructs durable history and may encounter an unsigned call
-// from an older or external session. Model IDs are open-ended, so unknown Gemini aliases inherit current behavior.
-const requiresThoughtSignatureFallback = (modelID: string) => {
-  if (!/(^|\/)gemini-/i.test(modelID)) return false
-  if (/(^|\/)gemini-(?:1|2)(?:[.-]|$)/i.test(modelID)) return false
-  if (/(^|\/)gemini-pro(?:-vision)?$/i.test(modelID)) return false
-  return !/(^|\/)gemini-robotics-er-1\.5(?:[.-]|$)/i.test(modelID)
-}
-
 export interface OptionsInput {
  readonly [key: string]: unknown
  readonly cachedContent?: string
@@ -157,9 +145,6 @@ const GeminiGenerationConfig = Schema.Struct({
  temperature: Schema.optional(Schema.Number),
  topP: Schema.optional(Schema.Number),
  topK: Schema.optional(Schema.Number),
-  frequencyPenalty: Schema.optional(Schema.Number),
-  presencePenalty: Schema.optional(Schema.Number),
-  seed: Schema.optional(Schema.Number),
  stopSequences: optionalArray(Schema.String),
  thinkingConfig: Schema.optional(GeminiThinkingConfig),
 })
@@ -217,13 +202,11 @@ interface ParserState {
 //    keys on non-object scalars. Mirrors OpenCode's historical Gemini rules.
 //
 // 2. Project — lossy mapping from JSON Schema to Gemini's schema dialect:
-//    drop empty root parameter schemas while preserving nested empty objects,
-//    expand type arrays into `anyOf`, derive `nullable: true` from null members,
-//    coerce `const` to `[const]` enum, recurse properties/items, and propagate
+//    drop empty objects, derive `nullable: true` from `type: [..., "null"]`,
+//    coerce `const` to `[const]` enum, recurse properties/items, propagate
 //    only an allowlisted set of keys (description, required, format, type,
-//    nullable, enum, properties, items, allOf, anyOf, oneOf, minLength).
-//    Anything outside the allowlist (e.g. `additionalProperties`, `$ref`) is
-//    silently dropped.
+//    properties, items, allOf, anyOf, oneOf, minLength). Anything outside the
+//    allowlist (e.g. `additionalProperties`, `$ref`) is silently dropped.
 //
 // Sanitize runs first, then project. The implementation lives in
 // `utils/gemini-tool-schema` so this protocol keeps the same shape as the other
@@ -299,8 +282,6 @@ const lowerMessages = Effect.fn("Gemini.lowerMessages")(function* (request: LLMR

    if (message.role === "assistant") {
      const parts: Array<Schema.Schema.Type<typeof GeminiContentPart>> = []
-      // Parallel Gemini 3 calls may carry one signature on the first call; unsigned sibling calls are valid.
-      let hasSignedToolCall = false
      for (const part of message.content) {
        if (!ProviderShared.supportsContent(part, ["text", "reasoning", "tool-call"]))
          return yield* ProviderShared.unsupportedContent("Gemini", "assistant", ["text", "reasoning", "tool-call"])
@@ -313,17 +294,7 @@ const lowerMessages = Effect.fn("Gemini.lowerMessages")(function* (request: LLMR
          continue
        }
        if (part.type === "tool-call") {
-          const lowered = lowerToolCall(part)
-          const signature = lowered.thoughtSignature
-          parts.push({
-            ...lowered,
-            thoughtSignature:
-              signature ??
-              (requiresThoughtSignatureFallback(request.model.id) && !hasSignedToolCall
-                ? SKIP_THOUGHT_SIGNATURE_VALIDATOR
-                : undefined),
-          })
-          if (signature !== undefined) hasSignedToolCall = true
+          parts.push(lowerToolCall(part))
          continue
        }
      }
@@ -417,9 +388,6 @@ const fromRequest = Effect.fn("Gemini.fromRequest")(function* (request: LLMReque
    temperature: generation?.temperature,
    topP: generation?.topP,
    topK: generation?.topK,
-    frequencyPenalty: generation?.frequencyPenalty,
-    presencePenalty: generation?.presencePenalty,
-    seed: generation?.seed,
    stopSequences: generation?.stop,
    thinkingConfig: options.thinkingConfig,
  }
@@ -90,15 +90,10 @@ const OpenResponsesFunctionCallOutput = Schema.Union([
 ])

 export const InputItem = Schema.Union([
-  Schema.Struct({ role: Schema.tag("system"), id: Schema.optionalKey(Schema.String), content: Schema.String }),
-  Schema.Struct({
-    role: Schema.tag("user"),
-    id: Schema.optionalKey(Schema.String),
-    content: Schema.Array(OpenResponsesInputContent),
-  }),
+  Schema.Struct({ role: Schema.tag("system"), content: Schema.String }),
+  Schema.Struct({ role: Schema.tag("user"), content: Schema.Array(OpenResponsesInputContent) }),
  Schema.Struct({
    role: Schema.tag("assistant"),
-    id: Schema.optionalKey(Schema.String),
    content: Schema.Array(OpenResponsesOutputText),
    phase: Schema.optionalKey(MessagePhase),
  }),
@@ -106,23 +101,19 @@ export const InputItem = Schema.Union([
  OpenResponsesItemReference,
  Schema.Struct({
    type: Schema.tag("function_call"),
-    id: Schema.optionalKey(Schema.String),
    call_id: Schema.String,
    name: Schema.String,
    arguments: Schema.String,
  }),
  Schema.Struct({
    type: Schema.tag("function_call_output"),
-    id: Schema.optionalKey(Schema.String),
    call_id: Schema.String,
    output: OpenResponsesFunctionCallOutput,
  }),
 ])
 type OpenResponsesInputItem = Schema.Schema.Type<typeof InputItem>
-type ProviderInputItem = Readonly<Record<string, unknown>> & { readonly type: string; readonly id?: string }
 type LoweredInputItem =
  | OpenResponsesInputItem
-  | ProviderInputItem
  | {
      readonly role: "assistant"
      readonly content: ReadonlyArray<{ readonly type: "output_text"; readonly text: string }>
@@ -137,7 +128,7 @@ type OpenResponsesReasoningInput = {
  summary: Array<{ type: "summary_text"; text: string }>
  encrypted_content?: string | null
 }
-type OpenResponsesReasoningReplay = Omit<OpenResponsesReasoningInput, "id"> & { id?: string }
+type OpenResponsesReasoningReplay = Omit<OpenResponsesReasoningInput, "id">

 export const Tool = Schema.Struct({
  type: Schema.tag("function"),
@@ -263,11 +254,6 @@ export interface Extension {
    readonly request: LLMRequest
  }) => MediaInput | undefined
  readonly messagePhase?: (value: unknown) => MessagePhase | null | undefined
-  readonly lowerProviderItem?: (
-    part: ToolResultPart,
-    providerMetadataKey: string,
-    store: boolean | undefined,
-  ) => ProviderInputItem | undefined
 }

 const BASE: Extension = { id: ADAPTER, name: NAME }
@@ -324,47 +310,35 @@ export const lowerToolChoice = (protocolName: string, toolChoice: NonNullable<LL
    tool: (toolName) => ({ type: "function" as const, name: toolName }),
  })

-const metadataItemID = (
-  part: { readonly itemId?: string; readonly providerMetadata?: ProviderMetadata },
-  providerMetadataKey: string,
-) => {
-  if (part.itemId) return part.itemId
-  const metadata = part.providerMetadata?.[providerMetadataKey]
-  return ProviderShared.isRecord(metadata) && typeof metadata.itemId === "string" && metadata.itemId.length > 0
-    ? metadata.itemId
-    : undefined
-}
-
-const lowerToolCall = (part: ToolCallPart, providerMetadataKey: string): OpenResponsesInputItem => {
-  const itemId = metadataItemID(part, providerMetadataKey)
-  return {
-    type: "function_call",
-    ...(itemId === undefined ? {} : { id: itemId }),
-    call_id: part.id,
-    name: part.name,
-    arguments: ProviderShared.encodeJson(part.input),
-  }
-}
+const lowerToolCall = (part: ToolCallPart): OpenResponsesInputItem => ({
+  type: "function_call",
+  call_id: part.id,
+  name: part.name,
+  arguments: ProviderShared.encodeJson(part.input),
+})

 const lowerReasoning = (part: ReasoningPart, providerMetadataKey: string): OpenResponsesReasoningInput | undefined => {
  const metadata = part.providerMetadata?.[providerMetadataKey]
-  const itemId = metadataItemID(part, providerMetadataKey)
-  if (!itemId) return undefined
+  if (!ProviderShared.isRecord(metadata) || typeof metadata.itemId !== "string" || metadata.itemId.length === 0)
+    return undefined
  const encryptedContent =
-    ProviderShared.isRecord(metadata) &&
-    (typeof metadata.reasoningEncryptedContent === "string" || metadata.reasoningEncryptedContent === null)
+    typeof metadata.reasoningEncryptedContent === "string" || metadata.reasoningEncryptedContent === null
      ? metadata.reasoningEncryptedContent
      : undefined
  return {
    type: "reasoning",
-    id: itemId,
+    id: metadata.itemId,
    summary: part.text.length > 0 ? [{ type: "summary_text", text: part.text }] : [],
    encrypted_content: encryptedContent,
  }
 }

-const hostedToolItemID = (part: ToolResultPart, providerMetadataKey: string) =>
-  metadataItemID(part, providerMetadataKey)
+const hostedToolItemID = (part: ToolResultPart, providerMetadataKey: string) => {
+  const metadata = part.providerMetadata?.[providerMetadataKey]
+  return ProviderShared.isRecord(metadata) && typeof metadata.itemId === "string" && metadata.itemId.length > 0
+    ? metadata.itemId
+    : undefined
+}

 const lowerMedia = Effect.fn("OpenResponses.lowerMedia")(function* (
  part: MediaPart,
@@ -423,18 +397,17 @@ const lowerToolResultOutput = Effect.fn("OpenResponses.lowerToolResultOutput")(f
 })

 const lowerMessages = Effect.fn("OpenResponses.lowerMessages")(function* (request: LLMRequest, extension: Extension) {
-  const options = OpenResponsesOptions.resolve(request)
  const system: LoweredInputItem[] =
    request.system.length === 0 ? [] : [{ role: "system", content: ProviderShared.joinText(request.system) }]
  const input: LoweredInputItem[] = [...system]
-  const store = options.store
+  const store = OpenResponsesOptions.resolve(request).store
  const providerMetadataKey = request.model.route.providerMetadataKey ?? "openresponses"

  for (const message of request.messages) {
    if (message.role === "system") {
      const part = yield* ProviderShared.wrappedSystemUpdate(extension.name, message)
      const previous = input.at(-1)
-      if (previous && "role" in previous && previous.role === "user" && Array.isArray(previous.content))
+      if (previous && "role" in previous && previous.role === "user")
        input[input.length - 1] = {
          role: "user",
          content: [...previous.content, { type: "input_text", text: part.text }],
@@ -454,24 +427,24 @@ const lowerMessages = Effect.fn("OpenResponses.lowerMessages")(function* (reques
    if (message.role === "assistant") {
      const content: TextPart[] = []
      const reasoningItems: Record<string, OpenResponsesReasoningReplay> = {}
-      const hostedToolItems = new Set<string>()
+      const reasoningReferences = new Set<string>()
+      const hostedToolReferences = new Set<string>()
      const flushText = () => {
        if (content.length === 0) return
-        const groups = content.reduce<
-          Array<{ phase: MessagePhase | null | undefined; itemId: string | undefined; parts: TextPart[] }>
-        >((groups, part) => {
-          const metadata = part.providerMetadata?.[providerMetadataKey]
-          const phase = ProviderShared.isRecord(metadata) ? messagePhase(metadata.phase, extension) : undefined
-          const itemId = metadataItemID(part, providerMetadataKey)
-          const group = groups.at(-1)
-          if (group && group.phase === phase && group.itemId === itemId) group.parts.push(part)
-          else groups.push({ phase, itemId, parts: [part] })
-          return groups
-        }, [])
+        const groups = content.reduce<Array<{ phase: MessagePhase | null | undefined; parts: TextPart[] }>>(
+          (groups, part) => {
+            const metadata = part.providerMetadata?.[providerMetadataKey]
+            const phase = ProviderShared.isRecord(metadata) ? messagePhase(metadata.phase, extension) : undefined
+            const group = groups.at(-1)
+            if (group && group.phase === phase) group.parts.push(part)
+            else groups.push({ phase, parts: [part] })
+            return groups
+          },
+          [],
+        )
        input.push(
          ...groups.map((group) => ({
            role: "assistant" as const,
-            ...(group.itemId === undefined ? {} : { id: group.itemId }),
            content: group.parts.map((part) => ({ type: "output_text" as const, text: part.text })),
            ...(group.phase === undefined ? {} : { phase: group.phase }),
          })),
@@ -487,6 +460,11 @@ const lowerMessages = Effect.fn("OpenResponses.lowerMessages")(function* (reques
          flushText()
          const reasoning = lowerReasoning(part, providerMetadataKey)
          if (!reasoning) continue
+          if (store !== false) {
+            if (!reasoningReferences.has(reasoning.id)) input.push({ type: "item_reference", id: reasoning.id })
+            reasoningReferences.add(reasoning.id)
+            continue
+          }
          const existing = reasoningItems[reasoning.id]
          if (existing) {
            existing.summary.push(...reasoning.summary)
@@ -496,7 +474,6 @@ const lowerMessages = Effect.fn("OpenResponses.lowerMessages")(function* (reques
          }
          const replay = {
            type: reasoning.type,
-            id: reasoning.id,
            summary: reasoning.summary,
            encrypted_content: reasoning.encrypted_content,
          }
@@ -507,24 +484,22 @@ const lowerMessages = Effect.fn("OpenResponses.lowerMessages")(function* (reques
        if (part.type === "tool-call") {
          flushText()
          if (part.providerExecuted === true) continue
-          input.push(lowerToolCall(part, providerMetadataKey))
+          input.push(lowerToolCall(part))
          continue
        }
        if (part.type === "tool-result" && part.providerExecuted === true) {
          flushText()
          const itemID = hostedToolItemID(part, providerMetadataKey)
-          const providerItem = extension.lowerProviderItem?.(part, providerMetadataKey, store)
-          if (providerItem && itemID && !hostedToolItems.has(itemID)) input.push(providerItem)
-          if (!providerItem && store !== false && itemID && !hostedToolItems.has(itemID))
+          if (store !== false && itemID && !hostedToolReferences.has(itemID))
            input.push({ type: "item_reference", id: itemID })
-          if (!providerItem && store === false && part.result.type === "content") {
+          if (store === false && part.result.type === "content") {
            const content: ReadonlyArray<Content> = part.result.value
            input.push({
              role: "user",
              content: yield* Effect.forEach(content, (item) => lowerToolResultContentItem(item, request, extension)),
            })
          }
-          if (itemID) hostedToolItems.add(itemID)
+          if (itemID) hostedToolReferences.add(itemID)
          continue
        }
        return yield* ProviderShared.unsupportedContent(extension.name, "assistant", [
@@ -666,9 +641,9 @@ const onOutputTextDelta = (state: ParserState, event: Event, id: string): StepRe
  if (!event.delta) return [state, NO_EVENTS]
  const events: LLMEvent[] = []
  const phase = state.messagePhases[id]
-  const metadata = providerMetadata(state, { itemId: id, ...(phase === undefined ? {} : { phase }) })
-  const lifecycle = Lifecycle.textStart(state.lifecycle, events, id, metadata, id)
-  return [{ ...state, lifecycle: Lifecycle.textDelta(lifecycle, events, id, event.delta, metadata, id) }, events]
+  const metadata = phase === undefined ? undefined : providerMetadata(state, { phase })
+  const lifecycle = Lifecycle.textStart(state.lifecycle, events, id, metadata)
+  return [{ ...state, lifecycle: Lifecycle.textDelta(lifecycle, events, id, event.delta) }, events]
 }

 const onOutputTextDone = (state: ParserState, event: Event, id: string): StepResult => {
@@ -677,13 +652,7 @@ const onOutputTextDone = (state: ParserState, event: Event, id: string): StepRes
    return onOutputTextDelta(state, { ...event, delta: event.text }, id)
  }
  const events: LLMEvent[] = []
-  return [
-    {
-      ...state,
-      lifecycle: Lifecycle.textEnd(state.lifecycle, events, id, providerMetadata(state, { itemId: id }), id),
-    },
-    events,
-  ]
+  return [{ ...state, lifecycle: Lifecycle.textEnd(state.lifecycle, events, id) }, events]
 }

 export const onReasoningDelta = (state: ParserState, event: Event, itemID: string): StepResult => {
@@ -694,14 +663,7 @@ export const onReasoningDelta = (state: ParserState, event: Event, itemID: strin
  return [
    {
      ...state,
-      lifecycle: Lifecycle.reasoningDelta(
-        state.lifecycle,
-        events,
-        id,
-        event.delta,
-        providerMetadata(state, { itemId: itemID }),
-        itemID,
-      ),
+      lifecycle: Lifecycle.reasoningDelta(state.lifecycle, events, id, event.delta),
    },
    events,
  ]
@@ -743,13 +705,7 @@ const onOutputItemAdded = (state: ParserState, event: Event): StepResult => {
    return [
      {
        ...state,
-        lifecycle: Lifecycle.reasoningStart(
-          state.lifecycle,
-          events,
-          `${item.id}:0`,
-          reasoningMetadata(state, item),
-          item.id,
-        ),
+        lifecycle: Lifecycle.reasoningStart(state.lifecycle, events, `${item.id}:0`, reasoningMetadata(state, item)),
        reasoningItems: {
          ...state.reasoningItems,
          [item.id]: { encryptedContent: item.encrypted_content, summaryParts: { 0: "active" } },
@@ -768,7 +724,6 @@ const onOutputItemAdded = (state: ParserState, event: Event): StepResult => {
      lifecycle,
      tools: ToolStream.start(state.tools, item.id, {
        id: item.call_id ?? item.id,
-        itemId: item.id,
        name: item.name ?? "",
        input: item.arguments ?? "",
        providerMetadata: metadata,
@@ -776,12 +731,7 @@ const onOutputItemAdded = (state: ParserState, event: Event): StepResult => {
    },
    [
      ...events,
-      LLMEvent.toolInputStart({
-        id: item.call_id ?? item.id,
-        itemId: item.id,
-        name: item.name ?? "",
-        providerMetadata: metadata,
-      }),
+      LLMEvent.toolInputStart({ id: item.call_id ?? item.id, name: item.name ?? "", providerMetadata: metadata }),
    ],
  ]
 }
@@ -800,7 +750,6 @@ const onReasoningSummaryPartAdded = (state: ParserState, event: Event): StepResu
          events,
          `${event.item_id}:0`,
          providerMetadata(state, { itemId: event.item_id, reasoningEncryptedContent: null }),
-          event.item_id,
        ),
        reasoningItems: {
          ...state.reasoningItems,
@@ -821,7 +770,6 @@ const onReasoningSummaryPartAdded = (state: ParserState, event: Event): StepResu
          events,
          `${event.item_id}:${entry[0]}`,
          providerMetadata(state, { itemId: event.item_id }),
-          event.item_id,
        ),
      state.lifecycle,
    )
@@ -833,7 +781,6 @@ const onReasoningSummaryPartAdded = (state: ParserState, event: Event): StepResu
        events,
        `${event.item_id}:${event.summary_index}`,
        providerMetadata(state, { itemId: event.item_id, reasoningEncryptedContent: item.encryptedContent ?? null }),
-        event.item_id,
      ),
      reasoningItems: {
        ...state.reasoningItems,
@@ -869,7 +816,6 @@ const onReasoningSummaryPartDone = (state: ParserState, event: Event): StepResul
              events,
              `${event.item_id}:${event.summary_index}`,
              providerMetadata(state, { itemId: event.item_id }),
-              event.item_id,
            )
          : state.lifecycle,
      reasoningItems: {
@@ -924,8 +870,7 @@ const onOutputItemDone = Effect.fn("OpenResponses.onOutputItemDone")(function* (
          state.lifecycle,
          events,
          item.id,
-          providerMetadata(state, { itemId: item.id, ...(phase === undefined ? {} : { phase }) }),
-          item.id,
+          phase === undefined ? undefined : providerMetadata(state, { phase }),
        ),
        messageItems,
        messagePhases,
@@ -936,15 +881,9 @@ const onOutputItemDone = Effect.fn("OpenResponses.onOutputItemDone")(function* (

  if (item.type === "function_call") {
    if (!item.id || !item.call_id || !item.name) return [state, NO_EVENTS] satisfies StepResult
-    const metadata = providerMetadata(state, { itemId: item.id })
    const tools = state.tools[item.id]
      ? state.tools
-      : ToolStream.start(state.tools, item.id, {
-          id: item.call_id,
-          itemId: item.id,
-          name: item.name,
-          providerMetadata: metadata,
-        })
+      : ToolStream.start(state.tools, item.id, { id: item.call_id, name: item.name })
    const result =
      item.arguments === undefined
        ? yield* ToolStream.finish(state.id, tools, item.id)
@@ -974,7 +913,7 @@ const onOutputItemDone = Effect.fn("OpenResponses.onOutputItemDone")(function* (
      const lifecycle = Object.entries(reasoningItem.summaryParts)
        .filter((entry) => entry[1] === "active" || entry[1] === "can-conclude")
        .reduce(
-          (lifecycle, entry) => Lifecycle.reasoningEnd(lifecycle, events, `${item.id}:${entry[0]}`, metadata, item.id),
+          (lifecycle, entry) => Lifecycle.reasoningEnd(lifecycle, events, `${item.id}:${entry[0]}`, metadata),
          state.lifecycle,
        )
      const { [item.id]: _removed, ...reasoningItems } = state.reasoningItems
@@ -982,12 +921,12 @@ const onOutputItemDone = Effect.fn("OpenResponses.onOutputItemDone")(function* (
    }
    if (!state.lifecycle.reasoning.has(item.id)) {
      const lifecycle = Lifecycle.stepStart(state.lifecycle, events)
-      events.push(LLMEvent.reasoningStart({ id: item.id, itemId: item.id, providerMetadata: metadata }))
-      events.push(LLMEvent.reasoningEnd({ id: item.id, itemId: item.id, providerMetadata: metadata }))
+      events.push(LLMEvent.reasoningStart({ id: item.id, providerMetadata: metadata }))
+      events.push(LLMEvent.reasoningEnd({ id: item.id, providerMetadata: metadata }))
      return [{ ...state, lifecycle }, events] satisfies StepResult
    }
    return [
-      { ...state, lifecycle: Lifecycle.reasoningEnd(state.lifecycle, events, item.id, metadata, item.id) },
+      { ...state, lifecycle: Lifecycle.reasoningEnd(state.lifecycle, events, item.id, metadata) },
      events,
    ] satisfies StepResult
  }
@@ -38,14 +38,10 @@ const OpenAIResponsesToolChoice = Schema.Union([
 const OpenAIResponsesInputItem = Schema.Union([
  Schema.Struct({
    role: Schema.tag("assistant"),
-    id: Schema.optionalKey(Schema.String),
    content: Schema.Array(Schema.Struct({ type: Schema.tag("output_text"), text: Schema.String })),
    phase: Schema.optionalKey(Schema.NullOr(OpenResponses.MessagePhase)),
  }),
  OpenResponses.InputItem,
-  Schema.StructWithRest(Schema.Struct({ type: Schema.String, id: Schema.optionalKey(Schema.String) }), [
-    Schema.Record(Schema.String, Schema.Unknown),
-  ]),
 ])

 const OpenAIResponsesCoreFields = {
@@ -84,25 +80,6 @@ const extension = {
      mime_type: media.mime,
    }
  },
-  lowerProviderItem: (part, providerMetadataKey, store) => {
-    const metadata = part.providerMetadata?.[providerMetadataKey]
-    if (!ProviderShared.isRecord(metadata) || !ProviderShared.isRecord(metadata.item)) return undefined
-    if (typeof metadata.item.type !== "string") return undefined
-    const id = typeof metadata.item.id === "string" ? metadata.item.id : undefined
-    // The public API requires stored state to replay image-generation items. In
-    // stateless mode, lower the generated file through the existing user-image fallback.
-    if (metadata.item.type === "image_generation_call" && store === false) return undefined
-    if (metadata.item.type === "image_generation_call")
-      return {
-        type: metadata.item.type,
-        ...(id === undefined ? {} : { id }),
-        ...(typeof metadata.item.status === "string" ? { status: metadata.item.status } : {}),
-        ...(typeof metadata.item.revised_prompt === "string" ? { revised_prompt: metadata.item.revised_prompt } : {}),
-        ...(typeof metadata.item.result === "string" ? { result: metadata.item.result } : {}),
-      }
-    const item: Record<string, unknown> & { type: string } = { ...metadata.item, type: metadata.item.type }
-    return item
-  },
 } satisfies OpenResponses.Extension

 const nativeImageToolInput = (tool: ToolDefinition) => {
@@ -218,29 +195,23 @@ const onHostedToolDone = Effect.fn("OpenAIResponses.onHostedToolDone")(function*
  item: HostedToolItem,
 ) {
  const tool = HOSTED_TOOLS[item.type]
-  const callMetadata = OpenResponses.providerMetadata(state, { itemId: item.id })
-  const resultMetadata = OpenResponses.providerMetadata(
-    state,
-    item.type === "image_generation_call" ? { itemId: item.id } : { itemId: item.id, item },
-  )
+  const providerMetadata = OpenResponses.providerMetadata(state, { itemId: item.id })
  const events: LLMEvent[] = []
  const lifecycle = Lifecycle.stepStart(state.lifecycle, events)
  events.push(
    LLMEvent.toolCall({
      id: item.id,
-      itemId: item.id,
      name: tool.name,
      input: tool.input(item),
      providerExecuted: true,
-      providerMetadata: callMetadata,
+      providerMetadata,
    }),
    LLMEvent.toolResult({
      id: item.id,
-      itemId: item.id,
      name: tool.name,
      result: yield* hostedToolResult(item),
      providerExecuted: true,
-      providerMetadata: resultMetadata,
+      providerMetadata,
    }),
  )
  return [{ ...state, lifecycle }, events] satisfies OpenResponses.StepResult
@@ -61,57 +61,37 @@ const emptyObjectSchema = (schema: Record<string, unknown>) =>
  (!isRecord(schema.properties) || Object.keys(schema.properties).length === 0) &&
  !schema.additionalProperties

-const projectNode = (schema: unknown, nested = false): Record<string, unknown> | undefined => {
+const projectNode = (schema: unknown): Record<string, unknown> | undefined => {
  if (!isRecord(schema)) return undefined
-  if (!nested && emptyObjectSchema(schema)) return undefined
-  const types = Array.isArray(schema.type) ? schema.type.filter((type) => type !== "null") : undefined
-  const anyOf = Array.isArray(schema.anyOf) ? schema.anyOf : undefined
-  const hasNullAnyOf = anyOf?.some((item) => isRecord(item) && item.type === "null") ?? false
-  const anyOfTypes = hasNullAnyOf ? anyOf?.filter((item) => !isRecord(item) || item.type !== "null") : anyOf
-  const flattenedAnyOf = hasNullAnyOf && anyOfTypes?.length === 1 ? projectNode(anyOfTypes[0], true) : undefined
-  const result = Object.fromEntries(
+  if (emptyObjectSchema(schema)) return undefined
+  return Object.fromEntries(
    [
      ["description", schema.description],
      ["required", schema.required],
      ["format", schema.format],
-      ["type", types ? (types.length === 0 ? "null" : undefined) : schema.type],
-      [
-        "nullable",
-        (Array.isArray(schema.type) && schema.type.includes("null") && types && types.length > 0) || hasNullAnyOf
-          ? true
-          : undefined,
-      ],
+      ["type", Array.isArray(schema.type) ? schema.type.filter((type) => type !== "null")[0] : schema.type],
+      ["nullable", Array.isArray(schema.type) && schema.type.includes("null") ? true : undefined],
      ["enum", schema.const !== undefined ? [schema.const] : schema.enum],
      [
        "properties",
        isRecord(schema.properties)
-          ? Object.fromEntries(Object.entries(schema.properties).map(([key, value]) => [key, projectNode(value, true)]))
+          ? Object.fromEntries(Object.entries(schema.properties).map(([key, value]) => [key, projectNode(value)]))
          : undefined,
      ],
      [
        "items",
        Array.isArray(schema.items)
-          ? schema.items.map((item) => projectNode(item, true))
+          ? schema.items.map(projectNode)
          : schema.items === undefined
            ? undefined
-            : projectNode(schema.items, true),
+            : projectNode(schema.items),
      ],
-      ["allOf", Array.isArray(schema.allOf) ? schema.allOf.map((item) => projectNode(item, true)) : undefined],
-      [
-        "anyOf",
-        anyOfTypes
-          ? hasNullAnyOf && anyOfTypes.length === 1
-            ? undefined
-            : anyOfTypes.map((item) => projectNode(item, true))
-          : types && types.length > 0
-            ? types.map((type) => ({ type }))
-            : undefined,
-      ],
-      ["oneOf", Array.isArray(schema.oneOf) ? schema.oneOf.map((item) => projectNode(item, true)) : undefined],
+      ["allOf", Array.isArray(schema.allOf) ? schema.allOf.map(projectNode) : undefined],
+      ["anyOf", Array.isArray(schema.anyOf) ? schema.anyOf.map(projectNode) : undefined],
+      ["oneOf", Array.isArray(schema.oneOf) ? schema.oneOf.map(projectNode) : undefined],
      ["minLength", schema.minLength],
    ].filter((entry) => entry[1] !== undefined),
  )
-  return flattenedAnyOf ? { ...result, ...flattenedAnyOf } : result
 }

 export const convert = (schema: unknown) => projectNode(sanitizeNode(schema))
@@ -1,10 +1,4 @@
-import {
-  LLMEvent,
-  type FinishReasonDetails,
-  type ProviderMetadata,
-  type ResponseItemID,
-  type Usage,
-} from "../../schema"
+import { LLMEvent, type FinishReasonDetails, type ProviderMetadata, type Usage } from "../../schema"

 export interface State {
  readonly stepStarted: boolean
@@ -20,29 +14,16 @@ export const stepStart = (state: State, events: LLMEvent[]): State => {
  return { ...state, stepStarted: true }
 }

-export const textStart = (
-  state: State,
-  events: LLMEvent[],
-  id: string,
-  providerMetadata?: ProviderMetadata,
-  itemId?: ResponseItemID,
-): State => {
+export const textStart = (state: State, events: LLMEvent[], id: string, providerMetadata?: ProviderMetadata): State => {
  if (state.text.has(id)) return state
  const stepped = stepStart(state, events)
-  events.push(LLMEvent.textStart({ id, ...(itemId === undefined ? {} : { itemId }), providerMetadata }))
+  events.push(LLMEvent.textStart({ id, providerMetadata }))
  return { ...stepped, text: new Set([...stepped.text, id]) }
 }

-export const textDelta = (
-  state: State,
-  events: LLMEvent[],
-  id: string,
-  text: string,
-  providerMetadata?: ProviderMetadata,
-  itemId?: ResponseItemID,
-): State => {
-  const started = textStart(state, events, id, providerMetadata, itemId)
-  events.push(LLMEvent.textDelta({ id, ...(itemId === undefined ? {} : { itemId }), text, providerMetadata }))
+export const textDelta = (state: State, events: LLMEvent[], id: string, text: string): State => {
+  const started = textStart(state, events, id)
+  events.push(LLMEvent.textDelta({ id, text }))
  return started
 }

@@ -51,11 +32,10 @@ export const reasoningStart = (
  events: LLMEvent[],
  id: string,
  providerMetadata?: ProviderMetadata,
-  itemId?: ResponseItemID,
 ): State => {
  if (state.reasoning.has(id)) return state
  const stepped = stepStart(state, events)
-  events.push(LLMEvent.reasoningStart({ id, ...(itemId === undefined ? {} : { itemId }), providerMetadata }))
+  events.push(LLMEvent.reasoningStart({ id, providerMetadata }))
  return { ...stepped, reasoning: new Set([...stepped.reasoning, id]) }
 }

@@ -65,10 +45,9 @@ export const reasoningDelta = (
  id: string,
  text: string,
  providerMetadata?: ProviderMetadata,
-  itemId?: ResponseItemID,
 ): State => {
-  const started = reasoningStart(state, events, id, providerMetadata, itemId)
-  events.push(LLMEvent.reasoningDelta({ id, ...(itemId === undefined ? {} : { itemId }), text, providerMetadata }))
+  const started = reasoningStart(state, events, id, providerMetadata)
+  events.push(LLMEvent.reasoningDelta({ id, text, providerMetadata }))
  return started
 }

@@ -77,26 +56,19 @@ export const reasoningEnd = (
  events: LLMEvent[],
  id: string,
  providerMetadata?: ProviderMetadata,
-  itemId?: ResponseItemID,
 ): State => {
  if (!state.reasoning.has(id)) return state
  const stepped = stepStart(state, events)
-  events.push(LLMEvent.reasoningEnd({ id, ...(itemId === undefined ? {} : { itemId }), providerMetadata }))
+  events.push(LLMEvent.reasoningEnd({ id, providerMetadata }))
  const reasoning = new Set(stepped.reasoning)
  reasoning.delete(id)
  return { ...stepped, reasoning }
 }

-export const textEnd = (
-  state: State,
-  events: LLMEvent[],
-  id: string,
-  providerMetadata?: ProviderMetadata,
-  itemId?: ResponseItemID,
-): State => {
+export const textEnd = (state: State, events: LLMEvent[], id: string, providerMetadata?: ProviderMetadata): State => {
  if (!state.text.has(id)) return state
  const stepped = stepStart(state, events)
-  events.push(LLMEvent.textEnd({ id, ...(itemId === undefined ? {} : { itemId }), providerMetadata }))
+  events.push(LLMEvent.textEnd({ id, providerMetadata }))
  const text = new Set(stepped.text)
  text.delete(id)
  return { ...stepped, text }
@@ -1,12 +1,5 @@
 import { Effect } from "effect"
-import {
-  AIError,
-  LLMEvent,
-  type ProviderMetadata,
-  type ResponseItemID,
-  type ToolCall,
-  type ToolInputError,
-} from "../../schema"
+import { AIError, LLMEvent, type ProviderMetadata, type ToolCall, type ToolInputError } from "../../schema"
 import { eventError, parseToolInput, type ToolAccumulator } from "../shared"

 type StreamKey = string | number
@@ -17,7 +10,6 @@ type StreamKey = string | number
 * so far, not the parsed object.
 */
 export interface PendingTool extends ToolAccumulator {
-  readonly itemId?: ResponseItemID
  readonly providerExecuted?: boolean
  readonly providerMetadata?: ProviderMetadata
 }
@@ -60,7 +52,6 @@ const withoutTool = <K extends StreamKey>(tools: State<K>, key: K): State<K> =>
 const inputStart = (tool: PendingTool) =>
  LLMEvent.toolInputStart({
    id: tool.id,
-    ...(tool.itemId === undefined ? {} : { itemId: tool.itemId }),
    name: tool.name,
    providerExecuted: tool.providerExecuted ? true : undefined,
    providerMetadata: tool.providerMetadata,
@@ -69,7 +60,6 @@ const inputStart = (tool: PendingTool) =>
 const inputDelta = (tool: PendingTool, text: string) =>
  LLMEvent.toolInputDelta({
    id: tool.id,
-    ...(tool.itemId === undefined ? {} : { itemId: tool.itemId }),
    name: tool.name,
    text,
  })
@@ -80,7 +70,6 @@ const toolCall = (route: string, tool: PendingTool, inputOverride?: string) => {
    Effect.map((input): ToolCall | ToolInputError =>
      LLMEvent.toolCall({
        id: tool.id,
-        ...(tool.itemId === undefined ? {} : { itemId: tool.itemId }),
        name: tool.name,
        input,
        providerExecuted: tool.providerExecuted ? true : undefined,
@@ -93,7 +82,6 @@ const toolCall = (route: string, tool: PendingTool, inputOverride?: string) => {
        : Effect.succeed(
            LLMEvent.toolInputError({
              id: tool.id,
-              ...(tool.itemId === undefined ? {} : { itemId: tool.itemId }),
              name: tool.name,
              raw,
            }),
@@ -105,15 +93,7 @@ const toolCall = (route: string, tool: PendingTool, inputOverride?: string) => {
 const finishEvents = (tool: PendingTool, event: ToolCall | ToolInputError): ReadonlyArray<LLMEvent> =>
  event.type === "tool-input-error"
    ? [event]
-    : [
-        LLMEvent.toolInputEnd({
-          id: tool.id,
-          ...(tool.itemId === undefined ? {} : { itemId: tool.itemId }),
-          name: tool.name,
-          providerMetadata: tool.providerMetadata,
-        }),
-        event,
-      ]
+    : [LLMEvent.toolInputEnd({ id: tool.id, name: tool.name, providerMetadata: tool.providerMetadata }), event]

 /** Store the updated tool and produce the optional public delta event. */
 const appendTool = <K extends StreamKey>(
@@ -168,7 +148,6 @@ export const appendOrStart = <K extends StreamKey>(
    id,
    name,
    input: `${current?.input ?? ""}${delta.text}`,
-    itemId: current?.itemId,
    providerExecuted: current?.providerExecuted,
    providerMetadata: current?.providerMetadata,
  }
@@ -1,6 +1,7 @@
-import { ProviderID, type ModelID } from "../schema"
+import { HttpOptions, ProviderID, mergeHttpOptions, type ModelID } from "../schema"
 import * as OpenAICompatibleChat from "../protocols/openai-compatible-chat"
 import type { RouteDefaultsInput } from "../route/client"
+import { Auth } from "../route/auth"
 import { AuthOptions, type ProviderAuthOption } from "../route/auth-options"
 import type { ProviderPackage } from "../provider-package"
 import { profiles, type OpenAICompatibleProfile } from "./openai-compatible-profile"
@@ -19,6 +20,8 @@ export interface Settings extends ProviderPackage.Settings {
  readonly apiKey?: string
  readonly baseURL: string
  readonly provider?: string
+  readonly http?: RouteDefaultsInput["http"]
+  readonly providerOptions?: OpenAIProviderOptionsInput
 }

 export type FamilyModelOptions = Omit<RouteDefaultsInput, "providerOptions"> &
@@ -31,16 +34,24 @@ export const routes = [OpenAICompatibleChat.route]

 export const configure = (input: GenericModelOptions) => {
  const provider = input.provider ?? "openai-compatible"
-  const { provider: _, baseURL, apiKey: _apiKey, auth: _auth, ...rest } = input
+  const {
+    provider: _,
+    baseURL,
+    apiKey: _apiKey,
+    auth: _auth,
+    headers,
+    ...rest
+  } = input
  const route = OpenAICompatibleChat.route.with({
    ...rest,
    provider,
    endpoint: { baseURL },
-    auth: AuthOptions.bearer(input, []),
+    auth: AuthOptions.bearer(input, []).andThen(Auth.headers(headers ?? {})),
  })
  return {
    id: ProviderID.make(provider),
    model: (modelID: string | ModelID) =>
+      // oxlint-disable-next-line typescript-eslint/no-unnecessary-type-arguments -- preserves provider-option validation at call sites
      route.model<OpenAIProviderOptionsInput>({ id: modelID, provider: ProviderID.make(provider) }),
    configure,
  }
@@ -67,14 +78,18 @@ export const provider = {
  configure,
 }

-export const model: ProviderPackage.Definition<Settings, OpenAIProviderOptionsInput>["model"] = (modelID, settings) =>
+export const model: ProviderPackage.Definition<Settings>["model"] = (modelID, settings) =>
  configure({
    apiKey: settings.apiKey,
    baseURL: settings.baseURL,
    headers: settings.headers === undefined ? undefined : { ...settings.headers },
-    http: settings.body === undefined ? undefined : { body: { ...settings.body } },
+    http: mergeHttpOptions(
+      settings.http === undefined ? undefined : HttpOptions.make(settings.http),
+      settings.body === undefined ? undefined : new HttpOptions({ body: { ...settings.body } }),
+    ),
    limits: settings.limits,
    provider: settings.provider,
+    providerOptions: settings.providerOptions,
  }).model(modelID)

 export const baseten = define(profiles.baseten)
@@ -1,5 +1,5 @@
 import { Schema } from "effect"
-import { ContentBlockID, FinishReason, ProviderMetadata, ResponseItemID, ToolCallID } from "./ids"
+import { ContentBlockID, FinishReason, ProviderMetadata, ToolCallID } from "./ids"
 import { Message, ToolCallPart, ToolOutput, ToolResultPart, ToolResultValue, type ContentPart } from "./messages"
 import { ProviderFailureClassification } from "./errors"

@@ -84,7 +84,6 @@ export type StepStart = Schema.Schema.Type<typeof StepStart>
 export const TextStart = Schema.Struct({
  type: Schema.tag("text-start"),
  id: ContentBlockID,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.TextStart" })
 export type TextStart = Schema.Schema.Type<typeof TextStart>
@@ -93,7 +92,6 @@ export const TextDelta = Schema.Struct({
  type: Schema.tag("text-delta"),
  id: ContentBlockID,
  text: Schema.String,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.TextDelta" })
 export type TextDelta = Schema.Schema.Type<typeof TextDelta>
@@ -101,7 +99,6 @@ export type TextDelta = Schema.Schema.Type<typeof TextDelta>
 export const TextEnd = Schema.Struct({
  type: Schema.tag("text-end"),
  id: ContentBlockID,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.TextEnd" })
 export type TextEnd = Schema.Schema.Type<typeof TextEnd>
@@ -109,7 +106,6 @@ export type TextEnd = Schema.Schema.Type<typeof TextEnd>
 export const ReasoningStart = Schema.Struct({
  type: Schema.tag("reasoning-start"),
  id: ContentBlockID,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.ReasoningStart" })
 export type ReasoningStart = Schema.Schema.Type<typeof ReasoningStart>
@@ -118,7 +114,6 @@ export const ReasoningDelta = Schema.Struct({
  type: Schema.tag("reasoning-delta"),
  id: ContentBlockID,
  text: Schema.String,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.ReasoningDelta" })
 export type ReasoningDelta = Schema.Schema.Type<typeof ReasoningDelta>
@@ -126,7 +121,6 @@ export type ReasoningDelta = Schema.Schema.Type<typeof ReasoningDelta>
 export const ReasoningEnd = Schema.Struct({
  type: Schema.tag("reasoning-end"),
  id: ContentBlockID,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.ReasoningEnd" })
 export type ReasoningEnd = Schema.Schema.Type<typeof ReasoningEnd>
@@ -135,7 +129,6 @@ export const ToolInputStart = Schema.Struct({
  type: Schema.tag("tool-input-start"),
  id: ToolCallID,
  name: Schema.String,
-  itemId: Schema.optional(ResponseItemID),
  providerExecuted: Schema.optional(Schema.Boolean),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.ToolInputStart" })
@@ -144,7 +137,6 @@ export type ToolInputStart = Schema.Schema.Type<typeof ToolInputStart>
 export const ToolInputDelta = Schema.Struct({
  type: Schema.tag("tool-input-delta"),
  id: ToolCallID,
-  itemId: Schema.optional(ResponseItemID),
  name: Schema.String,
  text: Schema.String,
 }).annotate({ identifier: "LLM.Event.ToolInputDelta" })
@@ -154,7 +146,6 @@ export const ToolInputEnd = Schema.Struct({
  type: Schema.tag("tool-input-end"),
  id: ToolCallID,
  name: Schema.String,
-  itemId: Schema.optional(ResponseItemID),
  providerMetadata: Schema.optional(ProviderMetadata),
 }).annotate({ identifier: "LLM.Event.ToolInputEnd" })
 export type ToolInputEnd = Schema.Schema.Type<typeof ToolInputEnd>
@@ -163,7 +154,6 @@ export type ToolInputEnd = Schema.Schema.Type<typeof ToolInputEnd>
 export const ToolInputError = Schema.Struct({
  type: Schema.tag("tool-input-error"),
  id: ToolCallID,
-  itemId: Schema.optional(ResponseItemID),
  name: Schema.String,
  raw: Schema.String,
 }).annotate({ identifier: "LLM.Event.ToolInputError" })
@@ -172,7 +162,6 @@ export type ToolInputError = Schema.Schema.Type<typeof ToolInputError>
 export const ToolCall = Schema.Struct({
  type: Schema.tag("tool-call"),
  id: ToolCallID,
-  itemId: Schema.optional(ResponseItemID),
  name: Schema.String,
  input: Schema.Unknown,
  providerExecuted: Schema.optional(Schema.Boolean),
@@ -183,7 +172,6 @@ export type ToolCall = Schema.Schema.Type<typeof ToolCall>
 export const ToolResult = Schema.Struct({
  type: Schema.tag("tool-result"),
  id: ToolCallID,
-  itemId: Schema.optional(ResponseItemID),
  name: Schema.String,
  result: ToolResultValue,
  output: Schema.optional(ToolOutput),
@@ -195,7 +183,6 @@ export type ToolResult = Schema.Schema.Type<typeof ToolResult>
 export const ToolError = Schema.Struct({
  type: Schema.tag("tool-error"),
  id: ToolCallID,
-  itemId: Schema.optional(ResponseItemID),
  name: Schema.String,
  message: Schema.String,
  error: Schema.optional(Schema.Defect()),
@@ -347,14 +334,12 @@ const responseUsage = (events: ReadonlyArray<LLMEvent>) =>
 interface ContentAssembly {
  readonly contentIndex: number
  readonly text: string
-  readonly itemId?: ResponseItemID
  readonly providerMetadata?: ProviderMetadata
 }

 interface ToolInputAssembly {
  readonly name: string
  readonly text: string
-  readonly itemId?: ResponseItemID
  readonly providerMetadata?: ProviderMetadata
 }

@@ -400,27 +385,11 @@ const appendEvent = (state: ResponseState, event: LLMEvent): ResponseState => {
  }
 }

-const textContent = (
-  text: string,
-  itemId: ResponseItemID | undefined,
-  providerMetadata: ProviderMetadata | undefined,
-): ContentPart => ({
-  type: "text",
-  text,
-  ...(itemId === undefined ? {} : { itemId }),
-  ...(providerMetadata === undefined ? {} : { providerMetadata }),
-})
+const textContent = (text: string, providerMetadata: ProviderMetadata | undefined): ContentPart =>
+  providerMetadata === undefined ? { type: "text", text } : { type: "text", text, providerMetadata }

-const reasoningContent = (
-  text: string,
-  itemId: ResponseItemID | undefined,
-  providerMetadata: ProviderMetadata | undefined,
-): ContentPart => ({
-  type: "reasoning",
-  text,
-  ...(itemId === undefined ? {} : { itemId }),
-  ...(providerMetadata === undefined ? {} : { providerMetadata }),
-})
+const reasoningContent = (text: string, providerMetadata: ProviderMetadata | undefined): ContentPart =>
+  providerMetadata === undefined ? { type: "reasoning", text } : { type: "reasoning", text, providerMetadata }

 const contentWith = (state: ResponseState, content: ReadonlyArray<ContentPart>): ResponseState => ({
  ...state,
@@ -435,32 +404,26 @@ const replaceContent = (state: ResponseState, index: number, part: ContentPart)
    state.message.content.map((item, itemIndex) => (itemIndex === index ? part : item)),
  )

-const ensureText = (
-  state: ResponseState,
-  id: string,
-  itemId?: ResponseItemID,
-  providerMetadata?: ProviderMetadata,
-): ResponseState => {
+const ensureText = (state: ResponseState, id: string, providerMetadata?: ProviderMetadata): ResponseState => {
  if (state.textParts[id]) return state
  return {
-    ...appendContent(state, textContent("", itemId, providerMetadata)),
+    ...appendContent(state, textContent("", providerMetadata)),
    textParts: {
      ...state.textParts,
-      [id]: { contentIndex: state.message.content.length, text: "", itemId, providerMetadata },
+      [id]: { contentIndex: state.message.content.length, text: "", providerMetadata },
    },
  }
 }

 const reduceTextDelta = (state: ResponseState, event: TextDelta): ResponseState => {
-  const started = ensureText(state, event.id, event.itemId, event.providerMetadata)
+  const started = ensureText(state, event.id, event.providerMetadata)
  const current = started.textParts[event.id]
  if (!current) return started
  const text = current.text + event.text
-  const itemId = event.itemId ?? current.itemId
  const providerMetadata = event.providerMetadata ?? current.providerMetadata
  return {
-    ...replaceContent(started, current.contentIndex, textContent(text, itemId, providerMetadata)),
-    textParts: { ...started.textParts, [event.id]: { ...current, text, itemId, providerMetadata } },
+    ...replaceContent(started, current.contentIndex, textContent(text, providerMetadata)),
+    textParts: { ...started.textParts, [event.id]: { ...current, text, providerMetadata } },
  }
 }

@@ -468,39 +431,32 @@ const reduceTextEnd = (state: ResponseState, event: TextEnd): ResponseState => {
  const current = state.textParts[event.id]
  if (!current) return state
  const providerMetadata = event.providerMetadata ?? current.providerMetadata
-  const itemId = event.itemId ?? current.itemId
  return {
-    ...replaceContent(state, current.contentIndex, textContent(current.text, itemId, providerMetadata)),
-    textParts: { ...state.textParts, [event.id]: { ...current, itemId, providerMetadata } },
+    ...replaceContent(state, current.contentIndex, textContent(current.text, providerMetadata)),
+    textParts: { ...state.textParts, [event.id]: { ...current, providerMetadata } },
  }
 }

-const ensureReasoning = (
-  state: ResponseState,
-  id: string,
-  itemId?: ResponseItemID,
-  providerMetadata?: ProviderMetadata,
-): ResponseState => {
+const ensureReasoning = (state: ResponseState, id: string, providerMetadata?: ProviderMetadata): ResponseState => {
  if (state.reasoningParts[id]) return state
  return {
-    ...appendContent(state, reasoningContent("", itemId, providerMetadata)),
+    ...appendContent(state, reasoningContent("", providerMetadata)),
    reasoningParts: {
      ...state.reasoningParts,
-      [id]: { contentIndex: state.message.content.length, text: "", itemId, providerMetadata },
+      [id]: { contentIndex: state.message.content.length, text: "", providerMetadata },
    },
  }
 }

 const reduceReasoningDelta = (state: ResponseState, event: ReasoningDelta): ResponseState => {
-  const started = ensureReasoning(state, event.id, event.itemId, event.providerMetadata)
+  const started = ensureReasoning(state, event.id, event.providerMetadata)
  const current = started.reasoningParts[event.id]
  if (!current) return started
  const text = current.text + event.text
-  const itemId = event.itemId ?? current.itemId
  const providerMetadata = event.providerMetadata ?? current.providerMetadata
  return {
-    ...replaceContent(started, current.contentIndex, reasoningContent(text, itemId, providerMetadata)),
-    reasoningParts: { ...started.reasoningParts, [event.id]: { ...current, text, itemId, providerMetadata } },
+    ...replaceContent(started, current.contentIndex, reasoningContent(text, providerMetadata)),
+    reasoningParts: { ...started.reasoningParts, [event.id]: { ...current, text, providerMetadata } },
  }
 }

@@ -508,10 +464,9 @@ const reduceReasoningEnd = (state: ResponseState, event: ReasoningEnd): Response
  const current = state.reasoningParts[event.id]
  if (!current) return state
  const providerMetadata = event.providerMetadata ?? current.providerMetadata
-  const itemId = event.itemId ?? current.itemId
  return {
-    ...replaceContent(state, current.contentIndex, reasoningContent(current.text, itemId, providerMetadata)),
-    reasoningParts: { ...state.reasoningParts, [event.id]: { ...current, itemId, providerMetadata } },
+    ...replaceContent(state, current.contentIndex, reasoningContent(current.text, providerMetadata)),
+    reasoningParts: { ...state.reasoningParts, [event.id]: { ...current, providerMetadata } },
  }
 }

@@ -519,7 +474,7 @@ const reduceToolInputStart = (state: ResponseState, event: ToolInputStart): Resp
  ...state,
  toolInputs: {
    ...state.toolInputs,
-    [event.id]: { name: event.name, text: "", itemId: event.itemId, providerMetadata: event.providerMetadata },
+    [event.id]: { name: event.name, text: "", providerMetadata: event.providerMetadata },
  },
 })

@@ -540,7 +495,6 @@ const reduceToolInputEnd = (state: ResponseState, event: ToolInputEnd): Response
      [event.id]: {
        ...current,
        name: event.name,
-        itemId: event.itemId ?? current.itemId,
        providerMetadata: event.providerMetadata ?? current.providerMetadata,
      },
    },
@@ -550,7 +504,6 @@ const reduceToolInputEnd = (state: ResponseState, event: ToolInputEnd): Response
 const toolCallContent = (event: ToolCall): ContentPart =>
  ToolCallPart.make({
    id: event.id,
-    ...(event.itemId === undefined ? {} : { itemId: event.itemId }),
    name: event.name,
    input: event.input,
    ...(event.providerExecuted === undefined ? {} : { providerExecuted: event.providerExecuted }),
@@ -560,7 +513,6 @@ const toolCallContent = (event: ToolCall): ContentPart =>
 const toolResultContent = (event: ToolResult): ContentPart =>
  ToolResultPart.make({
    id: event.id,
-    ...(event.itemId === undefined ? {} : { itemId: event.itemId }),
    name: event.name,
    result: event.result,
    ...(event.providerExecuted === undefined ? {} : { providerExecuted: event.providerExecuted }),
@@ -576,13 +528,13 @@ const reduceResponseState = (state: ResponseState, event: LLMEvent): ResponseSta
  const next = appendEvent(state, event)
  switch (event.type) {
    case "text-start":
-      return ensureText(next, event.id, event.itemId, event.providerMetadata)
+      return ensureText(next, event.id, event.providerMetadata)
    case "text-delta":
      return reduceTextDelta(next, event)
    case "text-end":
      return reduceTextEnd(next, event)
    case "reasoning-start":
-      return ensureReasoning(next, event.id, event.itemId, event.providerMetadata)
+      return ensureReasoning(next, event.id, event.providerMetadata)
    case "reasoning-delta":
      return reduceReasoningDelta(next, event)
    case "reasoning-end":
@@ -21,9 +21,6 @@ export type ProviderID = typeof ProviderID.Type
 export const ResponseID = Schema.String
 export type ResponseID = Schema.Schema.Type<typeof ResponseID>

-export const ResponseItemID = Schema.String
-export type ResponseItemID = Schema.Schema.Type<typeof ResponseItemID>
-
 export const ContentBlockID = Schema.String
 export type ContentBlockID = Schema.Schema.Type<typeof ContentBlockID>

@@ -1,6 +1,6 @@
 import { Schema } from "effect"
 import { Tool } from "@opencode-ai/schema/tool"
-import { JsonSchema, MessageRole, ProviderMetadata, ResponseItemID } from "./ids"
+import { JsonSchema, MessageRole, ProviderMetadata } from "./ids"
 import { CacheHint, CachePolicy, GenerationOptions, HttpOptions, LanguageModelSchema, ProviderOptions } from "./options"
 import { isRecord } from "../utils/record"

@@ -25,7 +25,6 @@ export const SystemPart = Object.assign(systemPartSchema, {
 export const TextPart = Schema.Struct({
  type: Schema.Literal("text"),
  text: Schema.String,
-  itemId: Schema.optional(ResponseItemID),
  cache: Schema.optional(CacheHint),
  metadata: Schema.optional(Schema.Record(Schema.String, Schema.Unknown)),
  providerMetadata: Schema.optional(ProviderMetadata),
@@ -122,7 +121,6 @@ export const ToolCallPart = Object.assign(
  Schema.Struct({
    type: Schema.Literal("tool-call"),
    id: Schema.String,
-    itemId: Schema.optional(ResponseItemID),
    name: Schema.String,
    input: Schema.Unknown,
    providerExecuted: Schema.optional(Schema.Boolean),
@@ -140,7 +138,6 @@ export const ToolResultPart = Object.assign(
  Schema.Struct({
    type: Schema.Literal("tool-result"),
    id: Schema.String,
-    itemId: Schema.optional(ResponseItemID),
    name: Schema.String,
    result: ToolResultValue,
    providerExecuted: Schema.optional(Schema.Boolean),
@@ -157,7 +154,6 @@ export const ToolResultPart = Object.assign(
    ): ToolResultPart => ({
      type: "tool-result",
      id: input.id,
-      ...(input.itemId === undefined ? {} : { itemId: input.itemId }),
      name: input.name,
      result: ToolResultValue.make(input.result, input.resultType),
      providerExecuted: input.providerExecuted,
@@ -172,7 +168,6 @@ export type ToolResultPart = Schema.Schema.Type<typeof ToolResultPart>
 export const ReasoningPart = Schema.Struct({
  type: Schema.Literal("reasoning"),
  text: Schema.String,
-  itemId: Schema.optional(ResponseItemID),
  encrypted: Schema.optional(Schema.String),
  cache: Schema.optional(CacheHint),
  metadata: Schema.optional(Schema.Record(Schema.String, Schema.Unknown)),
@@ -186,7 +181,7 @@ export const ContentPart = Schema.Union([TextPart, MediaPart, ToolCallPart, Tool
 export type ContentPart = Schema.Schema.Type<typeof ContentPart>

 export class Message extends Schema.Class<Message>("LLM.Message")({
-  id: Schema.optional(ResponseItemID),
+  id: Schema.optional(Schema.String),
  role: MessageRole,
  content: Schema.Array(ContentPart),
  metadata: Schema.optional(Schema.Record(Schema.String, Schema.Unknown)),
@@ -79,7 +79,7 @@ const result = (call: ToolCallPart, value: ToolResultValueType | ToolSettlement,
              id: call.id,
              name: call.name,
              result: settlement.result,
-              ...(call.providerMetadata === undefined ? {} : { providerMetadata: call.providerMetadata }),
+              providerMetadata: call.providerMetadata,
            }),
          ]
        : [
@@ -88,7 +88,7 @@ const result = (call: ToolCallPart, value: ToolResultValueType | ToolSettlement,
              name: call.name,
              result: settlement.result,
              output: settlement.output,
-              ...(call.providerMetadata === undefined ? {} : { providerMetadata: call.providerMetadata }),
+              providerMetadata: call.providerMetadata,
            }),
          ],
  }
@@ -8,6 +8,7 @@ import {
  type ProviderMetadata,
  type ToolCallPart,
  ToolResultPart,
+  type ToolResultValue,
  type Usage,
 } from "../../src/schema"
 import { type Tools, toDefinitions } from "../../src/tool"
@@ -60,10 +61,9 @@ export const runTools = <T extends Tools>(options: RunOptions<T>) =>
            ...dispatched.map(([call, dispatched]) =>
              Message.tool({
                id: call.id,
-                itemId: dispatched.events.find(LLMEvent.is.toolResult)?.itemId,
                name: call.name,
                result: dispatched.result,
-                providerMetadata: dispatched.events.find(LLMEvent.is.toolResult)?.providerMetadata,
+                providerMetadata: call.providerMetadata,
              }),
            ),
          ],
@@ -89,15 +89,9 @@ const stepState = (events: ReadonlyArray<LLMEvent>) => {

  for (const event of events) {
    if (event.type === "text-delta" || event.type === "reasoning-delta") {
-      appendText(assistantContent, event.type === "text-delta" ? "text" : "reasoning", event.text, event.itemId)
+      appendText(assistantContent, event.type === "text-delta" ? "text" : "reasoning", event.text)
    } else if (event.type === "text-end" || event.type === "reasoning-end") {
-      appendText(
-        assistantContent,
-        event.type === "text-end" ? "text" : "reasoning",
-        "",
-        event.itemId,
-        event.providerMetadata,
-      )
+      appendText(assistantContent, event.type === "text-end" ? "text" : "reasoning", "", event.providerMetadata)
    } else if (event.type === "tool-call") {
      assistantContent.push(event)
      if (!event.providerExecuted) toolCalls.push(event)
@@ -105,7 +99,6 @@ const stepState = (events: ReadonlyArray<LLMEvent>) => {
      assistantContent.push(
        ToolResultPart.make({
          id: event.id,
-          itemId: event.itemId,
          name: event.name,
          result: event.result,
          providerExecuted: true,
@@ -125,7 +118,6 @@ const appendText = (
  content: ContentPart[],
  type: "text" | "reasoning",
  text: string,
-  itemId?: string,
  providerMetadata?: ProviderMetadata,
 ) => {
  const last = content.at(-1)
@@ -133,12 +125,11 @@ const appendText = (
    content[content.length - 1] = {
      ...last,
      text: `${last.text}${text}`,
-      itemId: itemId ?? last.itemId,
      providerMetadata: providerMetadata ?? last.providerMetadata,
    }
    return
  }
-  content.push({ type, text, itemId, providerMetadata })
+  content.push({ type, text, providerMetadata })
 }

 const addUsage = (left: Usage | undefined, right: Usage | undefined): Usage | undefined => {
@@ -111,6 +111,22 @@ describe("provider package entrypoints", () => {
    })
  })

+  test("maps OpenAI-compatible Chat settings onto the executable model", async () => {
+    const OpenAICompatible = await import("@opencode-ai/ai/providers/openai-compatible")
+    const selected = OpenAICompatible.model("custom-model", {
+      apiKey: "fixture",
+      baseURL: "https://chat.example.test/v1",
+      provider: "example",
+      http: { query: { tenant: "one" } },
+      providerOptions: { openai: { reasoningEffort: "high" } },
+    })
+
+    expect(String(selected.provider)).toBe("example")
+    expect(selected.route.id).toBe("openai-compatible-chat")
+    expect(selected.route.defaults.http?.query).toEqual({ tenant: "one" })
+    expect(selected.route.defaults.providerOptions).toEqual({ openai: { reasoningEffort: "high" } })
+  })
+
  test("maps Anthropic-compatible settings onto the executable model", async () => {
    const AnthropicCompatible = await import("@opencode-ai/ai/providers/anthropic-compatible")
    const selected = AnthropicCompatible.model("compatible-model", {
@@ -16,13 +16,6 @@ const model = Gemini.route
  })
  .model({ id: "gemini-2.5-flash" })

-const gemini3 = Gemini.route
-  .with({
-    endpoint: { baseURL: "https://generativelanguage.test/v1beta/" },
-    auth: Auth.header("x-goog-api-key", "test"),
-  })
-  .model({ id: "gemini-3-flash-preview" })
-
 const request = LLM.request({
  id: "req_1",
  model,
@@ -93,39 +86,6 @@ describe("Gemini route", () => {
    }),
  )

-  it.effect("forwards standard Gemini generation options", () =>
-    Effect.gen(function* () {
-      const prepared = yield* compileRequest(
-        LLM.request({
-          model,
-          prompt: "Say hello.",
-          generation: {
-            maxTokens: 40,
-            temperature: 0.2,
-            topP: 0.8,
-            topK: 12,
-            frequencyPenalty: 0.3,
-            presencePenalty: 0.4,
-            seed: 42,
-            stop: ["done"],
-          },
-        }),
-      )
-
-      expect(prepared.body.generationConfig).toEqual({
-        maxOutputTokens: 40,
-        temperature: 0.2,
-        topP: 0.8,
-        topK: 12,
-        frequencyPenalty: 0.3,
-        presencePenalty: 0.4,
-        seed: 42,
-        stopSequences: ["done"],
-        thinkingConfig: undefined,
-      })
-    }),
-  )
-
  it.effect("lowers chronological system updates to wrapped user text in order", () =>
    Effect.gen(function* () {
      const prepared = yield* compileRequest(
@@ -390,100 +350,6 @@ describe("Gemini route", () => {
    }),
  )

-  it.effect("preserves nested empty object tool schemas", () =>
-    Effect.gen(function* () {
-      const prepared = yield* compileRequest(
-        LLM.request({
-          model,
-          prompt: "Use the tool.",
-          tools: [
-            {
-              name: "configure",
-              description: "Configure the operation",
-              inputSchema: {
-                type: "object",
-                required: ["options"],
-                properties: {
-                  options: { type: "object", description: "Optional provider settings", properties: {} },
-                },
-              },
-            },
-          ],
-        }),
-      )
-
-      expect(prepared.body.tools).toEqual([
-        {
-          functionDeclarations: [
-            {
-              name: "configure",
-              description: "Configure the operation",
-              parameters: {
-                type: "object",
-                required: ["options"],
-                properties: {
-                  options: { type: "object", description: "Optional provider settings", properties: {} },
-                },
-              },
-            },
-          ],
-        },
-      ])
-    }),
-  )
-
-  it.effect("projects Gemini type arrays without narrowing their allowed values", () =>
-    Effect.gen(function* () {
-      const prepared = yield* compileRequest(
-        LLM.request({
-          model,
-          prompt: "Use the tool.",
-          tools: [
-            {
-              name: "filter",
-              description: "Filter values",
-              inputSchema: {
-                type: "object",
-                properties: {
-                  status: { type: ["number", "string"], description: "Status filter" },
-                  maybe: { type: ["string", "null"] },
-                  nothing: { type: ["null"] },
-                  explicit: { anyOf: [{ type: "string" }, { type: "null" }] },
-                  choice: { anyOf: [{ type: "string" }, { type: "number" }, { type: "null" }] },
-                },
-              },
-            },
-          ],
-        }),
-      )
-
-      expect(prepared.body.tools?.[0]?.functionDeclarations[0]?.parameters).toEqual({
-        type: "object",
-        properties: {
-          status: {
-            description: "Status filter",
-            anyOf: [{ type: "number" }, { type: "string" }],
-          },
-          maybe: {
-            nullable: true,
-            anyOf: [{ type: "string" }],
-          },
-          nothing: {
-            type: "null",
-          },
-          explicit: {
-            type: "string",
-            nullable: true,
-          },
-          choice: {
-            anyOf: [{ type: "string" }, { type: "number" }],
-            nullable: true,
-          },
-        },
-      })
-    }),
-  )
-
  it.effect("parses text, reasoning, and usage stream fixtures", () =>
    Effect.gen(function* () {
      const body = sseEvents(
@@ -670,44 +536,6 @@ describe("Gemini route", () => {
    }),
  )

-  it.effect("replays unsigned Gemini 3 tool calls with the validator bypass sentinel", () =>
-    Effect.gen(function* () {
-      const prepared = yield* compileRequest(
-        LLM.request({
-          model: gemini3,
-          messages: [
-            Message.assistant([ToolCallPart.make({ id: "tool_0", name: "lookup", input: { query: "weather" } })]),
-            Message.tool({ id: "tool_0", name: "lookup", result: "done", resultType: "text" }),
-          ],
-        }),
-      )
-
-      expect(prepared.body.contents).toEqual([
-        {
-          role: "model",
-          parts: [
-            {
-              functionCall: { id: undefined, name: "lookup", args: { query: "weather" } },
-              thoughtSignature: "skip_thought_signature_validator",
-            },
-          ],
-        },
-        {
-          role: "user",
-          parts: [
-            {
-              functionResponse: {
-                id: undefined,
-                name: "lookup",
-                response: { name: "lookup", content: "done" },
-              },
-            },
-          ],
-        },
-      ])
-    }),
-  )
-
  it.effect("emits streamed tool calls and maps finish reason", () =>
    Effect.gen(function* () {
      const body = sseEvents({
@@ -4,6 +4,7 @@ import { HttpClientRequest } from "effect/unstable/http"
 import { LLM, LLMRequest, Message, ToolCallPart, ToolChoice, ToolDefinition } from "../../src"
 import { Auth, LLMClient } from "../../src/route"
 import { compileRequest } from "../../src/route/client"
+import { jsonRequestParts } from "../../src/route/transport/http"
 import * as OpenAICompatible from "../../src/providers/openai-compatible"
 import * as OpenAICompatibleChat from "../../src/protocols/openai-compatible-chat"
 import { it } from "../lib/effect"
@@ -144,6 +145,48 @@ describe("OpenAI-compatible Chat route", () => {
    }),
  )

+  it.effect("preserves compatible provider URL, usage, options, and body extensions", () =>
+    Effect.gen(function* () {
+      const selected = OpenAICompatible.model("custom-model", {
+        apiKey: "generated-key",
+        baseURL: "https://compatible.example/v1",
+        provider: "custom",
+        headers: { Authorization: "Bearer configured-key" },
+        http: {
+          query: { tenant: "one" },
+          body: {
+            user: "user-1",
+            verbosity: "low",
+            vendor_extension: { enabled: true },
+            custom_boolean: false,
+          },
+        },
+        providerOptions: { openai: { reasoningEffort: "high" } },
+      })
+      const request = LLM.request({ model: selected, prompt: "Hello" })
+      const prepared = yield* compileRequest(request)
+      const parts = yield* jsonRequestParts({
+        endpoint: selected.route.endpoint,
+        auth: selected.route.auth,
+        headers: selected.route.headers,
+        request: LLMRequest.update(request, { http: selected.route.defaults.http }),
+        body: prepared.body,
+        encodeBody: (body) => JSON.stringify(body),
+      })
+
+      expect(parts.url).toBe("https://compatible.example/v1/chat/completions?tenant=one")
+      expect(parts.headers.authorization).toBe("Bearer configured-key")
+      expect(parts.jsonBody).toMatchObject({
+        user: "user-1",
+        reasoning_effort: "high",
+        verbosity: "low",
+        vendor_extension: { enabled: true },
+        custom_boolean: false,
+      })
+      expect(parts.jsonBody).toMatchObject({ stream_options: { include_usage: true } })
+    }),
+  )
+
  it.effect("configures the max tokens request field", () =>
    Effect.gen(function* () {
      const compatible = OpenAICompatibleChat.route
@@ -45,7 +45,7 @@ describe("Open Responses-compatible route", () => {
          },
        },
      })
-      expect(prepared.body).toMatchObject({
+      expect(prepared.body).toEqual({
        model: "example-model",
        input: [
          { role: "system", content: "You are concise." },
@@ -53,8 +53,6 @@ describe("Open Responses-compatible route", () => {
        ],
        stream: true,
      })
-      expect(prepared.body.input[0]).not.toHaveProperty("id")
-      expect(prepared.body.input[1]).not.toHaveProperty("id")
    }),
  )

@@ -69,9 +69,6 @@ describe("OpenAI Responses route", () => {
        stream: true,
        max_output_tokens: 20,
        temperature: 0,
-        tool_choice: undefined,
-        tools: undefined,
-        top_p: undefined,
      })
    }),
  )
@@ -332,7 +329,7 @@ describe("OpenAI Responses route", () => {
      yield* LLMClient.generate(
        LLMRequest.update(request, {
          model: Azure.configure({
-            baseURL: "https://opencode-test.openai.azure.com/openai/",
+            baseURL: "https://opencode-test.openai.azure.com/openai/v1/",
            apiKey: "azure-key",
            headers: { authorization: "Bearer stale" },
          }).responses("gpt-4.1-mini"),
@@ -413,7 +410,7 @@ describe("OpenAI Responses route", () => {
        }),
      )

-      expect(prepared.body).toMatchObject({
+      expect(prepared.body).toEqual({
        model: "gpt-4.1-mini",
        input: [
          { role: "user", content: [{ type: "input_text", text: "What is the weather?" }] },
@@ -428,65 +425,6 @@ describe("OpenAI Responses route", () => {
        tools: undefined,
        top_p: undefined,
      })
-      const call = prepared.body.input.find((item) => "type" in item && item.type === "function_call")
-      const output = prepared.body.input.find((item) => "type" in item && item.type === "function_call_output")
-      expect(call?.id).toBeUndefined()
-      expect(output?.id).toBeUndefined()
-    }),
-  )
-
-  it.effect("does not generate response item ids for client-created history", () =>
-    Effect.sync(() => {
-      const canonical = LLM.request({
-        model,
-        messages: [
-          Message.assistant([
-            { type: "text", text: "Working." },
-            { type: "reasoning", text: "Thinking." },
-            ToolCallPart.make({ id: "call_1", name: "lookup", input: {} }),
-          ]),
-          Message.tool({ id: "call_1", name: "lookup", result: "done" }),
-        ],
-      })
-
-      expect(canonical.messages[0]?.id).toBeUndefined()
-      expect(canonical.messages[1]?.id).toBeUndefined()
-      expect(canonical.messages[0]?.content.every((part) => part.type === "media" || part.itemId === undefined)).toBe(
-        true,
-      )
-      expect(canonical.messages[1]?.content[0]).not.toHaveProperty("itemId")
-    }),
-  )
-
-  it.effect("replays provider function call item ids without assigning output ids", () =>
-    Effect.gen(function* () {
-      const canonical = LLM.request({
-        model,
-        messages: [
-          Message.assistant([
-            { type: "text", text: "Calling.", itemId: "plain-text" },
-            ToolCallPart.make({
-              id: "call_1",
-              name: "lookup",
-              input: {},
-              providerMetadata: { openai: { itemId: "plain-call" } },
-            }),
-          ]),
-          Message.tool({ id: "call_1", itemId: "plain-output", name: "lookup", result: "done" }),
-        ],
-      })
-      const prepared = yield* compileRequest(canonical)
-
-      expect(canonical.messages[0]?.content.map((part) => (part.type === "media" ? undefined : part.itemId))).toEqual([
-        "plain-text",
-        undefined,
-      ])
-      expect(canonical.messages[1]?.content[0]).toMatchObject({ itemId: "plain-output" })
-      expect(prepared.body.input).toEqual([
-        { role: "assistant", id: "plain-text", content: [{ type: "output_text", text: "Calling." }] },
-        { type: "function_call", id: "plain-call", call_id: "call_1", name: "lookup", arguments: "{}" },
-        { type: "function_call_output", call_id: "call_1", output: '"done"' },
-      ])
    }),
  )

@@ -926,21 +864,9 @@ describe("OpenAI Responses route", () => {
      expect(response.text).toBe("Hello!")
      expect(response.events).toEqual([
        { type: "step-start", index: 0 },
-        { type: "text-start", id: "msg_1", itemId: "msg_1", providerMetadata: { openai: { itemId: "msg_1" } } },
-        {
-          type: "text-delta",
-          id: "msg_1",
-          itemId: "msg_1",
-          text: "Hello",
-          providerMetadata: { openai: { itemId: "msg_1" } },
-        },
-        {
-          type: "text-delta",
-          id: "msg_1",
-          itemId: "msg_1",
-          text: "!",
-          providerMetadata: { openai: { itemId: "msg_1" } },
-        },
+        { type: "text-start", id: "msg_1" },
+        { type: "text-delta", id: "msg_1", text: "Hello" },
+        { type: "text-delta", id: "msg_1", text: "!" },
        { type: "text-end", id: "msg_1" },
        {
          type: "step-finish",
@@ -997,20 +923,17 @@ describe("OpenAI Responses route", () => {
        {
          type: "text",
          text: "Checking.",
-          itemId: "msg_commentary",
-          providerMetadata: { openai: { itemId: "msg_commentary", phase: "commentary" } },
+          providerMetadata: { openai: { phase: "commentary" } },
        },
        {
          type: "text",
          text: "Finished.",
-          itemId: "msg_final",
-          providerMetadata: { openai: { itemId: "msg_final", phase: "final_answer" } },
+          providerMetadata: { openai: { phase: "final_answer" } },
        },
        {
          type: "text",
          text: "Unclassified.",
-          itemId: "msg_null",
-          providerMetadata: { openai: { itemId: "msg_null", phase: null } },
+          providerMetadata: { openai: { phase: null } },
        },
      ])

@@ -1018,19 +941,16 @@ describe("OpenAI Responses route", () => {
      expect(prepared.body.input).toEqual([
        {
          role: "assistant",
-          id: "msg_commentary",
          content: [{ type: "output_text", text: "Checking." }],
          phase: "commentary",
        },
        {
          role: "assistant",
-          id: "msg_final",
          content: [{ type: "output_text", text: "Finished." }],
          phase: "final_answer",
        },
        {
          role: "assistant",
-          id: "msg_null",
          content: [{ type: "output_text", text: "Unclassified." }],
          phase: null,
        },
@@ -1123,24 +1043,12 @@ describe("OpenAI Responses route", () => {
      )

      expect(response.events.filter((event) => event.type.startsWith("text-"))).toEqual([
-        { type: "text-start", id: "msg_1", itemId: "msg_1", providerMetadata: { openai: { itemId: "msg_1" } } },
-        {
-          type: "text-delta",
-          id: "msg_1",
-          itemId: "msg_1",
-          text: "First",
-          providerMetadata: { openai: { itemId: "msg_1" } },
-        },
-        { type: "text-end", id: "msg_1", itemId: "msg_1", providerMetadata: { openai: { itemId: "msg_1" } } },
-        { type: "text-start", id: "msg_2", itemId: "msg_2", providerMetadata: { openai: { itemId: "msg_2" } } },
-        {
-          type: "text-delta",
-          id: "msg_2",
-          itemId: "msg_2",
-          text: "Second",
-          providerMetadata: { openai: { itemId: "msg_2" } },
-        },
-        { type: "text-end", id: "msg_2", itemId: "msg_2", providerMetadata: { openai: { itemId: "msg_2" } } },
+        { type: "text-start", id: "msg_1" },
+        { type: "text-delta", id: "msg_1", text: "First" },
+        { type: "text-end", id: "msg_1" },
+        { type: "text-start", id: "msg_2" },
+        { type: "text-delta", id: "msg_2", text: "Second" },
+        { type: "text-end", id: "msg_2" },
      ])
    }),
  )
@@ -1160,15 +1068,9 @@ describe("OpenAI Responses route", () => {
      expect(response.text).toBe("Hello")
      expect(response.events).toMatchObject([
        { type: "step-start", index: 0 },
-        { type: "reasoning-start", id: "rs_1", itemId: "rs_1", providerMetadata: { openai: { itemId: "rs_1" } } },
-        {
-          type: "reasoning-delta",
-          id: "rs_1",
-          itemId: "rs_1",
-          text: "thinking",
-          providerMetadata: { openai: { itemId: "rs_1" } },
-        },
-        { type: "text-start", id: "msg_1", itemId: "msg_1", providerMetadata: { openai: { itemId: "msg_1" } } },
+        { type: "reasoning-start", id: "rs_1" },
+        { type: "reasoning-delta", id: "rs_1", text: "thinking" },
+        { type: "text-start", id: "msg_1" },
        { type: "text-delta", id: "msg_1", text: "Hello" },
        { type: "reasoning-end", id: "rs_1" },
        { type: "text-end", id: "msg_1" },
@@ -1177,8 +1079,8 @@ describe("OpenAI Responses route", () => {
      ])
      expect(response.events.filter((event) => event.type === "finish")).toHaveLength(1)
      expect(response.message.content).toEqual([
-        { type: "reasoning", text: "thinking", itemId: "rs_1", providerMetadata: { openai: { itemId: "rs_1" } } },
-        { type: "text", text: "Hello", itemId: "msg_1", providerMetadata: { openai: { itemId: "msg_1" } } },
+        { type: "reasoning", text: "thinking" },
+        { type: "text", text: "Hello" },
      ])
    }),
  )
@@ -1209,7 +1111,6 @@ describe("OpenAI Responses route", () => {
        expect.objectContaining({
          type: "reasoning-end",
          id: "rs_1",
-          itemId: "rs_1",
          providerMetadata: { openai: { itemId: "rs_1", reasoningEncryptedContent: "encrypted-state" } },
        }),
      )
@@ -1250,34 +1151,19 @@ describe("OpenAI Responses route", () => {
        {
          type: "reasoning-start",
          id: "rs_1:0",
-          itemId: "rs_1",
          providerMetadata: { openai: { itemId: "rs_1", reasoningEncryptedContent: null } },
        },
-        {
-          type: "reasoning-delta",
-          id: "rs_1:0",
-          itemId: "rs_1",
-          text: "First",
-          providerMetadata: { openai: { itemId: "rs_1" } },
-        },
-        { type: "reasoning-end", id: "rs_1:0", itemId: "rs_1", providerMetadata: { openai: { itemId: "rs_1" } } },
+        { type: "reasoning-delta", id: "rs_1:0", text: "First" },
+        { type: "reasoning-end", id: "rs_1:0", providerMetadata: { openai: { itemId: "rs_1" } } },
        {
          type: "reasoning-start",
          id: "rs_1:1",
-          itemId: "rs_1",
          providerMetadata: { openai: { itemId: "rs_1", reasoningEncryptedContent: null } },
        },
-        {
-          type: "reasoning-delta",
-          id: "rs_1:1",
-          itemId: "rs_1",
-          text: "Second",
-          providerMetadata: { openai: { itemId: "rs_1" } },
-        },
+        { type: "reasoning-delta", id: "rs_1:1", text: "Second" },
        {
          type: "reasoning-end",
          id: "rs_1:1",
-          itemId: "rs_1",
          providerMetadata: { openai: { itemId: "rs_1", reasoningEncryptedContent: "encrypted-state" } },
        },
        { type: "step-finish", index: 0, reason: { normalized: "stop", raw: undefined } },
@@ -1315,8 +1201,8 @@ describe("OpenAI Responses route", () => {
      )

      expect(response.events.filter((event) => event.type === "reasoning-end")).toEqual([
-        { type: "reasoning-end", id: "rs_1:0", itemId: "rs_1", providerMetadata: { openai: { itemId: "rs_1" } } },
-        { type: "reasoning-end", id: "rs_1:1", itemId: "rs_1", providerMetadata: { openai: { itemId: "rs_1" } } },
+        { type: "reasoning-end", id: "rs_1:0", providerMetadata: { openai: { itemId: "rs_1" } } },
+        { type: "reasoning-end", id: "rs_1:1", providerMetadata: { openai: { itemId: "rs_1" } } },
      ])
    }),
  )
@@ -1364,7 +1250,7 @@ describe("OpenAI Responses route", () => {
                  { role: "user", content: [{ type: "input_text", text: "Summarize it." }] },
                ],
              })
-              expect(body.input[1]).toHaveProperty("id", "rs_1")
+              expect(body.input[1]).not.toHaveProperty("id")
              return input.respond(
                sseEvents(
                  { type: "response.output_text.delta", item_id: "msg_1", delta: "Parser now round-trips reasoning." },
@@ -1411,7 +1297,6 @@ describe("OpenAI Responses route", () => {
        { role: "assistant", content: [{ type: "output_text", text: "Before." }] },
        {
          type: "reasoning",
-          id: "rs_1",
          encrypted_content: "encrypted-state",
          summary: [{ type: "summary_text", text: "Checked order." }],
        },
@@ -1420,7 +1305,7 @@ describe("OpenAI Responses route", () => {
    }),
  )

-  it.effect("replays complete stored reasoning items with their id", () =>
+  it.effect("references stored reasoning items by id", () =>
    Effect.gen(function* () {
      const prepared = yield* compileRequest(
        LLM.request({
@@ -1438,14 +1323,7 @@ describe("OpenAI Responses route", () => {
        }),
      )

-      expect(prepared.body.input).toEqual([
-        {
-          type: "reasoning",
-          id: "rs_1",
-          summary: [{ type: "summary_text", text: "Checked the previous diff." }],
-          encrypted_content: undefined,
-        },
-      ])
+      expect(prepared.body.input).toEqual([{ type: "item_reference", id: "rs_1" }])
    }),
  )

@@ -1554,7 +1432,6 @@ describe("OpenAI Responses route", () => {
      expect(prepared.body.input).toEqual([
        {
          type: "reasoning",
-          id: "rs_1",
          encrypted_content: "encrypted-state",
          summary: [
            { type: "summary_text", text: "First" },
@@ -1634,7 +1511,6 @@ describe("OpenAI Responses route", () => {
        outputTokens: 1,
        nonCachedInputTokens: 5,
        cacheReadInputTokens: undefined,
-        cacheWriteInputTokens: undefined,
        reasoningTokens: undefined,
        totalTokens: 6,
        providerMetadata: { openai: { input_tokens: 5, output_tokens: 1 } },
@@ -1645,35 +1521,30 @@ describe("OpenAI Responses route", () => {
        {
          type: "tool-input-start",
          id: "call_1",
-          itemId: "item_1",
          name: "lookup",
          providerMetadata: { openai: { itemId: "item_1" } },
        },
        {
          type: "tool-input-delta",
          id: "call_1",
-          itemId: "item_1",
          name: "lookup",
          text: '{"query"',
        },
        {
          type: "tool-input-delta",
          id: "call_1",
-          itemId: "item_1",
          name: "lookup",
          text: ':"weather"}',
        },
        {
          type: "tool-input-end",
          id: "call_1",
-          itemId: "item_1",
          name: "lookup",
          providerMetadata: { openai: { itemId: "item_1" } },
        },
        {
          type: "tool-call",
          id: "call_1",
-          itemId: "item_1",
          name: "lookup",
          input: { query: "weather" },
          providerExecuted: undefined,
@@ -1693,17 +1564,6 @@ describe("OpenAI Responses route", () => {
          usage,
        },
      ])
-      expect(response.message.content).toEqual([
-        {
-          type: "tool-call",
-          id: "call_1",
-          itemId: "item_1",
-          name: "lookup",
-          input: { query: "weather" },
-          providerExecuted: undefined,
-          providerMetadata: { openai: { itemId: "item_1" } },
-        },
-      ])
    }),
  )

@@ -1736,7 +1596,6 @@ describe("OpenAI Responses route", () => {
      expect(response.events.find(LLMEvent.is.toolInputError)).toEqual({
        type: "tool-input-error",
        id: "call_1",
-        itemId: "item_1",
        name: "lookup",
        raw: '{"query":"partial',
      })
@@ -1793,7 +1652,6 @@ describe("OpenAI Responses route", () => {
        {
          type: "tool-call",
          id: "ws_1",
-          itemId: "ws_1",
          name: "web_search",
          input: { type: "search", query: "effect 4" },
          providerExecuted: true,
@@ -1802,35 +1660,11 @@ describe("OpenAI Responses route", () => {
        {
          type: "tool-result",
          id: "ws_1",
-          itemId: "ws_1",
          name: "web_search",
          result: { type: "json", value: item },
          providerExecuted: true,
-          providerMetadata: { openai: { itemId: "ws_1", item } },
-          output: undefined,
-        },
-      ])
-      expect(response.message.content).toEqual([
-        {
-          type: "tool-call",
-          id: "ws_1",
-          itemId: "ws_1",
-          name: "web_search",
-          input: { type: "search", query: "effect 4" },
-          providerExecuted: true,
          providerMetadata: { openai: { itemId: "ws_1" } },
        },
-        {
-          type: "tool-result",
-          id: "ws_1",
-          itemId: "ws_1",
-          name: "web_search",
-          result: { type: "json", value: item },
-          providerExecuted: true,
-          providerMetadata: { openai: { itemId: "ws_1", item } },
-          metadata: undefined,
-          cache: undefined,
-        },
      ])
    }),
  )
@@ -1908,7 +1742,6 @@ describe("OpenAI Responses route", () => {
      expect(toolCall).toEqual({
        type: "tool-call",
        id: "ci_1",
-        itemId: "ci_1",
        name: "code_interpreter",
        input: { code: "print(1+1)", container_id: "cnt_xyz" },
        providerExecuted: true,
@@ -1918,12 +1751,10 @@ describe("OpenAI Responses route", () => {
      expect(toolResult).toEqual({
        type: "tool-result",
        id: "ci_1",
-        itemId: "ci_1",
        name: "code_interpreter",
        result: { type: "json", value: item },
        providerExecuted: true,
-        providerMetadata: { openai: { itemId: "ci_1", item } },
-        output: undefined,
+        providerMetadata: { openai: { itemId: "ci_1" } },
      })
    }),
  )
@@ -49,43 +49,6 @@ describe("LLMResponse reducer", () => {
    expect(state.message.content).toEqual([{ type: "text", text: "partial" }])
  })

-  test("assembles response item identity and provider metadata", () => {
-    const response = LLMResponse.fromEvents([
-      LLMEvent.textStart({ id: "text-block", itemId: "msg_existing" }),
-      LLMEvent.textDelta({
-        id: "text-block",
-        itemId: "msg_existing",
-        text: "Answer",
-        providerMetadata: { openai: { itemId: "msg_existing" } },
-      }),
-      LLMEvent.textEnd({ id: "text-block", itemId: "msg_existing" }),
-      LLMEvent.reasoningStart({ id: "reasoning-block", itemId: "rs_existing" }),
-      LLMEvent.reasoningDelta({
-        id: "reasoning-block",
-        itemId: "rs_existing",
-        text: "Thought",
-        providerMetadata: { openai: { itemId: "rs_existing" } },
-      }),
-      LLMEvent.reasoningEnd({ id: "reasoning-block", itemId: "rs_existing" }),
-      LLMEvent.finish({ reason: { normalized: "stop" } }),
-    ])
-
-    expect(response?.message.content).toEqual([
-      {
-        type: "text",
-        text: "Answer",
-        itemId: "msg_existing",
-        providerMetadata: { openai: { itemId: "msg_existing" } },
-      },
-      {
-        type: "reasoning",
-        text: "Thought",
-        itemId: "rs_existing",
-        providerMetadata: { openai: { itemId: "rs_existing" } },
-      },
-    ])
-  })
-
  test("does not complete ended content without a terminal finish", () => {
    const state = reduce([
      LLMEvent.textStart({ id: "t1" }),
@@ -172,7 +172,7 @@ describe("LLMClient tools", () => {
      expect(calls).toEqual([{ id: "call_projected", parameters: { prefix: "count" }, output: { count: "2" } }])
      expect(dispatched.result).toEqual({ type: "text", value: "count:2" })
      expect(dispatched.output).toEqual({ structured: { count: "2" }, content: [{ type: "text", text: "count:2" }] })
-      expect(dispatched.events).toMatchObject([
+      expect(dispatched.events).toEqual([
        LLMEvent.toolResult({
          id: "call_projected",
          name: "projected",
@@ -180,7 +180,6 @@ describe("LLMClient tools", () => {
          output: { structured: { count: "2" }, content: [{ type: "text", text: "count:2" }] },
        }),
      ])
-      expect(dispatched.events[0]?.itemId).toBeUndefined()
    }),
  )

@@ -198,7 +197,7 @@ describe("LLMClient tools", () => {
        LLMEvent.toolCall({ id: "call_1", name: "tool", input: {}, providerMetadata }),
      )

-      expect(dispatched.events).toMatchObject([
+      expect(dispatched.events).toEqual([
        LLMEvent.toolResult({
          id: "call_1",
          name: "tool",
@@ -207,13 +206,12 @@ describe("LLMClient tools", () => {
          providerMetadata,
        }),
      ])
-      expect(dispatched.events[0]?.itemId).toBeUndefined()

      const failed = yield* ToolRuntime.dispatch(
        {},
-        LLMEvent.toolCall({ id: "call_2", itemId: "fc_failed", name: "missing", input: {}, providerMetadata }),
+        LLMEvent.toolCall({ id: "call_2", name: "missing", input: {}, providerMetadata }),
      )
-      expect(failed.events).toMatchObject([
+      expect(failed.events).toEqual([
        LLMEvent.toolError({
          id: "call_2",
          name: "missing",
@@ -227,27 +225,6 @@ describe("LLMClient tools", () => {
          providerMetadata,
        }),
      ])
-      const errorItemID = failed.events.find(LLMEvent.is.toolError)?.itemId
-      const resultItemID = failed.events.find(LLMEvent.is.toolResult)?.itemId
-      expect(errorItemID).toBeUndefined()
-      expect(resultItemID).toBeUndefined()
-    }),
-  )
-
-  it.effect("does not derive a function output item id from the function call item id", () =>
-    Effect.gen(function* () {
-      const tool = Tool.make({
-        description: "Return text.",
-        parameters: Schema.Struct({}),
-        success: Schema.String,
-        execute: () => Effect.succeed("hello"),
-      })
-      const dispatched = yield* ToolRuntime.dispatch(
-        { tool },
-        LLMEvent.toolCall({ id: "call_1", itemId: "fc_existing", name: "tool", input: {} }),
-      )
-
-      expect(dispatched.events.find(LLMEvent.is.toolResult)?.itemId).toBeUndefined()
    }),
  )

@@ -460,7 +437,7 @@ describe("LLMClient tools", () => {
      )

      expect(dispatched.result).toEqual(callerOwned)
-      expect(dispatched.events).toMatchObject([
+      expect(dispatched.events).toEqual([
        LLMEvent.toolResult({
          id: "call_1",
          name: "eventful",
@@ -468,7 +445,6 @@ describe("LLMClient tools", () => {
          output: { structured: { ok: true }, content: [] },
        }),
      ])
-      expect(dispatched.events[0]?.itemId).toBeUndefined()
    }),
  )

@@ -688,8 +688,6 @@ export default function Page() {
    return {
      queryKey: [...vcsKey(), mode] as const,
      enabled,
-      refetchOnMount: "always" as const,
-      refetchOnWindowFocus: true,
      queryFn: mode
        ? () =>
            sdk()
@@ -703,16 +701,6 @@ export default function Page() {
    }
  })
  const refreshVcs = debounce(() => void queryClient.invalidateQueries({ queryKey: vcsKey() }), 100)
-  createEffect(
-    on(
-      () => desktopReviewOpen() || mobileChanges(),
-      (open, previous) => {
-        if (!open || previous || !desktopFileTreeOpen() || vcsQuery.isFetching) return
-        refreshVcs()
-      },
-      { defer: true },
-    ),
-  )
  const reviewDiffs = () => {
    if (reviewMode() === "git" || reviewMode() === "branch")
      // avoids suspense
@@ -959,6 +947,19 @@ export default function Page() {
    ),
  )

+  const stopVcs = sdk().event.listen((evt) => {
+    const details = evt.details as { type: string; properties?: unknown }
+    if (details.type !== "file.watcher.updated" && details.type !== "filesystem.changed") return
+    const props =
+      typeof details.properties === "object" && details.properties
+        ? (details.properties as Record<string, unknown>)
+        : undefined
+    const file = typeof props?.file === "string" ? props.file : undefined
+    if (!file || file.startsWith(".git/")) return
+    refreshVcs()
+  })
+  onCleanup(stopVcs)
+
  createEffect(
    on(
      () => sdk().directory,
@@ -51,6 +51,8 @@ export function map(input: MapInput): Mapping | undefined {
          ...mapGoogleOptions(input.settings),
        },
      }
+    case "@ai-sdk/openai-compatible":
+      return mapOpenAICompatible(input.settings)
    case "@openrouter/ai-sdk-provider":
      return mapOpenRouter(input.settings, baseSettings)
    case "@ai-sdk/xai":
@@ -63,6 +65,34 @@ export function map(input: MapInput): Mapping | undefined {
        },
      }
  }
+  return undefined
+}
+
+function mapOpenAICompatible(settings: Readonly<Record<string, unknown>>): Mapping | undefined {
+  if (typeof settings.baseURL !== "string") return undefined
+  if (
+    settings.timeout !== undefined ||
+    settings.headerTimeout !== undefined ||
+    settings.chunkTimeout !== undefined ||
+    settings.fetch !== undefined ||
+    settings.transformRequestBody !== undefined ||
+    settings.metadataExtractor !== undefined ||
+    settings.supportsStructuredOutputs === true ||
+    settings.strictJsonSchema !== undefined
+  )
+    return undefined
+  const options = typeof settings.reasoningEffort === "string" ? { reasoningEffort: settings.reasoningEffort } : undefined
+  return {
+    package: "@opencode-ai/ai/providers/openai-compatible",
+    settings: {
+      baseURL: settings.baseURL,
+      ...(typeof settings.name === "string" ? { provider: settings.name } : {}),
+      ...mapAPIKey(settings),
+      ...(isStringRecord(settings.queryParams) ? { http: { query: settings.queryParams } } : {}),
+      ...(options === undefined ? {} : { providerOptions: { openai: options } }),
+    },
+    ...(isStringRecord(settings.headers) ? { headers: settings.headers } : {}),
+  }
 }

 function mapBedrockMantle(input: MapInput, baseSettings: Readonly<Record<string, unknown>>): Mapping | undefined {
@@ -192,9 +222,7 @@ function mapOpenAIOptions(settings: Readonly<Record<string, unknown>>) {
 }

 function mapBaseSettings(settings: Readonly<Record<string, unknown>>) {
-  return {
-    ...(typeof settings.baseURL === "string" ? { baseURL: settings.baseURL } : {}),
-  }
+  return typeof settings.baseURL === "string" ? { baseURL: settings.baseURL } : {}
 }

 function mapAPIKey(settings: Readonly<Record<string, unknown>>) {
@@ -11,6 +11,15 @@ import { FSUtil } from "@opencode-ai/util/fs-util"
 import { Git } from "../git"
 import { Location } from "../location"
 import { Watcher } from "./watcher"
+import { Ignore } from "./ignore"
+import { Protected } from "./protected"
+
+function protecteds(dir: string) {
+  return Protected.paths().filter((item) => {
+    const relative = path.relative(dir, item)
+    return relative !== "" && !relative.startsWith("..") && !path.isAbsolute(relative)
+  })
+}

 export interface Interface {}

@@ -35,6 +44,19 @@ const layer = Layer.effect(
      const config = (yield* configService.entries())
        .filter((entry): entry is Document => entry.type === "document")
        .flatMap((item) => item.info.watcher?.ignore ?? [])
+      const home = Protected.isHome(location.directory)
+
+      if (!home && location.vcs) {
+        const updates = yield* watcher.subscribe({
+          path: location.directory,
+          type: "directory",
+          ignore: [...Ignore.PATTERNS, ...config, ...protecteds(location.directory)],
+        })
+        yield* updates.pipe(Stream.runForEach(publish), Effect.forkScoped)
+      }
+      if (home) {
+        yield* Effect.logInfo("location watcher skipped home directory", { directory: location.directory })
+      }

      if (location.vcs?.type === "git") {
        const resolved = (yield* git.repo.discover(location.directory))?.gitDirectory
@@ -42,7 +64,10 @@ const layer = Layer.effect(
          ? yield* fs.realPath(resolved).pipe(Effect.catch(() => Effect.succeed(resolved)))
          : undefined
        if (vcs && !config.includes(".git") && !config.includes(vcs) && (!resolved || !config.includes(resolved))) {
-          const updates = yield* watcher.subscribe({ path: path.join(vcs, "HEAD"), type: "file" })
+          const ignore = (yield* fs.readDirectoryEntries(vcs).pipe(Effect.catch(() => Effect.succeed([])))).flatMap(
+            (entry) => (entry.name === "HEAD" ? [] : [entry.name]),
+          )
+          const updates = yield* watcher.subscribe({ path: vcs, type: "directory", ignore })
          yield* updates.pipe(Stream.runForEach(publish), Effect.forkScoped)
        }
      }
@@ -5,8 +5,6 @@ import { LanguageModel } from "@opencode-ai/ai"
 // ast-grep-ignore: no-star-import
 import * as AnthropicMessages from "@opencode-ai/ai/protocols/anthropic-messages"
 // ast-grep-ignore: no-star-import
-import * as OpenAICompatibleChat from "@opencode-ai/ai/protocols/openai-compatible-chat"
-// ast-grep-ignore: no-star-import
 import * as OpenAIResponses from "@opencode-ai/ai/protocols/openai-responses"
 import { Auth, type AnyRoute } from "@opencode-ai/ai/route"
 import { Context, Effect, Layer, Schema } from "effect"
@@ -164,17 +162,6 @@ export const fromCatalogModel = (
        .model({ id: resolved.modelID ?? resolved.id, compatibility: resolved.compatibility }),
    )
  }
-  if (
-    Provider.isAISDK(resolved.package) &&
-    packageName === "@ai-sdk/openai-compatible" &&
-    typeof resolved.settings?.baseURL === "string"
-  ) {
-    return Effect.succeed(
-      withDefaults(resolved, OpenAICompatibleChat.route)
-        .with({ auth: key === undefined ? Auth.none : Auth.bearer(key) })
-        .model({ id: resolved.modelID ?? resolved.id, compatibility: resolved.compatibility }),
-    )
-  }
  const configured = { ...resolved.settings, ...credential?.metadata }
  const mapping = Provider.isAISDK(resolved.package)
    ? AISDKNative.map({
@@ -2,7 +2,8 @@ export * as Skill from "./skill"

 import { makeLocationNode } from "@opencode-ai/util/effect/app-node"
 import path from "path"
-import { Context, Effect, FiberMap, Layer, PubSub, Schema, Semaphore, Stream, Types } from "effect"
+import { Context, Effect, Layer, Schema, Scope, Stream, Types } from "effect"
+import { FileSystem } from "@opencode-ai/schema/filesystem"
 import { Skill } from "@opencode-ai/schema/skill"
 import { Agent } from "./agent"
 import { ConfigMarkdown } from "./config/markdown"
@@ -82,78 +83,47 @@ const layer = Layer.effect(
    const fs = yield* FSUtil.Service
    const bus = yield* Bus.Service
    const watcher = yield* Watcher.Service
+    const scope = yield* Scope.Scope
    const cache = new Map<string, { skills: Info[]; paths: readonly string[] }>()
-    const watches = yield* FiberMap.make<string>()
-    const lock = Semaphore.makeUnsafe(1)
-    const changes = yield* PubSub.unbounded<string>()
+    const watched = new Set<string>()

    const invalidate = Effect.fn("Skill.invalidateFromWatcher")(function* (file: string) {
-      const changed = yield* lock.withPermit(
-        Effect.gen(function* () {
-          const invalidated = Array.from(cache.entries()).filter(([, loaded]) =>
-            loaded.paths.some((item) => FSUtil.overlaps(item, file)),
-          )
-          if (invalidated.length === 0) return false
-          cache.clear()
-          yield* FiberMap.clear(watches)
-          yield* Effect.logInfo("skill cache invalidated", {
-            file,
-            sources: invalidated.map(([key]) => key),
-            skills: invalidated.flatMap(([, loaded]) => loaded.skills.map((skill) => skill.id)),
-          })
-          return true
-        }),
+      const invalidated = Array.from(cache.entries()).filter(([, loaded]) =>
+        loaded.paths.some((item) => FSUtil.overlaps(item, file)),
      )
-      if (!changed) return
+      if (invalidated.length === 0) return
+      for (const [key] of invalidated) cache.delete(key)
+      yield* Effect.logInfo("skill cache invalidated", {
+        file,
+        sources: invalidated.map(([key]) => key),
+        skills: invalidated.flatMap(([, loaded]) => loaded.skills.map((skill) => skill.id)),
+      })
      yield* bus.publish(Skill.Event.Updated, {}).pipe(Effect.asVoid)
    })

-    yield* Stream.fromPubSub(changes).pipe(Stream.runForEach(invalidate), Effect.forkScoped({ startImmediately: true }))
-
-    const watch = Effect.fn("Skill.watch")(function* (directory: string, type: Watcher.WatchInput["type"]) {
+    const watch = Effect.fn("Skill.watch")(function* (directory: string) {
      const target = path.resolve(directory)
-      const updates = yield* watcher.subscribe(
-        type === "file" ? { path: target, type: "file" } : { path: target, type: "directory" },
-      )
-      yield* FiberMap.run(
-        watches,
-        `${type}:${target}`,
-        updates.pipe(Stream.runForEach((update) => PubSub.publish(changes, update.path).pipe(Effect.asVoid))),
-        {
-          onlyIfMissing: true,
-          startImmediately: true,
-        },
+      if (watched.has(target)) return
+      watched.add(target)
+      const updates = yield* watcher.subscribe({ path: target, type: "directory" })
+      yield* updates.pipe(
+        Stream.runForEach((update) => invalidate(update.path)),
+        Effect.forkIn(scope, { startImmediately: true }),
      )
    })

-    function firstMissing(target: string): Effect.Effect<string | undefined> {
-      const parent = path.dirname(target)
-      if (parent === target) return Effect.succeed(undefined)
-      return fs.isDir(parent).pipe(Effect.flatMap((exists) => (exists ? Effect.succeed(target) : firstMissing(parent))))
-    }
-
-    const watchDirectory: (directory: string) => Effect.Effect<string[]> = Effect.fn("Skill.watchDirectory")(function* (
-      directory: string,
-    ) {
+    const watchDirectory = Effect.fn("Skill.watchDirectory")(function* (directory: string) {
      const target = path.resolve(directory)
      const resolved = yield* fs.realPath(directory).pipe(Effect.catch(() => Effect.succeed(undefined)))
      if (resolved) {
-        yield* watch(resolved, "directory")
+        yield* watch(resolved)
        if (resolved !== target) {
-          yield* watch(target, "file")
+          yield* watch(path.dirname(target))
        }
        return resolved === target ? [target] : [target, resolved]
      }
-      const missing = yield* firstMissing(target)
-      if (missing) yield* watch(missing, "file")
-      if (
-        yield* fs.realPath(directory).pipe(
-          Effect.as(true),
-          Effect.catch(() => Effect.succeed(false)),
-        )
-      ) {
-        if (missing) yield* FiberMap.remove(watches, `file:${path.resolve(missing)}`)
-        return yield* watchDirectory(directory)
+      if (yield* fs.isDir(path.dirname(target))) {
+        yield* watch(path.dirname(target))
      }
      return [target]
    })
@@ -169,9 +139,7 @@ const layer = Layer.effect(
        list: () => draft.sources as Source[],
      }),
      finalize: () =>
-        lock
-          .withPermit(FiberMap.clear(watches).pipe(Effect.andThen(Effect.sync(() => cache.clear())), Effect.asVoid))
-          .pipe(Effect.andThen(bus.publish(Skill.Event.Updated, {})), Effect.asVoid),
+        Effect.sync(() => cache.clear()).pipe(Effect.andThen(bus.publish(Skill.Event.Updated, {})), Effect.asVoid),
    })

    const load = Effect.fn("Skill.load")(function* (source: Source) {
@@ -197,7 +165,7 @@ const layer = Layer.effect(
          if (!roots.some((root) => FSUtil.contains(root, resolved))) {
            const external = path.dirname(resolved)
            paths.push(external)
-            yield* watch(external, "directory")
+            yield* watch(external)
          }
          const content = yield* fs.readFileStringSafe(filepath).pipe(Effect.catch(() => Effect.succeed(undefined)))
          if (!content) continue
@@ -229,19 +197,20 @@ const layer = Layer.effect(
      return { skills, paths }
    })

+    yield* bus.subscribe(FileSystem.Event.Changed).pipe(
+      Stream.runForEach((event) => invalidate(event.data.file)),
+      Effect.forkScoped({ startImmediately: true }),
+    )
+
    const list = Effect.fn("Skill.list")(function* () {
-      return yield* lock.withPermit(
-        Effect.gen(function* () {
-          const skills = new Map<ID, Info>()
-          for (const source of state.get().sources) {
-            const key = Source.key(source)
-            const loaded = cache.get(key) ?? (yield* load(source))
-            cache.set(key, loaded)
-            for (const skill of loaded.skills) skills.set(skill.id, skill)
-          }
-          return Array.from(skills.values())
-        }),
-      )
+      const skills = new Map<ID, Info>()
+      for (const source of state.get().sources) {
+        const key = Source.key(source)
+        const loaded = cache.get(key) ?? (yield* load(source))
+        cache.set(key, loaded)
+        for (const skill of loaded.skills) skills.set(skill.id, skill)
+      }
+      return Array.from(skills.values())
    })

    return Service.of({
@@ -118,12 +118,13 @@ const layer = Layer.effect(
        yield* hooks.trigger("tool", "execute.after", afterEvent)
        return yield* afterEvent.error
      }
+      const content = yield* normalizeImages(execution.value.content)
      const afterEvent: PluginHooks.Domains["tool"]["execute.after"] = {
        ...base,
        status: "completed",
        result: {
          ...(execution.value.output === undefined ? {} : { output: execution.value.output }),
-          content: execution.value.content,
+          content: content.length > 0 ? content : execution.value.content,
          ...(execution.value.metadata === undefined ? {} : { metadata: execution.value.metadata }),
        },
      }
@@ -248,7 +248,7 @@ function migrateStandardProvider(info: ConfigProviderV1.Info) {
    body: info.options && options.body,
    models:
      info.models &&
-      Object.fromEntries(Object.entries(info.models).map(([name, model]) => [name, migrateModel(model)])),
+      Object.fromEntries(Object.entries(info.models).map(([name, model]) => [name, migrateModel(model, info.npm)])),
  }
 }

@@ -294,8 +294,9 @@ export function providerID(input: string) {
  return input
 }

-function migrateModel(info: typeof ConfigProviderV1.Model.Type) {
-  const settings = info.options && ConfigProviderOptionsV1.model(info.options)
+function migrateModel(info: typeof ConfigProviderV1.Model.Type, inheritedPackage?: string) {
+  const packageName = info.provider?.npm ?? inheritedPackage
+  const overlays = info.options && ConfigProviderOptionsV1.modelOverlays(info.options, packageName)
  const costs = info.cost && [
    {
      input: info.cost.input,
@@ -323,14 +324,15 @@ function migrateModel(info: typeof ConfigProviderV1.Model.Type) {
    name: info.name,
    compatibility: Model.compatibility(info.interleaved),
    package: info.provider?.npm ? Provider.aisdk(info.provider.npm) : undefined,
-    settings: info.provider?.api ? { ...settings, baseURL: info.provider.api } : settings,
+    settings: info.provider?.api ? { ...overlays?.settings, baseURL: info.provider.api } : overlays?.settings,
+    body: overlays?.body,
    capabilities,
    headers: info.headers,
    variants:
      info.variants &&
      Object.entries(info.variants).map(([id, options]) => ({
        id,
-        settings: ConfigProviderOptionsV1.model(options),
+        ...ConfigProviderOptionsV1.modelOverlays(options, packageName),
      })),
    cost: costs,
    disabled: info.status === "deprecated" ? true : undefined,
@@ -29,3 +29,18 @@ export function provider(options: Options): ProviderResult {
 export function model(options: Options) {
  return { ...options }
 }
+
+export function modelOverlays(options: Options, packageName: string | undefined) {
+  if (packageName !== "@ai-sdk/openai-compatible") return { settings: model(options) }
+  const known = new Set(["reasoningEffort", "strictJsonSchema"])
+  const settings = Object.fromEntries(Object.entries(options).filter(([key]) => known.has(key)))
+  const body = Object.fromEntries(
+    Object.entries(options)
+      .filter(([key]) => !known.has(key))
+      .map(([key, value]) => [key === "textVerbosity" ? "verbosity" : key, value]),
+  )
+  return {
+    settings: Object.keys(settings).length === 0 ? undefined : settings,
+    body: Object.keys(body).length === 0 ? undefined : body,
+  }
+}
@@ -5,6 +5,49 @@ const map = (packageName: string, settings: Readonly<Record<string, unknown>>, m
  AISDKNative.map({ packageName, settings, modelID })

 describe("AISDKNative", () => {
+  test("maps the generic OpenAI-compatible package to the native provider package", () => {
+    expect(
+      map("@ai-sdk/openai-compatible", {
+        apiKey: "secret",
+        baseURL: "https://compatible.example/v1",
+        name: "example",
+        headers: { "x-test": "value" },
+        queryParams: { tenant: "one" },
+        reasoningEffort: "high",
+      }),
+    ).toEqual({
+      package: "@opencode-ai/ai/providers/openai-compatible",
+      settings: {
+        apiKey: "secret",
+        baseURL: "https://compatible.example/v1",
+        provider: "example",
+        http: { query: { tenant: "one" } },
+        providerOptions: {
+          openai: {
+            reasoningEffort: "high",
+          },
+        },
+      },
+      headers: { "x-test": "value" },
+    })
+    expect(map("@ai-sdk/openai-compatible", {})).toBeUndefined()
+    expect(
+      map("@ai-sdk/openai-compatible", { baseURL: "https://compatible.example/v1", timeout: 30_000 }),
+    ).toBeUndefined()
+    expect(
+      map("@ai-sdk/openai-compatible", {
+        baseURL: "https://compatible.example/v1",
+        supportsStructuredOutputs: true,
+      }),
+    ).toBeUndefined()
+    expect(
+      map("@ai-sdk/openai-compatible", {
+        baseURL: "https://compatible.example/v1",
+        strictJsonSchema: false,
+      }),
+    ).toBeUndefined()
+  })
+
  test("maps both models.dev Bedrock packages to native providers", () => {
    expect(map("@ai-sdk/amazon-bedrock", { region: "us-east-1" })).toEqual({
      package: "@opencode-ai/ai/providers/amazon-bedrock",
@@ -570,6 +570,72 @@ describe("Config", () => {
    }),
  )

+  it.effect("preserves serializable OpenAI-compatible options across v1 migration", () =>
+    Effect.sync(() => {
+      const migrated = ConfigMigrateV1.migrate({
+        provider: {
+          acme: {
+            npm: "@ai-sdk/openai-compatible",
+            api: "https://api.example/v1",
+            options: {
+              apiKey: "secret",
+              name: "acme",
+              headers: { "x-provider": "yes" },
+              body: { provider_body_extension: true },
+              queryParams: { tenant: "one" },
+              includeUsage: false,
+              supportsStructuredOutputs: true,
+            },
+            models: {
+              chat: {
+                options: {
+                  user: "user-1",
+                  reasoningEffort: "high",
+                  textVerbosity: "low",
+                  strictJsonSchema: false,
+                  vendor_extension: { enabled: true },
+                },
+                variants: {
+                  strict: { strictJsonSchema: true, variant_extension: "value" },
+                },
+              },
+            },
+          },
+        },
+      })
+
+      expect(migrated.providers?.acme).toMatchObject({
+        package: Provider.aisdk("@ai-sdk/openai-compatible"),
+        settings: {
+          apiKey: "secret",
+          name: "acme",
+          queryParams: { tenant: "one" },
+          includeUsage: false,
+          supportsStructuredOutputs: true,
+          baseURL: "https://api.example/v1",
+        },
+        headers: { "x-provider": "yes" },
+        body: { provider_body_extension: true },
+        models: {
+          chat: {
+            settings: {
+              reasoningEffort: "high",
+              strictJsonSchema: false,
+            },
+            body: { user: "user-1", verbosity: "low", vendor_extension: { enabled: true } },
+            variants: [
+              {
+                id: "strict",
+                settings: { strictJsonSchema: true },
+                body: { variant_extension: "value" },
+              },
+            ],
+          },
+        },
+      })
+    }),
+  )
+
  it.effect("renames old provider IDs while migrating v1 configuration", () =>
    Effect.sync(() => {
      const migrated = ConfigMigrateV1.migrate({
@@ -38,6 +38,28 @@ describe("ConfigProviderOptionsV1", () => {
    })
  })

+  test("splits OpenAI-compatible model options into native settings and body extensions", () => {
+    expect(
+      ConfigProviderOptionsV1.modelOverlays(
+        {
+          user: "user-1",
+          reasoningEffort: "high",
+          textVerbosity: "low",
+          strictJsonSchema: false,
+          vendor_extension: { enabled: true },
+          store: false,
+        },
+        "@ai-sdk/openai-compatible",
+      ),
+    ).toEqual({
+      settings: {
+        reasoningEffort: "high",
+        strictJsonSchema: false,
+      },
+      body: { user: "user-1", verbosity: "low", vendor_extension: { enabled: true }, store: false },
+    })
+  })
+
  test("uses mechanical lowering for custom provider options", () => {
    expect(ConfigProviderOptionsV1.provider({ enabled: true })).toEqual({
      settings: { enabled: true },
@@ -17,8 +17,9 @@ import { location } from "../fixture/location"
 import { tmpdir } from "../fixture/tmpdir"
 import { testEffect } from "../lib/effect"

+const describeWatcher = Watcher.hasNativeBinding() && !process.env.CI ? describe : describe.skip
+
 type WatcherEvent = { file: string; event: "add" | "change" | "unlink" }
-const describeNative = process.env.CI ? describe.skip : describe

 const it = testEffect(AppNodeBuilder.build(LayerNode.group([FSUtil.node, Bus.node])))

@@ -74,9 +75,10 @@ describe("Watcher lifecycle", () => {
      const interrupted = yield* Deferred.make<void>()
      yield* Effect.gen(function* () {
        const watcher = yield* Watcher.Service
-        const consumer = yield* watcher
-          .subscribe({ path: "/pending", type: "directory" })
-          .pipe(Effect.flatMap(Stream.runDrain), Effect.forkScoped({ startImmediately: true }))
+        const consumer = yield* watcher.subscribe({ path: "/pending", type: "directory" }).pipe(
+          Effect.flatMap(Stream.runDrain),
+          Effect.forkScoped({ startImmediately: true }),
+        )
        yield* Deferred.await(started)
        yield* Fiber.interrupt(consumer)
        expect(yield* Deferred.isDone(interrupted)).toBe(true)
@@ -97,9 +99,10 @@ describe("Watcher lifecycle", () => {
    return Effect.gen(function* () {
      const watcher = yield* Watcher.Service
      const consume = () =>
-        watcher
-          .subscribe({ path: "/shared", type: "directory" })
-          .pipe(Effect.flatMap(Stream.runDrain), Effect.forkScoped({ startImmediately: true }))
+        watcher.subscribe({ path: "/shared", type: "directory" }).pipe(
+          Effect.flatMap(Stream.runDrain),
+          Effect.forkScoped({ startImmediately: true }),
+        )
      const first = yield* consume()
      const second = yield* consume()
      yield* Effect.yieldNow
@@ -135,26 +138,22 @@ describe("Watcher lifecycle", () => {
  })
 })

-function provide(directory: string, vcs?: Location.Interface["vcs"], watcher?: Layer.Layer<Watcher.Service>) {
+function provide(directory: string, vcs?: Location.Interface["vcs"]) {
  const locationLayer = Layer.succeed(
    Location.Service,
    Location.Service.of(location({ directory: AbsolutePath.make(directory) }, { vcs })),
  )
-  const built = AppNodeBuilder.build(LocationWatcher.node, [
-    [Config.node, configLayer],
-    [Location.node, locationLayer],
-    ...(watcher ? ([[Watcher.node, watcher]] as const) : []),
-  ])
-  return Effect.provide(built)
+  return Effect.provide(
+    AppNodeBuilder.build(LocationWatcher.node, [
+      [Config.node, configLayer],
+      [Location.node, locationLayer],
+    ]),
+  )
 }

 function withTmp<A, E, R>(
  f: (directory: string, vcs?: Location.Interface["vcs"]) => Effect.Effect<A, E, R>,
-  options?: {
-    vcs?: "git" | "hg"
-    init?: (directory: string) => Promise<void>
-    watcher?: Layer.Layer<Watcher.Service>
-  },
+  options?: { vcs?: "git" | "hg"; init?: (directory: string) => Promise<void> },
 ) {
  return Effect.acquireRelease(
    Effect.promise(async () => {
@@ -174,57 +173,9 @@ function withTmp<A, E, R>(
      return { tmp, vcs: { type: "git" as const, store: AbsolutePath.make(path.join(tmp.path, ".git")) } }
    }),
    ({ tmp }) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
-  ).pipe(Effect.flatMap(({ tmp, vcs }) => f(tmp.path, vcs).pipe(provide(tmp.path, vcs, options?.watcher))))
+  ).pipe(Effect.flatMap(({ tmp, vcs }) => f(tmp.path, vcs).pipe(provide(tmp.path, vcs))))
 }

-describe("LocationWatcher subscriptions", () => {
-  it.live("watches only exact Git branch metadata", () => {
-    const subscriptions: Watcher.WatchInput[] = []
-    const watcher = Layer.succeed(
-      Watcher.Service,
-      Watcher.Service.of({
-        subscribe: (input) => Effect.sync(() => subscriptions.push(input)).pipe(Effect.as(Stream.empty)),
-      }),
-    )
-    return withTmp(
-      (directory) =>
-        Effect.gen(function* () {
-          yield* LocationWatcher.Service
-          yield* Effect.sync(() => subscriptions.length).pipe(
-            Effect.filterOrFail((count) => count > 0),
-            Effect.retry(Schedule.spaced("10 millis")),
-          )
-          yield* Effect.sleep("10 millis")
-          expect(subscriptions).toEqual([{ path: path.join(directory, ".git", "HEAD"), type: "file" }])
-        }),
-      { vcs: "git", watcher },
-    )
-  })
-
-  it.live("watches only exact Hg branch metadata", () => {
-    const subscriptions: Watcher.WatchInput[] = []
-    const watcher = Layer.succeed(
-      Watcher.Service,
-      Watcher.Service.of({
-        subscribe: (input) => Effect.sync(() => subscriptions.push(input)).pipe(Effect.as(Stream.empty)),
-      }),
-    )
-    return withTmp(
-      (directory) =>
-        Effect.gen(function* () {
-          yield* LocationWatcher.Service
-          yield* Effect.sync(() => subscriptions.length).pipe(
-            Effect.filterOrFail((count) => count > 0),
-            Effect.retry(Schedule.spaced("10 millis")),
-          )
-          yield* Effect.sleep("10 millis")
-          expect(subscriptions).toEqual([{ path: path.join(directory, ".hg", "branch"), type: "file" }])
-        }),
-      { vcs: "hg", watcher },
-    )
-  })
-})
-
 function wait(check: (event: WatcherEvent) => boolean) {
  return Effect.gen(function* () {
    const bus = yield* Bus.Service
@@ -275,18 +226,31 @@ function eventuallyUpdate<E>(check: (event: WatcherEvent) => boolean, trigger: (
  )
 }

-function ready(file: string, eventFile = file) {
+function noUpdate<E>(check: (event: WatcherEvent) => boolean, trigger: Effect.Effect<void, E>, timeout = 500) {
+  return Effect.acquireUseRelease(
+    wait(check),
+    ({ deferred }) =>
+      trigger.pipe(
+        Effect.andThen(Deferred.await(deferred)),
+        Effect.timeoutOption(`${timeout} millis`),
+        Effect.tap((result) => Effect.sync(() => expect(result).toEqual(Option.none()))),
+      ),
+    ({ fiber }) => Fiber.interrupt(fiber),
+  )
+}
+
+function ready(directory: string) {
+  const file = path.join(directory, `.watcher-${Math.random().toString(36).slice(2)}`)
  return Effect.gen(function* () {
    const fs = yield* FSUtil.Service
-    const content = (yield* fs.readFileStringSafe(file)) ?? `ready-${Math.random()}`
    yield* eventuallyUpdate(
-      (event) => event.file === eventFile,
-      () => fs.writeFileString(file, content),
-    ).pipe(Effect.asVoid)
+      (event) => event.file === file,
+      () => fs.writeFileString(file, `ready-${Math.random()}`),
+    ).pipe(Effect.ensuring(fs.remove(file, { force: true }).pipe(Effect.ignore)), Effect.asVoid)
  })
 }

-describeNative("LocationWatcher", () => {
+describeWatcher("LocationWatcher", () => {
  it.live("limits file watches to the exact target", () =>
    withTmp((directory) =>
      Effect.gen(function* () {
@@ -312,25 +276,94 @@ describeNative("LocationWatcher", () => {
    ),
  )

-  it.live("detects creation of a missing directory target", () =>
+  it.live("publishes root create, update, and delete events", () =>
+    withTmp(
+      (directory) =>
+        Effect.gen(function* () {
+          const fs = yield* FSUtil.Service
+          const file = path.join(directory, "watch.txt")
+          yield* ready(directory)
+          for (const item of [
+            { event: "add" as const, trigger: fs.writeFileString(file, "a") },
+            { event: "change" as const, trigger: fs.writeFileString(file, "b") },
+            { event: "unlink" as const, trigger: fs.remove(file) },
+          ]) {
+            expect(
+              yield* nextUpdate((event) => event.file === file && event.event === item.event, item.trigger),
+            ).toEqual({
+              file,
+              event: item.event,
+            })
+          }
+        }),
+      { vcs: "git" },
+    ),
+  )
+
+  it.live("skips non-git roots", () =>
    withTmp((directory) =>
      Effect.gen(function* () {
        const fs = yield* FSUtil.Service
-        const watcher = yield* Watcher.Service
-        const target = path.join(directory, "generated")
-        const updates = yield* watcher.subscribe({ path: target, type: "file" })
-        const update = yield* updates.pipe(
-          Stream.take(1),
-          Stream.runHead,
-          Effect.forkScoped({ startImmediately: true }),
-        )
-        const creates = yield* Effect.suspend(() =>
-          fs.remove(target, { recursive: true, force: true }).pipe(Effect.andThen(fs.ensureDir(target))),
-        ).pipe(Effect.repeat(Schedule.spaced("10 millis")), Effect.forkScoped)
-        const event = yield* Fiber.join(update).pipe(Effect.ensuring(Fiber.interrupt(creates)))
+        const file = path.join(directory, "plain.txt")
+        yield* noUpdate((event) => event.file === file, fs.writeFileString(file, "plain"))
+      }),
+    ),
+  )

-        expect(event.valueOrUndefined?.path).toBe(target)
-      }).pipe(Effect.provide(AppNodeBuilder.build(Watcher.node))),
+  it.live("ignores dependency, VCS, and build directories at any depth", () =>
+    withTmp(
+      (directory) =>
+        Effect.gen(function* () {
+          const afs = yield* FSUtil.Service
+          yield* ready(directory)
+          const roots = ["node_modules", ".git", "dist"].map((name) => path.join(directory, "nested", name))
+          const files = roots.map((root) => path.join(root, "package", "index.js"))
+          yield* noUpdate(
+            (event) => roots.some((root) => event.file === root || event.file.startsWith(`${root}${path.sep}`)),
+            Effect.forEach(files, (file) => afs.writeWithDirs(file, "ignored"), {
+              concurrency: "unbounded",
+              discard: true,
+            }),
+          )
+        }),
+      { vcs: "git" },
+    ),
+  )
+
+  it.live("cleanup stops publishing events", () =>
+    Effect.gen(function* () {
+      const bus = yield* Bus.Service
+      const fs = yield* FSUtil.Service
+      const tmp = yield* Effect.acquireRelease(
+        Effect.promise(() => tmpdir()),
+        (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
+      )
+      yield* ready(tmp.path).pipe(
+        provide(tmp.path, { type: "git", store: AbsolutePath.make(path.join(tmp.path, ".git")) }),
+        Effect.scoped,
+      )
+      const file = path.join(tmp.path, "after-dispose.txt")
+      yield* noUpdate((event) => event.file === file, fs.writeFileString(file, "gone")).pipe(
+        Effect.provideService(Bus.Service, bus),
+      )
+    }).pipe(Effect.provide(AppNodeBuilder.build(LayerNode.group([FSUtil.node, Bus.node])))),
+  )
+
+  it.live("ignores .git/index changes", () =>
+    withTmp(
+      (directory) =>
+        Effect.gen(function* () {
+          const fs = yield* FSUtil.Service
+          const index = path.join(directory, ".git", "index")
+          yield* ready(directory)
+          yield* noUpdate(
+            (event) => event.file === index,
+            fs
+              .writeFileString(path.join(directory, "tracked.txt"), "a")
+              .pipe(Effect.andThen(Effect.promise(() => $`git add .`.cwd(directory).quiet())), Effect.asVoid),
+          )
+        }),
+      { vcs: "git" },
    ),
  )

@@ -341,11 +374,11 @@ describeNative("LocationWatcher", () => {
          const fs = yield* FSUtil.Service
          const head = path.join(directory, ".git", "HEAD")
          const branch = `watch-${Math.random().toString(36).slice(2)}`
-          yield* ready(head)
+          yield* ready(directory)
          yield* Effect.promise(() => $`git branch ${branch}`.cwd(directory).quiet())
          expect(
            yield* nextUpdate((event) => event.file === head, fs.writeFileString(head, `ref: refs/heads/${branch}\n`)),
-          ).toEqual({ file: head, event: "change" })
+          ).toMatchObject({ file: head })
        }),
      { vcs: "git" },
    ),
@@ -360,8 +393,8 @@ describeNative("LocationWatcher", () => {
            const afs = yield* FSUtil.Service
            const actual = path.join(directory, "..", `actual_${path.basename(directory)}`)
            yield* Effect.addFinalizer(() => Effect.promise(() => fs.rm(actual, { recursive: true, force: true })))
+            yield* ready(directory)
            const head = path.join(directory, ".git", "HEAD")
-            yield* ready(head, path.join(actual, "HEAD"))
            const branch = `watch-${Math.random().toString(36).slice(2)}`
            yield* Effect.promise(() => $`git branch ${branch}`.cwd(directory).quiet())
            expect(
@@ -389,7 +422,7 @@ describeNative("LocationWatcher", () => {
        Effect.gen(function* () {
          const fs = yield* FSUtil.Service
          const branch = path.join(directory, ".hg", "branch")
-          yield* ready(branch)
+          yield* ready(directory)
          expect(
            yield* nextUpdate((event) => event.file === branch, fs.writeFileString(branch, "feature\n")),
          ).toMatchObject({ file: branch })
@@ -3,12 +3,10 @@ import { Agent } from "@opencode-ai/core/agent"
 import type { Permission } from "@opencode-ai/core/permission"
 import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
 import { Image } from "@opencode-ai/core/image"
-import { PluginHooks } from "@opencode-ai/core/plugin/hooks"
 import { Session } from "@opencode-ai/core/session"
 import { SessionMessage } from "@opencode-ai/core/session/message"
 import { Tool } from "@opencode-ai/core/tool"
 import type { Info } from "@opencode-ai/schema/tool"
-import { LayerNode } from "@opencode-ai/util/effect/layer-node"
 import { executeTool, toolDefinitions } from "./lib/tool"
 import { Cause, Deferred, Effect, Exit, Fiber, Layer, Option, Schema, SchemaGetter, SchemaIssue, Scope } from "effect"
 import { testEffect } from "./lib/effect"
@@ -28,14 +26,10 @@ const imageStore = Layer.mock(Image.Service, {
          maxBytes: 5,
        }),
      )
-    return Effect.succeed({
-      ...content,
-      content: Buffer.from(`${Buffer.from(content.content, "base64").toString()} normalized`).toString("base64"),
-      mime: "image/jpeg",
-    })
+    return Effect.succeed({ ...content, content: "bm9ybWFsaXplZA==", mime: "image/jpeg" })
  },
 })
-const registryLayer = AppNodeBuilder.build(LayerNode.group([Tool.node, PluginHooks.node]), [[Image.node, imageStore]])
+const registryLayer = AppNodeBuilder.build(Tool.node, [[Image.node, imageStore]])
 const it = testEffect(registryLayer)
 const identity = {
  agent: Agent.ID.make("build"),
@@ -350,7 +344,7 @@ describe("Tool", () => {
    }),
  )

-  it.effect("normalizes image tool output once and drops unresizable images", () =>
+  it.effect("normalizes image tool output at execution and drops unresizable images", () =>
    Effect.gen(function* () {
      const service = yield* Tool.Service
      yield* transform(service,
@@ -382,12 +376,7 @@ describe("Tool", () => {

      const execution = yield* executeTool(service, call("snapshot"))
      expect(execution.content).toEqual([
-        {
-          type: "file",
-          uri: "data:image/jpeg;base64,aW1hZ2Ugbm9ybWFsaXplZA==",
-          mime: "image/jpeg",
-          name: "frame.png",
-        },
+        { type: "file", uri: "data:image/jpeg;base64,bm9ybWFsaXplZA==", mime: "image/jpeg", name: "frame.png" },
        { type: "text", text: "snapshot" },
        { type: "text", text: "[1 image omitted: could not be decoded.]" },
        { type: "text", text: "[1 image omitted: could not be resized below the image size limit.]" },
@@ -395,34 +384,6 @@ describe("Tool", () => {
    }),
  )

-  it.effect("normalizes image content added by an after hook", () =>
-    Effect.gen(function* () {
-      const service = yield* Tool.Service
-      const hooks = yield* PluginHooks.Service
-      yield* transform(service, { hooked: constant("original") }, { codemode: false })
-      yield* hooks.register("tool", "execute.after", (event) =>
-        Effect.sync(() => {
-          if (event.status !== "completed") return
-          event.result = {
-            ...event.result,
-            content: [
-              { type: "file", uri: "data:image/png;base64,aW1hZ2U=", mime: "image/png", name: "hook.png" },
-            ],
-          }
-        }),
-      )
-
-      expect((yield* executeTool(service, call("hooked"))).content).toEqual([
-        {
-          type: "file",
-          uri: "data:image/jpeg;base64,aW1hZ2Ugbm9ybWFsaXplZA==",
-          mime: "image/jpeg",
-          name: "hook.png",
-        },
-      ])
-    }),
-  )
-
  it.effect("publishes progress metadata unchanged", () =>
    Effect.gen(function* () {
      const service = yield* Tool.Service
@@ -9,6 +9,7 @@ import { Bus } from "@opencode-ai/core/bus"
 import { AbsolutePath } from "@opencode-ai/core/schema"
 import { Skill } from "@opencode-ai/core/skill"
 import { SkillDiscovery } from "@opencode-ai/core/skill/discovery"
+import { FileSystem } from "@opencode-ai/schema/filesystem"
 import { Watcher } from "@opencode-ai/core/filesystem/watcher"
 import { tmpdir } from "./fixture/tmpdir"
 import { testEffect } from "./lib/effect"
@@ -113,7 +114,6 @@ describe("Skill", () => {
          })

          const skill = yield* Skill.Service
-          const watcher = yield* Watcher.Test
          yield* skill.transform((editor) => {
            editor.source({ type: "directory", path: AbsolutePath.make(first) })
            editor.source({ type: "directory", path: AbsolutePath.make(first) })
@@ -144,21 +144,6 @@ describe("Skill", () => {
              content: "# review",
            },
          ])
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: first, type: "directory" },
-            { path: second, type: "directory" },
-          ])
-
-          yield* Effect.promise(() => write(second, "review", "Updated Second"))
-          yield* emitAndWait({ type: "update", path: path.join(second, "review", "SKILL.md") })
-
-          expect((yield* skill.list()).find((item) => item.id === "review")?.description).toBe("Updated Second")
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: first, type: "directory" },
-            { path: second, type: "directory" },
-            { path: first, type: "directory" },
-            { path: second, type: "directory" },
-          ])
        }),
      ),
    ),
@@ -251,30 +236,13 @@ metadata:
          })

          const skill = yield* Skill.Service
-          const watcher = yield* Watcher.Test
-          const bus = yield* Bus.Service
          yield* skill.transform((editor) => editor.source({ type: "directory", path: AbsolutePath.make(tmp.path) }))
          expect((yield* skill.list()).find((item) => item.id === "deploy")?.description).toBe("Initial deploy")
-          expect(yield* watcher.subscriptions()).toEqual([{ path: tmp.path, type: "directory" }])
-
-          let refreshed: Skill.Info[] = []
-          const unsubscribe = yield* bus.listen((event) => {
-            if (event.type !== Skill.Event.Updated.type) return Effect.void
-            return skill.list().pipe(
-              Effect.tap((items) => Effect.sync(() => (refreshed = items))),
-              Effect.asVoid,
-            )
-          })

          yield* Effect.promise(() => write(tmp.path, "deploy", "Updated deploy"))
-          yield* skill.reload().pipe(Effect.timeout("1 second"))
-          yield* unsubscribe
+          yield* skill.reload()

-          expect(refreshed.find((item) => item.id === "deploy")?.description).toBe("Updated deploy")
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: tmp.path, type: "directory" },
-            { path: tmp.path, type: "directory" },
-          ])
+          expect((yield* skill.list()).find((item) => item.id === "deploy")?.description).toBe("Updated deploy")
        }),
      ),
    ),
@@ -290,31 +258,24 @@ metadata:
          const source = path.join(tmp.path, "generated", "skills")
          const file = path.join(source, "deploy", "SKILL.md")
          const skill = yield* Skill.Service
-          const watcher = yield* Watcher.Test
+          const bus = yield* Bus.Service
          yield* skill.transform((editor) => editor.source({ type: "directory", path: AbsolutePath.make(source) }))
          expect(yield* skill.list()).toEqual([])
-          expect(yield* watcher.subscriptions()).toEqual([{ path: path.join(tmp.path, "generated"), type: "file" }])
-
-          yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, "generated")))
-          yield* emitAndWait({ type: "create", path: path.join(tmp.path, "generated") })
-          expect(yield* skill.list()).toEqual([])
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: path.join(tmp.path, "generated"), type: "file" },
-            { path: source, type: "file" },
-          ])

          yield* Effect.promise(async () => {
            await fs.mkdir(path.dirname(file), { recursive: true })
            await write(source, "deploy", "Deploy production")
          })
-          yield* emitAndWait({ type: "create", path: source })
+          yield* Effect.acquireUseRelease(
+            waitForSkillUpdate(),
+            ({ deferred }) =>
+              bus
+                .publish(FileSystem.Event.Changed, { file, event: "add" })
+                .pipe(Effect.andThen(Deferred.await(deferred)), Effect.timeout("1 second")),
+            ({ fiber }) => Fiber.interrupt(fiber),
+          )

          expect((yield* skill.list()).map((item) => item.id)).toEqual([Skill.ID.make("deploy")])
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: path.join(tmp.path, "generated"), type: "file" },
-            { path: source, type: "file" },
-            { path: source, type: "directory" },
-          ])
        }),
      ),
    ),
@@ -410,13 +371,10 @@ metadata:
          })

          const skill = yield* Skill.Service
-          const watcher = yield* Watcher.Test
          yield* skill.transform((editor) => editor.source({ type: "directory", path: AbsolutePath.make(source) }))
          expect((yield* skill.list()).find((item) => item.id === "bro")?.description).toBe("First")
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: first, type: "directory" },
-            { path: source, type: "file" },
-          ])
+          yield* expectSubscription((input) => input.type === "directory" && input.path === first)
+          yield* expectSubscription((input) => input.type === "directory" && input.path === tmp.path)

          yield* Effect.promise(async () => {
            await fs.unlink(source)
@@ -425,12 +383,7 @@ metadata:
          yield* emitAndWait({ type: "update", path: source })

          expect((yield* skill.list()).find((item) => item.id === "bro")?.description).toBe("Second")
-          expect(yield* watcher.subscriptions()).toEqual([
-            { path: first, type: "directory" },
-            { path: source, type: "file" },
-            { path: second, type: "directory" },
-            { path: source, type: "file" },
-          ])
+          yield* expectSubscription((input) => input.type === "directory" && input.path === second)
        }),
      ),
    ),