ceos/opencode
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use SyncEvent.remove

Browse source
This commit is contained in:
James Long 2026-05-04 10:24:30 -04:00
commit e1f49c2cbe
1 changed files with 2 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

12
packages/opencode/src/server/routes/instance/sync.ts
View file

@ -9,7 +9,7 @@ import { not } from "drizzle-orm"
import { or } from "drizzle-orm" import { or } from "drizzle-orm"
import { lte } from "drizzle-orm" import { lte } from "drizzle-orm"
import { eq } 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 { lazy } from "@/util/lazy"
import * as Log from "@opencode-ai/core/util/log" import * as Log from "@opencode-ai/core/util/log"
import { startWorkspaceSyncing } from "@/control-plane/workspace" import { startWorkspaceSyncing } from "@/control-plane/workspace"
@ -132,15 +132,7 @@ export const SyncRoutes = lazy(() =>
validator("json", SessionPayload), validator("json", SessionPayload),
async (c) => { async (c) => {
const body = c.req.valid("json") const body = c.req.valid("json")
Database.transaction((tx) => { SyncEvent.remove(body.sessionID)
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,
})
return c.json({ return c.json({
sessionID: body.sessionID, sessionID: body.sessionID,
}) })