feat(session): add messageCount endpoint for efficient message counting

resolve: merge conflicts in generated SDK files

Author: sjawhar

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

@@ -632,6 +632,36 @@ export const SessionRoutes = lazy(() =>
         return c.json(page.items)
       },
     )
+    .get(
+      "/:sessionID/message/count",
+      describeRoute({
+        summary: "Get message count",
+        description: "Get the total number of messages in a session.",
+        operationId: "session.messageCount",
+        responses: {
+          200: {
+            description: "Message count",
+            content: {
+              "application/json": {
+                schema: resolver(z.object({ count: z.number() })),
+              },
+            },
+          },
+          ...errors(400, 404),
+        },
+      }),
+      validator(
+        "param",
+        z.object({
+          sessionID: SessionID.zod,
+        }),
+      ),
+      async (c) => {
+        const sessionID = c.req.valid("param").sessionID
+        const count = await Session.messageCount({ sessionID })
+        return c.json({ count })
+      },
+    )
     .get(
       "/:sessionID/message/:messageID",
       describeRoute({

packages/opencode/src/session/index.ts

@@ -9,7 +9,7 @@ import { Config } from "../config/config"
 import { Flag } from "../flag/flag"
 import { Installation } from "../installation"
 
-import { Database, NotFoundError, eq, and, gte, isNull, desc, like, inArray, lt } from "../storage/db"
+import { Database, NotFoundError, eq, and, or, gte, isNull, desc, like, inArray, lt, sql } from "../storage/db"
 import { SyncEvent } from "../sync"
 import type { SQL } from "../storage/db"
 import { SessionTable } from "./session.sql"
@@ -483,6 +483,22 @@ export namespace Session {
     },
   )
 
+  export const messageCount = fn(
+    z.object({
+      sessionID: SessionID.zod,
+    }),
+    async (input) => {
+      const result = Database.use((db) =>
+        db
+          .select({ count: sql<number>`COUNT(*)` })
+          .from(MessageTable)
+          .where(eq(MessageTable.session_id, input.sessionID))
+          .get(),
+      )
+      return result?.count ?? 0
+    },
+  )
+
   export function* list(input?: {
     directory?: string
     workspaceID?: WorkspaceID