mirrors/opencode
1
0
Fork 0
mirror of https://github.com/sst/opencode.git synced 2025-12-23 10:11:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

send msg/part removed events

Browse source
This commit is contained in:
Dax Raad 2025-07-22 19:29:22 -04:00
parent 9b0935d14c
commit 687dc5acd4
2 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
packages/opencode/src/session/index.ts
View file

@ -534,6 +534,7 @@ export namespace Session {
msgs = preserve
for (const msg of remove) {
await Storage.remove(`session/message/${input.sessionID}/${msg.info.id}`)
await Bus.publish(MessageV2.Event.Removed, { sessionID: input.sessionID, messageID: msg.info.id })
}
const last = preserve.at(-1)
if (session.revert.partID && last) {
@ -542,6 +543,10 @@ export namespace Session {
last.parts = preserveParts
for (const part of removeParts) {
await Storage.remove(`session/part/${input.sessionID}/${last.info.id}/${part.id}`)
await Bus.publish(MessageV2.Event.PartRemoved, {
messageID: last.info.id,
partID: part.id,
})
}
}
}

7
packages/opencode/src/session/message-v2.ts
View file

@ -271,6 +271,13 @@ export namespace MessageV2 {
part: Part,
}),
),
PartRemoved: Bus.event(
"message.part.removed",
z.object({
messageID: z.string(),
partID: z.string(),
}),
),
}
export function fromV1(v1: Message.Info) {