refactor(core): replace sync event cast with Schema guard

Use Schema.is to narrow converted sync events instead of asserting the payload type manually. Move the Zod-to-Effect bridge into effect-zod so remaining Zod-backed sync payloads have one explicit interop helper.

Author: kitlangton

packages/opencode/src/server/projectors.ts

@@ -5,12 +5,14 @@ import { Session } from "@/session"
 import { SessionTable } from "@/session/session.sql"
 import { Database, eq } from "@/storage"
 
+const isSessionUpdated = Schema.is(Session.Event.Updated.schema)
+
 export function initProjectors() {
   SyncEvent.init({
     projectors: sessionProjectors,
     convertEvent: (type, data) => {
-      if (type === "session.updated") {
-        const id = (data as Schema.Schema.Type<typeof Session.Event.Updated.schema>).sessionID
+      if (type === Session.Event.Updated.type && isSessionUpdated(data)) {
+        const id = data.sessionID
         const row = Database.use((db) => db.select().from(SessionTable).where(eq(SessionTable.id, id)).get())
 
         if (!row) return data

packages/opencode/src/session/session.ts

@@ -28,7 +28,7 @@ import type { Provider } from "@/provider"
 import { Permission } from "@/permission"
 import { Global } from "@/global"
 import { Effect, Layer, Option, Context, Schema } from "effect"
-import { ZodOverride } from "@/util/effect-zod"
+import { fromZod } from "@/util/effect-zod"
 
 const log = Log.create({ service: "session" })
 
@@ -201,14 +201,8 @@ export const SetRevertInput = z.object({
 })
 export const MessagesInput = z.object({ sessionID: SessionID.zod, limit: z.number().optional() })
 
-function schemaFromZod<T extends z.ZodTypeAny>(value: T) {
-  return Schema.declare((input): input is z.output<T> => value.safeParse(input).success).annotate({
-    [ZodOverride]: value,
-  })
-}
-
-const SessionInfoSchema = schemaFromZod(Info)
-const SessionUpdateInfoSchema = schemaFromZod(
+const SessionInfoSchema = fromZod(Info)
+const SessionUpdateInfoSchema = fromZod(
   updateSchema(Info).extend({
     share: updateSchema(Info.shape.share.unwrap()).optional(),
     time: updateSchema(Info.shape.time).optional(),

packages/opencode/src/util/effect-zod.ts

@@ -22,6 +22,14 @@ export function zod<S extends Schema.Top>(schema: S): z.ZodType<Schema.Schema.Ty
   return walk(schema.ast) as z.ZodType<Schema.Schema.Type<S>>
 }
 
+// Bridge a Zod-first schema into Effect Schema while preserving the original
+// Zod for downstream JSON Schema/OpenAPI generation.
+export function fromZod<T extends z.ZodTypeAny>(value: T) {
+  return Schema.declare((input): input is z.output<T> => value.safeParse(input).success).annotate({
+    [ZodOverride]: value,
+  })
+}
+
 function walk(ast: SchemaAST.AST): z.ZodTypeAny {
   const cached = walkCache.get(ast)
   if (cached) return cached