mirror of
https://github.com/paperclipai/paperclip.git
synced 2026-11-08 12:33:05 +01:00
## Thinking Path > - Paperclip is the open source app people use to manage AI agents for work. > - The task chat shows what an agent does in a run. The Paperclip Runner sends this activity as canonical provider events. > - Claude runs subagents through its Agent (Task) tool. A run that delegates showed a confusing burst of unrelated tool calls. > - The subagent data was already sent, but it was lost: ACPX dropped `_meta`, the hardened sidecar dropped `rawInput`, and async subagents report "launched" as the tool result. > - This pull request maps each Agent call to a canonical `delegation` event, links each child tool to its subagent, and shows subagents as a collapsible card or tree. > - The benefit is that operators can see what each subagent was asked, what it is doing now, which tools it used, and what it returned. ## Linked Issues or Issue Description Refs #19252 (the docked plan card used the same canonical-event pattern) Refs #19259 (ACPX `_meta` passthrough, merged). This PR builds on it. **What happened?** When a Claude agent used its Agent tool, the task chat showed one generic "Task" row and then the subagents' tool calls as flat rows in the parent turn. The subagent type, prompt, progress and result were not visible. **Expected behavior** Each subagent shows as its own card with its type, description, prompt, live progress summary, nested tool rows and result. Subagents that start together show as one tree with status dots. **Steps to reproduce** 1. Assign a Claude (Paperclip Runner, ACPX) agent a task that asks it to launch three Explore subagents in parallel. 2. Open the task while the run is live. 3. Before this change, the subagents' tool calls appear flat in the parent turn. ## What Changed - **claude-agent-acp patch:** Under the isolated runner context, the patch turns on the SDK option `agentProgressSummaries`. It forwards each subagent's `task_progress` summary and its terminal state and summary onto the spawning tool call as `_meta.claudeCode.subagentProgress` and `subagentState`. Native subagent sessions stay off, because ACPX cannot follow child ACP sessions. - **Runner:** The new file `claude-subagent-lineage.ts` tracks each Agent/Task call across ACP update deltas. It maps the call to `delegation.started|updated|completed` events and stamps child tools with `parentItemId`. An async subagent stays running after its "Async agent launched" result until its own state settles. - **Sidecar path:** `acpx-runtime-sidecar.ts` reads the lineage before it drops `_meta` and `rawInput`. Delegations go out as schema-checked rich events. Child tools carry `parentToolCallId`, which Rust (`acpx_event_payload.rs`, `provider_events.rs`) maps to `parentItemId`. - **Contracts:** The provider-event schema adds optional `prompt` and `result` to delegation children and optional `parentItemId` to tool executions. The protocol modules are regenerated. ACPX Claude now advertises the `delegation` event family. - **UI:** `native-run-events.ts` keeps delegation payloads and the tool parent link. `buildTurnTimelineRows` groups adjacent delegations into a new `subagent_group` row, nests child tool rows (plain and provider-activity shapes), and hides the spawning call's own tool row. The new `TaskChatSubagentCard.tsx` renders the card and tree. A new size token caps the result height. - **Storybook:** The new story `Tasks and conversations/…/Task chat/Subagents` has 7 states. ## Verification - `pnpm --filter @paperclipai/paperclip-runner exec vitest run src/cli src/drivers/acpx src/provider-events.test.ts src/claude-subagent-lineage.test.ts src/protocol` (2069 passed) - `cargo test --release --locked -p paperclip-runner-core --lib` in `packages/paperclip-runner/runner` (488 passed, including the new parent-link test) - `node --test test/protocol-contract.test.mjs test/acpx-sidecar-contract.test.mjs test/acpx-codex-package-contract.test.mjs test/acpx-rich-extensions-package-contract.test.mjs` (48 passed) - `pnpm --filter @paperclipai/ui exec vitest run src/components/task-chat src/components/transcript`, including the new `subagent-timeline.test.ts` - `check:protocol-types`, `check:protocol-manifest`, `check:acpx-profiles` and `pnpm check:token-gates` pass. - **Live test:** A local test-drive instance ran a Claude Opus 5.5 agent on the Paperclip Runner (hardened sidecar path). The agent ran real tasks that launched three parallel Explore subagents. The live view showed "Running 3 subagents · 2 done" with a progress summary. The settled view showed "Ran 3 subagents", each with its prompt, nested tools and its own result text. ## Risks - `agentProgressSummaries` makes Claude Code generate a short progress summary for each running subagent about every 30 seconds. This adds a small model cost to runs that delegate. - The adapter patch reads `task_notification` and terminal `task_updated` messages. A future claude-agent-acp version can change these. The patch hunks then fail to apply, and the dependency bump must update them. - If a delegation event is lost, child tools stay at the top level as before. Nothing is hidden without a matching delegation. - Codex is not changed. Codex subagents need `multi_agent`, which Paperclip keeps off on purpose. Changing that is a separate policy decision. ## Model Used - Claude Opus 5.5 (`claude-opus-5-5`) in Claude Code, with tool use (shell, file edits, browser automation). It did the investigation, implementation, tests and live test. ## Checklist - [x] I have included a thinking path that traces from project context to this change - [x] I have specified the model used (with version and capability details) - [x] I have checked ROADMAP.md and confirmed this PR does not duplicate planned core work - [x] I have searched GitHub for duplicate or related PRs and linked them above - [x] I have either (a) linked existing issues with `Fixes: #` / `Closes #` / `Refs #` OR (b) described the issue in-PR following the relevant issue template - [x] I have not referenced internal/instance-local Paperclip issues or links (only public GitHub `#NNN` / `github.com/paperclipai/paperclip` URLs) - [x] My branch name describes the change (e.g. `docs/...`, `fix/...`) and contains no internal Paperclip ticket id or instance-derived details - [x] I have run tests locally and they pass - [x] I have added or updated tests where applicable - [x] I have updated relevant documentation to reflect my changes - [x] I have considered and documented any risks above - [ ] All Paperclip CI gates are green - [ ] Greptile is 5/5 with no open P2s, recommendations, or follow-ups - [x] I will address all Greptile and reviewer comments before requesting merge 🤖 Generated with [Claude Code](https://claude.com/claude-code) --------- Co-authored-by: Claude Opus 5.5 <noreply@anthropic.com>
755 lines
24 KiB
TypeScript
755 lines
24 KiB
TypeScript
/**
|
||
* Normalized presentation model for the chat-style task thread (the default
|
||
* task view; the classic legacy view sits behind enableClassicTaskInterface).
|
||
*
|
||
* This is a deliberately small, protocol-agnostic model that the new render
|
||
* layer consumes. Two producers feed it:
|
||
* 1. The dev harness, via synthetic fixtures (task-chat-fixtures.ts).
|
||
* 2. The live thread, via an adapter over the existing comment/run props.
|
||
*
|
||
* Every field traces to a real agent-protocol concept (ACP SessionUpdate /
|
||
* acpx AcpRuntimeEvent / TranscriptEntry). See DESIGN.md and the plan's state
|
||
* inventory for the mapping. No timing/motion values live here — those are
|
||
* CSS motion tokens in ui/src/index.css.
|
||
*/
|
||
import type { TaskChatMcpStartupFailure } from "./TaskChatRunHealthBanner";
|
||
import type {
|
||
Issue,
|
||
TaskBrowser,
|
||
IssueAttachment,
|
||
IssueCommentMetadata,
|
||
IssueCommentPresentation,
|
||
IssueDocument,
|
||
IssueDocumentSummary,
|
||
IssueWorkProduct,
|
||
DecisionHistoryItem,
|
||
ConversationTaskHandoff,
|
||
AttentionItem,
|
||
} from "@paperclipai/shared";
|
||
import type {
|
||
PaperclipQuestionResponse,
|
||
PaperclipQuestionSet,
|
||
} from "@paperclipai/adapter-utils";
|
||
|
||
export type { PaperclipQuestionResponse, PaperclipQuestionSet };
|
||
|
||
export type TaskChatProviderActivityFamily =
|
||
| "plan"
|
||
| "tool_execution"
|
||
| "research"
|
||
| "delegation"
|
||
| "model_identity"
|
||
| "context"
|
||
| "artifact"
|
||
| "review"
|
||
| "hook"
|
||
| "memory"
|
||
| "safety"
|
||
| "terminal"
|
||
| "wait"
|
||
| "verification"
|
||
| "provider_notice";
|
||
|
||
export type TaskChatProviderActivityStatus =
|
||
"running" | "completed" | "failed" | "interrupted" | "informational";
|
||
|
||
export interface TaskChatWorkspaceChangeFile {
|
||
path: string;
|
||
operation: "create" | "modify" | "delete" | "rename" | "mode_change";
|
||
previousPath: string | null;
|
||
additions: number | null;
|
||
deletions: number | null;
|
||
binary: boolean;
|
||
diff: string | null;
|
||
/** The patch was shortened by its producer; counts still cover all of it. */
|
||
diffTruncated?: boolean;
|
||
}
|
||
import type { IssueThreadInteraction } from "@/lib/issue-thread-interactions";
|
||
|
||
/** Who authored a thread row — the primary legibility signal. */
|
||
export type TaskChatAuthorKind = "human" | "agent" | "system";
|
||
|
||
/** ACP ToolCallStatus. */
|
||
export type TaskChatToolStatus =
|
||
"pending" | "in_progress" | "completed" | "failed" | "interrupted";
|
||
|
||
/** ACP PermissionOptionKind. */
|
||
export type TaskChatApprovalOptionKind =
|
||
"allow_once" | "allow_always" | "reject_once" | "reject_always";
|
||
|
||
/** ACP PlanEntryStatus. */
|
||
export type TaskChatPlanEntryStatus = "pending" | "in_progress" | "completed";
|
||
|
||
/** ACP PlanEntryPriority. */
|
||
export type TaskChatPlanEntryPriority = "high" | "medium" | "low";
|
||
|
||
export interface TaskChatApprovalOption {
|
||
id: string;
|
||
label: string;
|
||
kind: TaskChatApprovalOptionKind;
|
||
}
|
||
|
||
export interface TaskChatDiff {
|
||
path?: string;
|
||
added: number;
|
||
removed: number;
|
||
/** Optional unified-diff-ish lines for display only. */
|
||
lines?: TaskChatDiffLine[];
|
||
/** True when the producer bounded the patch and lines were omitted. */
|
||
truncated?: boolean;
|
||
/**
|
||
* Per-file counts reported by the producer for the whole patch. When present
|
||
* they are authoritative; `added`/`removed` are their sums, not line counts.
|
||
*/
|
||
files?: Array<{ path: string; additions: number; deletions: number; truncated: boolean }>;
|
||
}
|
||
|
||
export interface TaskChatDiffLine {
|
||
/** `file` starts the next file when one edit call changed several files. */
|
||
kind: "add" | "remove" | "context" | "hunk" | "file";
|
||
text: string;
|
||
}
|
||
|
||
export interface TaskChatTokenUsage {
|
||
/** ACP UsageUpdate.used — tokens in context. */
|
||
used: number;
|
||
/** ACP UsageUpdate.size — context window size. */
|
||
size: number;
|
||
inputTokens?: number;
|
||
outputTokens?: number;
|
||
costUsd?: number;
|
||
}
|
||
|
||
/** A human/agent/system message bubble. */
|
||
export interface TaskChatMessageItem {
|
||
origin?: "comment" | "fast_response";
|
||
/** Stable UI identity through optimistic acknowledgement; id remains canonical. */
|
||
renderKey?: string;
|
||
id: string;
|
||
kind: "message";
|
||
author: TaskChatAuthorKind;
|
||
authorName?: string;
|
||
/** Human identity comes from the company directory, matched by stored user ID. */
|
||
authorUserId?: string | null;
|
||
authorAvatarUrl?: string | null;
|
||
isCurrentUser?: boolean;
|
||
text: string;
|
||
/** Runner-authored output channel. Legacy adapters leave this unset. */
|
||
channel?: "progress" | "final" | "unknown";
|
||
/** Transport attribution for an inbound human comment. */
|
||
sourceChannel?: IssueCommentMetadata["sourceChannel"];
|
||
timestamp?: string;
|
||
/** Show a streaming cursor and suppress collapse while true. */
|
||
streaming?: boolean;
|
||
/** Optimistic local echo state (matches IssueChatComment.clientStatus). */
|
||
optimistic?: "pending" | "queued";
|
||
/** Live run this queued message is waiting behind. */
|
||
queueTargetRunId?: string | null;
|
||
/** Non-blocking verification limitations attached to the run's durable reply. */
|
||
verificationCaveats?: Array<{
|
||
commandOrCheck: string;
|
||
reasonCode?: string | null;
|
||
detail?: string | null;
|
||
}>;
|
||
/** Assigned agent icon name (AgentIconName) for the avatar header. */
|
||
agentIcon?: string | null;
|
||
agent?: import("../AgentAvatar").AvatarAgent;
|
||
/**
|
||
* Responsible user's display name, set only when this agent comment is a
|
||
* cross-issue write (the author is not the assignee). Renders as a
|
||
* "for {user}" chip beside the author name (the open cross-task write design (attribution)).
|
||
*/
|
||
onBehalfOfUserName?: string;
|
||
/** A transient provider progress update, distinct from the durable final response. */
|
||
interstitial?: boolean;
|
||
/** Epoch ms of the message's first streamed chunk. */
|
||
atMs?: number;
|
||
/** Index of the latest transcript event folded into this logical block. */
|
||
transcriptIndex?: number;
|
||
/**
|
||
* The settled run turn "attached" to this bubble (round 9): when the run's
|
||
* final reply lands, the live parent row transforms into the "Worked · …"
|
||
* summary rendered on this bubble's always-visible timestamp line —
|
||
* "2:34 PM · ✓ Worked · 38s · 3 tools" — instead of a standalone row.
|
||
* Expanding still nests the tool history beneath the bubble.
|
||
*/
|
||
attachedTurn?: TaskChatTurnItem;
|
||
/**
|
||
* Structured system-notice fields (PAP-443), carried only for
|
||
* author === "system": either system attribution or an explicit
|
||
* system_notice presentation routes the comment here. The comment's
|
||
* server-authored presentation hints and metadata sections drive the
|
||
* collapsed one-line row + expandable detail.
|
||
*/
|
||
presentation?: IssueCommentPresentation | null;
|
||
metadata?: IssueCommentMetadata | null;
|
||
chatMessage?: IssueCommentMetadata["chatMessage"];
|
||
/** Agent that owns the source run, used to build run-detail links in metadata rows. */
|
||
runAgentId?: string | null;
|
||
/** Raw comment timestamp (ISO) — the collapsed system row shows relative time. */
|
||
createdAtIso?: string;
|
||
}
|
||
|
||
/** Collapsed chain-of-thought (ACP agent_thought_chunk). */
|
||
export interface TaskChatThinkingItem {
|
||
id: string;
|
||
kind: "thinking";
|
||
lines: string[];
|
||
streaming?: boolean;
|
||
/** When true, render collapsed ("Worked for N") with an expand affordance. */
|
||
collapsed?: boolean;
|
||
/** Human-readable elapsed label for the collapsed header. */
|
||
summaryLabel?: string;
|
||
/** Provider-emitted reasoning surface; never synthesized by the UI. */
|
||
channel?: "summary" | "detail" | "unknown";
|
||
/** A real provider reasoning lifecycle with no provider-authored text. */
|
||
lifecycleOnly?: boolean;
|
||
/** Index of the latest transcript event folded into this logical block. */
|
||
transcriptIndex?: number;
|
||
}
|
||
|
||
/** A tool invocation row (ACP tool_call / tool_call_update). */
|
||
export interface TaskChatToolItem {
|
||
id: string;
|
||
kind: "tool";
|
||
name: string;
|
||
/** Raw ACP tool name pre-collapse ("mcp__server__tool") for taxonomy lookup. */
|
||
rawName?: string;
|
||
/** ACP ToolKind. */
|
||
toolKind?: string;
|
||
status: TaskChatToolStatus;
|
||
/**
|
||
* Summarized primary argument (file path, command, pattern…) rendered mono
|
||
* next to the tool name — the v7 toolrow "target".
|
||
*/
|
||
target?: string;
|
||
detail?: string;
|
||
diff?: TaskChatDiff;
|
||
/** Resolved permission decision badge, when one applied. */
|
||
decision?: "allowed" | "rejected";
|
||
/** Execution id of the delegation (subagent) that made this call. */
|
||
parentToolUseId?: string;
|
||
}
|
||
|
||
/**
|
||
* A lifecycle state rendered as a status affordance — never a bubble.
|
||
* Covers both LIVE (running/working) and Tier-B (awaiting_approval,
|
||
* interrupted, refused, truncated) states.
|
||
*/
|
||
export interface TaskChatStatusItem {
|
||
id: string;
|
||
kind: "status";
|
||
status:
|
||
| "running"
|
||
| "working"
|
||
| "awaiting_approval"
|
||
| "interrupted"
|
||
| "refused"
|
||
| "truncated";
|
||
label: string;
|
||
detail?: string;
|
||
/** Raw tool name of the in-flight tail tool_call (drives the pill's icon). */
|
||
toolName?: string;
|
||
/**
|
||
* Flattened plain text of the interstitial update currently streaming
|
||
* (PAP-361, round 9): it renders in a dedicated single-line row directly
|
||
* above the status line — a slot PERMANENTLY RESERVED while the turn is
|
||
* live, so the layout above never jumps — inside a one-line viewport
|
||
* showing the streaming tail line; the gerund rotation below runs
|
||
* uninterrupted. When the message finishes the pill HOLDS the text as a
|
||
* static ellipsized line until the next update supersedes it or the turn
|
||
* ends (PAP-368) — nothing persists in the settled thread.
|
||
*/
|
||
selfTalk?: string;
|
||
elapsedMs?: number;
|
||
/** Run start epoch ms; live states tick their own elapsed from this. */
|
||
startedAtMs?: number;
|
||
tokens?: TaskChatTokenUsage;
|
||
/** Present for awaiting_approval (ACP RequestPermissionRequest). */
|
||
approval?: { toolName: string; options: TaskChatApprovalOption[] };
|
||
}
|
||
|
||
/** A lifecycle divider (session start, interruption, turn boundary). */
|
||
export interface TaskChatMarkerItem {
|
||
id: string;
|
||
kind: "marker";
|
||
variant: "session_start" | "interrupted" | "turn_boundary";
|
||
label: string;
|
||
detail?: string;
|
||
/** False when the recorded run cannot be retried, even after the chat continues. */
|
||
retryable?: boolean;
|
||
/** Renders the marker as a quiet disclosure row with detail beneath it. */
|
||
collapsible?: boolean;
|
||
/** Expected cancellation is neutral; unexpected failures remain destructive. */
|
||
tone?: "neutral" | "error";
|
||
runId?: string;
|
||
createdAtIso?: string;
|
||
runHref?: string;
|
||
planHref?: string;
|
||
/** An actionable credential denial is always expanded in the task conversation. */
|
||
credentialAccess?: {
|
||
agentName: string;
|
||
credentialName?: string;
|
||
deniedUser: string;
|
||
settingsHref: string;
|
||
};
|
||
}
|
||
|
||
/** A second-tier live token/cost readout (ACP UsageUpdate). */
|
||
export interface TaskChatUsageItem {
|
||
id: string;
|
||
kind: "usage";
|
||
usage: TaskChatTokenUsage;
|
||
/** Present when the measurement is not scoped to the current run. */
|
||
label?: string;
|
||
detail?: string;
|
||
}
|
||
|
||
export interface TaskChatActivityPhaseItem {
|
||
id: string;
|
||
kind: "activity_phase";
|
||
/** Historical assistant update that introduced this phase. */
|
||
interstitial?: TaskChatMessageItem;
|
||
/** Chronological tool/usage rows owned exclusively by this phase. */
|
||
items: Array<
|
||
| TaskChatToolItem
|
||
| TaskChatUsageItem
|
||
| TaskChatThinkingItem
|
||
| TaskChatMarkerItem
|
||
| TaskChatProtocolItem
|
||
>;
|
||
/** Deterministic, taxonomy-based summary (for example "Read 3 files, ran 1 command"). */
|
||
summary: string;
|
||
/** The tail phase of an in-flight run stays foregrounded. */
|
||
active: boolean;
|
||
}
|
||
|
||
/**
|
||
* The task description rendered as the requester's first chat bubble
|
||
* (PAP-375). A placeholder kind only — the host supplies the render
|
||
* (TaskChatThread binds TaskChatDescriptionBubble to the live issue), mirroring
|
||
* how interaction items defer to renderInteraction. Always prepended AFTER
|
||
* thread assembly, so no backbone entry or settled turn can sort above it.
|
||
*/
|
||
export interface TaskChatBriefItem {
|
||
id: string;
|
||
kind: "brief";
|
||
}
|
||
|
||
/**
|
||
* An issue-thread interaction (plan confirmation, question card, suggested
|
||
* tasks…) interleaved chronologically into the thread. The payload is the
|
||
* existing control-plane IssueThreadInteraction — the render layer wraps the
|
||
* shared IssueThreadInteractionCard rather than re-modeling the five kinds.
|
||
*/
|
||
export interface TaskChatInteractionItem {
|
||
id: string;
|
||
kind: "interaction";
|
||
interaction: IssueThreadInteraction;
|
||
}
|
||
|
||
/** A canonical, atomically saved Plan document interleaved into the thread. */
|
||
export interface TaskChatPlanDocumentItem {
|
||
id: string;
|
||
kind: "plan_document";
|
||
document: IssueDocument;
|
||
/** Distinguishes a proven semantic write boundary from lossless fallback. */
|
||
placement?: "write_boundary" | "fallback";
|
||
}
|
||
|
||
export interface TaskChatProtocolDetail {
|
||
label: string;
|
||
value: string;
|
||
mono?: boolean;
|
||
}
|
||
|
||
export interface TaskChatProtocolStep {
|
||
id: string;
|
||
label: string;
|
||
status: "pending" | "in_progress" | "completed" | "blocked" | "failed";
|
||
}
|
||
|
||
export interface TaskChatProtocolLink {
|
||
label: string;
|
||
href: string;
|
||
description?: string;
|
||
}
|
||
|
||
export interface TaskChatProtocolChild {
|
||
id: string;
|
||
title: string;
|
||
status: string;
|
||
metadata?: string;
|
||
summary?: string;
|
||
/** Subagent type the provider dispatched (`Explore`, `general-purpose`). */
|
||
role?: string;
|
||
model?: string;
|
||
/** Latest provider progress summary while the child runs. */
|
||
progress?: string;
|
||
prompt?: string;
|
||
result?: string;
|
||
}
|
||
|
||
export interface TaskChatProviderActivityItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "provider_activity";
|
||
family: TaskChatProviderActivityFamily;
|
||
eventType: string;
|
||
status: TaskChatProviderActivityStatus;
|
||
title: string;
|
||
summary?: string;
|
||
details: TaskChatProtocolDetail[];
|
||
steps: TaskChatProtocolStep[];
|
||
links: TaskChatProtocolLink[];
|
||
children: TaskChatProtocolChild[];
|
||
output?: string;
|
||
outputTruncated?: boolean;
|
||
/** Index of the latest provider event coalesced into this activity. */
|
||
transcriptIndex?: number;
|
||
/** Provider activity identity, e.g. the delegation id for a subagent. */
|
||
activityId?: string;
|
||
/** Delegation (subagent) execution that made this tool call. */
|
||
parentToolUseId?: string;
|
||
/** First and latest provider event times coalesced into this activity. */
|
||
startedAtMs?: number;
|
||
updatedAtMs?: number;
|
||
/** A retry status notice the turn has moved past. */
|
||
resolved?: boolean;
|
||
/** When the provider first reported this activity (ISO timestamp). */
|
||
startedAt?: string;
|
||
}
|
||
|
||
export type TaskChatSubagentStatus = "running" | "completed" | "failed" | "cancelled";
|
||
|
||
/**
|
||
* A delegated subagent (Claude Agent/Task call, Codex or Cursor child) with
|
||
* the tool rows it made, nested under the parent turn.
|
||
*/
|
||
export interface TaskChatSubagent {
|
||
id: string;
|
||
/** Subagent type the provider dispatched, e.g. `Explore` or `general-purpose`. */
|
||
agentType: string;
|
||
/** Short task description the parent wrote for the child. */
|
||
description: string;
|
||
prompt?: string;
|
||
model?: string;
|
||
status: TaskChatSubagentStatus;
|
||
/** Latest provider progress summary (Claude `agentProgressSummaries`). */
|
||
progressSummary?: string;
|
||
startedAtMs?: number | null;
|
||
finishedAtMs?: number | null;
|
||
/** Child tool/thinking rows, in order. */
|
||
activity: TaskChatActivityPhaseItem["items"];
|
||
result?: string;
|
||
}
|
||
|
||
/** Subagents dispatched together; one renders as a card, several as a tree. */
|
||
export interface TaskChatSubagentGroupItem {
|
||
id: string;
|
||
kind: "subagent_group";
|
||
subagents: TaskChatSubagent[];
|
||
}
|
||
|
||
export interface TaskChatWorkspaceChangeItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "workspace_change";
|
||
changeSetId: string;
|
||
revision: number;
|
||
source: "harness_reported" | "runner_verified";
|
||
complete: boolean;
|
||
files: TaskChatWorkspaceChangeFile[];
|
||
totals: { files: number; additions: number | null; deletions: number | null };
|
||
patchArtifactRef: string | null;
|
||
}
|
||
|
||
export interface TaskChatWorkspaceFileItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "workspace_file";
|
||
referenceId: string;
|
||
source: "harness_reported" | "runner_verified";
|
||
path: string;
|
||
displayName: string;
|
||
mediaType: string | null;
|
||
presentation: "document" | "code" | "image" | "generic";
|
||
line: number | null;
|
||
preview: string | null;
|
||
previewTruncated: boolean;
|
||
}
|
||
|
||
export interface TaskChatRuntimeRequestItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "runtime_request";
|
||
runId: string;
|
||
requestId: string;
|
||
requestKind:
|
||
| "runtime"
|
||
| "command_approval"
|
||
| "file_approval"
|
||
| "permission_approval"
|
||
| "user_input"
|
||
| "elicitation"
|
||
| null;
|
||
turnId: string | null;
|
||
requestType: "permission" | "input";
|
||
status: "pending" | "resolved" | "expired" | "cancelled";
|
||
prompt: string;
|
||
choices: Array<{ key: string; label: string }>;
|
||
fields: Array<{ name: string; label: string; placeholder: string | null }>;
|
||
questionSet?: PaperclipQuestionSet | null;
|
||
resolvedAction?: string | null;
|
||
response?: PaperclipQuestionResponse | null;
|
||
}
|
||
|
||
export type TaskChatRuntimeRequestDecision =
|
||
| { action: "accept" | "accept_for_session" | "decline" | "cancel" }
|
||
| { action: "submit"; values: Record<string, string> }
|
||
| { action: "submit"; response: PaperclipQuestionResponse };
|
||
|
||
export interface TaskChatRunResultItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "run_result";
|
||
disposition: "done" | "blocked" | "needs_review" | "yielded";
|
||
summary: string;
|
||
objectiveSatisfied: boolean | null;
|
||
verification: Array<{
|
||
commandOrCheck: string;
|
||
status: "passed" | "failed" | "not_run";
|
||
detail?: string;
|
||
artifactRef?: string;
|
||
}>;
|
||
remainingWork: Array<{ description: string; blocksCompletion: boolean }>;
|
||
blocker: {
|
||
reasonCode: string;
|
||
unblockAction: string;
|
||
scope: "current_track" | "task_wide";
|
||
} | null;
|
||
artifacts: Array<{ kind: string; ref: string; title?: string }>;
|
||
/** Proven by accepted native result and same-run successful terminal events. */
|
||
acceptedResponseWake?: { runId: string; sourceEventId: string };
|
||
}
|
||
|
||
export interface TaskChatRunTerminalItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "run_terminal";
|
||
turnState: "completed" | "failed" | "interrupted" | "cancelled";
|
||
runState: "succeeded" | "failed" | "cancelled";
|
||
disposition: "done" | "blocked" | "needs_review" | "yielded";
|
||
stopReason?: string;
|
||
}
|
||
|
||
export interface TaskChatMaterializedResourceItem {
|
||
id: string;
|
||
kind: "protocol";
|
||
surface: "resource";
|
||
resourceKind: "document" | "deliverable" | "attachment";
|
||
title: string;
|
||
subtitle: string;
|
||
href: string | null;
|
||
timestamp?: string;
|
||
document?: IssueDocumentSummary;
|
||
workProduct?: IssueWorkProduct;
|
||
attachment?: IssueAttachment;
|
||
}
|
||
|
||
export type TaskChatProtocolItem =
|
||
| TaskChatProviderActivityItem
|
||
| TaskChatWorkspaceChangeItem
|
||
| TaskChatWorkspaceFileItem
|
||
| TaskChatRuntimeRequestItem
|
||
| TaskChatRunResultItem
|
||
| TaskChatRunTerminalItem
|
||
| TaskChatMaterializedResourceItem;
|
||
|
||
/** Items a turn can group — everything except another turn. */
|
||
export type TaskChatTurnChildItem =
|
||
| TaskChatSubagentGroupItem
|
||
| TaskChatMessageItem
|
||
| TaskChatThinkingItem
|
||
| TaskChatToolItem
|
||
| TaskChatStatusItem
|
||
| TaskChatMarkerItem
|
||
| TaskChatUsageItem
|
||
| TaskChatActivityPhaseItem
|
||
| TaskChatPlanDocumentItem
|
||
| TaskChatProtocolItem;
|
||
|
||
/**
|
||
* One agent turn's activity (thinking/tools/diffs) grouped so a finished turn
|
||
* can fold into a one-line expandable summary ("✓ Worked · 38s · 3 tools ·
|
||
* +34 −3"). A live turn carrying `liveStatus` renders as a single expandable
|
||
* parent row headed by that status line (gerund/tool-state + elapsed +
|
||
* tokens); expanding nests the chronological activity underneath, and on
|
||
* settle the header morphs in place into the summary. The live → settled
|
||
* fold animates (~ --motion-turn-fold), while turns that load already-settled
|
||
* collapse instantly.
|
||
*/
|
||
export interface TaskChatTurnItem {
|
||
id: string;
|
||
kind: "turn";
|
||
items: TaskChatTurnChildItem[];
|
||
settled: boolean;
|
||
/** Superseded execution status is omitted; activity remains inspectable. */
|
||
historical?: boolean;
|
||
/** Agent identity retained when a live runner turn becomes durable history. */
|
||
agentName?: string;
|
||
agentIcon?: string | null;
|
||
agent?: import("../AgentAvatar").AvatarAgent;
|
||
/**
|
||
* The in-flight run's status line, hoisted to be THE turn's single visible
|
||
* row while collapsed (PAP-354 parent-row model). Absent once settled.
|
||
*/
|
||
liveStatus?: TaskChatStatusItem;
|
||
/** Animate the fold when settling (false = collapse instantly, e.g. history). */
|
||
animateFold?: boolean;
|
||
/** New-runner turns keep Worked/Stopped fixed above their ordered timeline. */
|
||
standaloneHeader?: boolean;
|
||
/** This segment resumes the same native run after a steering input. */
|
||
continuedAfterSteering?: boolean;
|
||
/** Durable response shown after the ordered Paperclip Runner timeline. */
|
||
finalResponse?: TaskChatMessageItem;
|
||
/** MCP servers the harness could not start for this run (run-health banner). */
|
||
mcpStartupFailures?: TaskChatMcpStartupFailure[];
|
||
summary: {
|
||
/** e.g. "38s" — omitted when unknown. */
|
||
durationLabel?: string;
|
||
toolCount: number;
|
||
added: number;
|
||
removed: number;
|
||
/** e.g. "12.3k tokens" — omitted when unknown. */
|
||
tokensLabel?: string;
|
||
/** Failed/interrupted turns get a ✗ affordance instead of ✓. */
|
||
failed?: boolean;
|
||
};
|
||
}
|
||
|
||
export interface TaskChatTaskCreatedItem {
|
||
id: string;
|
||
kind: "task_created";
|
||
task: Pick<Issue, "id" | "identifier" | "title" | "status">;
|
||
isSubtask: boolean;
|
||
timestamp: string;
|
||
}
|
||
|
||
export interface TaskChatProjectCreatedItem {
|
||
id: string;
|
||
kind: "project_created";
|
||
projectId: string;
|
||
name: string;
|
||
description?: string | null;
|
||
repositories: { id: string; name: string; url: string }[];
|
||
timestamp: string;
|
||
}
|
||
|
||
export interface TaskChatSkillCreatedItem {
|
||
id: string;
|
||
kind: "skill_created";
|
||
skillId: string;
|
||
name: string;
|
||
description?: string | null;
|
||
slug?: string | null;
|
||
versionId?: string | null;
|
||
timestamp: string;
|
||
}
|
||
|
||
export interface TaskChatBrowserItem {
|
||
id: string;
|
||
kind: "browser";
|
||
browser: TaskBrowser;
|
||
label: string;
|
||
timestamp: string;
|
||
}
|
||
|
||
export type TaskChatItem =
|
||
| { id: string; kind: "pending_question"; question: AttentionItem }
|
||
| { id: string; kind: "decision_receipt"; receipt: DecisionHistoryItem }
|
||
| { id: string; kind: "task_handoff"; handoff: ConversationTaskHandoff; animateEntry?: boolean }
|
||
| TaskChatBrowserItem
|
||
| TaskChatTaskCreatedItem
|
||
| TaskChatProjectCreatedItem
|
||
| TaskChatSkillCreatedItem
|
||
| TaskChatMessageItem
|
||
| TaskChatThinkingItem
|
||
| TaskChatToolItem
|
||
| TaskChatStatusItem
|
||
| TaskChatMarkerItem
|
||
| TaskChatUsageItem
|
||
| TaskChatActivityPhaseItem
|
||
| TaskChatInteractionItem
|
||
| TaskChatPlanDocumentItem
|
||
| TaskChatTurnItem
|
||
| TaskChatBriefItem
|
||
| TaskChatSubagentGroupItem
|
||
| TaskChatProtocolItem;
|
||
|
||
/** Latest lifecycle state wins for each request; terminal entries suppress stale pending cards. */
|
||
export function latestPendingRuntimeRequest(
|
||
items: readonly TaskChatItem[],
|
||
): TaskChatRuntimeRequestItem | null {
|
||
const seen = new Set<string>();
|
||
for (let index = items.length - 1; index >= 0; index -= 1) {
|
||
const item = items[index];
|
||
if (item.kind !== "protocol" || item.surface !== "runtime_request")
|
||
continue;
|
||
const key = `${item.runId}:${item.requestId}`;
|
||
if (seen.has(key)) continue;
|
||
seen.add(key);
|
||
if (item.status === "pending") return item;
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/** A protocol denial is the explicit negative path, so a second Skip action is redundant. */
|
||
export function runtimeRequestReplacesComposerSkip(
|
||
item: TaskChatRuntimeRequestItem,
|
||
): boolean {
|
||
return item.choices.some((choice) => {
|
||
const key = choice.key.trim().toLowerCase();
|
||
const label = choice.label.trim().toLowerCase();
|
||
return (
|
||
["deny", "decline", "reject"].includes(key) ||
|
||
/^(deny|decline|reject)(\b|\s)/.test(label)
|
||
);
|
||
});
|
||
}
|
||
|
||
/** One latest lifecycle entry per request, in the order each request began. */
|
||
export function latestRuntimeRequests(
|
||
items: readonly TaskChatItem[],
|
||
): TaskChatRuntimeRequestItem[] {
|
||
const latest = new Map<
|
||
string,
|
||
{ order: number; item: TaskChatRuntimeRequestItem }
|
||
>();
|
||
for (const [order, item] of items.entries()) {
|
||
if (item.kind !== "protocol" || item.surface !== "runtime_request")
|
||
continue;
|
||
const key = `${item.runId}:${item.requestId}`;
|
||
const existing = latest.get(key);
|
||
latest.set(key, { order: existing?.order ?? order, item });
|
||
}
|
||
return [...latest.values()]
|
||
.sort((left, right) => left.order - right.order)
|
||
.map(({ item }) => item);
|
||
}
|
||
|
||
/** A structured plan entry (ACP PlanEntry) for the Plans tab. */
|
||
export interface TaskChatPlanEntry {
|
||
id: string;
|
||
content: string;
|
||
status: TaskChatPlanEntryStatus;
|
||
priority: TaskChatPlanEntryPriority;
|
||
}
|
||
|
||
export interface TaskChatPlan {
|
||
/** Revision index (1-based); higher supersedes. */
|
||
revision: number;
|
||
entries: TaskChatPlanEntry[];
|
||
updatedAt?: string;
|
||
}
|