Skip to content

Commit f75bff5

Browse files
committed
style(session): inline session id event fields
1 parent 49a31d7 commit f75bff5

1 file changed

Lines changed: 18 additions & 22 deletions

File tree

packages/opencode/src/v2/session-event.ts

Lines changed: 18 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -16,15 +16,11 @@ export const Source = Schema.Struct({
1616
})
1717
export type Source = Schema.Schema.Type<typeof Source>
1818

19-
const Base = {
20-
sessionID: SessionID,
21-
}
22-
2319
export const Prompted = BaseEvent.define({
2420
type: "session.prompted",
2521
aggregate: "sessionID",
2622
schema: {
27-
...Base,
23+
sessionID: SessionID,
2824
prompt: Prompt,
2925
},
3026
})
@@ -34,7 +30,7 @@ export const Synthetic = BaseEvent.define({
3430
type: "session.synthetic",
3531
aggregate: "sessionID",
3632
schema: {
37-
...Base,
33+
sessionID: SessionID,
3834
text: Schema.String,
3935
},
4036
})
@@ -45,7 +41,7 @@ export namespace Step {
4541
type: "session.step.started",
4642
aggregate: "sessionID",
4743
schema: {
48-
...Base,
44+
sessionID: SessionID,
4945
model: Schema.Struct({
5046
id: Schema.String,
5147
providerID: Schema.String,
@@ -59,7 +55,7 @@ export namespace Step {
5955
type: "session.step.ended",
6056
aggregate: "sessionID",
6157
schema: {
62-
...Base,
58+
sessionID: SessionID,
6359
reason: Schema.String,
6460
cost: Schema.Number,
6561
tokens: Schema.Struct({
@@ -81,7 +77,7 @@ export namespace Text {
8177
type: "session.text.started",
8278
aggregate: "sessionID",
8379
schema: {
84-
...Base,
80+
sessionID: SessionID,
8581
},
8682
})
8783
export type Started = Schema.Schema.Type<typeof Started>
@@ -90,7 +86,7 @@ export namespace Text {
9086
type: "session.text.delta",
9187
aggregate: "sessionID",
9288
schema: {
93-
...Base,
89+
sessionID: SessionID,
9490
delta: Schema.String,
9591
},
9692
})
@@ -100,7 +96,7 @@ export namespace Text {
10096
type: "session.text.ended",
10197
aggregate: "sessionID",
10298
schema: {
103-
...Base,
99+
sessionID: SessionID,
104100
text: Schema.String,
105101
},
106102
})
@@ -112,7 +108,7 @@ export namespace Reasoning {
112108
type: "session.reasoning.started",
113109
aggregate: "sessionID",
114110
schema: {
115-
...Base,
111+
sessionID: SessionID,
116112
},
117113
})
118114
export type Started = Schema.Schema.Type<typeof Started>
@@ -121,7 +117,7 @@ export namespace Reasoning {
121117
type: "session.reasoning.delta",
122118
aggregate: "sessionID",
123119
schema: {
124-
...Base,
120+
sessionID: SessionID,
125121
delta: Schema.String,
126122
},
127123
})
@@ -131,7 +127,7 @@ export namespace Reasoning {
131127
type: "session.reasoning.ended",
132128
aggregate: "sessionID",
133129
schema: {
134-
...Base,
130+
sessionID: SessionID,
135131
text: Schema.String,
136132
},
137133
})
@@ -144,7 +140,7 @@ export namespace Tool {
144140
type: "session.tool.input.started",
145141
aggregate: "sessionID",
146142
schema: {
147-
...Base,
143+
sessionID: SessionID,
148144
callID: Schema.String,
149145
name: Schema.String,
150146
},
@@ -155,7 +151,7 @@ export namespace Tool {
155151
type: "session.tool.input.delta",
156152
aggregate: "sessionID",
157153
schema: {
158-
...Base,
154+
sessionID: SessionID,
159155
callID: Schema.String,
160156
delta: Schema.String,
161157
},
@@ -166,7 +162,7 @@ export namespace Tool {
166162
type: "session.tool.input.ended",
167163
aggregate: "sessionID",
168164
schema: {
169-
...Base,
165+
sessionID: SessionID,
170166
callID: Schema.String,
171167
text: Schema.String,
172168
},
@@ -178,7 +174,7 @@ export namespace Tool {
178174
type: "session.tool.called",
179175
aggregate: "sessionID",
180176
schema: {
181-
...Base,
177+
sessionID: SessionID,
182178
callID: Schema.String,
183179
tool: Schema.String,
184180
input: Schema.Record(Schema.String, Schema.Unknown),
@@ -194,7 +190,7 @@ export namespace Tool {
194190
type: "session.tool.success",
195191
aggregate: "sessionID",
196192
schema: {
197-
...Base,
193+
sessionID: SessionID,
198194
callID: Schema.String,
199195
title: Schema.String,
200196
output: Schema.String.pipe(Schema.optional),
@@ -211,7 +207,7 @@ export namespace Tool {
211207
type: "session.tool.error",
212208
aggregate: "sessionID",
213209
schema: {
214-
...Base,
210+
sessionID: SessionID,
215211
callID: Schema.String,
216212
error: Schema.String,
217213
provider: Schema.Struct({
@@ -239,7 +235,7 @@ export const Retried = BaseEvent.define({
239235
type: "session.retried",
240236
aggregate: "sessionID",
241237
schema: {
242-
...Base,
238+
sessionID: SessionID,
243239
attempt: Schema.Number,
244240
error: RetryError,
245241
},
@@ -250,7 +246,7 @@ export const Compacted = BaseEvent.define({
250246
type: "session.compacted",
251247
aggregate: "sessionID",
252248
schema: {
253-
...Base,
249+
sessionID: SessionID,
254250
auto: Schema.Boolean,
255251
overflow: Schema.Boolean.pipe(Schema.optional),
256252
},

0 commit comments

Comments
 (0)