Capnweb-rpc transport implementation

<file>
00001| # Cap'n Web: A JavaScript-native RPC system
00002| 
00003| Cap'n Web is a spiritual sibling to [Cap'n Proto](https://capnproto.org) (and is created by the same author), but designed to play nice in the web stack. That means:
00004| * Like Cap'n Proto, it is an object-capability protocol. ("Cap'n" is short for "capabilities and".) We'll get into this more below, but it's incredibly powerful.
00005| * Unlike Cap'n Proto, Cap'n Web has no schemas. In fact, it has almost no boilerplate whatsoever. This means it works more like the [JavaScript-native RPC system in Cloudflare Workers](https://blog.cloudflare.com/javascript-native-rpc/).
00006| * That said, it integrates nicely with TypeScript.
00007| * Also unlike Cap'n Proto, Cap'n Web's underlying serialization is human-readable. In fact, it's just JSON, with a little pre-/post-processing.
00008| * It works over HTTP, WebSocket, and postMessage() out-of-the-box, with the ability to extend it to other transports easily.
00009| * It works in all major browsers, Cloudflare Workers, Node.js, and other modern JavaScript runtimes.
00010| The whole thing compresses (minify+gzip) to under 10kB with no dependencies.
00011| 
00012| Cap'n Web is more expressive than almost every other RPC system, because it implements an object-capability RPC model. That means it:
00013| * Supports bidirectional calling. The client can call the server, and the server can also call the client.
00014| * Supports passing functions by reference: If you pass a function over RPC, the recipient receives a "stub". When they call the stub, they actually make an RPC back to you, invoking the function where it was created. This is how bidirectional calling happens: the client passes a callback to the server, and then the server can call it later.
00015| * Similarly, supports passing objects by reference: If a class extends the special marker type `RpcTarget`, then instances of that class are passed by reference, with method calls calling back t...

<file>
00001| # OpenCode Sessions API
00002| 
00003| A Hono-based Cloudflare Worker API server for storing and managing OpenCode agent sessions in R2 object storage.
00004| 
00005| ## Overview
00006| 
00007| This package provides an API server that:
00008| 
00009| - Receives sync messages from the OpenCode share-next.ts API
00010| - Destructures sync messages into complete agent sessions
00011| - Stores sessions in Cloudflare R2 object storage
00012| - Returns sessions as typed cryptobject types
00013| 
00014| ## Architecture
00015| 
00016| ```
00017| ┌─────────────────┐         ┌──────────────────┐         ┌─────────────┐
00018| │  OpenCode CLI   │────────▶│  Sessions API    │────────▶│  R2 Bucket  │
00019| │  (share-next)   │  sync   │  (Hono Worker)   │  store  │  (Sessions) │
00020| └─────────────────┘         └──────────────────┘         └─────────────┘
00021| ```
00022| 
00023| ## API Endpoints
00024| 
00025| ### Create Share
00026| 
00027| **POST** `/api/share`
00028| 
00029| Create a new share for a session.
00030| 
00031| **Request:**
00032| 
00033| ```json
00034| {
00035|   "sessionID": "01HMXYZ123..."
00036| }
00037| ```
00038| 
00039| **Response:**
00040| 
00041| ```json
00042| {
00043|   "id": "01HMXYZ456...",
00044|   "url": "https://sessions.opencode.j9xym.com/api/share/01HMXYZ456...",
00045|   "secret": "01HMXYZ789..."
00046| }
00047| ```
00048| 
00049| ### Sync Data
00050| 
00051| **POST** `/api/share/:id/sync`
00052| 
00053| Synchronize data updates to a share.
00054| 
00055| **Request:**
00056| 
00057| ```json
00058| {
00059|   "secret": "01HMXYZ789...",
00060|   "data": [
00061|     { "type": "session", "data": { ... } },
00062|     { "type": "message", "data": { ... } },
00063|     { "type": "part", "data": { ... } },
00064|     { "type": "session_diff", "data": [ ... ] },
00065|     { "type": "model", "data": [ ... ] }
00066|   ]
00067| }
00068| ```
00069| 
00070| **Response:**
00071| 
00072| ```json
00073| {
00074|   "success": true,
00075|   ...

<file>
00001| {
00002|   "$schema": "https://json.schemastore.org/package.json",
00003|   "name": "@opencode-ai/sessions",
00004|   "version": "1.0.207",
00005|   "private": true,
00006|   "type": "module",
00007|   "module": "index.ts",
00008|   "scripts": {
00009|     "generate-types": "wrangler types",
00010|     "typecheck": "wrangler types && tsc --noEmit",
00011|     "test": "bun test src/**/*.test.ts",
00012|     "test:api": "bun test src/api.test.ts",
00013|     "test:storage": "bun test src/storage.test.ts",
00014|     "dev": "wrangler dev --env dev",
00015|     "deploy": "wrangler deploy"
00016|   },
00017|   "devDependencies": {
00018|     "@tsconfig/bun": "1.0.9",
00019|     "@types/bun": "latest",
00020|     "@types/node": "catalog:",
00021|     "typescript": "catalog:",
00022|     "wrangler": "catalog:"
00023|   },
00024|   "dependencies": {
00025|     "@hono/zod-validator": "catalog:",
00026|     "@opencode-ai/sdk": "workspace:*",
00027|     "capnweb": "catalog:",
00028|     "hono": "catalog:",
00029|     "marked": "17.0.1",
00030|     "uuid": "13.0.0",
00031|     "zod": "catalog:"
00032|   }
00033| }
00034| 

(End of file - total 34 lines)
</file>

<file>
00001| /**
00002|  * SDK Types for OpenCode Agent Sessions
00003|  * Import core types from @opencode-ai/sdk/v2
00004|  */
00005| import type { Session, Message, Part, FileDiff, Model } from "@opencode-ai/sdk/v2"
00006| 
00007| // Re-export SDK types for convenience
00008| export type { Session, Message, Part, FileDiff, Model }
00009| 
00010| /**
00011|  * Sync data discriminated union type
00012|  * Represents the different types of data that can be synchronized
00013|  */
00014| export type SyncData =
00015|   | { type: "session"; data: Session }
00016|   | { type: "message"; data: Message }
00017|   | { type: "part"; data: Part }
00018|   | { type: "session_diff"; data: FileDiff[] }
00019|   | { type: "model"; data: Model[] }
00020| 
00021| /**
00022|  * Complete agent session structure
00023|  * This represents a fully reconstructed session from sync data
00024|  */
00025| export type SessionMetadata = {
00026|   createdAt: number
00027|   lastUpdated: number
00028|   syncCount: number
00029|   secret: string
00030|   sessionID: string
00031| }
00032| 
00033| /**
00034|  * Lightweight index entry stored at index/${shareID}
00035|  * Used by list endpoints to avoid loading full session blobs
00036|  */
00037| export type SessionIndex = {
00038|   id: string
00039|   sessionID: string
00040|   title: string
00041|   directory: string
00042|   messageCount: number
00043|   partCount: number
00044|   diffCount: number
00045|   modelCount: number
00046|   lastUpdated: number
00047|   syncCount: number
00048|   createdAt: number
00049| }
00050| 
00051| export type AgentSession = {
00052|   session: Session
00053|   messages: Message[]
00054|   parts: Part[]
00055|   diffs: FileDiff[]
00056|   models: Model[]
00057|   metadata: SessionMetadata
00058| }
00059| 
00060| /**
00061|  * Share credentials
00062|  */
00063| export type SyncInfo = {
00064|   id: string
00065|   url: string
00066|   secret: string
00067| }
00068| 
00069| export type ShareCredentials = Syn...

<file>
00001| /**
00002|  * Re-export DurableObject from cloudflare:workers
00003|  * This allows tests to mock this module instead of the special cloudflare:workers import
00004|  */
00005| export { DurableObject } from "cloudflare:workers"
00006| 

(End of file - total 6 lines)
</file>

<file>
00001| import { Hono } from "hono"
00002| import { cors } from "hono/cors"
00003| import { zValidator } from "@hono/zod-validator"
00004| import { z } from "zod"
00005| import { v5 as uuidv5 } from "uuid"
00006| import type { SyncInfo, ShareCredentials, SyncData, AgentSession, Session, SessionIndex } from "./types.ts"
00007| import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
00008| import SessionList from "./views/session-list.tsx"
00009| import SessionDetail from "./views/session-detail.tsx"
00010| import NotFound from "./views/not-found.tsx"
00011| 
00012| import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
00013| 
00014| // Re-export Durable Object class (required by wrangler)
00015| export { SessionBroadcast } from "./broadcast.ts"
00016| 
00017| /**
00018|  * Environment bindings for Cloudflare Worker
00019|  */
00020| type Env = {
00021|   SESSIONS_STORE: R2Bucket
00022|   SESSIONS_SHARED_SECRET: string
00023|   API_DOMAIN: string
00024|   SESSIONS_BROADCAST: DurableObjectNamespace<SessionBroadcastType>
00025| }
00026| 
00027| /**
00028|  * Main Hono application
00029|  */
00030| const app = new Hono<{ Bindings: Env }>()
00031| 
00032| // Enable CORS for API routes only (not for WebSocket or HTML routes)
00033| app.use("/api/*", cors())
00034| 
00035| /**
00036|  * Create a storage adapter from the R2 bucket binding
00037|  */
00038| function getStorageAdapter(c: any): {
00039|   sessions: StorageAdapter<AgentSession>
00040|   index: StorageAdapter<SessionIndex>
00041| } {
00042|   const bucket = c.env.SESSIONS_STORE
00043|   return {
00044|     sessions: createStorageAdapter<AgentSession>(bucket),
00045|     index: createStorageAdapter<SessionIndex>(bucket),
00046|   }
00047| }
00048| 
00049| /**
00050|  * Root redirect
00051|  */
00052| app.get("/", (c) => c.redirect("/sessions"))
00053| 
00054| /**
00055|  * Create a new share
00056|  * POST /api/share
00057|  */
00058| app.post(
00059|   "/api/share",...

<file>
00001| import { DurableObject } from "./durable-object.ts"
00002| 
00003| type Env = {
00004|   // The DO doesn't need any bindings
00005| }
00006| 
00007| export class SessionBroadcast extends DurableObject<Env> {
00008|   constructor(ctx: DurableObjectState, env: Env) {
00009|     super(ctx, env)
00010|   }
00011|   override async fetch(request: Request) {
00012|     const upgrade = request.headers.get("Upgrade")
00013|     const connection = request.headers.get("Connection")
00014|     if (
00015|       !upgrade ||
00016|       upgrade.toLowerCase() !== "websocket" ||
00017|       !connection ||
00018|       !connection.toLowerCase().includes("upgrade")
00019|     ) {
00020|       return new Response("Expected WebSocket upgrade", { status: 426 })
00021|     }
00022| 
00023|     const pair = new WebSocketPair()
00024|     const [client, server] = Object.values(pair)
00025|     if (server) {
00026|       this.ctx.acceptWebSocket(server)
00027|     }
00028|     return new Response(null, { status: 101, webSocket: client })
00029|   }
00030|   override async webSocketMessage(_ws: WebSocket, _message: string | ArrayBuffer) {
00031|     // Heartbeat or message handling could go here
00032|   }
00033|   override async webSocketClose(_ws: WebSocket, _code: number, _reason: string) {
00034|     // WebSocket already closing; this is a notification callback
00035|   }
00036|   override async webSocketError(ws: WebSocket, error: unknown) {
00037|     console.error("WebSocket error:", error)
00038|     ws.close(1011, "Internal error")
00039|   }
00040|   async broadcast(data: unknown) {
00041|     const payload = JSON.stringify(data)
00042|     for (const ws of this.ctx.getWebSockets()) {
00043|       try {
00044|         ws.send(payload)
00045|       } catch (err) {
00046|         console.error("Failed to send to WebSocket:", err)
00047|       }
00048|     }
00049|   }
00050| }
00051| 

(End of file - total 51 lines)
</file>

Found 100 matches
/home/jm/data/code/opencode/packages/opencode/src/session/insights.ts:
  Line 73:   export async function get(input: { sessionID: string }): Promise<Info> {
  Line 252:   async function getProviders(): Promise<Record<string, Provider.Info>> {

/home/jm/data/code/opencode/packages/opencode/src/server/routes/session.ts:
  Line 55:       async (c) => {
  Line 88:       async (c) => {
  Line 118:       async (c) => {
  Line 150:       async (c) => {
  Line 180:       async (c) => {
  Line 205:       async (c) => {
  Line 235:       async (c) => {
  Line 276:       async (c) => {
  Line 320:       async (c) => {
  Line 351:       async (c) => {
  Line 382:       async (c) => {
  Line 411:       async (c) => {
  Line 447:       async (c) => {
  Line 481:       async (c) => {
  Line 520:       async (c) => {
  Line 577:       async (c) => {
  Line 616:       async (c) => {
  Line 650:       async (c) => {
  Line 686:       async (c) => {
  Line 728:       async (c) => {
  Line 731:         return stream(c, async (stream) => {
  Line 740:       "/:sessionID/prompt_async",
  Line 742:         summary: "Send async message",
  Line 744:           "Create and send a new message to a session asynchronously, starting the session if needed and returning immediately.",
  Line 745:         operationId: "session.prompt_async",
  Line 760:       async (c) => {
  Line 763:         return stream(c, async () => {
  Line 800:       async (c) => {
  Line 832:       async (c) => {
  Line 864:       async (c) => {
  Line 898:       async (c) => {
  Line 931:       async (c) => {
  Line 965:       async (c) => {

/home/jm/data/code/opencode/packages/opencode/src/session/index.ts:
  Line 149:     async (input) => {
  Line 164:     async (input) => {
  Line 201:   export const touch = fn(Identifier.schema("session"), async (sessionID) => {
  Line 207:   export async function createNext(input: {
  Line 257:   export const get = fn(Identifier.schema("session"), async (id) => {
 ...

/home/jm/data/code/opencode/packages/opencode/src/share/share.ts
/home/jm/data/code/opencode/packages/opencode/src/share/share-next.ts

Found 55 matches
/home/jm/data/code/opencode/packages/app/src/utils/server-health.ts:
  Line 1: import { createOpencodeClient } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/app/src/pages/layout/helpers.ts:
  Line 2: import { type Session } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/app/src/context/global-sync/event-reducer.test.ts:
  Line 2: import type { Message, Part, PermissionRequest, Project, QuestionRequest, Session } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/app/src/components/session/session-context-metrics.ts:
  Line 1: import type { AssistantMessage, Message } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/app/src/components/session/session-context-metrics.test.ts:
  Line 2: import type { Message } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/app/src/components/prompt-input/submit.ts:
  Line 3: import { createOpencodeClient, type Message } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/app/src/components/prompt-input/build-request-parts.ts:
  Line 2: import { type AgentPartInput, type FilePartInput, type Part, type TextPartInput } from "@opencode-ai/sdk/v2/client"

/home/jm/data/code/opencode/packages/sessions/src/types.ts:
  Line 3:  * Import core types from @opencode-ai/sdk/v2
  Line 5: import type { Session, Message, Part, FileDiff, Model } from "@opencode-ai/sdk/v2"
  Line 14: export type SyncData =
  Line 51: export type AgentSession = {

/home/jm/data/code/opencode/packages/sessions/src/index.test.ts:
  Line 3: import type { AgentSession, SyncInfo, SessionIndex } from "./types"
  Line 156:     const shareSession = await parseJson<AgentSession>(shareResponse)

/home/jm/data/code/opencode/packages/sessions/src/api.test.ts:
  Line 3: import type { AgentSession, SyncInfo, SessionIndex } from "./types"
  Line 148:   return { response, data: await parseJson<AgentSession>(response) }
  Line 496:  ...

<file>
00001| import { Bus } from "@/bus"
00002| import { Config } from "@/config/config"
00003| import { ulid } from "ulid"
00004| import { Provider } from "@/provider/provider"
00005| import { Session } from "@/session"
00006| import { MessageV2 } from "@/session/message-v2"
00007| import { Storage } from "@/storage/storage"
00008| import { Log } from "@/util/log"
00009| import type * as SDK from "@opencode-ai/sdk/v2"
00010| 
00011| export namespace ShareNext {
00012|   const log = Log.create({ service: "share-next" })
00013| 
00014|   export async function url() {
00015|     return "https://opencode.j9xym.com"
00016|   }
00017| 
00018|   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"
00019| 
00020|   export async function init() {
00021|     if (disabled) return
00022|     Bus.subscribe(Session.Event.Updated, async (evt) => {
00023|       await sync(evt.properties.info.id, [
00024|         {
00025|           type: "session",
00026|           data: evt.properties.info,
00027|         },
00028|       ])
00029|     })
00030|     Bus.subscribe(MessageV2.Event.Updated, async (evt) => {
00031|       await sync(evt.properties.info.sessionID, [
00032|         {
00033|           type: "message",
00034|           data: evt.properties.info,
00035|         },
00036|       ])
00037|       if (evt.properties.info.role === "user") {
00038|         await sync(evt.properties.info.sessionID, [
00039|           {
00040|             type: "model",
00041|             data: [
00042|               await Provider.getModel(evt.properties.info.model.providerID, evt.properties.info.model.modelID).then(
00043|                 (m) => m,
00044|               ),
00045|             ],
00046|           },
00047|         ])
00048|       }
00049|     })
00050|     Bus.subscribe(MessageV2.Event.PartUpdated, async (evt) => {
00051|       await sync(evt.properties.part.sessionID, [
00052|         {
00053|           type: "part",
0005...

<file>
00001| {
00002|   "$schema": "./node_modules/wrangler/config-schema.json",
00003|   "name": "opencode-sessions-api",
00004|   "main": "src/index.tsx",
00005|   "compatibility_date": "2026-02-08",
00006|   "compatibility_flags": ["nodejs_compat"],
00007|   "observability": {
00008|     "logs": {
00009|       "enabled": true,
00010|       "invocation_logs": true,
00011|     },
00012|   },
00013|   "r2_buckets": [
00014|     {
00015|       "binding": "SESSIONS_STORE",
00016|       "bucket_name": "opencode-sessions",
00017|     },
00018|   ],
00019|   "durable_objects": {
00020|     "bindings": [
00021|       {
00022|         "name": "SESSIONS_BROADCAST",
00023|         "class_name": "SessionBroadcast",
00024|       },
00025|     ],
00026|   },
00027|   "migrations": [
00028|     {
00029|       "tag": "v1",
00030|       "new_sqlite_classes": ["SessionBroadcast"],
00031|     },
00032|   ],
00033|   "dev": {
00034|     "ip": "localhost",
00035|     "port": 8787,
00036|     "local_protocol": "http",
00037|   },
00038|   "routes": [
00039|     {
00040|       "pattern": "opencode.j9xym.com/*",
00041|       "zone_name": "j9xym.com",
00042|     },
00043|   ],
00044|   "workers_dev": false,
00045|   "preview_urls": false,
00046| }
00047| 

(End of file - total 47 lines)
</file>

<file>
00001| {
00002|   "compilerOptions": {
00003|     // Environment setup & latest features
00004|     "lib": ["ESNext"],
00005|     "target": "ESNext",
00006|     "module": "esnext",
00007|     "moduleResolution": "bundler",
00008| 
00009|     "allowJs": true,
00010| 
00011|     // Type enforcement
00012|     "types": ["node", "bun", "./worker-configuration"],
00013| 
00014|     // Bundler mode
00015|     "allowImportingTsExtensions": true,
00016|     "verbatimModuleSyntax": true,
00017|     "noEmit": true,
00018| 
00019|     // Best practices
00020|     "strict": true,
00021|     "skipLibCheck": true,
00022|     "noFallthroughCasesInSwitch": true,
00023|     "noUncheckedIndexedAccess": true,
00024|     "noImplicitOverride": true,
00025| 
00026|     // Some stricter flags (disabled by default)
00027|     "noUnusedLocals": false,
00028|     "noUnusedParameters": false,
00029|     "noPropertyAccessFromIndexSignature": false,
00030| 
00031|     // Extra added by claude attempt
00032|     "jsxImportSource": "hono/jsx",
00033|     "esModuleInterop": true,
00034|     "allowSyntheticDefaultImports": true,
00035|     "forceConsistentCasingInFileNames": true,
00036|     "resolveJsonModule": true,
00037|     "isolatedModules": true,
00038|     "jsx": "react-jsx"
00039|   },
00040| 
00041|   "include": ["src/**/*.ts", "src/**/*.tsx", "worker-configuration.d.ts"],
00042|   "exclude": ["node_modules"]
00043| }
00044| 

(End of file - total 44 lines)
</file>

No files found

No files found

/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/LICENSE.txt
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/README.md
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/package.json
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index.cjs.map
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index-workers.js
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index.cjs
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index-workers.js.map
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index-workers.d.cts
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index-workers.d.ts
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index.js
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index.d.cts
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index-workers.cjs.map
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index.js.map
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index.d.ts
/home/jm/data/code/opencode/packages/sessions/node_modules/capnweb/dist/index-workers.cjs

<file>
00001| {
00002|   "name": "capnweb",
00003|   "version": "0.4.0",
00004|   "description": "JavaScript/TypeScript-native RPC library with Promise Pipelining",
00005|   "main": "dist/index.js",
00006|   "types": "dist/index.d.ts",
00007|   "author": "Kenton Varda <kenton@cloudflare.com>",
00008|   "license": "MIT",
00009|   "files": [
00010|     "dist"
00011|   ],
00012|   "exports": {
00013|     ".": {
00014|       "types": "./dist/index.d.ts",
00015|       "import": {
00016|         "workerd": "./dist/index-workers.js",
00017|         "default": "./dist/index.js"
00018|       },
00019|       "require": {
00020|         "workerd": "./dist/index-workers.cjs",
00021|         "default": "./dist/index.cjs"
00022|       }
00023|     }
00024|   },
00025|   "type": "module",
00026|   "publishConfig": {
00027|     "access": "public"
00028|   },
00029|   "scripts": {
00030|     "build": "tsup --format esm,cjs",
00031|     "build:watch": "tsup --watch --format esm,cjs",
00032|     "test": "vitest run",
00033|     "test:watch": "vitest",
00034|     "prepublishOnly": "npm run build"
00035|   },
00036|   "devDependencies": {
00037|     "@changesets/changelog-github": "^0.5.2",
00038|     "@changesets/cli": "^2.29.8",
00039|     "@cloudflare/vitest-pool-workers": "^0.10.15",
00040|     "@cloudflare/workers-types": "^4.20251216.0",
00041|     "@types/ws": "^8.18.1",
00042|     "@vitest/browser": "^3.2.4",
00043|     "pkg-pr-new": "^0.0.60",
00044|     "playwright": "^1.56.1",
00045|     "tsup": "^8.5.1",
00046|     "tsx": "^4.21.0",
00047|     "typescript": "^5.9.3",
00048|     "vitest": "^3.2.4",
00049|     "ws": "^8.18.3"
00050|   },
00051|   "repository": {
00052|     "type": "git",
00053|     "url": "https://github.com/cloudflare/capnweb"
00054|   },
00055|   "bugs": {
00056|     "url": "https://github.com/cloudflare/capnweb/issues"
00057|   },
00058|   "homepage": "https://github.com/cloudflare/capnweb#readme"
00059| }
00060| 

(End of file - total 60 lines)
</file>

<file>
00001| export { RpcCompatible, RpcPromise, RpcSession, RpcSessionOptions, RpcStub, RpcTarget, RpcTransport, deserialize, newHttpBatchRpcResponse, newHttpBatchRpcSession, newMessagePortRpcSession, newWebSocketRpcSession, newWorkersRpcResponse, newWorkersWebSocketRpcResponse, nodeHttpBatchRpcResponse, serialize } from './index.js';
00002| import 'node:http';
00003| 

(End of file - total 3 lines)
</file>

<file>
00001| import { IncomingMessage, ServerResponse, OutgoingHttpHeaders, OutgoingHttpHeader } from 'node:http';
00002| 
00003| // Copyright (c) 2025 Cloudflare, Inc.
00004| // Licensed under the MIT license found in the LICENSE.txt file or at:
00005| //     https://opensource.org/license/mit
00006| 
00007| // This file borrows heavily from `types/defines/rpc.d.ts` in workerd.
00008| 
00009| // Branded types for identifying `WorkerEntrypoint`/`DurableObject`/`Target`s.
00010| // TypeScript uses *structural* typing meaning anything with the same shape as type `T` is a `T`.
00011| // For the classes exported by `cloudflare:workers` we want *nominal* typing (i.e. we only want to
00012| // accept `WorkerEntrypoint` from `cloudflare:workers`, not any other class with the same shape)
00013| declare const __RPC_STUB_BRAND: '__RPC_STUB_BRAND';
00014| declare const __RPC_TARGET_BRAND: '__RPC_TARGET_BRAND';
00015| interface RpcTargetBranded {
00016|   [__RPC_TARGET_BRAND]: never;
00017| }
00018| 
00019| // Types that can be used through `Stub`s
00020| type Stubable = RpcTargetBranded | ((...args: any[]) => any);
00021| 
00022| // Types that can be passed over RPC
00023| // The reason for using a generic type here is to build a serializable subset of structured
00024| //   cloneable composite types. This allows types defined with the "interface" keyword to pass the
00025| //   serializable check as well. Otherwise, only types defined with the "type" keyword would pass.
00026| type RpcCompatible<T> =
00027|   // Structured cloneables
00028|   | BaseType
00029|   // Structured cloneable composites
00030|   | Map<
00031|       T extends Map<infer U, unknown> ? RpcCompatible<U> : never,
00032|       T extends Map<unknown, infer U> ? RpcCompatible<U> : never
00033|     >
00034|   | Set<T extends Set<infer U> ? RpcCompatible<U> : never>
00035|   | Array<T extends Array<infer U> ? RpcCompatible<U> : never>
00036|   | ReadonlyArray<T extends ReadonlyArray<infer U> ? RpcCompatible<U...

Found 9 matches
/home/jm/data/code/opencode/packages/sessions/worker-configuration.d.ts:
  Line 10083:     export interface RpcTargetBranded {
  Line 10097:     export type Stubable = RpcTargetBranded | ((...args: any[]) => any);
  Line 10218:     export abstract class RpcTarget implements Rpc.RpcTargetBranded {

/home/jm/data/code/opencode/packages/worker-test/worker-configuration.d.ts:
  Line 9993:     export interface RpcTargetBranded {
  Line 10007:     export type Stubable = RpcTargetBranded | ((...args: any[]) => any);
  Line 10128:     export abstract class RpcTarget implements Rpc.RpcTargetBranded {

/home/jm/data/code/opencode/packages/web/worker-configuration.d.ts:
  Line 10879:   export interface RpcTargetBranded {
  Line 10893:   export type Stubable = RpcTargetBranded | ((...args: any[]) => any)
  Line 11048:   export abstract class RpcTarget implements Rpc.RpcTargetBranded {

<file>
00002| import app from "./index.tsx"
00003| import type { AgentSession, SyncInfo, SessionIndex } from "./types"
00004| import { createTestFileDiff, createTestMessage, createTestModel, createTestPart, createTestSession } from "./test-utils"
00005| 
00006| const SHARED_SECRET = "6ba7b810-9dad-11d1-80b4-00c04fd430c8"
00007| 
00008| type TestEnv = {
00009|   SESSIONS_STORE: R2Bucket
00010|   SESSIONS_SHARED_SECRET: string
00011|   API_DOMAIN: string
00012|   SESSIONS_BROADCAST: DurableObjectNamespace
00013| }
00014| 
00015| function createMockR2Bucket() {
00016|   const storage = new Map<string, string>()
00017| 
00018|   return {
00019|     put: async (key: string, value: string | ArrayBuffer | ReadableStream) => {
00020|       let content = ""
00021|       if (typeof value === "string") {
00022|         content = value
00023|       } else if (value instanceof ArrayBuffer) {
00024|         content = new TextDecoder().decode(value)
00025|       } else if (value instanceof ReadableStream) {
00026|         const reader = value.getReader()
00027|         const chunks: Uint8Array[] = []
00028|         while (true) {
00029|           const { done, value: chunk } = await reader.read()
00030|           if (done) break
00031|           chunks.push(chunk)
00032|         }
00033|         content = new TextDecoder().decode(Buffer.concat(chunks))
00034|       }
00035|       storage.set(key, content)
00036|     },
00037|     get: async (key: string) => {
00038|       const data = storage.get(key)
00039|       if (!data) return null
00040|       return {
00041|         async text() {
00042|           return data
00043|         },
00044|         async arrayBuffer() {
00045|           return new TextEncoder().encode(data).buffer
00046|         },
00047|         async json() {
00048|           return JSON.parse(data)
00049|         },
00050|       }
00051|     },
00052|     delete: async (key: string) => {
00053|       storage.delete(key)
00054|     },
00055|     list: async (opt...

<file>
00002| import app from "./index.tsx"
00003| import type { AgentSession, SyncInfo, SessionIndex } from "./types"
00004| import {
00005|   createTestFileDiff,
00006|   createTestMessage,
00007|   createTestModel,
00008|   createTestPart,
00009|   createTestSession,
00010|   SESSION_PROPERTIES,
00011|   validateTypeStructure,
00012| } from "./test-utils"
00013| 
00014| const sharedSecret = "6ba7b810-9dad-11d1-80b4-00c04fd430c8"
00015| 
00016| const createMockR2Bucket = () => {
00017|   const storage = new Map<string, string>()
00018| 
00019|   const mockBucket: any = {
00020|     put: async (key: string, value: string | ArrayBuffer) => {
00021|       let content = ""
00022|       if (typeof value === "string") {
00023|         content = value
00024|       }
00025|       if (value instanceof ArrayBuffer) {
00026|         content = new TextDecoder().decode(value)
00027|       }
00028| 
00029|       storage.set(key, content)
00030|     },
00031|     get: async (key: string) => {
00032|       const data = storage.get(key)
00033|       if (!data) return null
00034| 
00035|       return {
00036|         async text() {
00037|           return data
00038|         },
00039|         async arrayBuffer() {
00040|           return new TextEncoder().encode(data).buffer
00041|         },
00042|       }
00043|     },
00044|     delete: async (key: string) => {
00045|       storage.delete(key)
00046|     },
00047|     list: async (options?: any) => {
00048|       const prefix = options?.prefix || ""
00049|       const objects = Array.from(storage.keys())
00050|         .filter((key) => key.startsWith(prefix))
00051|         .map((key) => ({
00052|           key,
00053|           version: "mock",
00054|           size: storage.get(key)!.length,
00055|           etag: `"mock-${key}"`,
00056|           httpMetadata: { contentType: "application/json" },
00057|           customMetadata: {},
00058|           uploaded: new Date(),
00059|         }))
00060|       return { objects }
0006...

No files found

No files found

/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/.env
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/tsconfig.json
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/views/session-list.tsx
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/views/session-detail.tsx
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/views/not-found.tsx
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/wrangler.jsonc
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/STORAGE_ADAPTER.md
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/README.md
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/AGENTS.md
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/script/fix-malformed.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/script/clean-malformed.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/script/backfill-index.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/package.json
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/examples/storage-usage.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/bunfig.toml
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/durable-object.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/broadcast.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/api.test.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/index.tsx
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/index.test.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessi...

/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/opencode/src/share/share-next.ts

No files found

<file>
00001| import { Bus } from "@/bus"
00002| import { Config } from "@/config/config"
00003| import { ulid } from "ulid"
00004| import { Provider } from "@/provider/provider"
00005| import { Session } from "@/session"
00006| import { MessageV2 } from "@/session/message-v2"
00007| import { Storage } from "@/storage/storage"
00008| import { Log } from "@/util/log"
00009| import type * as SDK from "@opencode-ai/sdk/v2"
00010| 
00011| export namespace ShareNext {
00012|   const log = Log.create({ service: "share-next" })
00013| 
00014|   export async function url() {
00015|     return "https://opencode.j9xym.com"
00016|   }
00017| 
00018|   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"
00019| 
00020|   export async function init() {
00021|     if (disabled) return
00022|     Bus.subscribe(Session.Event.Updated, async (evt) => {
00023|       await sync(evt.properties.info.id, [
00024|         {
00025|           type: "session",
00026|           data: evt.properties.info,
00027|         },
00028|       ])
00029|     })
00030|     Bus.subscribe(MessageV2.Event.Updated, async (evt) => {
00031|       await sync(evt.properties.info.sessionID, [
00032|         {
00033|           type: "message",
00034|           data: evt.properties.info,
00035|         },
00036|       ])
00037|       if (evt.properties.info.role === "user") {
00038|         await sync(evt.properties.info.sessionID, [
00039|           {
00040|             type: "model",
00041|             data: [
00042|               await Provider.getModel(evt.properties.info.model.providerID, evt.properties.info.model.modelID).then(
00043|                 (m) => m,
00044|               ),
00045|             ],
00046|           },
00047|         ])
00048|       }
00049|     })
00050|     Bus.subscribe(MessageV2.Event.PartUpdated, async (evt) => {
00051|       await sync(evt.properties.part.sessionID, [
00052|         {
00053|           type: "part",
0005...

<file>
00002| import { cors } from "hono/cors"
00003| import { zValidator } from "@hono/zod-validator"
00004| import { z } from "zod"
00005| import { v5 as uuidv5 } from "uuid"
00006| import type { SyncInfo, ShareCredentials, SyncData, AgentSession, Session, SessionIndex } from "./types.ts"
00007| import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
00008| import SessionList from "./views/session-list.tsx"
00009| import SessionDetail from "./views/session-detail.tsx"
00010| import NotFound from "./views/not-found.tsx"
00011| 
00012| import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
00013| 
00014| // Re-export Durable Object class (required by wrangler)
00015| export { SessionBroadcast } from "./broadcast.ts"
00016| 
00017| /**
00018|  * Environment bindings for Cloudflare Worker
00019|  */
00020| type Env = {
00021|   SESSIONS_STORE: R2Bucket
00022|   SESSIONS_SHARED_SECRET: string
00023|   API_DOMAIN: string
00024|   SESSIONS_BROADCAST: DurableObjectNamespace<SessionBroadcastType>
00025| }
00026| 
00027| /**
00028|  * Main Hono application
00029|  */
00030| const app = new Hono<{ Bindings: Env }>()
00031| 
00032| // Enable CORS for API routes only (not for WebSocket or HTML routes)
00033| app.use("/api/*", cors())
00034| 
00035| /**
00036|  * Create a storage adapter from the R2 bucket binding
00037|  */
00038| function getStorageAdapter(c: any): {
00039|   sessions: StorageAdapter<AgentSession>
00040|   index: StorageAdapter<SessionIndex>
00041| } {
00042|   const bucket = c.env.SESSIONS_STORE
00043|   return {
00044|     sessions: createStorageAdapter<AgentSession>(bucket),
00045|     index: createStorageAdapter<SessionIndex>(bucket),
00046|   }
00047| }
00048| 
00049| /**
00050|  * Root redirect
00051|  */
00052| app.get("/", (c) => c.redirect("/sessions"))
00053| 
00054| /**
00055|  * Create a new share
00056|  * POST /api/share
00057|  */
00058| app.post(
00059|   "/api/share",
00060|   zValidator(
00061|     "j...

<file>
00001| /**
00002|  * SDK Types for OpenCode Agent Sessions
00003|  * Import core types from @opencode-ai/sdk/v2
00004|  */
00005| import type { Session, Message, Part, FileDiff, Model } from "@opencode-ai/sdk/v2"
00006| 
00007| // Re-export SDK types for convenience
00008| export type { Session, Message, Part, FileDiff, Model }
00009| 
00010| /**
00011|  * Sync data discriminated union type
00012|  * Represents the different types of data that can be synchronized
00013|  */
00014| export type SyncData =
00015|   | { type: "session"; data: Session }
00016|   | { type: "message"; data: Message }
00017|   | { type: "part"; data: Part }
00018|   | { type: "session_diff"; data: FileDiff[] }
00019|   | { type: "model"; data: Model[] }
00020| 
00021| /**
00022|  * Complete agent session structure
00023|  * This represents a fully reconstructed session from sync data
00024|  */
00025| export type SessionMetadata = {
00026|   createdAt: number
00027|   lastUpdated: number
00028|   syncCount: number
00029|   secret: string
00030|   sessionID: string
00031| }
00032| 
00033| /**
00034|  * Lightweight index entry stored at index/${shareID}
00035|  * Used by list endpoints to avoid loading full session blobs
00036|  */
00037| export type SessionIndex = {
00038|   id: string
00039|   sessionID: string
00040|   title: string
00041|   directory: string
00042|   messageCount: number
00043|   partCount: number
00044|   diffCount: number
00045|   modelCount: number
00046|   lastUpdated: number
00047|   syncCount: number
00048|   createdAt: number
00049| }
00050| 
00051| export type AgentSession = {
00052|   session: Session
00053|   messages: Message[]
00054|   parts: Part[]
00055|   diffs: FileDiff[]
00056|   models: Model[]
00057|   metadata: SessionMetadata
00058| }
00059| 
00060| /**
00061|  * Share credentials
00062|  */
00063| export type SyncInfo = {
00064|   id: string
00065|   url: string
00066|   secret: string
00067| }
00068| 
00069| export type ShareCredentials = Syn...

No files found

No files found

<file>
00001| {
00002|   "$schema": "https://json.schemastore.org/package.json",
00003|   "version": "1.1.53",
00004|   "name": "opencode",
00005|   "type": "module",
00006|   "license": "MIT",
00007|   "private": true,
00008|   "scripts": {
00009|     "typecheck": "tsgo --noEmit",
00010|     "test": "bun test",
00011|     "build": "bun run script/build.ts",
00012|     "dev": "bun run --conditions=browser ./src/index.ts",
00013|     "random": "echo 'Random script updated at $(date)' && echo 'Change queued successfully' && echo 'Another change made' && echo 'Yet another change' && echo 'One more change' && echo 'Final change' && echo 'Another final change' && echo 'Yet another final change'",
00014|     "clean": "echo 'Cleaning up...' && rm -rf node_modules dist",
00015|     "lint": "echo 'Running lint checks...' && bun test --coverage",
00016|     "format": "echo 'Formatting code...' && bun run --prettier --write src/**/*.ts",
00017|     "docs": "echo 'Generating documentation...' && find src -name '*.ts' -exec echo 'Processing: {}' \\;",
00018|     "deploy": "echo 'Deploying application...' && bun run build && echo 'Deployment completed successfully'"
00019|   },
00020|   "bin": {
00021|     "opencode": "./bin/opencode"
00022|   },
00023|   "randomField": "this-is-a-random-value-12345",
00024|   "exports": {
00025|     "./*": "./src/*.ts"
00026|   },
00027|   "devDependencies": {
00028|     "@babel/core": "7.28.4",
00029|     "@octokit/webhooks-types": "7.6.1",
00030|     "@opencode-ai/script": "workspace:*",
00031|     "@parcel/watcher-darwin-arm64": "2.5.1",
00032|     "@parcel/watcher-darwin-x64": "2.5.1",
00033|     "@parcel/watcher-linux-arm64-glibc": "2.5.1",
00034|     "@parcel/watcher-linux-arm64-musl": "2.5.1",
00035|     "@parcel/watcher-linux-x64-glibc": "2.5.1",
00036|     "@parcel/watcher-linux-x64-musl": "2.5.1",
00037|     "@parcel/watcher-win32-x64": "2.5.1",
00038|     "@standard-schema/spec": "1.0.0",
00039|     "@tsconfig/bun": "catalog:",
00040|...

Found 2 matches
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/opencode/src/share/share.ts:
  Line 70:   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"

/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/opencode/src/share/share-next.ts:
  Line 18:   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"

<file>
00001| /**
00002|  * Mock for cloudflare:workers module in tests
00003|  * This file is preloaded before tests run
00004|  */
00005| 
00006| import { mock } from "bun:test"
00007| 
00008| // Mock the durable-object wrapper module
00009| mock.module("./durable-object.ts", () => ({
00010|   DurableObject: class DurableObject<Env = unknown> {
00011|     constructor(protected ctx: DurableObjectState, protected env: Env) {}
00012|   },
00013| }))
00014| 
00015| // Also mock with absolute path
00016| mock.module("/home/jm/data/code/opencode-trees/sessions-viewer/packages/sessions/src/durable-object.ts", () => ({
00017|   DurableObject: class DurableObject<Env = unknown> {
00018|     constructor(protected ctx: DurableObjectState, protected env: Env) {}
00019|   },
00020| }))
00021| 

(End of file - total 21 lines)
</file>

<file>
00001| {
00002|   "$schema": "https://json.schemastore.org/package.json",
00003|   "name": "opencode",
00004|   "description": "AI-powered development tool",
00005|   "private": true,
00006|   "type": "module",
00007|   "packageManager": "bun@1.3.8",
00008|   "scripts": {
00009|     "dev": "bun run --cwd packages/opencode --conditions=browser src/index.ts",
00010|     "dev:desktop": "bun --cwd packages/desktop tauri dev",
00011|     "dev:web": "bun --cwd packages/app dev",
00012|     "typecheck": "bun turbo typecheck",
00013|     "prepare": "husky",
00014|     "random": "echo 'Random script'",
00015|     "hello": "echo 'Hello World!'",
00016|     "test": "echo 'do not run tests from root' && exit 1"
00017|   },
00018|   "workspaces": {
00019|     "packages": [
00020|       "packages/*",
00021|       "packages/console/*",
00022|       "packages/sdk/js",
00023|       "packages/slack"
00024|     ],
00025|     "catalog": {
00026|       "@types/bun": "1.3.8",
00027|       "@octokit/rest": "22.0.0",
00028|       "@hono/zod-validator": "0.4.2",
00029|       "ulid": "3.0.1",
00030|       "@kobalte/core": "0.13.11",
00031|       "@types/luxon": "3.7.1",
00032|       "@types/node": "22.13.9",
00033|       "@types/semver": "7.7.1",
00034|       "@tsconfig/node22": "22.0.2",
00035|       "@tsconfig/bun": "1.0.9",
00036|       "@cloudflare/workers-types": "4.20251008.0",
00037|       "@openauthjs/openauth": "0.0.0-20250322224806",
00038|       "@pierre/diffs": "1.0.2",
00039|       "@solid-primitives/storage": "4.3.3",
00040|       "@tailwindcss/vite": "4.1.11",
00041|       "diff": "8.0.2",
00042|       "dompurify": "3.3.1",
00043|       "ai": "5.0.124",
00044|       "hono": "4.10.7",
00045|       "hono-openapi": "1.1.2",
00046|       "fuzzysort": "3.1.0",
00047|       "luxon": "3.6.1",
00048|       "marked": "17.0.1",
00049|       "marked-shiki": "1.2.1",
00050|       "@playwright/test": "1.51.0",
00051|       "typescript": "5.8.2",
00052|       "@typescript/native-prev...

<file>
00001| [install]
00002| exact = true
00003| 
00004| [test]
00005| root = "./do-not-run-tests-from-root"
00006| 
00007| 

(End of file - total 7 lines)
</file>

Found 2 matches
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/package.json:
  Line 26:     "@hono/capnweb": "0.1.0",
  Line 29:     "capnweb": "0.4.0",

<file>
00001| {
00002|   "$schema": "https://json.schemastore.org/package.json",
00003|   "name": "@opencode-ai/sessions",
00004|   "version": "1.0.207",
00005|   "private": true,
00006|   "type": "module",
00007|   "module": "index.ts",
00008|   "scripts": {
00009|     "generate-types": "wrangler types",
00010|     "typecheck": "wrangler types && tsc --noEmit",
00011|     "test": "bun test src/**/*.test.ts",
00012|     "test:api": "bun test src/api.test.ts",
00013|     "test:storage": "bun test src/storage.test.ts",
00014|     "dev": "wrangler dev --env dev",
00015|     "deploy": "wrangler deploy"
00016|   },
00017|   "devDependencies": {
00018|     "@tsconfig/bun": "1.0.9",
00019|     "@types/bun": "latest",
00020|     "@types/node": "22.13.9",
00021|     "typescript": "5.9.3",
00022|     "wrangler": "4.63.0"
00023|   },
00024|   "dependencies": {
00025|     "@cloudflare/types": "7.0.0",
00026|     "@hono/capnweb": "0.1.0",
00027|     "@hono/zod-validator": "catalog:",
00028|     "@opencode-ai/sdk": "workspace:*",
00029|     "capnweb": "0.4.0",
00030|     "hono": "catalog:",
00031|     "marked": "17.0.1",
00032|     "uuid": "13.0.0",
00033|     "zod": "catalog:"
00034|   }
00035| }
00036| 

(End of file - total 36 lines)
</file>

No files found

No files found

No files found

<file>
00221|       }
00222| 
00223|       if (item.type === "session_diff") {
00224|         nextSession.diffs = [...nextSession.diffs, ...item.data]
00225|         continue
00226|       }
00227| 
00228|       if (item.type === "model") {
00229|         for (const model of item.data) {
00230|           const index = nextSession.models.findIndex((entry) => entry.id === model.id)
00231|           if (index === -1) {
00232|             nextSession.models.push(model)
00233|             continue
00234|           }
00235|           nextSession.models[index] = model
00236|         }
00237|       }
00238|     }
00239| 
00240|     const updatedIndex: SessionIndex = {
00241|       id: shareID,
00242|       sessionID: nextSession.session.id,
00243|       title: nextSession.session.title,
00244|       directory: nextSession.session.directory,
00245|       messageCount: nextSession.messages.length,
00246|       partCount: nextSession.parts.length,
00247|       diffCount: nextSession.diffs.length,
00248|       modelCount: nextSession.models.length,
00249|       lastUpdated: now,
00250|       syncCount: nextSession.metadata.syncCount,
00251|       createdAt: nextSession.metadata.createdAt,
00252|     }
00253| 
00254|     await Promise.all([sessions.put(`share/${shareID}`, nextSession), index.put(`index/${shareID}`, updatedIndex)])
00255| 
00256|     // Notify connected WebSocket viewers
00257|     const doID = c.env.SESSIONS_BROADCAST.idFromName(shareID)
00258|     const stub = c.env.SESSIONS_BROADCAST.get(doID)
00259|     await stub.broadcast(data)
00260| 
00261|     return c.json({ success: true, syncCount: nextSession.metadata.syncCount })
00262|   },
00263| )
00264| 
00265| /**
00266|  * Get a complete agent session
00267|  * GET /api/share/:id/data
00268|  */
00269| app.get("/api/share/:id", async (c) => {
00270|   const shareID = c.req.param("id")
00271|   const { sessions } = getStorageAdapter(c)
00272| 
00273|   // Get session data using storage adapter
00274|   const age...

<file>
00001| import { Hono } from "hono"
00002| import { cors } from "hono/cors"
00003| import { zValidator } from "@hono/zod-validator"
00004| import { z } from "zod"
00005| import { v5 as uuidv5 } from "uuid"
00006| import type { SyncInfo, ShareCredentials, SyncData, AgentSession, Session, SessionIndex } from "./types.ts"
00007| import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
00008| import SessionList from "./views/session-list.tsx"
00009| import SessionDetail from "./views/session-detail.tsx"
00010| import NotFound from "./views/not-found.tsx"
00011| 
00012| import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
00013| 
00014| // Re-export Durable Object class (required by wrangler)
00015| export { SessionBroadcast } from "./broadcast.ts"
00016| 
00017| /**
00018|  * Environment bindings for Cloudflare Worker
00019|  */
00020| type Env = {
00021|   SESSIONS_STORE: R2Bucket
00022|   SESSIONS_SHARED_SECRET: string
00023|   API_DOMAIN: string
00024|   SESSIONS_BROADCAST: DurableObjectNamespace<SessionBroadcastType>
00025| }
00026| 
00027| 
00028| import { newRpcResponse } from '@hono/capnweb'
00029| import { CapnWeb } from './rpc'
00030| 
00031| const route = new Hono()
00032| const apiServer = new ApiServer()
00033| 
00034| route.post('/rpc/share', async (c) => {
00035|   const request = c.req.raw
00036|   const response = await apiServer.handle(request)
00037|   return new Response(response.body, {
00038|     status: response.status,
00039|     headers: response.headers,
00040|   })

(File has more lines. Use 'offset' parameter to read beyond line 40)
</file>

<file>
00041| }
00042| 
00043| 
00044| /**
00045|  * Main Hono application
00046|  */
00047| const app = new Hono<{ Bindings: Env }>()
00048| 
00049| // Enable CORS for API routes only (not for WebSocket or HTML routes)
00050| app.use("/api/*", cors())
00051| 
00052| /**
00053|  * Create a storage adapter from the R2 bucket binding
00054|  */
00055| function getStorageAdapter(c: any): {
00056|   sessions: StorageAdapter<AgentSession>
00057|   index: StorageAdapter<SessionIndex>
00058| } {
00059|   const bucket = c.env.SESSIONS_STORE
00060|   return {
00061|     sessions: createStorageAdapter<AgentSession>(bucket),
00062|     index: createStorageAdapter<SessionIndex>(bucket),
00063|   }
00064| }
00065| 
00066| /**
00067|  * Root redirect
00068|  */
00069| app.get("/", (c) => c.redirect("/sessions"))
00070| 
00071| /**
00072|  * Create a new share
00073|  * POST /api/share
00074|  */
00075| app.post(
00076|   "/api/share",
00077|   zValidator(
00078|     "json",
00079|     z.object({
00080|       sessionID: z.string(),
00081|     }),
00082|   ),
00083|   async (c) => {
00084|     const { sessionID } = c.req.valid("json")
00085|     const { sessions, index } = getStorageAdapter(c)
00086| 
00087|     const shareID = sessionID.slice(-8)
00088| 
00089|     const shareSecret = uuidv5(sessionID, c.env.SESSIONS_SHARED_SECRET)
00090|     const now = Date.now()
00091| 
00092|     const info: SyncInfo = {
00093|       id: shareID,
00094|       secret: shareSecret,
00095|       url: `${c.env.API_DOMAIN}/api/share/${shareID}`,
00096|     }
00097| 
00098|     // Create share credentials
00099|     const credentialsData: ShareCredentials = {
00100|       ...info, // Automatically includes id, secret, and sessionID
00101|       sessionID: sessionID,
00102|       createdAt: now,
00103|     }
00104| 
00105|     // Initialize empty session data
00106|     const initialSession: AgentSession = {
00107|       session: {
00108|         id: sessionID,
00109|         slug: sessionID,
00110| ...

/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/rpc.ts
/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/sessions/src/rpc-contract.ts

<file>
00001| import { env } from "cloudflare:workers"
00002| import { RpcTarget } from "capnweb"
00003| import type { SyncInfo } from "./types.ts"
00004| import { v5 as uuidv5 } from "uuid"
00005| 
00006| type Env {
00007|   SESSIONS_SHARED_SECRET: string
00008| } 
00009| 
00010| export class Capnweb extends RpcTarget {
00011|   constructor() {
00012|     super()
00013|   }
00014| 
00015|   async createShare(sessionID: string) : Promise<SyncInfo> {
00016|     return {
00017|       id: sessionID.slice(-8),
00018|       secret: uuidv5(sessionID, env.API_DOMAIN,
00019|       url: `https://${env.API_DOMAIN}/share/${sessionID.slice(-8)}`,
00020|     }
00021|   }
00022| 
00023|   async function syncShare(shareID: any, string: any, secret: any, string1: any, data: any, arg5: any) {
00024| 
00025|     // Validate the secret
00026|     // In a real implementation, you would look up the shareID in your storage to find the associated sessionID and validate the secret against it
00027|     const expectedSecret = uuidv5(shareID, c.env.SESSIONS_SHARED_SECRET)
00028|     if (secret !== expectedSecret) {
00029|       throw new Error("Invalid secret")
00030|     }
00031| 
00032|     // Process the sync data
00033|     // This is where you would apply the incoming data to your session storage
00034|     console.log(`Received sync for share ${shareID}:`, data)
00035| 
00036|     // Return a response indicating success and the new sync count
00037|     throw new Error("Function not implemented.")
00038|   }
00039| }
00040| 

