Mirror_Repos/anomalyco_opencode
2
0
Fork 0
Code Issues Pull Requests Actions 80 Packages Projects Releases Wiki Activity

Preserve message row union types

Browse Source
This commit is contained in:
Dax Raad
2026-05-10 20:31:51 -04:00
parent e2c00f8794
commit 988d406ff4
2 changed files with 1 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/opencode/src/data-migration.ts
-9
View File
@@ -56,15 +56,6 @@ export const layer = Layer.effect(
.where(inArray(MessageTable.session_id, sessions.map((session) => session.id)))
.all()) {
if (row.data.role !== "assistant") continue
if (!("cost" in row.data) || typeof row.data.cost !== "number") continue
if (!("tokens" in row.data) || typeof row.data.tokens !== "object" || row.data.tokens === null) continue
if (!("input" in row.data.tokens) || typeof row.data.tokens.input !== "number") continue
if (!("output" in row.data.tokens) || typeof row.data.tokens.output !== "number") continue
if (!("reasoning" in row.data.tokens) || typeof row.data.tokens.reasoning !== "number") continue
if (!("cache" in row.data.tokens) || typeof row.data.tokens.cache !== "object" || row.data.tokens.cache === null)
continue
if (!("read" in row.data.tokens.cache) || typeof row.data.tokens.cache.read !== "number") continue
if (!("write" in row.data.tokens.cache) || typeof row.data.tokens.cache.write !== "number") continue
const current = usageBySession.get(row.session_id)
if (!current) continue
packages/opencode/src/session/session.sql.ts
+1 -1
View File
@@ -10,7 +10,7 @@ import type { WorkspaceID } from "../control-plane/schema"
import { Timestamps } from "../storage/schema.sql"
type PartData = Omit<MessageV2.Part, "id" | "sessionID" | "messageID">
type InfoData = Omit<MessageV2.Info, "id" | "sessionID">
type InfoData<T extends MessageV2.Info = MessageV2.Info> = T extends unknown ? Omit<T, "id" | "sessionID"> : never
type SessionMessageData = Omit<(typeof SessionMessage.Message)["Encoded"], "type" | "id">
export const SessionTable = sqliteTable(