chore: drop superseded fork patches and stale artifacts

Reset to upstream dev:
- plugin/index.ts (upstream anomalyco#18280 rewrote plugin error handling)
- cli/error.ts (upstream anomalyco#27803 reworked TUI error rendering)
- session-data.ts (upstream error typing changes)
- session/prompt.ts (massive upstream refactor)
- cli/cmd/tui/worker.ts (restored — was deleted by stale merge)

Removed dead artifacts:
- script/patch-aft-lsp.sh (targets deleted worker.ts architecture)
- session-ses_1d10.md, sessions.jsonl (stale session dumps)

Backup: fork/local-backup

Author: rustybret

packages/opencode/script/patch-aft-lsp.sh

@@ -1096,10 +1096,7 @@ export function reduceSessionData(input: SessionDataInput): SessionDataOutput {
   }
 
   if (event.type === "session.error") {
-    if (
-      (event.properties.sessionID !== undefined && event.properties.sessionID !== input.sessionID) ||
-      !event.properties.error
-    ) {
+    if (event.properties.sessionID !== input.sessionID || !event.properties.error) {
       return out(data, commits)
     }
 

packages/opencode/src/cli/cmd/run/session-data.ts

@@ -0,0 +1,99 @@
+import { Installation } from "@/installation"
+import { Server } from "@/server/server"
+import * as Log from "@opencode-ai/core/util/log"
+import { InstanceRuntime } from "@/project/instance-runtime"
+import { Rpc } from "@/util/rpc"
+import { upgrade } from "@/cli/upgrade"
+import { Config } from "@/config/config"
+import { GlobalBus } from "@/bus/global"
+import { ServerAuth } from "@/server/auth"
+import { writeHeapSnapshot } from "node:v8"
+import { Heap } from "@/cli/heap"
+import { AppRuntime } from "@/effect/app-runtime"
+import { ensureProcessMetadata } from "@opencode-ai/core/util/opencode-process"
+import { Effect } from "effect"
+import { disposeAllInstancesAndEmitGlobalDisposed } from "@/server/global-lifecycle"
+
+ensureProcessMetadata("worker")
+
+await Log.init({
+  print: process.argv.includes("--print-logs"),
+  dev: Installation.isLocal(),
+  level: (() => {
+    if (Installation.isLocal()) return "DEBUG"
+    return "INFO"
+  })(),
+})
+
+Heap.start()
+
+process.on("unhandledRejection", (e) => {
+  Log.Default.error("rejection", {
+    e: e instanceof Error ? e.message : e,
+  })
+})
+
+process.on("uncaughtException", (e) => {
+  Log.Default.error("exception", {
+    e: e instanceof Error ? e.message : e,
+  })
+})
+
+// Subscribe to global events and forward them via RPC
+GlobalBus.on("event", (event) => {
+  Rpc.emit("global.event", event)
+})
+
+let server: Awaited<ReturnType<typeof Server.listen>> | undefined
+
+export const rpc = {
+  async fetch(input: { url: string; method: string; headers: Record<string, string>; body?: string }) {
+    const headers = { ...input.headers }
+    const auth = ServerAuth.header()
+    if (auth && !headers["authorization"] && !headers["Authorization"]) {
+      headers["Authorization"] = auth
+    }
+    const request = new Request(input.url, {
+      method: input.method,
+      headers,
+      body: input.body,
+    })
+    const response = await Server.Default().app.fetch(request)
+    const body = await response.text()
+    return {
+      status: response.status,
+      headers: Object.fromEntries(response.headers.entries()),
+      body,
+    }
+  },
+  snapshot() {
+    const result = writeHeapSnapshot("server.heapsnapshot")
+    return result
+  },
+  async server(input: { port: number; hostname: string; mdns?: boolean; cors?: string[] }) {
+    if (server) await server.stop(true)
+    server = await Server.listen(input)
+    return { url: server.url.toString() }
+  },
+  async checkUpgrade(input: { directory: string }) {
+    await InstanceRuntime.load({ directory: input.directory })
+    await upgrade().catch(() => {})
+  },
+  async reload() {
+    await AppRuntime.runPromise(
+      Effect.gen(function* () {
+        const cfg = yield* Config.Service
+        yield* cfg.invalidate()
+        yield* disposeAllInstancesAndEmitGlobalDisposed({ swallowErrors: true })
+      }),
+    )
+  },
+  async shutdown() {
+    Log.Default.info("worker shutting down")
+
+    await InstanceRuntime.disposeAllInstances()
+    if (server) await server.stop(true)
+  },
+}
+
+Rpc.listen(rpc)

packages/opencode/src/cli/cmd/tui/worker.ts

@@ -1,4 +1,3 @@
-import { Cause } from "effect"
 import { NamedError } from "@opencode-ai/core/util/error"
 import { errorFormat } from "@/util/error"
 import { isRecord } from "@/util/record"
@@ -33,14 +32,7 @@ function configIssues(input: Record<string, unknown>): ConfigIssue[] {
     : []
 }
 
-const FiberFailureCauseId = Symbol.for("effect/FiberFailure")
-
 export function FormatError(input: unknown): string | undefined {
-  if (typeof input === "object" && input !== null && FiberFailureCauseId in input) {
-    const cause = (input as Record<symbol, unknown>)[FiberFailureCauseId] as Cause.Cause<unknown>
-    return FormatError(Cause.squash(cause))
-  }
-
   if (input instanceof Error && isRecord(input.cause) && "body" in input.cause) {
     const formatted = FormatError(input.cause.body)
     if (formatted) return formatted
@@ -102,18 +94,6 @@ export function FormatError(input: unknown): string | undefined {
     return stringField(configFrontmatter, "message") ?? ""
   }
 
-  // ConfigRemoteAuthError: { url: string, remote: string }
-  const remoteAuth = configData(input, "ConfigRemoteAuthError")
-  if (remoteAuth) {
-    const url = stringField(remoteAuth, "url")
-    const remote = stringField(remoteAuth, "remote")
-    return [
-      `Failed to load remote config${remote ? ` from ${remote}` : ""}: the server returned a login page instead of JSON.`,
-      `Authentication is missing or has expired (the endpoint is likely behind an SSO or identity-aware proxy).`,
-      ...(url ? [`Run \`opencode auth login ${url}\` to re-authenticate.`] : []),
-    ].join("\n")
-  }
-
   // ConfigInvalidError: { path?: string, message?: string, issues?: Array<{ message: string, path: string[] }> }
   const configInvalid = configData(input, "ConfigInvalidError")
   if (configInvalid) {