d2542c9a62
Squash the current repository state back into one baseline commit while preserving the README reframing and repository contents. Constraint: User explicitly requested a single squashed commit with subject "asdf" Confidence: high Scope-risk: broad Reversibility: clean Directive: This commit intentionally rewrites published history; coordinate before future force-pushes Tested: git status clean; local history rewritten to one commit; force-pushed main to origin and instructkr Not-tested: Fresh clone verification after push
56 lines
1.3 KiB
TypeScript
56 lines
1.3 KiB
TypeScript
import type { AttachmentMessage, RenderableMessage } from '../types/message.js'
|
|
|
|
function isTeammateShutdownAttachment(
|
|
msg: RenderableMessage,
|
|
): msg is AttachmentMessage {
|
|
return (
|
|
msg.type === 'attachment' &&
|
|
msg.attachment.type === 'task_status' &&
|
|
msg.attachment.taskType === 'in_process_teammate' &&
|
|
msg.attachment.status === 'completed'
|
|
)
|
|
}
|
|
|
|
/**
|
|
* Collapses consecutive in-process teammate shutdown task_status attachments
|
|
* into a single `teammate_shutdown_batch` attachment with a count.
|
|
*/
|
|
export function collapseTeammateShutdowns(
|
|
messages: RenderableMessage[],
|
|
): RenderableMessage[] {
|
|
const result: RenderableMessage[] = []
|
|
let i = 0
|
|
|
|
while (i < messages.length) {
|
|
const msg = messages[i]!
|
|
if (isTeammateShutdownAttachment(msg)) {
|
|
let count = 0
|
|
while (
|
|
i < messages.length &&
|
|
isTeammateShutdownAttachment(messages[i]!)
|
|
) {
|
|
count++
|
|
i++
|
|
}
|
|
if (count === 1) {
|
|
result.push(msg)
|
|
} else {
|
|
result.push({
|
|
type: 'attachment',
|
|
uuid: msg.uuid,
|
|
timestamp: msg.timestamp,
|
|
attachment: {
|
|
type: 'teammate_shutdown_batch',
|
|
count,
|
|
},
|
|
})
|
|
}
|
|
} else {
|
|
result.push(msg)
|
|
i++
|
|
}
|
|
}
|
|
|
|
return result
|
|
}
|