From e1f49c2cbe1c19d5162ebca76c568e9dfec65a33 Mon Sep 17 00:00:00 2001 From: James Long Date: Mon, 4 May 2026 10:24:30 -0400 Subject: [PATCH] Use SyncEvent.remove --- packages/opencode/src/server/routes/instance/sync.ts | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/packages/opencode/src/server/routes/instance/sync.ts b/packages/opencode/src/server/routes/instance/sync.ts index 82a91d5bcb..164a1375ea 100644 --- a/packages/opencode/src/server/routes/instance/sync.ts +++ b/packages/opencode/src/server/routes/instance/sync.ts @@ -9,7 +9,7 @@ import { not } from "drizzle-orm" import { or } from "drizzle-orm" import { lte } from "drizzle-orm" import { eq } from "drizzle-orm" -import { EventSequenceTable, EventTable } from "@/sync/event.sql" +import { EventTable } from "@/sync/event.sql" import { lazy } from "@/util/lazy" import * as Log from "@opencode-ai/core/util/log" import { startWorkspaceSyncing } from "@/control-plane/workspace" @@ -132,15 +132,7 @@ export const SyncRoutes = lazy(() => validator("json", SessionPayload), async (c) => { const body = c.req.valid("json") - Database.transaction((tx) => { - tx.delete(EventTable).where(eq(EventTable.aggregate_id, body.sessionID)).run() - tx.delete(EventSequenceTable).where(eq(EventSequenceTable.aggregate_id, body.sessionID)).run() - }) - - log.info("sync events erased", { - sessionID: body.sessionID, - }) - + SyncEvent.remove(body.sessionID) return c.json({ sessionID: body.sessionID, })