Something went wrong. Try again.
Pi extension for async subagent delegation with truncation, artifacts, and session sharing
Something went wrong. Try again.
2.6 kB · 55 lines
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556import type { ActivityState, AsyncJobStep } from "./types.ts";
type StepStatusLike = Pick<AsyncJobStep, "status">;
function formatActivityAge(ms: number): string { if (ms < 1000) return "now"; if (ms < 60000) return `${Math.floor(ms / 1000)}s`; return `${Math.floor(ms / 60000)}m`;}
export function formatActivityLabel(lastActivityAt: number | undefined, activityState?: ActivityState, now = Date.now()): string | undefined { if (lastActivityAt === undefined) { if (activityState === "needs_attention") return "needs attention"; if (activityState === "active_long_running") return "active but long-running"; return undefined; } const age = formatActivityAge(Math.max(0, now - lastActivityAt)); if (activityState === "needs_attention") return `no activity for ${age}`; if (activityState === "active_long_running") { const activityAge = age === "now" ? "now" : `${age} ago`; return `active but long-running · last activity ${activityAge}`; } return age === "now" ? "active now" : `active ${age} ago`;}
function isCompletedStepStatus(status: AsyncJobStep["status"]): boolean { return status === "complete" || status === "completed";}
export function aggregateStepStatus(steps: StepStatusLike[]): AsyncJobStep["status"] { if (steps.some((step) => step.status === "running")) return "running"; if (steps.some((step) => step.status === "failed")) return "failed"; if (steps.some((step) => step.status === "stopped")) return "stopped"; if (steps.some((step) => step.status === "paused")) return "paused"; if (steps.length > 0 && steps.every((step) => isCompletedStepStatus(step.status))) return "complete"; return "pending";}
export function formatAgentRunningLabel(count: number): string { return count === 1 ? "1 agent running" : `${count} agents running`;}
export function formatParallelOutcome(steps: StepStatusLike[], total: number, options: { showRunning?: boolean } = {}): string { const running = steps.filter((step) => step.status === "running").length; const done = steps.filter((step) => isCompletedStepStatus(step.status)).length; const failed = steps.filter((step) => step.status === "failed").length; const stopped = steps.filter((step) => step.status === "stopped").length; const paused = steps.filter((step) => step.status === "paused").length; const parts = [`${done}/${total} done`]; if (options.showRunning !== false && running > 0) parts.unshift(formatAgentRunningLabel(running)); if (failed > 0) parts.push(`${failed} failed`); if (stopped > 0) parts.push(`${stopped} stopped`); if (paused > 0) parts.push(`${paused} paused`); return parts.join(" · ");}