test(opencode): use local server for Codex refresh dedupe

bun.lock

@@ -29,7 +29,7 @@
     },
     "packages/app": {
       "name": "@opencode-ai/app",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@kobalte/core": "catalog:",
         "@opencode-ai/core": "workspace:*",
@@ -84,7 +84,7 @@
     },
     "packages/console/app": {
       "name": "@opencode-ai/console-app",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@cloudflare/vite-plugin": "1.15.2",
         "@ibm/plex": "6.4.1",
@@ -119,7 +119,7 @@
     },
     "packages/console/core": {
       "name": "@opencode-ai/console-core",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@aws-sdk/client-sts": "3.782.0",
         "@jsx-email/render": "1.1.1",
@@ -146,7 +146,7 @@
     },
     "packages/console/function": {
       "name": "@opencode-ai/console-function",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@ai-sdk/anthropic": "3.0.64",
         "@ai-sdk/openai": "3.0.48",
@@ -168,7 +168,7 @@
     },
     "packages/console/mail": {
       "name": "@opencode-ai/console-mail",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@jsx-email/all": "2.2.3",
         "@jsx-email/cli": "1.4.3",
@@ -192,7 +192,7 @@
     },
     "packages/core": {
       "name": "@opencode-ai/core",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "bin": {
         "opencode": "./bin/opencode",
       },
@@ -253,7 +253,7 @@
     },
     "packages/desktop": {
       "name": "@opencode-ai/desktop",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "drizzle-orm": "catalog:",
         "effect": "catalog:",
@@ -307,7 +307,7 @@
     },
     "packages/enterprise": {
       "name": "@opencode-ai/enterprise",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@opencode-ai/core": "workspace:*",
         "@opencode-ai/ui": "workspace:*",
@@ -337,7 +337,7 @@
     },
     "packages/function": {
       "name": "@opencode-ai/function",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@octokit/auth-app": "8.0.1",
         "@octokit/rest": "catalog:",
@@ -353,7 +353,7 @@
     },
     "packages/http-recorder": {
       "name": "@opencode-ai/http-recorder",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@effect/platform-node": "catalog:",
         "effect": "catalog:",
@@ -366,7 +366,7 @@
     },
     "packages/llm": {
       "name": "@opencode-ai/llm",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@smithy/eventstream-codec": "4.2.14",
         "@smithy/util-utf8": "4.2.2",
@@ -384,7 +384,7 @@
     },
     "packages/opencode": {
       "name": "opencode",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "bin": {
         "opencode": "./bin/opencode",
       },
@@ -522,7 +522,7 @@
     },
     "packages/plugin": {
       "name": "@opencode-ai/plugin",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@opencode-ai/sdk": "workspace:*",
         "effect": "catalog:",
@@ -560,7 +560,7 @@
     },
     "packages/sdk/js": {
       "name": "@opencode-ai/sdk",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "cross-spawn": "catalog:",
       },
