From d18891523d3b5af05671fcf6b1418e5ce29d6ac9 Mon Sep 17 00:00:00 2001 From: Ryan Vogel Date: Thu, 16 Apr 2026 01:05:37 +0000 Subject: [PATCH] fix(push-relay): update Session.get to use direct DB access after Effect migration --- packages/opencode/src/server/push-relay.ts | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/packages/opencode/src/server/push-relay.ts b/packages/opencode/src/server/push-relay.ts index 3503e35513..b73a3e729d 100644 --- a/packages/opencode/src/server/push-relay.ts +++ b/packages/opencode/src/server/push-relay.ts @@ -326,10 +326,16 @@ async function notify(input: { type: Type; sessionID: string }): Promise } try { - const [{ Session }, { MessageV2 }] = await Promise.all([import("@/session"), import("@/session/message-v2")]) + const [{ Session }, { MessageV2 }, { SessionTable }, { Database, eq }] = await Promise.all([ + import("@/session"), + import("@/session/message-v2"), + import("@/session/session.sql"), + import("@/storage/db"), + ]) const sessionID = SessionID.make(input.sessionID) - const session = await Session.get(sessionID) - out.title = session.title + const row = Database.use((db) => db.select().from(SessionTable).where(eq(SessionTable.id, sessionID)).get()) + const session = row ? Session.fromRow(row) : undefined + out.title = session?.title let latestUser: string | undefined for await (const msg of MessageV2.stream(sessionID)) {