sandvich
/
opencode
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(sync): restore ALS for published events

pull/20597/head
Kit Langton 2026-04-02 00:04:56 -04:00
parent a68395bfef
commit 89c0db86b9
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/opencode/src/sync/index.ts
View File

@ -2,6 +2,7 @@ import z from "zod"
import type { ZodObject } from "zod" import type { ZodObject } from "zod"
import { EventEmitter } from "events" import { EventEmitter } from "events"
import { Effect, Layer, ServiceMap } from "effect" import { Effect, Layer, ServiceMap } from "effect"
import { InstanceState } from "@/effect/instance-state"
import { makeRuntime } from "@/effect/run-service" import { makeRuntime } from "@/effect/run-service"
import { Database, eq } from "@/storage/db" import { Database, eq } from "@/storage/db"
import { Bus as ProjectBus } from "@/bus" import { Bus as ProjectBus } from "@/bus"
@ -219,7 +220,7 @@ export namespace SyncEvent {
) )
} }
yield* Effect.sync(() => process(def, event, { publish: !!options?.republish })) yield* InstanceState.withALS(() => process(def, event, { publish: !!options?.republish }))
}) })
const run: Interface["run"] = Effect.fn("SyncEvent.run")(function* <Def extends Definition>( const run: Interface["run"] = Effect.fn("SyncEvent.run")(function* <Def extends Definition>(
@ -235,7 +236,7 @@ export namespace SyncEvent {
throw new Error(`SyncEvent.run: running old versions of events is not allowed: ${def.type}`) throw new Error(`SyncEvent.run: running old versions of events is not allowed: ${def.type}`)
} }
yield* Effect.sync(() => yield* InstanceState.withALS(() =>
Database.transaction( Database.transaction(
(tx) => { (tx) => {
const id = EventID.ascending() const id = EventID.ascending()