summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authoropencode-agent[bot] <opencode-agent[bot]@users.noreply.github.com>2026-04-23 16:44:32 +0000
committeropencode-agent[bot] <opencode-agent[bot]@users.noreply.github.com>2026-04-23 16:44:32 +0000
commitaed03078f88af5c28035a28b6edbbf10228a49ed (patch)
tree293e41fa7d5d4f6a71639ece4fa081c63bd072b2
parentc50d65b4d6b956cad44663d9d31b7b5eb01c8e57 (diff)
downloadopencode-aed03078f88af5c28035a28b6edbbf10228a49ed.tar.gz
opencode-aed03078f88af5c28035a28b6edbbf10228a49ed.zip
chore: generate
-rw-r--r--packages/opencode/src/bus/index.ts20
-rw-r--r--packages/opencode/src/sync/index.ts16
-rw-r--r--packages/sdk/openapi.json21
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"]