diff options
| author | opencode-agent[bot] <opencode-agent[bot]@users.noreply.github.com> | 2026-04-23 16:44:32 +0000 |
|---|---|---|
| committer | opencode-agent[bot] <opencode-agent[bot]@users.noreply.github.com> | 2026-04-23 16:44:32 +0000 |
| commit | aed03078f88af5c28035a28b6edbbf10228a49ed (patch) | |
| tree | 293e41fa7d5d4f6a71639ece4fa081c63bd072b2 | |
| parent | c50d65b4d6b956cad44663d9d31b7b5eb01c8e57 (diff) | |
| download | opencode-aed03078f88af5c28035a28b6edbbf10228a49ed.tar.gz opencode-aed03078f88af5c28035a28b6edbbf10228a49ed.zip | |
chore: generate
| -rw-r--r-- | packages/opencode/src/bus/index.ts | 20 | ||||
| -rw-r--r-- | packages/opencode/src/sync/index.ts | 16 | ||||
| -rw-r--r-- | packages/sdk/openapi.json | 21 |
3 files changed, 18 insertions, 39 deletions
diff --git a/packages/opencode/src/bus/index.ts b/packages/opencode/src/bus/index.ts index a2f9f5ccb..9183ff72a 100644 --- a/packages/opencode/src/bus/index.ts +++ b/packages/opencode/src/bus/index.ts @@ -33,10 +33,7 @@ type State = { } export interface Interface { - readonly publish: <D extends BusEvent.Definition>( - def: D, - properties: BusProperties<D>, - ) => Effect.Effect<void> + readonly publish: <D extends BusEvent.Definition>(def: D, properties: BusProperties<D>) => Effect.Effect<void> readonly subscribe: <D extends BusEvent.Definition>(def: D) => Stream.Stream<Payload<D>> readonly subscribeAll: () => Stream.Stream<Payload> readonly subscribeCallback: <D extends BusEvent.Definition>( @@ -85,10 +82,7 @@ export const layer = Layer.effect( }) } - function publish<D extends BusEvent.Definition>( - def: D, - properties: BusProperties<D>, - ) { + function publish<D extends BusEvent.Definition>(def: D, properties: BusProperties<D>) { return Effect.gen(function* () { const s = yield* InstanceState.get(state) const payload: Payload = { type: def.type, properties } @@ -184,17 +178,11 @@ const { runPromise, runSync } = makeRuntime(Service, layer) // runSync is safe here because the subscribe chain (InstanceState.get, PubSub.subscribe, // Scope.make, Effect.forkScoped) is entirely synchronous. If any step becomes async, this will throw. -export async function publish<D extends BusEvent.Definition>( - def: D, - properties: BusProperties<D>, -) { +export async function publish<D extends BusEvent.Definition>(def: D, properties: BusProperties<D>) { return runPromise((svc) => svc.publish(def, properties)) } -export function subscribe<D extends BusEvent.Definition>( - def: D, - callback: (event: Payload<D>) => unknown, -) { +export function subscribe<D extends BusEvent.Definition>(def: D, callback: (event: Payload<D>) => unknown) { return runSync((svc) => svc.subscribeCallback(def, callback)) } diff --git a/packages/opencode/src/sync/index.ts b/packages/opencode/src/sync/index.ts index 5a4078402..482ad4fbb 100644 --- a/packages/opencode/src/sync/index.ts +++ b/packages/opencode/src/sync/index.ts @@ -12,7 +12,10 @@ import { Schema as EffectSchema, Types } from "effect" import { zodObject } from "@/util/effect-zod" import { isRecord } from "@/util/record" -export type Definition<Schema extends EffectSchema.Top = EffectSchema.Top, BusSchema extends EffectSchema.Top = Schema> = { +export type Definition< + Schema extends EffectSchema.Top = EffectSchema.Top, + BusSchema extends EffectSchema.Top = Schema, +> = { type: string version: number aggregate: string @@ -87,10 +90,13 @@ export function define< Agg extends string, Schema extends EffectSchema.Top, BusSchema extends EffectSchema.Top = Schema, ->(input: { type: Type; version: number; aggregate: Agg; schema: Schema; busSchema?: BusSchema }): Definition< - Schema, - BusSchema -> { +>(input: { + type: Type + version: number + aggregate: Agg + schema: Schema + busSchema?: BusSchema +}): Definition<Schema, BusSchema> { if (frozen) { throw new Error("Error defining sync event: sync system has been frozen") } diff --git a/packages/sdk/openapi.json b/packages/sdk/openapi.json index 55570d47d..e54648e19 100644 --- a/packages/sdk/openapi.json +++ b/packages/sdk/openapi.json @@ -10570,8 +10570,7 @@ } ] } - }, - "required": ["url"] + } }, "title": { "anyOf": [ @@ -10636,8 +10635,7 @@ } ] } - }, - "required": ["created", "updated", "compacting", "archived"] + } }, "permission": { "anyOf": [ @@ -10676,20 +10674,7 @@ } ] } - }, - "required": [ - "id", - "slug", - "projectID", - "workspaceID", - "directory", - "parentID", - "summary", - "title", - "version", - "permission", - "revert" - ] + } } }, "required": ["sessionID", "info"] |
