feat(session): add ts_before and breakpoint params to Session.messages API

Add optional parameters to Session.messages() for loading older messages:
- ts_before: filter to messages created before this timestamp
- breakpoint: stop at first compaction summary when true

This is a foundational API enhancement that enables clients to implement
pagination and history loading without breaking existing functionality.

Author: ryanwyler

packages/opencode/src/server/routes/session.ts

@@ -571,13 +571,17 @@ export const SessionRoutes = lazy(() =>
         "query",
         z.object({
           limit: z.coerce.number().optional(),
+          ts_before: z.coerce.number().optional(),
+          breakpoint: z.coerce.boolean().optional(),
         }),
       ),
       async (c) => {
         const query = c.req.valid("query")
         const messages = await Session.messages({
           sessionID: c.req.valid("param").sessionID,
           limit: query.limit,
+          ts_before: query.ts_before,
+          breakpoint: query.breakpoint,
         })
         return c.json(messages)
       },

packages/opencode/src/session/index.ts

@@ -317,12 +317,16 @@ export namespace Session {
     z.object({
       sessionID: Identifier.schema("session"),
       limit: z.number().optional(),
+      ts_before: z.number().optional(),
+      breakpoint: z.boolean().optional(),
     }),
     async (input) => {
       const result = [] as MessageV2.WithParts[]
       for await (const msg of MessageV2.stream(input.sessionID)) {
+        if (input.ts_before && msg.info.time.created >= input.ts_before) continue
         if (input.limit && result.length >= input.limit) break
         result.push(msg)
+        if (input.ts_before && input.breakpoint && msg.parts.some((p) => p.type === "compaction")) break
       }
       result.reverse()
       return result

packages/sdk/js/src/v2/gen/client/client.gen.ts

@@ -162,16 +162,10 @@ export const createClient = (config: Config = {}): Client => {
         case "arrayBuffer":
         case "blob":
         case "formData":
+        case "json":
         case "text":
           data = await response[parseAs]()
           break
-        case "json": {
-          // Some servers return 200 with no Content-Length and empty body.
-          // response.json() would throw; read as text and parse if non-empty.
-          const text = await response.text()
-          data = text ? JSON.parse(text) : {}
-          break
-        }
         case "stream":
           return opts.responseStyle === "data"
             ? response.body
@@ -250,7 +244,6 @@ export const createClient = (config: Config = {}): Client => {
         }
         return request
       },
-      serializedBody: getValidRequestBody(opts) as BodyInit | null | undefined,
       url,
     })
   }

packages/sdk/js/src/v2/gen/core/serverSentEvents.gen.ts

@@ -151,8 +151,6 @@ export const createSseClient = <TData = unknown>({
             const { done, value } = await reader.read()
             if (done) break
             buffer += value
-            // Normalize line endings: CRLF -> LF, then CR -> LF
-            buffer = buffer.replace(/\r\n/g, "\n").replace(/\r/g, "\n")
 
             const chunks = buffer.split("\n\n")
             buffer = chunks.pop() ?? ""