@@ -575,7 +575,7 @@
     },
     "packages/slack": {
       "name": "@opencode-ai/slack",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@opencode-ai/sdk": "workspace:*",
         "@slack/bolt": "^3.17.1",
@@ -610,7 +610,7 @@
     },
     "packages/ui": {
       "name": "@opencode-ai/ui",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@kobalte/core": "catalog:",
         "@opencode-ai/core": "workspace:*",
@@ -659,7 +659,7 @@
     },
     "packages/web": {
       "name": "@opencode-ai/web",
-      "version": "1.15.5",
+      "version": "1.15.4",
       "dependencies": {
         "@astrojs/cloudflare": "12.6.3",
         "@astrojs/markdown-remark": "6.3.1",

packages/app/e2e/smoke/session-timeline.fixture.ts

@@ -1,314 +0,0 @@
-const words = [
-  "alpha",
-  "bravo",
-  "charlie",
-  "delta",
-  "echo",
-  "foxtrot",
-  "golf",
-  "hotel",
-  "india",
-  "juliet",
-  "kilo",
-  "lima",
-  "metro",
-  "nova",
-  "orbit",
-  "pixel",
-  "quartz",
-  "river",
-  "signal",
-  "vector",
-]
-
-const sourceID = "ses_smoke_source"
-const targetID = "ses_smoke_target"
-const directory = "C:/OpenCode/SmokeProject"
-const projectID = "proj_smoke_timeline"
-const model = { providerID: "opencode", modelID: "claude-opus-4-6", variant: "max" }
-
-type MessageInfo = Record<string, unknown> & { id: string; role: "user" | "assistant" }
-type MessagePart = Record<string, unknown> & { id: string; type: string; text?: string; tool?: string }
-type Message = { info: MessageInfo; parts: MessagePart[] }
-
-function lorem(seed: number, length: number) {
-  let out = ""
-  let i = seed
-  while (out.length < length) {
-    const word = words[i % words.length]
-    out += (out ? " " : "") + word
-    if (i % 17 === 0) out += ".\n\n"
-    i += 7
-  }
-  return out.slice(0, length)
-}
-
-function id(prefix: string, value: number) {
-  return `${prefix}_smoke_${String(value).padStart(4, "0")}`
-}
-
-function userMessage(sessionID: string, index: number, textLength: number, diffs: unknown[] = []): Message {
-  const messageID = id("msg_user", index)
-  return {
-    info: {
-      id: messageID,
-      sessionID,
-      role: "user",
-      time: { created: 1700000000000 + index * 10_000 },
-      summary: { diffs },
-      agent: "build",
-      model,
-    },
-    parts: [
-      {
-        id: id("prt_user_text", index),
-        sessionID,
-        messageID,
-        type: "text",
-        text: lorem(index, textLength),
-      },
-    ],
-  }
-}
-
-function assistantMessage(sessionID: string, index: number, parentID: string, parts: MessagePart[]): Message {
-  const messageID = id("msg_assistant", index)
-  return {
-    info: {
-      id: messageID,
-      sessionID,
-      role: "assistant",
-      time: { created: 1700000000000 + index * 10_000 + 1_000, completed: 1700000000000 + index * 10_000 + 8_000 },
-      parentID,
-      modelID: model.modelID,
-      providerID: model.providerID,
-      mode: "build",
-      agent: "build",
-      path: { cwd: directory, root: directory },
-      cost: 0.01,
-      tokens: { input: 100, output: 200, reasoning: 0, cache: { read: 0, write: 0 } },
-      variant: "max",
-      finish: "stop",
-    },
-    parts: parts.map((part) => ({
-      ...part,
-      sessionID,
-      messageID,
-    })),
-  }
-}
-
-function textPart(index: number, partIndex: number, length: number): MessagePart {
-  return { id: id(`prt_text_${partIndex}`, index), type: "text", text: lorem(index * 13 + partIndex, length) }
-}
-
-function reasoningPart(index: number, partIndex: number, length: number): MessagePart {
-  return {
-    id: id(`prt_reasoning_${partIndex}`, index),
-    type: "reasoning",
-    text: lorem(index * 19 + partIndex, length),
-    time: { start: 1700000000000 + index * 10_000, end: 1700000000000 + index * 10_000 + 500 },
-  }
-}
-
-function toolPart(
-  index: number,
-  partIndex: number,
-  tool: string,
-  input: Record<string, unknown>,
-  outputLength = 160,
-): MessagePart {
-  const metadata =
-    tool === "apply_patch"
-      ? { files: [patchFile(index, "update"), patchFile(index + 1, index % 2 === 0 ? "add" : "delete")] }
-      : tool === "edit" || tool === "write"
-        ? {
-            filediff: fileDiff(String(input.filePath ?? `src/generated/file-${index}.ts`), index),
-            diff: patch(index, outputLength),
-            preview: patch(index + 1, 420),
-          }
-        : tool === "question"
-          ? { answers: [["Proceed"], ["Keep sample output"]] }
-          : {}
-  return {
-    id: id(`prt_tool_${tool}_${partIndex}`, index),
-    type: "tool",
-    callID: id("call", index * 10 + partIndex),
-    tool,
-    state: {
-      status: "completed",
-      input,
-      output: lorem(index * 23 + partIndex, outputLength),
-      title: tool === "bash" ? "Verify generated output" : input.filePath || input.path || input.pattern || "completed",
-      metadata,
-      time: { start: 1700000000000 + index * 10_000, end: 1700000000000 + index * 10_000 + 400 },
-    },
-  }
-}
-
-function patchFile(seed: number, type: "add" | "update" | "delete") {
-  return {
-    filePath: `src/generated/patch-${seed}.ts`,
-    relativePath: `src/generated/patch-${seed}.ts`,
-    type,
-    additions: (seed % 7) + 1,
-    deletions: type === "add" ? 0 : seed % 4,
-    patch: patch(seed, 520),
-    before: type === "add" ? undefined : code(seed, 18),
-    after: type === "delete" ? undefined : code(seed + 1, 24),
-  }
-}
-
-function fileDiff(file: string, seed: number) {
-  return {
-    file,
-    additions: (seed % 9) + 1,
-    deletions: seed % 4,
-    before: code(seed, 32),
-    after: code(seed + 1, 38),
-  }
-}
-
-function patch(seed: number, length: number) {
-  return `diff --git a/src/generated/file-${seed}.ts b/src/generated/file-${seed}.ts\n+${lorem(seed, length).replace(/\n/g, "\n+")}`
-}
-
-function code(seed: number, lines: number) {
-  return Array.from({ length: lines }, (_, index) => `export const value${index} = "${lorem(seed + index, 32)}"`).join(
-    "\n",
-  )
-}
-
-function turn(index: number): Message[] {
-  const diff = index % 9 === 0 ? [fileDiff(`src/generated/summary-${index}.ts`, index)] : []
-  const user = userMessage(targetID, index, 100 + (index % 4) * 80, diff)
-  const parts = [
-    ...(index % 5 === 0 ? [reasoningPart(index, 0, 420)] : []),
-    ...(index % 3 === 0
-      ? [
-          toolPart(index, 0, "read", { filePath: `src/generated/file-${index}.ts`, offset: 0, limit: 80 }, 220),
-          toolPart(index, 5, "glob", { path: directory, pattern: `**/*sample-${index}*.ts` }, 140),
-          toolPart(index, 1, "grep", { path: directory, pattern: `sample-${index}`, include: "*.ts" }, 180),
-          toolPart(index, 6, "list", { path: `src/generated/${index}` }, 120),
-        ]
-      : []),
-    textPart(index, 2, 160 + (index % 6) * 90),
-    ...(index % 4 === 0 ? [toolPart(index, 3, "edit", { filePath: `src/generated/file-${index}.ts` }, 700)] : []),
-    ...(index % 6 === 0
-      ? [toolPart(index, 7, "write", { filePath: `src/generated/write-${index}.ts`, content: code(index, 28) }, 560)]
-      : []),
-    ...(index % 8 === 0
-      ? [toolPart(index, 8, "apply_patch", { files: [`src/generated/patch-${index}.ts`] }, 620)]
-      : []),
-    ...(index % 7 === 0
-      ? [toolPart(index, 4, "bash", { command: "bun typecheck", description: "Verify generated output" }, 620)]
-      : []),
-    ...(index % 10 === 0 ? [toolPart(index, 9, "webfetch", { url: "https://example.com/docs/sample" }, 120)] : []),
-    ...(index % 11 === 0 ? [toolPart(index, 10, "websearch", { query: "sample movement notes" }, 240)] : []),
-    ...(index % 13 === 0
-      ? [
-          toolPart(
-            index,
-            11,
-            "question",
-            { questions: [{ question: "Use generated fixture?" }, { question: "Keep same row shape?" }] },
-            120,
-          ),
-        ]
-      : []),
-    ...(index % 17 === 0
-      ? [toolPart(index, 12, "task", { description: "Inspect generated fixture", subagent_type: "explore" }, 160)]
-      : []),
-  ]
-  return [user, assistantMessage(targetID, index, user.info.id, parts)]
-}
-
-const targetMessages = Array.from({ length: 72 }, (_, index) => turn(index)).flat()
-const sourceMessages = Array.from({ length: 12 }, (_, index) => [
-  userMessage(sourceID, index + 1000, 120),
-  assistantMessage(sourceID, index + 1000, id("msg_user", index + 1000), [textPart(index + 1000, 0, 240)]),
-]).flat()
-
-function renderable(part: MessagePart) {
-  if (part.type === "tool" && part.tool === "todowrite") return false
-  if (part.type === "text") return !!part.text.trim()
-  if (part.type === "reasoning") return !!part.text.trim()
-  return part.type !== "step-start" && part.type !== "step-finish" && part.type !== "patch"
-}
-
-function orderedParts(message: Message) {
-  return message.parts.slice().sort((a, b) => a.id.localeCompare(b.id))
-}
-
-export const fixture = {
-  directory,
-  project: {
-    id: projectID,
-    worktree: directory,
-    vcs: "git",
-    name: "smoke-project",
-    time: { created: 1700000000000, updated: 1700000000000 },
-    sandboxes: [],
-  },
-  provider: {
-    all: [
-      {
-        id: "opencode",
-        name: "OpenCode",
-        models: { "claude-opus-4-6": { id: "claude-opus-4-6", name: "Claude Opus 4.6", limit: { context: 200_000 } } },
-      },
-    ],
-    connected: ["opencode"],
-    default: { providerID: "opencode", modelID: "claude-opus-4-6" },
-  },
-  sessions: [
-    {
-      id: sourceID,
-      slug: "source",
-      projectID,
-      directory,
-      title: "Uncommitted changes inquiry",
-      version: "dev",
-      time: { created: 1700000000000, updated: 1700000000000 },
-    },
-    {
-      id: targetID,
-      slug: "target",
-      projectID,
-      directory,
-      title: "Example Game: sample jump movement & sample physics analysis",
-      version: "dev",
-      time: { created: 1700000001000, updated: 1700000001000 },
-    },
-  ],
-  sourceID,
-  targetID,
-  messages: { [sourceID]: sourceMessages, [targetID]: targetMessages },
-  expected: {
-    sourceTitle: "Uncommitted changes inquiry",
-    targetTitle: "Example Game: sample jump movement & sample physics analysis",
-    targetMessageIDs: targetMessages
-      .filter((message) => message.info.role === "user")
-      .map((message) => message.info.id),
-    targetPartIDs: targetMessages.flatMap((message) =>
-      orderedParts(message)
-        .filter(renderable)
-        .map((part) => part.id),
-    ),
-  },
-}
-
-export function pageMessages(sessionID: string, limit: number, before?: string) {
-  const messages = fixture.messages[sessionID as keyof typeof fixture.messages] ?? []
-  const end = before
-    ? Math.max(
-        0,
-        messages.findIndex((message) => message.info.id === before),
-      )
-    : messages.length
-  const start = Math.max(0, end - limit)
-  return {
-    items: messages.slice(start, end),
-    cursor: start > 0 ? messages[start]!.info.id : undefined,
-  }
-}

packages/app/e2e/smoke/session-timeline.spec.ts

@@ -1,412 +0,0 @@
-import { expect, test, type Page } from "@playwright/test"
-import { fixture, pageMessages } from "./session-timeline.fixture"
-import { trackPageErrors, expectNoSmokeErrors } from "../utils/errors"
-import { mockOpenCodeServer } from "../utils/mock-server"
-
-const forbiddenText = ["Load details", "Show earlier steps"]
-
-type SmokeState = {
-  ids: string[]
-  visibleIds: string[]
-  messageIds: string[]
-  visibleMessageIds: string[]
-  topVisibleId?: string
-  signature: string
-  scrollTop: number
-  scrollHeight: number
-  clientHeight: number
-  errorToasts: string[]
-  forbiddenText: string[]
-}
-
-type SmokeWindow = Window & {
-  __timelineSmokeState?: () => SmokeState
-  __timelineSmokeErrorToasts?: string[]
-  __timelineSmokeForbiddenText?: string[]
-}
-
-test.describe("smoke: session timeline", () => {
-  test.setTimeout(240_000)
-
-  test("renders seeded timeline in order while paging through history", async ({ page }) => {
-    const errors = trackPageErrors(page)
-    await mockOpenCodeServer(page, {
-      sessions: fixture.sessions,
-      provider: fixture.provider,
-      directory: fixture.directory,
-      project: fixture.project,
-      pageMessages,
-    })
-    await configureSmokePage(page)
-
-    await openProject(page, "SmokeProject")
-    await navigateToSession(page, fixture.sourceID, fixture.expected.sourceTitle)
-    await expectSessionReady(page, "smoke-project")
-    await navigateToSession(page, fixture.targetID, fixture.expected.targetTitle)
-    const expectedPartIDs = fixture.expected.targetPartIDs
-    const expectedMessageIDs = fixture.expected.targetMessageIDs
-    await expectSessionTimelineReady(page, expectedPartIDs, expectedMessageIDs, errors)
-    await expectCanScrollToStart(page, expectedPartIDs, expectedMessageIDs, errors)
-  })
-})
-
-async function configureSmokePage(page: Page) {
-  await page.addInitScript(() => {
-    localStorage.setItem(
-      "settings.v3",
-      JSON.stringify({
-        general: {
-          editToolPartsExpanded: true,
-          shellToolPartsExpanded: true,
-          showReasoningSummaries: true,
-          showSessionProgressBar: true,
-        },
-      }),
-    )
-
-    const smoke = window as SmokeWindow
-    smoke.__timelineSmokeErrorToasts = []
-    smoke.__timelineSmokeForbiddenText = []
-    const partSelector = "[data-timeline-part-id], [data-timeline-part-ids]"
-    const idsOf = (el: HTMLElement) =>
-      [el.dataset.timelinePartId, ...(el.dataset.timelinePartIds?.split(",") ?? [])].filter((id): id is string => !!id)
-
-    smoke.__timelineSmokeState = () => {
-      const scroller = [...document.querySelectorAll<HTMLElement>(".scroll-view__viewport")].find((el) =>
-        el.querySelector("[data-timeline-row], [data-session-title]"),
-      )
-      if (!scroller) {
-        return {
-          ids: [],
-          visibleIds: [],
-          messageIds: [],
-          visibleMessageIds: [],
-          topVisibleId: undefined,
-          signature: "",
-          scrollTop: 0,
-          scrollHeight: 0,
-          clientHeight: 0,
-          errorToasts: smoke.__timelineSmokeErrorToasts ?? [],
-          forbiddenText: smoke.__timelineSmokeForbiddenText ?? [],
-        }
-      }
-
-      const ids: string[] = []
-      const visibleIds: string[] = []
-      const scrollerRect = scroller.getBoundingClientRect()
-      let topVisibleId: string | undefined
-      for (const el of scroller.querySelectorAll<HTMLElement>(partSelector)) {
-        const next = idsOf(el)
-        ids.push(...next)
-
-        const rect = el.getBoundingClientRect()
-        if (rect.bottom >= scrollerRect.top && rect.top <= scrollerRect.bottom) {
-          if (!topVisibleId) topVisibleId = next[0]
-          visibleIds.push(...next)
-        }
-      }
-
-      const messageIds: string[] = []
-      const visibleMessageIds: string[] = []
-      const rows = [...scroller.querySelectorAll<HTMLElement>("[data-message-id]")].map((el) => {
-        const rect = el.getBoundingClientRect()
-        const id = el.dataset.messageId
-        if (id) {
-          messageIds.push(id)
-          if (rect.bottom >= scrollerRect.top && rect.top <= scrollerRect.bottom) visibleMessageIds.push(id)
-        }
-        return {
-          id,
-          top: Math.round(rect.top),
-          bottom: Math.round(rect.bottom),
-        }
-      })
-      const signature = JSON.stringify({
-        top: Math.round(scroller.scrollTop),
-        height: Math.round(scroller.scrollHeight),
-        rows,
-        ids,
-      })
-
-      return {
-        ids,
-        visibleIds,
-        messageIds,
-        visibleMessageIds,
-        topVisibleId,
-        signature,
-        scrollTop: Math.round(scroller.scrollTop),
-        scrollHeight: Math.round(scroller.scrollHeight),
-        clientHeight: Math.round(scroller.clientHeight),
-        errorToasts: smoke.__timelineSmokeErrorToasts ?? [],
-        forbiddenText: smoke.__timelineSmokeForbiddenText ?? [],
-      }
-    }
-    let recordFrame: number | undefined
-    const record = () => {
-      for (const toast of document.querySelectorAll<HTMLElement>('[data-component="toast"][data-variant="error"]')) {
-        const text = toast.textContent?.trim()
-        if (text && !smoke.__timelineSmokeErrorToasts!.includes(text)) smoke.__timelineSmokeErrorToasts!.push(text)
-      }
-      const text = document.body?.textContent ?? ""
-      for (const value of ["Load details", "Show earlier steps"]) {
-        if (text.includes(value) && !smoke.__timelineSmokeForbiddenText!.includes(value)) {
-          smoke.__timelineSmokeForbiddenText!.push(value)
-        }
-      }
-    }
-    const start = () => {
-      const root = document.documentElement ?? document.body
-      if (!root) return
-      new MutationObserver(() => {
-        if (recordFrame) return
-        recordFrame = requestAnimationFrame(() => {
-          recordFrame = undefined
-          record()
-        })
-      }).observe(root, { childList: true, subtree: true })
-      record()
-    }
-    if (document.documentElement ?? document.body) start()
-    else document.addEventListener("DOMContentLoaded", start, { once: true })
-  })
-}
-
-async function expectCanScrollToStart(
-  page: Page,
-  expectedPartIDs: string[],
-  expectedMessageIDs: string[],
-  errors: string[],
-) {
-  await pointAtTimeline(page)
-  const seenParts = new Set<string>()
-  const seenMessages = new Set<string>()
-  const samples: TraversalSample[] = []
-  let current = await timelineState(page)
-  let unchangedAtTop = 0
-
-  for (let attempt = 0; attempt < 600; attempt++) {
-    collectSeen(current, seenParts, seenMessages)
-    samples.push(sampleTraversal(current, seenParts.size, seenMessages.size))
-    expectNoSmokeErrors(errors, current.errorToasts, current.forbiddenText)
-    expectOrderedIDs(expectedPartIDs, current.ids, "mounted part")
-    expectOrderedIDs(expectedPartIDs, current.visibleIds, "visible part")
-    expectOrderedIDs(expectedMessageIDs, unique(current.messageIds), "mounted message")
-    expectOrderedIDs(expectedMessageIDs, unique(current.visibleMessageIds), "visible message")
-
-    if (
-      current.scrollTop <= 1 &&
-      seenParts.size === expectedPartIDs.length &&
-      seenMessages.size === expectedMessageIDs.length
-    ) {
-      expectCompleteScroll(current, expectedPartIDs, expectedMessageIDs, seenParts, seenMessages, samples)
-      return
-    }
-
-    const before = current
-    const changed = await scrollTimelineUp(page, current)
-    current = await timelineState(page)
-    if (!changed && current.signature === before.signature && current.scrollTop <= 1) unchangedAtTop++
-    else unchangedAtTop = 0
-    if (unchangedAtTop >= 2) break
-  }
-
-  collectSeen(current, seenParts, seenMessages)
-  samples.push(sampleTraversal(current, seenParts.size, seenMessages.size))
-  expectCompleteScroll(current, expectedPartIDs, expectedMessageIDs, seenParts, seenMessages, samples)
-}
-
-async function timelineState(page: Page) {
-  return page.evaluate(
-    () =>
-      (window as SmokeWindow).__timelineSmokeState?.() ?? {
-        ids: [],
-        visibleIds: [],
-        messageIds: [],
-        visibleMessageIds: [],
-        topVisibleId: undefined,
-        signature: "",
-        scrollTop: 0,
-        scrollHeight: 0,
-        clientHeight: 0,
-        errorToasts: [],
-        forbiddenText: [],
-      },
-  )
-}
-
-function timelineScroller(page: Page) {
-  return page.locator(".scroll-view__viewport", { has: page.locator("[data-timeline-row]") })
-}
-
-async function pointAtTimeline(page: Page) {
-  const box = await timelineScroller(page).boundingBox()
-  if (!box) throw new Error("Timeline scroller is not visible")
-  await page.mouse.move(box.x + box.width / 2, box.y + box.height / 2)
-}
-
-async function scrollTimelineUp(page: Page, before: SmokeState) {
-  return page.evaluate(
-    (prev) =>
-      new Promise<boolean>((resolve) => {
-        const scroller = [...document.querySelectorAll<HTMLElement>(".scroll-view__viewport")].find((el) =>
-          el.querySelector("[data-timeline-row], [data-session-title]"),
-        )
-        if (!scroller) {
-          resolve(false)
-          return
-        }
-
-        scroller.dispatchEvent(new WheelEvent("wheel", { bubbles: true, cancelable: true, deltaY: -1, deltaMode: 0 }))
-        scroller.scrollTop = Math.max(0, scroller.scrollTop - Math.max(80, Math.round(scroller.clientHeight * 0.45)))
-
-        const read = () => (window as SmokeWindow).__timelineSmokeState?.().signature ?? ""
-        let frames = 0
-        let stableFrames = 0
-        let last = ""
-        let changed = false
-        const check = () => {
-          const current = read()
-          if (current !== prev) changed = true
-          if (current === last) stableFrames++
-          else {
-            stableFrames = 0
-            last = current
-          }
-          if (changed && stableFrames >= 2) {
-            resolve(true)
-            return
-          }
-          frames++
-          if (frames >= 30) {
-            resolve(changed)
-            return
-          }
-          requestAnimationFrame(check)
-        }
-        requestAnimationFrame(check)
-      }),
-    before.signature,
-  )
-}
-
-function expectOrderedIDs(expected: string[], actual: string[], label: string) {
-  expect(actual.length, `${label} ids should not be empty`).toBeGreaterThan(0)
-  const actualSet = new Set(actual)
-  expect(actual, `${label} ids`).toEqual(expected.filter((id) => actualSet.has(id)))
-}
-
-function unique(values: string[]) {
-  return values.filter((value, index) => values.indexOf(value) === index)
-}
-
-function collectSeen(state: SmokeState, seenParts: Set<string>, seenMessages: Set<string>) {
-  for (const id of state.ids) seenParts.add(id)
-  for (const id of state.visibleIds) seenParts.add(id)
-  for (const id of state.messageIds) seenMessages.add(id)
-  for (const id of state.visibleMessageIds) seenMessages.add(id)
-}
-
-type TraversalSample = ReturnType<typeof sampleTraversal>
-
-function sampleTraversal(state: SmokeState, seenParts: number, seenMessages: number) {
-  return {
-    seenParts,
-    seenMessages,
-    mounted: state.ids.length,
-    visible: state.visibleIds.length,
-    mountedMessages: unique(state.messageIds).length,
-    visibleMessages: unique(state.visibleMessageIds).length,
-    top: state.scrollTop,
-    height: state.scrollHeight,
-    first: state.ids[0],
-    last: state.ids.at(-1),
-    topVisible: state.topVisibleId,
-    visibleFirst: state.visibleIds[0],
-    visibleLast: state.visibleIds.at(-1),
-  }
-}
-
-function sampleSummary(samples: TraversalSample[]) {
-  return samples
-    .filter((_, index) => index % Math.max(1, Math.floor(samples.length / 8)) === 0 || index === samples.length - 1)
-    .map(
-      (sample, index) =>
-        `${index}: seenParts=${sample.seenParts} seenMessages=${sample.seenMessages} mounted=${sample.mounted}/${sample.mountedMessages} visible=${sample.visible}/${sample.visibleMessages} top=${sample.top}/${sample.height} first=${sample.first} last=${sample.last} topVisible=${sample.topVisible} visible=${sample.visibleFirst}..${sample.visibleLast}`,
-    )
-    .join("\n")
-}
-
-async function waitForTimelineStable(page: Page) {
-  await page.waitForFunction(
-    () =>
-      new Promise<boolean>((resolve) => {
-        requestAnimationFrame(() => {
-          const a = (window as SmokeWindow).__timelineSmokeState?.().signature ?? ""
-          requestAnimationFrame(() => {
-            const b = (window as SmokeWindow).__timelineSmokeState?.().signature ?? ""
-            requestAnimationFrame(() =>
-              resolve(!!a && a === b && b === ((window as SmokeWindow).__timelineSmokeState?.().signature ?? "")),
-            )
-          })
-        })
-      }),
-  )
-}
-
-async function expectSessionTimelineReady(
-  page: Page,
-  expectedPartIDs: string[],
-  expectedMessageIDs: string[],
-  errors: string[],
-) {
-  await waitForTimelineStable(page)
-  for (const text of forbiddenText) await expect(page.getByText(text)).toHaveCount(0)
-  const currentState = await timelineState(page)
-  expectNoSmokeErrors(errors, currentState.errorToasts, currentState.forbiddenText)
-  expectOrderedIDs(expectedPartIDs, currentState.ids, "mounted part")
-  expectOrderedIDs(expectedPartIDs, currentState.visibleIds, "visible part")
-  expectOrderedIDs(expectedMessageIDs, unique(currentState.messageIds), "mounted message")
-  expectOrderedIDs(expectedMessageIDs, unique(currentState.visibleMessageIds), "visible message")
-}
-
-function expectCompleteScroll(
-  state: SmokeState,
-  expectedPartIDs: string[],
-  expectedMessageIDs: string[],
-  seenParts: Set<string>,
-  seenMessages: Set<string>,
-  samples: TraversalSample[],
-) {
-  expect(state.scrollTop, `timeline should reach the start\n${sampleSummary(samples)}`).toBeLessThanOrEqual(1)
-  expect(
-    expectedPartIDs.filter((id) => !seenParts.has(id)),
-    `missing visible timeline parts\n${sampleSummary(samples)}`,
-  ).toEqual([])
-  expect(
-    expectedMessageIDs.filter((id) => !seenMessages.has(id)),
-    `missing visible messages\n${sampleSummary(samples)}`,
-  ).toEqual([])
-  expect(new Set(expectedPartIDs).size).toBe(expectedPartIDs.length)
-  expect(new Set(expectedMessageIDs).size).toBe(expectedMessageIDs.length)
-  expect(expectedPartIDs.length).toBe(331)
-}
-
-async function openProject(page: Page, projectName: string) {
-  await page.goto("/")
-  await page.getByRole("button", { name: new RegExp(projectName, "i") }).click()
-}
-
-async function navigateToSession(page: Page, sessionId: string, expectedTitle: string) {
-  // Use evaluate to click to avoid strict visibility/animation issues during rapid e2e navigation
-  await page
-    .locator(`a[href*="${sessionId}"]`)
-    .first()
-    .evaluate((el) => (el as HTMLElement).click())
-  await expect(page.getByRole("heading", { name: expectedTitle })).toBeVisible()
-}
-
-async function expectSessionReady(page: Page, projectName: string) {
-  await expect(page.getByText(projectName).first()).toBeVisible()
-  await expect(page.getByText("Ask anything...")).toBeVisible()
-}

packages/app/e2e/todo.spec.ts

@@ -0,0 +1,11 @@
+import { test } from "@playwright/test"
+
+test(
+  "test something cool",
+  {
+    annotation: { type: "todo" },
+  },
+  async () => {
+    test.fixme()
+  },
+)

packages/app/e2e/utils/errors.ts

@@ -1,18 +0,0 @@
-import { expect, type Page } from "@playwright/test"
-
-export function trackPageErrors(page: Page) {
-  const errors: string[] = []
-  page.on("console", (message) => {
-    if (message.type() === "error") errors.push(message.text())
-  })
-  page.on("pageerror", (error) => errors.push(error.stack ?? error.message))
-  return errors
-}
-
-export function expectNoSmokeErrors(consoleErrors: string[], toastErrors: string[], forbiddenText: string[]) {
-  expect({ consoleErrors, toastErrors, forbiddenText }).toEqual({
-    consoleErrors: [],
-    toastErrors: [],
-    forbiddenText: [],
-  })
-}

packages/app/e2e/utils/mock-server.ts

@@ -1,86 +0,0 @@
-import type { Page, Route } from "@playwright/test"
-
-const emptyList = new Set([
-  "/skill",
-  "/command",
-  "/lsp",
-  "/formatter",
-  "/permission",
-  "/question",
-  "/vcs/status",
-  "/vcs/diff",
-])
-const emptyObject = new Set(["/global/config", "/config", "/provider/auth", "/mcp", "/session/status"])
-
-export interface MockServerConfig {
-  provider: unknown
-  directory: string
-  project: unknown
-  sessions: ({ id: string } & Record<string, unknown>)[]
-  pageMessages: (sessionId: string, limit: number, before?: string) => { items: unknown[]; cursor?: string }
-}
-
-export async function mockOpenCodeServer(page: Page, config: MockServerConfig) {
-  const staticRoutes: Record<string, unknown> = {
-    "/provider": config.provider,
-    "/path": {
-      state: config.directory,
-      config: config.directory,
-      worktree: config.directory,
-      directory: config.directory,
-      home: "C:/OpenCode",
-    },
-    "/project": [config.project],
-    "/project/current": config.project,
-    "/agent": [{ name: "build", mode: "primary" }],
-    "/vcs": { branch: "main", default_branch: "main" },
-    "/session": config.sessions,
-  }
-
-  await page.route("**/*", async (route) => {
-    const url = new URL(route.request().url())
-    const targetPort = process.env.PLAYWRIGHT_SERVER_PORT ?? "4096"
-    if (url.port !== targetPort) return route.fallback()
-
-    const path = url.pathname
-    if (path === "/global/event" || path === "/event") return sse(route)
-    if (emptyObject.has(path)) return json(route, {})
-    if (emptyList.has(path)) return json(route, [])
-    if (path in staticRoutes) return json(route, staticRoutes[path])
-
-    const sessionMatch = path.match(/^\/session\/([^/]+)$/)
-    if (sessionMatch) {
-      const session = config.sessions.find((s) => s.id === sessionMatch[1])
-      return json(route, session ?? {})
-    }
-
-    if (/^\/session\/[^/]+\/(children|todo|diff)$/.test(path)) return json(route, [])
-
-    const messagesMatch = path.match(/^\/session\/([^/]+)\/message$/)
-    if (messagesMatch) {
-      const limit = Number(url.searchParams.get("limit") ?? 80)
-      const before = url.searchParams.get("before") ?? undefined
-      const pageData = config.pageMessages(messagesMatch[1], limit, before)
-      return json(route, pageData.items, pageData.cursor ? { "x-next-cursor": pageData.cursor } : undefined)
-    }
-
-    return json(route, {})
-  })
-}
-
-function json(route: Route, body: unknown, headers?: Record<string, string>) {
-  return route.fulfill({
-    status: 200,
-    contentType: "application/json",
-    headers: {
-      "access-control-allow-origin": "*",
-      "access-control-expose-headers": "x-next-cursor",
-      ...headers,
-    },
-    body: JSON.stringify(body ?? null),
-  })
-}
-
-function sse(route: Route) {
-  return route.fulfill({ status: 200, contentType: "text/event-stream", body: ": ok\n\n" })
-}

packages/app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/app",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "description": "",
   "type": "module",
   "exports": {

packages/console/app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/console-app",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "type": "module",
   "license": "MIT",
   "scripts": {

packages/console/core/package.json

@@ -1,7 +1,7 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
   "name": "@opencode-ai/console-core",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "private": true,
   "type": "module",
   "license": "MIT",

packages/console/function/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/console-function",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "$schema": "https://json.schemastore.org/package.json",
   "private": true,
   "type": "module",

packages/console/mail/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/console-mail",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "dependencies": {
     "@jsx-email/all": "2.2.3",
     "@jsx-email/cli": "1.4.3",

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "name": "@opencode-ai/core",
   "type": "module",
   "license": "MIT",

packages/desktop/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@opencode-ai/desktop",
   "private": true,
-  "version": "1.15.5",
+  "version": "1.15.4",
   "type": "module",
   "license": "MIT",
   "homepage": "https://opencode.ai",

packages/enterprise/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/enterprise",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "private": true,
   "type": "module",
   "license": "MIT",

packages/extensions/zed/extension.toml

@@ -1,7 +1,7 @@
 id = "opencode"
 name = "OpenCode"
 description = "The open source coding agent."
-version = "1.15.5"
+version = "1.15.4"
 schema_version = 1
 authors = ["Anomaly"]
 repository = "https://github.com/anomalyco/opencode"
@@ -11,26 +11,26 @@ name = "OpenCode"
 icon = "./icons/opencode.svg"
 
 [agent_servers.opencode.targets.darwin-aarch64]
-archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.5/opencode-darwin-arm64.zip"
+archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.4/opencode-darwin-arm64.zip"
 cmd = "./opencode"
 args = ["acp"]
 
 [agent_servers.opencode.targets.darwin-x86_64]
-archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.5/opencode-darwin-x64.zip"
+archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.4/opencode-darwin-x64.zip"
 cmd = "./opencode"
 args = ["acp"]
 
 [agent_servers.opencode.targets.linux-aarch64]
-archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.5/opencode-linux-arm64.tar.gz"
+archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.4/opencode-linux-arm64.tar.gz"
 cmd = "./opencode"
 args = ["acp"]
 
 [agent_servers.opencode.targets.linux-x86_64]
-archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.5/opencode-linux-x64.tar.gz"
+archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.4/opencode-linux-x64.tar.gz"
 cmd = "./opencode"
 args = ["acp"]
 
 [agent_servers.opencode.targets.windows-x86_64]
-archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.5/opencode-windows-x64.zip"
+archive = "https://github.com/anomalyco/opencode/releases/download/v1.15.4/opencode-windows-x64.zip"
 cmd = "./opencode.exe"
 args = ["acp"]

packages/function/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/function",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "$schema": "https://json.schemastore.org/package.json",
   "private": true,
   "type": "module",

packages/http-recorder/package.json

@@ -1,6 +1,6 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "name": "@opencode-ai/http-recorder",
   "type": "module",
   "license": "MIT",

packages/llm/package.json

@@ -1,6 +1,6 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "name": "@opencode-ai/llm",
   "type": "module",
   "license": "MIT",

packages/opencode/package.json

@@ -1,6 +1,6 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "name": "opencode",
   "type": "module",
   "license": "MIT",

packages/opencode/src/cli/cmd/tui/context/route.tsx

@@ -1,8 +1,6 @@
 import { createStore, reconcile } from "solid-js/store"
-import { Option, Schema } from "effect"
 import { createSimpleContext } from "./helper"
 import type { PromptInfo } from "../component/prompt/history"
-import { tryJsonConfig } from "@/util/json"
 
 export type HomeRoute = {
   type: "home"
@@ -23,25 +21,17 @@ export type PluginRoute = {
 
 export type Route = HomeRoute | SessionRoute | PluginRoute
 
-const HOME_ROUTE: Route = { type: "home" }
-
-// Schema covers only the env-fed shape — `prompt` is set programmatically and
-// not expected from OPENCODE_ROUTE, so we keep it out of validation.
-export const RouteSchema = Schema.Union([
-  Schema.Struct({ type: Schema.Literal("home") }),
-  Schema.Struct({ type: Schema.Literal("session"), sessionID: Schema.String }),
-  Schema.Struct({
-    type: Schema.Literal("plugin"),
-    id: Schema.String,
-    data: Schema.optional(Schema.Record(Schema.String, Schema.Unknown)),
-  }),
-])
-
 export const { use: useRoute, provider: RouteProvider } = createSimpleContext({
   name: "Route",
   init: (props: { initialRoute?: Route }) => {
-    const fromEnv = tryJsonConfig(process.env["OPENCODE_ROUTE"], RouteSchema, "OPENCODE_ROUTE")
-    const [store, setStore] = createStore<Route>(props.initialRoute ?? Option.getOrElse(fromEnv, () => HOME_ROUTE))
+    const [store, setStore] = createStore<Route>(
+      props.initialRoute ??
+        (process.env["OPENCODE_ROUTE"]
+          ? JSON.parse(process.env["OPENCODE_ROUTE"])
+          : {
+              type: "home",
+            }),
+    )
 
     return {
       get data() {

packages/opencode/src/cli/error.ts

@@ -106,21 +106,6 @@ export function FormatError(input: unknown): string | undefined {
     ].join("\n")
   }
 
-  // InvalidConfigError: malformed env-var JSON at a safety boundary
-  if (isTaggedError(input, "InvalidConfigError")) {
-    const source = stringField(input, "source") ?? ""
-    const value = stringField(input, "value") ?? ""
-    const reason = stringField(input, "reason") ?? ""
-    return [
-      `Error: ${source} is invalid and cannot be applied.`,
-      `  Value: '${value}'`,
-      `  Reason: ${reason}`,
-      "",
-      `opencode will not start with a malformed ${source}. Set ${source}`,
-      `correctly or unset it to use defaults.`,
-    ].join("\n")
-  }
-
   // UICancelledError: user cancelled an interactive CLI prompt
   if (isTaggedError(input, "UICancelledError") || NamedError.hasName(input, "UICancelledError")) {
     return ""

packages/opencode/src/config/config.ts

@@ -14,7 +14,6 @@ import { InstallationLocal, InstallationVersion } from "@opencode-ai/core/instal
 import { existsSync } from "fs"
 import { Account } from "@/account/account"
 import { isRecord } from "@/util/record"
-import { requireJsonConfig } from "@/util/json"
 import type { ConsoleState } from "./console-state"
 import { AppFileSystem } from "@opencode-ai/core/filesystem"
 import { InstanceState } from "@/effect/instance-state"
@@ -704,8 +703,7 @@ export const layer = Layer.effect(
         }
 
         if (Flag.OPENCODE_PERMISSION) {
-          const decoded = requireJsonConfig(Flag.OPENCODE_PERMISSION, ConfigPermission.Info, "OPENCODE_PERMISSION")
-          result.permission = mergeDeep(result.permission ?? {}, decoded)
+          result.permission = mergeDeep(result.permission ?? {}, JSON.parse(Flag.OPENCODE_PERMISSION))
         }
 
         if (result.tools) {

packages/opencode/src/plugin/codex.ts

@@ -118,6 +118,11 @@ interface TokenResponse {
   expires_in?: number
 }
 
+interface CodexAuthPluginOptions {
+  issuer?: string
+  codexApiEndpoint?: string
+}
+
 async function exchangeCodeForTokens(code: string, redirectUri: string, pkce: PkceCodes): Promise<TokenResponse> {
   const response = await fetch(`${ISSUER}/oauth/token`, {
     method: "POST",
@@ -136,8 +141,8 @@ async function exchangeCodeForTokens(code: string, redirectUri: string, pkce: Pk
   return response.json()
 }
 
-async function refreshAccessToken(refreshToken: string): Promise<TokenResponse> {
-  const response = await fetch(`${ISSUER}/oauth/token`, {
+async function refreshAccessToken(refreshToken: string, issuer = ISSUER): Promise<TokenResponse> {
+  const response = await fetch(`${issuer}/oauth/token`, {
     method: "POST",
     headers: { "Content-Type": "application/x-www-form-urlencoded" },
     body: new URLSearchParams({
@@ -364,7 +369,10 @@ function waitForOAuthCallback(pkce: PkceCodes, state: string): Promise<TokenResp
   })
 }
 
-export async function CodexAuthPlugin(input: PluginInput): Promise<Hooks> {
+export async function CodexAuthPlugin(input: PluginInput, options: CodexAuthPluginOptions = {}): Promise<Hooks> {
+  const issuer = options.issuer ?? ISSUER
+  const codexApiEndpoint = options.codexApiEndpoint ?? CODEX_API_ENDPOINT
+
   return {
     provider: {
       id: "openai",
@@ -405,6 +413,13 @@ export async function CodexAuthPlugin(input: PluginInput): Promise<Hooks> {
         const auth = await getAuth()
         if (auth.type !== "oauth") return {}
 
+        let refreshPromise:
+          | Promise<{
+              access: string
+              accountId: string | undefined
+            }>
+          | undefined
+
         return {
           apiKey: OAUTH_DUMMY_KEY,
           async fetch(requestInput: RequestInfo | URL, init?: RequestInit) {
@@ -429,21 +444,34 @@ export async function CodexAuthPlugin(input: PluginInput): Promise<Hooks> {
 
             // Check if token needs refresh
             if (!currentAuth.access || currentAuth.expires < Date.now()) {
-              log.info("refreshing codex access token")
-              const tokens = await refreshAccessToken(currentAuth.refresh)
-              const newAccountId = extractAccountId(tokens) || authWithAccount.accountId
-              await input.client.auth.set({
-                path: { id: "openai" },
-                body: {
-                  type: "oauth",
-                  refresh: tokens.refresh_token,
-                  access: tokens.access_token,
-                  expires: Date.now() + (tokens.expires_in ?? 3600) * 1000,
-                  ...(newAccountId && { accountId: newAccountId }),
-                },
-              })
-              currentAuth.access = tokens.access_token
-              authWithAccount.accountId = newAccountId
+              if (!refreshPromise) {
+                log.info("refreshing codex access token")
+                refreshPromise = refreshAccessToken(currentAuth.refresh, issuer)
+                  .then(async (tokens) => {
+                    const accountId = extractAccountId(tokens) || authWithAccount.accountId
+                    await input.client.auth.set({
+                      path: { id: "openai" },
+                      body: {
+                        type: "oauth",
+                        refresh: tokens.refresh_token,
+                        access: tokens.access_token,
+                        expires: Date.now() + (tokens.expires_in ?? 3600) * 1000,
+                        ...(accountId && { accountId }),
+                      },
+                    })
+                    return {
+                      access: tokens.access_token,
+                      accountId,
+                    }
+                  })
+                  .finally(() => {
+                    refreshPromise = undefined
+                  })
+              }
+
+              const refreshed = await refreshPromise
+              currentAuth.access = refreshed.access
+              authWithAccount.accountId = refreshed.accountId
             }
 
             // Build headers
@@ -477,7 +505,7 @@ export async function CodexAuthPlugin(input: PluginInput): Promise<Hooks> {
                 : new URL(typeof requestInput === "string" ? requestInput : requestInput.url)
             const url =
               parsed.pathname.includes("/v1/responses") || parsed.pathname.includes("/chat/completions")
-                ? new URL(CODEX_API_ENDPOINT)
+                ? new URL(codexApiEndpoint)
                 : parsed
 
             return fetch(url, {

packages/opencode/src/session/llm/native-runtime.ts

@@ -42,7 +42,12 @@ export function status(input: Pick<StreamInput, "model" | "provider" | "auth">):
   if (input.model.api.npm !== "@ai-sdk/openai") return { type: "unsupported", reason: "provider package is not OpenAI" }
   if (input.auth?.type === "oauth") return { type: "unsupported", reason: "OAuth auth is not supported" }
 
-  const apiKey = typeof input.provider.options.apiKey === "string" ? input.provider.options.apiKey : input.provider.key
+  const apiKey =
+    input.auth?.type === "api"
+      ? input.auth.key
+      : typeof input.provider.options.apiKey === "string"
+        ? input.provider.options.apiKey
+        : undefined
   if (!apiKey) return { type: "unsupported", reason: "OpenAI API key is not configured" }
 
   return {

packages/opencode/src/util/json.ts

@@ -1,49 +0,0 @@
-import { Option, Result, Schema } from "effect"
-import * as Log from "@opencode-ai/core/util/log"
-
-const log = Log.create({ service: "config" })
-
-const decodeJsonUnknown = Schema.decodeUnknownResult(Schema.UnknownFromJsonString)
-
-export class InvalidConfigError extends Schema.TaggedErrorClass<InvalidConfigError>()("InvalidConfigError", {
-  source: Schema.String,
-  value: Schema.String,
-  reason: Schema.String,
-}) {}
-
-// Decode JSON config at a safety boundary. On malformed JSON or schema
-// mismatch, throws `InvalidConfigError`. On success, returns the typed value.
-// Use when defaulting silently is dangerous (e.g. permissions).
-export function requireJsonConfig<S extends Schema.Decoder<unknown>>(raw: string, schema: S, source: string): S["Type"] {
-  const decoded = decode(raw, schema)
-  if (Result.isFailure(decoded)) {
-    throw new InvalidConfigError({ source, value: raw, reason: decoded.failure })
-  }
-  return decoded.success
-}
-
-// Decode JSON config at a UX-preference boundary. Returns `None` for absent,
-// empty, malformed, or schema-mismatched input, logging a warn so the user
-// can debug. Use when defaulting silently is benign (e.g. theme, route).
-export function tryJsonConfig<S extends Schema.Decoder<unknown>>(
-  raw: string | undefined,
-  schema: S,
-  source: string,
-): Option.Option<S["Type"]> {
-  if (!raw) return Option.none()
-  const decoded = decode(raw, schema)
-  if (Result.isFailure(decoded)) {
-    log.warn(`ignoring invalid ${source}`, { value: raw, reason: decoded.failure })
-    return Option.none()
-  }
-  return Option.some(decoded.success)
-}
-
-function decode<S extends Schema.Decoder<unknown>>(raw: string, schema: S): Result.Result<S["Type"], string> {
-  const decodeSchema = Schema.decodeUnknownResult(schema)
-  const parsed = decodeJsonUnknown(raw)
-  if (Result.isFailure(parsed)) return Result.fail(parsed.failure.toString())
-  const decoded = decodeSchema(parsed.success)
-  if (Result.isFailure(decoded)) return Result.fail(decoded.failure.toString())
-  return Result.succeed(decoded.success)
-}

packages/opencode/test/cli/tui/route-env.test.ts

@@ -1,43 +0,0 @@
-import { describe, expect, test } from "bun:test"
-import { Option } from "effect"
-import { RouteSchema } from "@/cli/cmd/tui/context/route"
-import { tryJsonConfig } from "@/util/json"
-
-const parse = (raw: string | undefined) => tryJsonConfig(raw, RouteSchema, "OPENCODE_ROUTE")
-
-describe("tryJsonConfig with RouteSchema", () => {
-  test("returns None for undefined input", () => {
-    expect(Option.isNone(parse(undefined))).toBe(true)
-  })
-
-  test("returns None for empty string", () => {
-    expect(Option.isNone(parse(""))).toBe(true)
-  })
-
-  test("returns None for malformed JSON", () => {
-    expect(Option.isNone(parse("{not json"))).toBe(true)
-  })
-
-  test("returns None when JSON does not match route schema", () => {
-    expect(Option.isNone(parse(`{"type":"unknown"}`))).toBe(true)
-  })
-
-  test("returns Some for valid home route", () => {
-    expect(Option.getOrThrow(parse(`{"type":"home"}`))).toEqual({ type: "home" })
-  })
-
-  test("returns Some for valid session route", () => {
-    expect(Option.getOrThrow(parse(`{"type":"session","sessionID":"abc123"}`))).toEqual({
-      type: "session",
-      sessionID: "abc123",
-    })
-  })
-
-  test("returns Some for valid plugin route", () => {
-    expect(Option.getOrThrow(parse(`{"type":"plugin","id":"foo","data":{"x":1}}`))).toEqual({
-      type: "plugin",
-      id: "foo",
-      data: { x: 1 },
-    })
-  })
-})

packages/opencode/test/config/permission-env.test.ts

@@ -1,54 +0,0 @@
-import { describe, expect, test } from "bun:test"
-import { ConfigPermission } from "@/config/permission"
-import { InvalidConfigError, requireJsonConfig } from "@/util/json"
-
-const decode = (raw: string) => requireJsonConfig(raw, ConfigPermission.Info, "OPENCODE_PERMISSION")
-
-describe("requireJsonConfig with ConfigPermission.Info", () => {
-  test("throws InvalidConfigError on malformed JSON", () => {
-    let caught: unknown
-    try {
-      decode("{not json")
-    } catch (error) {
-      caught = error
-    }
-    expect(caught).toBeInstanceOf(InvalidConfigError)
-    const data = caught as InvalidConfigError
-    expect(data.source).toBe("OPENCODE_PERMISSION")
-    expect(data.value).toBe("{not json")
-    expect(typeof data.reason).toBe("string")
-    expect(data.reason.length).toBeGreaterThan(0)
-  })
-
-  test("throws InvalidConfigError on shape mismatch", () => {
-    let caught: unknown
-    try {
-      // `banana` is not a valid Action ("ask" | "allow" | "deny")
-      decode(`{"bash":"banana"}`)
-    } catch (error) {
-      caught = error
-    }
-    expect(caught).toBeInstanceOf(InvalidConfigError)
-    const data = caught as InvalidConfigError
-    expect(data.source).toBe("OPENCODE_PERMISSION")
-    expect(data.value).toBe(`{"bash":"banana"}`)
-    expect(data.reason.length).toBeGreaterThan(0)
-  })
-
-  test("returns decoded value for Action shorthand", () => {
-    expect(decode(`"ask"`)).toEqual({ "*": "ask" })
-  })
-
-  test("returns decoded value for object of per-target rules", () => {
-    expect(decode(`{"bash":"ask","edit":"allow"}`)).toEqual({
-      bash: "ask",
-      edit: "allow",
-    })
-  })
-
-  test("returns decoded value for nested Object rule", () => {
-    expect(decode(`{"bash":{"rm *":"deny","ls":"allow"}}`)).toEqual({
-      bash: { "rm *": "deny", ls: "allow" },
-    })
-  })
-})

packages/opencode/test/plugin/codex.test.ts

@@ -1,5 +1,6 @@
 import { describe, expect, test } from "bun:test"
 import {
+  CodexAuthPlugin,
   parseJwtClaims,
   extractAccountIdFromClaims,
   extractAccountId,
@@ -120,4 +121,109 @@ describe("plugin.codex", () => {
       ).toBe("acc-123")
     })
   })
+
+  test("deduplicates concurrent Codex token refreshes", async () => {
+    let auth = {
+      type: "oauth" as const,
+      refresh: "refresh-old",
+      access: "",
+      expires: 0,
+    }
+    const authUpdates: Array<{
+      body: { refresh: string; access: string; expires: number; accountId?: string }
+    }> = []
+    let resolveRefresh: (() => void) | undefined
+    const refreshReady = new Promise<void>((resolve) => {
+      resolveRefresh = resolve
+    })
+    let refreshRequests = 0
+    const apiRequests: { authorization: string | null; accountId: string | null }[] = []
+
+    using server = Bun.serve({
+      port: 0,
+      async fetch(request) {
+        const url = new URL(request.url)
+        if (url.pathname === "/oauth/token") {
+          expect(await request.text()).toContain("refresh_token=refresh-old")
+          refreshRequests += 1
+          await refreshReady
+          return Response.json({
+            id_token: createTestJwt({ chatgpt_account_id: "acc-123" }),
+            access_token: "access-new",
+            refresh_token: "refresh-new",
+            expires_in: 3600,
+          })
+        }
+
+        if (url.pathname === "/backend-api/codex/responses") {
+          apiRequests.push({
+            authorization: request.headers.get("authorization"),
+            accountId: request.headers.get("ChatGPT-Account-Id"),
+          })
+          return new Response("{}", { status: 200 })
+        }
+
+        return new Response("unexpected request", { status: 500 })
+      },
+    })
+
+    const hooks = await CodexAuthPlugin(
+      {
+        client: {
+          auth: {
+            async set(input: { body: { refresh: string; access: string; expires: number; accountId?: string } }) {
+              authUpdates.push(input)
+              auth = {
+                type: "oauth",
+                refresh: input.body.refresh,
+                access: input.body.access,
+                expires: input.body.expires,
+                ...(input.body.accountId && { accountId: input.body.accountId }),
+              }
+            },
+          },
+        } as never,
+        project: {} as never,
+        directory: "",
+        worktree: "",
+        experimental_workspace: {
+          register() {},
+        },
+        serverUrl: new URL("https://example.com"),
+        $: {} as never,
+      },
+      {
+        issuer: server.url.origin,
+        codexApiEndpoint: new URL("/backend-api/codex/responses", server.url).toString(),
+      },
+    )
+    const loaded = await hooks.auth!.loader!(async () => auth as never, {} as never)
+
+    const first = loaded.fetch!("https://api.openai.com/v1/responses")
+    const second = loaded.fetch!("https://api.openai.com/v1/responses")
+
+    await waitFor(() => refreshRequests === 1)
+    expect(apiRequests).toHaveLength(0)
+
+    resolveRefresh!()
+    await Promise.all([first, second])
+
+    expect(refreshRequests).toBe(1)
+    expect(authUpdates).toHaveLength(1)
+    expect(authUpdates[0]?.body.refresh).toBe("refresh-new")
+    expect(authUpdates[0]?.body.access).toBe("access-new")
+    expect(authUpdates[0]?.body.accountId).toBe("acc-123")
+    expect(apiRequests).toEqual([
+      { authorization: "Bearer access-new", accountId: "acc-123" },
+      { authorization: "Bearer access-new", accountId: "acc-123" },
+    ])
+  })
 })
+
+async function waitFor(predicate: () => boolean) {
+  const started = Date.now()
+  while (!predicate()) {
+    if (Date.now() - started > 1_000) throw new Error("timed out waiting for condition")
+    await new Promise((resolve) => setTimeout(resolve, 1))
+  }
+}

packages/opencode/test/session/llm-native.test.ts

@@ -292,34 +292,6 @@ describe("session.llm-native.request", () => {
     ).toEqual({ type: "unsupported", reason: "OpenAI API key is not configured" })
   })
 
-  test("prefers console provider api key over stored opencode auth", () => {
-    expect(
-      LLMNativeRuntime.status({
-        model: { ...baseModel, providerID: ProviderID.make("opencode") },
-        provider: {
-          ...providerInfo,
-          id: ProviderID.make("opencode"),
-          options: { apiKey: "console-token" },
-          key: "zen-token",
-        },
-        auth: { type: "api", key: "zen-token" },
-      }),
-    ).toMatchObject({
-      type: "supported",
-      apiKey: "console-token",
-    })
-    expect(
-      LLMNativeRuntime.status({
-        model: baseModel,
-        provider: { ...providerInfo, options: {}, key: "provider-key" },
-        auth: undefined,
-      }),
-    ).toMatchObject({
-      type: "supported",
-      apiKey: "provider-key",
-    })
-  })
-
   test("native tool wrapper converts thrown errors into typed ToolFailure", async () => {
     const wrapped = LLMNativeRuntime.nativeTools(
       {

packages/opencode/test/util/json.test.ts

@@ -1,76 +0,0 @@
-import { describe, expect, test } from "bun:test"
-import { Option, Schema } from "effect"
-import { InvalidConfigError, requireJsonConfig, tryJsonConfig } from "@/util/json"
-
-const PointSchema = Schema.Struct({
-  x: Schema.Number,
-  y: Schema.Number,
-})
-
-describe("requireJsonConfig", () => {
-  test("returns decoded value on success", () => {
-    expect(requireJsonConfig(`{"x":1,"y":2}`, PointSchema, "TEST")).toEqual({ x: 1, y: 2 })
-  })
-
-  test("throws InvalidConfigError on malformed JSON", () => {
-    let caught: unknown
-    try {
-      requireJsonConfig("not json", PointSchema, "TEST")
-    } catch (error) {
-      caught = error
-    }
-    expect(caught).toBeInstanceOf(InvalidConfigError)
-    const err = caught as InvalidConfigError
-    expect(err.source).toBe("TEST")
-    expect(err.value).toBe("not json")
-    expect(err.reason.length).toBeGreaterThan(0)
-  })
-
-  test("throws InvalidConfigError on schema mismatch", () => {
-    let caught: unknown
-    try {
-      requireJsonConfig(`{"x":"oops"}`, PointSchema, "TEST")
-    } catch (error) {
-      caught = error
-    }
-    expect(caught).toBeInstanceOf(InvalidConfigError)
-    const err = caught as InvalidConfigError
-    expect(err.source).toBe("TEST")
-    expect(err.value).toBe(`{"x":"oops"}`)
-    expect(err.reason.length).toBeGreaterThan(0)
-  })
-
-  test("InvalidConfigError carries _tag for downstream matching", () => {
-    let caught: unknown
-    try {
-      requireJsonConfig("not json", PointSchema, "TEST")
-    } catch (error) {
-      caught = error
-    }
-    expect((caught as { _tag: string })._tag).toBe("InvalidConfigError")
-  })
-})
-
-describe("tryJsonConfig", () => {
-  test("returns Some on success", () => {
-    const decoded = tryJsonConfig(`{"x":1,"y":2}`, PointSchema, "TEST")
-    expect(Option.isSome(decoded)).toBe(true)
-    expect(Option.getOrThrow(decoded)).toEqual({ x: 1, y: 2 })
-  })
-
-  test("returns None for undefined input", () => {
-    expect(Option.isNone(tryJsonConfig(undefined, PointSchema, "TEST"))).toBe(true)
-  })
-
-  test("returns None for empty string", () => {
-    expect(Option.isNone(tryJsonConfig("", PointSchema, "TEST"))).toBe(true)
-  })
-
-  test("returns None for malformed JSON", () => {
-    expect(Option.isNone(tryJsonConfig("not json", PointSchema, "TEST"))).toBe(true)
-  })
-
-  test("returns None on schema mismatch", () => {
-    expect(Option.isNone(tryJsonConfig(`{"x":"oops"}`, PointSchema, "TEST"))).toBe(true)
-  })
-})

packages/plugin/package.json

@@ -1,7 +1,7 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
   "name": "@opencode-ai/plugin",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "type": "module",
   "license": "MIT",
   "scripts": {

packages/sdk/js/package.json

@@ -1,7 +1,7 @@
 {
   "$schema": "https://json.schemastore.org/package.json",
   "name": "@opencode-ai/sdk",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "type": "module",
   "license": "MIT",
   "scripts": {

packages/slack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/slack",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "type": "module",
   "license": "MIT",
   "scripts": {

packages/ui/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@opencode-ai/ui",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "type": "module",
   "license": "MIT",
   "exports": {

packages/web/package.json

@@ -2,7 +2,7 @@
   "name": "@opencode-ai/web",
   "type": "module",
   "license": "MIT",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "scripts": {
     "dev": "astro dev",
     "dev:remote": "VITE_API_URL=https://api.opencode.ai astro dev",

sdks/vscode/package.json

@@ -2,7 +2,7 @@
   "name": "opencode",
   "displayName": "opencode",
   "description": "opencode for VS Code",
-  "version": "1.15.5",
+  "version": "1.15.4",
   "publisher": "sst-dev",
   "repository": {
     "type": "git",