(End of file - total 40 lines)
</file>

No files found

<file>
00002| import { Config } from "@/config/config"
00003| import { ulid } from "ulid"
00004| import { Provider } from "@/provider/provider"
00005| import { Session } from "@/session"
00006| import { MessageV2 } from "@/session/message-v2"
00007| import { Storage } from "@/storage/storage"
00008| import { Log } from "@/util/log"
00009| import type * as SDK from "@opencode-ai/sdk/v2"
00010| 
00011| export namespace ShareNext {
00012|   const log = Log.create({ service: "share-next" })
00013| 
00014|   export async function url() {
00015|     return "https://opencode.j9xym.com"
00016|   }
00017| 
00018|   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"
00019| 
00020|   export async function init() {
00021|     if (disabled) return
00022|     Bus.subscribe(Session.Event.Updated, async (evt) => {
00023|       await sync(evt.properties.info.id, [
00024|         {
00025|           type: "session",
00026|           data: evt.properties.info,
00027|         },
00028|       ])
00029|     })
00030|     Bus.subscribe(MessageV2.Event.Updated, async (evt) => {
00031|       await sync(evt.properties.info.sessionID, [
00032|         {
00033|           type: "message",
00034|           data: evt.properties.info,
00035|         },
00036|       ])
00037|       if (evt.properties.info.role === "user") {
00038|         await sync(evt.properties.info.sessionID, [
00039|           {
00040|             type: "model",
00041|             data: [
00042|               await Provider.getModel(evt.properties.info.model.providerID, evt.properties.info.model.modelID).then(
00043|                 (m) => m,
00044|               ),
00045|             ],
00046|           },
00047|         ])
00048|       }
00049|     })
00050|     Bus.subscribe(MessageV2.Event.PartUpdated, async (evt) => {
00051|       await sync(evt.properties.part.sessionID, [
00052|         {
00053|           type: "part",
00054|           data: evt.properties.p...

<file>
00001| import type { RpcTarget } from "capnweb"
00002| import type { SyncData, SyncInfo } from "./types.ts"
00003| 
00004| type ProbeValueInput = { when: Date; bytes: Uint8Array; nested: { x: number } }
00005| type ProbeValueOutput = Promise<string> | string
00006| 
00007| export interface ShareRpc extends RpcTarget {
00008|   createShare: (sessionID: string) => Promise<SyncInfo>
00009|   syncShare: (shareID: string, secret: string, data: SyncData[]) => Promise<{ success: boolean; syncCount: number }>
00010|   // createShare: (sessionID: string) => SyncInfo
00011|   // syncShare: (shareID: string, secret: string, data: SyncData[]) => Promise<string>
00012| 
00013|   // Peek the encoded values, including encoded callbacks parameters
00014|   probeValue: (input: ProbeValueInput) => string
00015|   probeCallback: (cb: (msg: string) => ProbeValueOutput) => ProbeValueOutput
00016| }
00017| 

(End of file - total 17 lines)
</file>

<file>
00001| import { Hono } from "hono"
00002| import { cors } from "hono/cors"
00003| import { zValidator } from "@hono/zod-validator"
00004| import { z } from "zod"
00005| import { v5 as uuidv5 } from "uuid"
00006| import type { SyncInfo, ShareCredentials, SyncData, AgentSession, Session, SessionIndex } from "./types.ts"
00007| import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
00008| import SessionList from "./views/session-list.tsx"
00009| import SessionDetail from "./views/session-detail.tsx"
00010| import NotFound from "./views/not-found.tsx"
00011| import { Capnweb } from './rpc.ts'
00012| 
00013| import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
00014| 
00015| // Re-export Durable Object class (required by wrangler)
00016| export { SessionBroadcast } from "./broadcast.ts"
00017| 
00018| /**
00019|  * Environment bindings for Cloudflare Worker
00020|  */
00021| type Env = {
00022|   SESSIONS_STORE: R2Bucket
00023|   SESSIONS_SHARED_SECRET: string
00024|   API_DOMAIN: string
00025|   SESSIONS_BROADCAST: DurableObjectNamespace<SessionBroadcastType>
00026| }
00027| 
00028| 
00029| 
00030| const route = new Hono()
00031| const apiServer = new Capnweb()
00032| 
00033| route.post('/rpc/share', async (c) => {
00034|   const request = c.req.raw
00035|   const response = await apiServer.handle(request)
00036|   return new Response(response.body, {
00037|     status: response.status,
00038|     headers: response.headers,
00039|   })
00040| }
00041| 
00042| 
00043| /**
00044|  * Main Hono application
00045|  */
00046| const app = new Hono<{ Bindings: Env }>()
00047| 
00048| // Enable CORS for API routes only (not for WebSocket or HTML routes)
00049| app.use("/api/*", cors())
00050| 
00051| /**
00052|  * Create a storage adapter from the R2 bucket binding
00053|  */
00054| function getStorageAdapter(c: any): {
00055|   sessions: StorageAdapter<AgentSession>
00056|   index: StorageAdapter<SessionIndex>
00057| } {
00058|...

<file>
00001| /**
00002|  * Storage Adapter for R2 Bucket
00003|  * Typeclass-based abstraction for R2 storage operations
00004|  */
00005| 
00006| // R2 Types are available globally from worker-configuration.d.ts (generated by Wrangler)
00007| /**
00008|  * Storage Adapter Interface - Typeclass for storage operations
00009|  * This defines the contract that any storage implementation must satisfy
00010|  */
00011| export interface StorageAdapter<T> {
00012|   /**
00013|    * Put an object into storage
00014|    * @param key - The key/path where to store the object
00015|    * @param value - The value to store (will be serialized to JSON)
00016|    * @param options - Optional storage options
00017|    */
00018|   put(key: string, value: T, options?: R2PutOptions): Promise<void>
00019| 
00020|   /**
00021|    * Get an object from storage
00022|    * @param key - The key/path of the object to retrieve
00023|    * @returns The retrieved object or null if not found
00024|    */
00025|   get(key: string): Promise<T | null>
00026| 
00027|   /**
00028|    * Delete an object from storage
00029|    * @param key - The key/path of the object to delete
00030|    */
00031|   delete(key: string): Promise<void>
00032| 
00033|   /**
00034|    * List objects in storage with optional prefix
00035|    * @param options - List options including prefix
00036|    * @returns List of objects with their keys
00037|    */
00038|   list(options?: R2ListOptions): Promise<R2Object[]>
00039| 
00040|   /**
00041|    * Check if an object exists in storage
00042|    * @param key - The key/path to check
00043|    * @returns True if the object exists, false otherwise
00044|    */
00045|   exists(key: string): Promise<boolean>
00046| }
00047| 
00048| /**
00049|  * R2 Storage Adapter Implementation
00050|  * Concrete implementation of StorageAdapter for Cloudflare R2
00051|  */
00052| export class R2StorageAdapter<T> implements StorageAdapter<T> {
00053|   constructor(private readonly bucket: R2Bucket) ...

<file>
00001| import { RpcTarget } from "capnweb"
00002| import type { SyncData, SyncInfo } from "./types.ts"
00003| import { v5 as uuidv5 } from "uuid"
00004| 
00005| export class Capnweb extends RpcTarget {
00006|   constructor(private env: Env) {
00007|     super()
00008|   }
00009| 
00010|   async createShare(sessionID: string): Promise<SyncInfo> {
00011|     return {
00012|       id: sessionID.slice(-8),
00013|       secret: uuidv5(sessionID, this.env.SESSIONS_SECRET),
00014|       url: `https://${this.env.API_DOMAIN}/share/${sessionID.slice(-8)}`,
00015|     }
00016|   }
00017| 
00018|   async syncShare(shareID: string, secret: string, data: SyncData[]) {
00019|     /
00020| 
00021|   }
00022| }
00023| 

(End of file - total 23 lines)
</file>

<file>
00001| import type { RpcTarget } from "capnweb"
00002| import type { SyncData, SyncInfo } from "./types.ts"
00003| 
00004| type ProbeValueInput = { when: Date; bytes: Uint8Array; nested: { x: number } }
00005| type ProbeValueOutput = Promise<string> | string
00006| 
00007| export interface ShareRpc extends RpcTarget {
00008|   createShare: (sessionID: string) => Promise<SyncInfo>
00009|   syncShare: (shareID: string, secret: string, data: SyncData[]) => Promise<{ success: boolean; syncCount: number }>
00010|   // createShare: (sessionID: string) => SyncInfo
00011|   // syncShare: (shareID: string, secret: string, data: SyncData[]) => Promise<string>
00012| 
00013|   // Peek the encoded values, including encoded callbacks parameters
00014|   probeValue: (input: ProbeValueInput) => string
00015|   probeCallback: (cb: (msg: string) => ProbeValueOutput) => ProbeValueOutput
00016| }
00017| 

(End of file - total 17 lines)
</file>

Success. Updated the following files:
M packages/sessions/src/rpc-contract.ts

Success. Updated the following files:
D packages/sessions/src/rpc.ts

Success. Updated the following files:
A packages/sessions/src/rpc.ts

Success. Updated the following files:
M packages/sessions/src/index.tsx

Success. Updated the following files:
A packages/opencode/src/share/rpc-contract.ts

LSP errors detected in packages/opencode/src/share/rpc-contract.ts, please fix:
<diagnostics file="/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/opencode/src/share/rpc-contract.ts">
ERROR [1:32] Cannot find module 'capnweb' or its corresponding type declarations.
</diagnostics>

<file>
00001| import { Bus } from "@/bus"
00002| import { Config } from "@/config/config"
00003| import { ulid } from "ulid"
00004| import { Provider } from "@/provider/provider"
00005| import { Session } from "@/session"
00006| import { MessageV2 } from "@/session/message-v2"
00007| import { Storage } from "@/storage/storage"
00008| import { Log } from "@/util/log"
00009| import type * as SDK from "@opencode-ai/sdk/v2"
00010| 
00011| export namespace ShareNext {
00012|   const log = Log.create({ service: "share-next" })
00013| 
00014|   export async function url() {
00015|     return "https://opencode.j9xym.com"
00016|   }
00017| 
00018|   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"
00019| 
00020|   export async function init() {
00021|     if (disabled) return
00022|     Bus.subscribe(Session.Event.Updated, async (evt) => {
00023|       await sync(evt.properties.info.id, [
00024|         {
00025|           type: "session",
00026|           data: evt.properties.info,
00027|         },
00028|       ])
00029|     })
00030|     Bus.subscribe(MessageV2.Event.Updated, async (evt) => {
00031|       await sync(evt.properties.info.sessionID, [
00032|         {
00033|           type: "message",
00034|           data: evt.properties.info,
00035|         },
00036|       ])
00037|       if (evt.properties.info.role === "user") {
00038|         await sync(evt.properties.info.sessionID, [
00039|           {
00040|             type: "model",
00041|             data: [
00042|               await Provider.getModel(evt.properties.info.model.providerID, evt.properties.info.model.modelID).then(
00043|                 (m) => m,
00044|               ),
00045|             ],
00046|           },
00047|         ])
00048|       }
00049|     })
00050|     Bus.subscribe(MessageV2.Event.PartUpdated, async (evt) => {
00051|       await sync(evt.properties.part.sessionID, [
00052|         {
00053|           type: "part",
0005...

Success. Updated the following files:
M packages/opencode/src/share/share-next.ts

LSP errors detected in packages/opencode/src/share/share-next.ts, please fix:
<diagnostics file="/home/jm/data/code/opencode-trees/capnweb-session-transport/packages/opencode/src/share/share-next.ts">
ERROR [3:40] Cannot find module 'capnweb' or its corresponding type declarations.
</diagnostics>

Success. Updated the following files:
M packages/opencode/package.json

[0.01ms] ".env"
bun install v1.3.8 (b64edcb4)
Resolving dependencies
Resolved, downloaded and extracted [347]
Saved lockfile

$ husky

Checked 1690 installs across 1964 packages (no changes) [1442.00ms]

$ wrangler types && tsc --noEmit

▄
█▀▀█ █▀▀█ █▀▀█ █▀▀▄ █▀▀▀ █▀▀█ █▀▀█ █▀▀█
█  █ █  █ █▀▀▀ █  █ █    █  █ █  █ █▀▀▀
▀▀▀▀ █▀▀▀ ▀▀▀▀ ▀▀▀▀ ▀▀▀▀ ▀▀▀▀ ▀▀▀▀ ▀▀▀▀

Commands:
  opencode completion          generate shell completion script
  opencode acp                 start ACP (Agent Client Protocol) server
  opencode mcp                 manage MCP (Model Context Protocol) servers
  opencode [project]           start opencode tui                                          [default]
  opencode attach <url>        attach to a running opencode server
  opencode run [message..]     run opencode with a message
  opencode debug               debugging and troubleshooting tools
  opencode auth                manage credentials
  opencode agent               manage agents
  open...

$ tsgo --noEmit

 M bun.lock
 M packages/opencode/package.json
 M packages/opencode/src/share/share-next.ts
 M packages/sessions/package.json
 M packages/sessions/src/index.tsx
 M packages/sessions/tsconfig.json
 M packages/sessions/wrangler.jsonc
?? packages/opencode/src/share/rpc-contract.ts
?? packages/sessions/src/rpc-contract.ts
?? packages/sessions/src/rpc.ts
?? packages/sessions/src/share/

<file>
00002| import { cors } from "hono/cors"
00003| import { newWorkersRpcResponse } from "capnweb"
00004| import { zValidator } from "@hono/zod-validator"
00005| import { z } from "zod"
00006| import { v5 as uuidv5 } from "uuid"
00007| import type { SyncInfo, ShareCredentials, AgentSession, SessionIndex } from "./types.ts"
00008| import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
00009| import SessionList from "./views/session-list.tsx"
00010| import SessionDetail from "./views/session-detail.tsx"
00011| import NotFound from "./views/not-found.tsx"
00012| import { ShareRpcImpl } from "./rpc.ts"
00013| 
00014| import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
00015| 
00016| // Re-export Durable Object class (required by wrangler)
00017| export { SessionBroadcast } from "./broadcast.ts"
00018| 
00019| /**
00020|  * Environment bindings for Cloudflare Worker
00021|  */
00022| type Env = {
00023|   SESSIONS_STORE: R2Bucket
00024|   SESSIONS_SHARED_SECRET: string
00025|   API_DOMAIN: string
00026|   SESSIONS_BROADCAST: DurableObjectNamespace<SessionBroadcastType>
00027| }
00028| 
00029| /**
00030|  * Main Hono application
00031|  */
00032| const app = new Hono<{ Bindings: Env }>()
00033| 
00034| // Enable CORS for API routes only (not for WebSocket or HTML routes)
00035| app.use("/api/*", cors())
00036| 
00037| app.all("/rpc/share", async (c) => {
00038|   return newWorkersRpcResponse(c.req.raw, new ShareRpcImpl(c.env))
00039| })
00040| 
00041| /**
00042|  * Create a storage adapter from the R2 bucket binding
00043|  */
00044| function getStorageAdapter(c: any): {
00045|   sessions: StorageAdapter<AgentSession>
00046|   index: StorageAdapter<SessionIndex>
00047| } {
00048|   const bucket = c.env.SESSIONS_STORE
00049|   return {
00050|     sessions: createStorageAdapter<AgentSession>(bucket),
00051|     index: createStorageAdapter<SessionIndex>(bucket),
00052|   }
00053| }
00054| 
00055| /**
00056|  * Root redirect
000...

<file>
00001| import { RpcTarget } from "capnweb"
00002| import { v5 as uuidv5 } from "uuid"
00003| import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
00004| import type { ProbeCallback, ProbeValueInput, ProbeValueOutput } from "./rpc-contract.ts"
00005| import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
00006| import type { AgentSession, SessionIndex, SyncData, SyncInfo } from "./types.ts"
00007| 
00008| type Env = {
00009|   SESSIONS_STORE: R2Bucket
00010|   SESSIONS_SHARED_SECRET: string
00011|   API_DOMAIN: string
00012|   SESSIONS_BROADCAST: DurableObjectNamespace<SessionBroadcastType>
00013| }
00014| 
00015| export class ShareRpcImpl extends RpcTarget {
00016|   constructor(private env: Env) {
00017|     super()
00018|   }
00019| 
00020|   async createShare(sessionID: string): Promise<SyncInfo> {
00021|     const { sessions, index } = this.storage()
00022|     const shareID = sessionID.slice(-8)
00023|     const secret = uuidv5(sessionID, this.env.SESSIONS_SHARED_SECRET)
00024|     const now = Date.now()
00025|     const info: SyncInfo = {
00026|       id: shareID,
00027|       secret,
00028|       url: `${this.env.API_DOMAIN}/api/share/${shareID}`,
00029|     }
00030| 
00031|     const initial: AgentSession = {
00032|       session: {
00033|         id: sessionID,
00034|         slug: sessionID,
00035|         projectID: "",
00036|         directory: "",
00037|         title: "",
00038|         version: "1",
00039|         time: {
00040|           created: now,
00041|           updated: now,
00042|         },
00043|       },
00044|       messages: [],
00045|       parts: [],
00046|       diffs: [],
00047|       models: [],
00048|       metadata: {
00049|         createdAt: now,
00050|         lastUpdated: now,
00051|         syncCount: 0,
00052|         secret,
00053|         sessionID,
00054|       },
00055|     }
00056| 
00057|     const initialIndex: SessionIndex = {
00058|       id: shareID,
00059|       s...

<file>
00002| import { Config } from "@/config/config"
00003| import { newHttpBatchRpcSession } from "capnweb"
00004| import { ulid } from "ulid"
00005| import { Provider } from "@/provider/provider"
00006| import { Session } from "@/session"
00007| import { MessageV2 } from "@/session/message-v2"
00008| import { Storage } from "@/storage/storage"
00009| import { Log } from "@/util/log"
00010| import type * as SDK from "@opencode-ai/sdk/v2"
00011| import type { ShareRpc, SyncData, SyncInfo } from "./rpc-contract"
00012| 
00013| export namespace ShareNext {
00014|   const log = Log.create({ service: "share-next" })
00015| 
00016|   export async function url() {
00017|     return "https://opencode.j9xym.com"
00018|   }
00019| 
00020|   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"
00021|   const transport = process.env["OPENCODE_SHARE_TRANSPORT"] === "rpc" ? "rpc" : "http"
00022| 
00023|   export async function init() {
00024|     if (disabled) return
00025|     Bus.subscribe(Session.Event.Updated, async (evt) => {
00026|       await sync(evt.properties.info.id, [
00027|         {
00028|           type: "session",
00029|           data: evt.properties.info,
00030|         },
00031|       ])
00032|     })
00033|     Bus.subscribe(MessageV2.Event.Updated, async (evt) => {
00034|       await sync(evt.properties.info.sessionID, [
00035|         {
00036|           type: "message",
00037|           data: evt.properties.info,
00038|         },
00039|       ])
00040|       if (evt.properties.info.role === "user") {
00041|         await sync(evt.properties.info.sessionID, [
00042|           {
00043|             type: "model",
00044|             data: [
00045|               await Provider.getModel(evt.properties.info.model.providerID, evt.properties.info.model.modelID).then(
00046|                 (m) => m,
00047|               ),
00048|             ],
00049|           },
00050|         ])
00051|       }
00052...

diff --git a/packages/opencode/package.json b/packages/opencode/package.json
index ba3173f78..5f0c18b18 100644
--- a/packages/opencode/package.json
+++ b/packages/opencode/package.json
@@ -97,6 +97,7 @@
     "ai-gateway-provider": "2.3.1",
     "bonjour-service": "1.3.0",
     "bun-pty": "0.4.8",
+    "capnweb": "0.4.0",
     "chokidar": "4.0.3",
     "clipboardy": "4.0.0",
     "decimal.js": "10.5.0",
diff --git a/packages/opencode/src/share/share-next.ts b/packages/opencode/src/share/share-next.ts
index 72e1c8985..76f607dec 100644
--- a/packages/opencode/src/share/share-next.ts
+++ b/packages/opencode/src/share/share-next.ts
@@ -1,5 +1,6 @@
 import { Bus } from "@/bus"
 import { Config } from "@/config/config"
+import { newHttpBatchRpcSession } from "capnweb"
 import { ulid } from "ulid"
 import { Provider } from "@/provider/provider"
 import { Session } from "@/session"
@@ -7,6 +8,7 @@ import { MessageV2 } from "@/session/message-v2"
 import { Storage } from "@/storage/storage"
 import { Log } from "@/util/log"
 import type * as SDK from "@opencode-ai/sdk/v2"
+import type { ShareRpc, SyncData, SyncInfo } from "./rpc-contract"
 
 export namespace ShareNext {
   const log = Log.create({ service: "share-next" })
@@ -16,6 +18,7 @@ export namespace ShareNext {
   }
 
   const disabled = process.env["OPENCODE_DISABLE_SHARE"] === "true" || process.env["OPENCODE_DISABLE_SHARE"] === "1"
+  const transport = process.env["OPENCODE_SHARE_TRANSPORT"] === "rpc" ? "rpc" : "http"
 
   export async function init() {
     if (disabled) return
@@ -68,15 +71,18 @@ export namespace ShareNext {
   export async function create(sessionID: string) {
     if (disabled) return { id: "", url: "", secret: "" }
     log.info("creating share", { sessionID })
-    const result = await fetch(`${await url()}/api/share`, {
-      method: "POST",
-      headers: {
-        "Content-Type": "application/json",
-      },
-      body: JSON.stringify({ sessionID: sessionID }),
-    })
-      .then((x) =...

diff --git a/packages/sessions/src/index.tsx b/packages/sessions/src/index.tsx
index ecf44c5bb..e13e7dbe7 100644
--- a/packages/sessions/src/index.tsx
+++ b/packages/sessions/src/index.tsx
@@ -1,13 +1,15 @@
 import { Hono } from "hono"
 import { cors } from "hono/cors"
+import { newWorkersRpcResponse } from "capnweb"
 import { zValidator } from "@hono/zod-validator"
 import { z } from "zod"
 import { v5 as uuidv5 } from "uuid"
-import type { SyncInfo, ShareCredentials, SyncData, AgentSession, Session, SessionIndex } from "./types.ts"
+import type { SyncInfo, ShareCredentials, AgentSession, SessionIndex } from "./types.ts"
 import { createStorageAdapter, type StorageAdapter } from "./storage.ts"
 import SessionList from "./views/session-list.tsx"
 import SessionDetail from "./views/session-detail.tsx"
 import NotFound from "./views/not-found.tsx"
+import { ShareRpcImpl } from "./rpc.ts"
 
 import type { SessionBroadcast as SessionBroadcastType } from "./broadcast.ts"
 
@@ -32,6 +34,10 @@ const app = new Hono<{ Bindings: Env }>()
 // Enable CORS for API routes only (not for WebSocket or HTML routes)
 app.use("/api/*", cors())
 
+app.all("/rpc/share", async (c) => {
+  return newWorkersRpcResponse(c.req.raw, new ShareRpcImpl(c.env))
+})
+
 /**
  * Create a storage adapter from the R2 bucket binding
  */

<file>
00001| import type { FC, Child } from "hono/jsx"
00002| 
00003| const Layout: FC<{ title: string; children?: Child }> = ({ title, children }) => (
00004|   <html lang="en">
00005|     <head>
00006|       <meta charset="utf-8" />
00007|       <meta name="viewport" content="width=device-width, initial-scale=1" />
00008|       <title>{title}</title>
00009|       <style>{`
00010|         * { margin: 0; padding: 0; box-sizing: border-box; }
00011|         body { background: #0a0a0a; color: #e0e0e0; font-family: ui-monospace, 'Cascadia Code', 'Source Code Pro', Menlo, Consolas, monospace; font-size: 14px; line-height: 1.6; }
00012|         a { color: #6ee7b7; text-decoration: none; }
00013|         a:hover { text-decoration: underline; }
00014|         .container { max-width: 900px; margin: 0 auto; padding: 1rem; }
00015|         nav { border-bottom: 1px solid #1e293b; padding: 0.75rem 1rem; margin-bottom: 1.5rem; }
00016|         nav a { font-weight: bold; font-size: 16px; }
00017|         .meta { color: #94a3b8; font-size: 12px; }
00018|         .badge { display: inline-block; padding: 2px 8px; border-radius: 4px; font-size: 11px; background: #1e293b; color: #94a3b8; }
00019|         pre, code { font-family: inherit; }
00020|         pre { background: #1e1e2e; border: 1px solid #2d2d3d; border-radius: 6px; padding: 1rem; overflow-x: auto; margin: 0.5rem 0; }
00021|         code { background: #1e1e2e; padding: 2px 6px; border-radius: 3px; }
00022|         pre code { background: none; padding: 0; }
00023|         .message { border: 1px solid #1e293b; border-radius: 8px; margin: 1rem 0; padding: 1rem; }
00024|         .message.user { border-left: 3px solid #6ee7b7; }
00025|         .message.assistant { border-left: 3px solid #818cf8; }
00026|         .message-header { display: flex; justify-content: space-between; align-items: center; margin-bottom: 0.5rem; }
00027|         .role { font-weight: bold; text-transform: uppercase; font-size: 11px; letter-spacing: 0.05em...

<file>
00001| import type { FC } from "hono/jsx"
00002| import type { SessionIndex } from "../types.ts"
00003| import Layout from "./layout.tsx"
00004| 
00005| const formatTime = (ts: number) =>
00006|   new Date(ts).toLocaleString("en-US", { month: "short", day: "numeric", hour: "2-digit", minute: "2-digit" })
00007| 
00008| const SessionList: FC<{ sessions: SessionIndex[] }> = ({ sessions }) => (
00009|   <Layout title="Sessions">
00010|     <h1 style="margin-bottom: 1rem; font-size: 20px;">Sessions</h1>
00011|     <input type="text" class="search-box" placeholder="Search sessions..." id="search" />
00012|     <div id="session-list">
00013|       {sessions.map((s) => (
00014|         <a href={`/share/${s.id}`} class="session-card" data-title={(s.title || "").toLowerCase()}>
00015|           <div class="session-title">{s.title || "Untitled"}</div>
00016|           <div class="meta">
00017|             {s.directory ? <span>{s.directory} · </span> : null}
00018|             <span>{s.messageCount} messages · </span>
00019|             <span>{s.syncCount} syncs · </span>
00020|             <span>{formatTime(s.lastUpdated)}</span>
00021|           </div>
00022|         </a>
00023|       ))}
00024|     </div>
00025|     <script>{`
00026|       document.getElementById('search').addEventListener('input', function(e) {
00027|         const q = e.target.value.toLowerCase();
00028|         document.querySelectorAll('.session-card').forEach(function(card) {
00029|           card.style.display = card.getAttribute('data-title').includes(q) ? '' : 'none';
00030|         });
00031|       });
00032|     `}</script>
00033|   </Layout>
00034| )
00035| 
00036| export default SessionList
00037| 

(End of file - total 37 lines)
</file>

<file>
00001| import type { FC } from "hono/jsx"
00002| import { html, raw } from "hono/html"
00003| import { marked } from "marked"
00004| import Layout from "./layout.tsx"
00005| import type { AgentSession, Message, Part } from "../types.ts"
00006| 
00007| // Configure marked for dark theme code blocks
00008| marked.setOptions({ breaks: true, gfm: true })
00009| 
00010| const formatTime = (ts: number) =>
00011|   new Date(ts).toLocaleString("en-US", {
00012|     month: "short",
00013|     day: "numeric",
00014|     hour: "2-digit",
00015|     minute: "2-digit",
00016|     second: "2-digit",
00017|   })
00018| 
00019| const formatCost = (cost: number) => (cost > 0 ? `$${cost.toFixed(4)}` : "")
00020| 
00021| const formatTokens = (tokens: {
00022|   input: number
00023|   output: number
00024|   reasoning: number
00025|   cache: { read: number; write: number }
00026| }) =>
00027|   `${tokens.input.toLocaleString()}in / ${tokens.output.toLocaleString()}out` +
00028|   (tokens.reasoning > 0 ? ` / ${tokens.reasoning.toLocaleString()}reasoning` : "")
00029| 
00030| const renderMarkdown = (text: string) => raw(marked.parse(text) as string)
00031| 
00032| const TextPartView: FC<{ text: string }> = ({ text }) => <div class="text-content">{renderMarkdown(text)}</div>
00033| 
00034| const ToolPartView: FC<{ part: Part }> = ({ part }) => {
00035|   const state = (part as any).state
00036|   const status = state.status
00037|   const name = (part as any).tool
00038|   return (
00039|     <div class="tool">
00040|       <div class="tool-header">
00041|         <span class="tool-name">{name}</span>
00042|         <span class={`tool-status ${status}`}>{status}</span>
00043|       </div>
00044|       {state.title ? (
00045|         <div class="meta" style="margin-bottom: 0.5rem;">
00046|           {state.title}
00047|         </div>
00048|       ) : null}
00049|       {status === "completed" && state.output ? (
00050|         <details>
00051|           <summary class="meta" style=...

<file>
00001| import type { FC } from "hono/jsx"
00002| import Layout from "./layout.tsx"
00003| 
00004| const NotFound: FC = () => (
00005|   <Layout title="Not Found">
00006|     <h1 style="font-size: 20px;">404 - Not Found</h1>
00007|     <p class="meta" style="margin-top: 0.5rem;">The session you're looking for doesn't exist.</p>
00008|     <a href="/sessions" style="display: inline-block; margin-top: 1rem;">Back to sessions</a>
00009|   </Layout>
00010| )
00011| 
00012| export default NotFound
00013| 

(End of file - total 13 lines)
</file>

Success. Updated the following files:
M packages/sessions/src/views/layout.tsx

<file>
00146|         </div>
00147|         <div class="meta" style="margin-top: 0.25rem;">
00148|           <span>Created {formatTime(safeTime.created)}</span>
00149|           <span> · Updated {formatTime(session.metadata.lastUpdated)}</span>
00150|           <span> · {session.metadata.syncCount} syncs</span>
00151|         </div>
00152|       </div>
00153| 
00154|       <div id="messages">
00155|         {sorted.map((msg) => (
00156|           <MessageView message={msg} parts={partsByMessage.get(msg.id) || []} />
00157|         ))}
00158|       </div>
00159| 
00160|       <script>{html`
00161|         ${raw(`
00162|           (() => {
00163|             const poll = 30000
00164|             const reconnect = 5000
00165|             const path = "/ws/${shareID}"
00166|             const wsUrl = `${location.protocol === "https:" ? "wss:" : "ws:"}//${location.host}${path}`
00167| 
00168|             const startPollingFallback = () => {
00169|               const w = window as Window & { __sessionPoll?: number }
00170|               if (w.__sessionPoll) clearInterval(w.__sessionPoll)
00171|               w.__sessionPoll = window.setInterval(async () => {
00172|                 try {
00173|                   const response = await fetch(location.href, { cache: "no-store" })
00174|                   if (response.ok) location.reload()
00175|                 } catch {
00176|                   // no-op
00177|                 }
00178|               }, poll)
00179|             }
00180| 
00181|             try {
00182|               const ws = new WebSocket(wsUrl)
00183| 
00184|               ws.onclose = () => {
00185|                 setTimeout(() => location.reload(), reconnect)
00186|               }
00187| 
00188|               ws.onerror = () => {
00189|                 startPollingFallback()
00190|               }
00191| 
00192|               ws.onmessage = () => {
00193|                 location.reload()
00194|               }
00195|             } catch {
00196|     ...

Success. Updated the following files:
M packages/sessions/src/views/session-detail.tsx

bun test v1.3.8 (b64edcb4)

 2 pass
 0 fail
 25 expect() calls
Ran 2 tests across 1 file. [119.00ms]

src/views/layout.tsx(75,1): error TS1005: '}' expected.