diff --git a/src/reinject.ts b/src/reinject.ts index fdec78a..174ae66 100644 --- a/src/reinject.ts +++ b/src/reinject.ts @@ -113,6 +113,19 @@ export function sendImmediateReinjectIdle( }); } +/** Immediate path when streaming or overflow willRetry: all blocks as followUp (SPEC §5.2, §6.5.2). */ +export function sendImmediateReinjectAllFollowUp( + pi: ExtensionAPI, + skillNames: readonly string[], + state: ExtensionState, + settings: SkillReinjectSettings, + registeredSkills: readonly Pick[], +): void { + for (const block of buildReinjectBlocks(skillNames, state, settings, registeredSkills)) { + pi.sendUserMessage(block, { deliverAs: "followUp" }); + } +} + /** * Defer path on before_agent_start: inject one combined message, then clear queue (SPEC §6.5.1). * Returns undefined when pendingReinject is empty.