feat(acp): add inline file chips, slash commands, and session-aware prompt restore

Author: bajrangCoder

src/lib/acp/history.ts

@@ -13,6 +13,11 @@ export interface ACPHistoryTurnStop {
 	timestamp: number;
 }
 
+export interface ACPHistoryUserMessageSnapshot {
+	index: number;
+	content: Record<string, unknown>[];
+}
+
 export interface ACPHistoryEntry {
 	sessionId: string;
 	url: string;
@@ -21,6 +26,7 @@ export interface ACPHistoryEntry {
 	title: string;
 	preview: string;
 	turnStops: ACPHistoryTurnStop[];
+	userMessageSnapshots: ACPHistoryUserMessageSnapshot[];
 	createdAt: string;
 	updatedAt: string;
 }
@@ -58,7 +64,23 @@ function normalizeEntry(entry: Partial<ACPHistoryEntry> = {}): ACPHistoryEntry {
 				})
 				.filter((item): item is ACPHistoryTurnStop => Boolean(item))
 		: [];
-
+	const userMessageSnapshots = Array.isArray(entry.userMessageSnapshots)
+		? entry.userMessageSnapshots
+				.map((item) => {
+					const index = Number.isInteger(item?.index) ? Number(item.index) : -1;
+					const content = Array.isArray(item?.content)
+						? item.content.filter((block) => {
+								return block && typeof block === "object";
+							})
+						: [];
+					if (index < 0 || !content.length) return null;
+					return {
+						index,
+						content,
+					};
+				})
+				.filter((item): item is ACPHistoryUserMessageSnapshot => Boolean(item))
+		: [];
 	return {
 		sessionId:
 			typeof entry.sessionId === "string" ? entry.sessionId.trim() : "",
@@ -69,6 +91,7 @@ function normalizeEntry(entry: Partial<ACPHistoryEntry> = {}): ACPHistoryEntry {
 		title: typeof entry.title === "string" ? entry.title.trim() : "",
 		preview: typeof entry.preview === "string" ? entry.preview.trim() : "",
 		turnStops,
+		userMessageSnapshots,
 		createdAt,
 		updatedAt,
 	};
@@ -136,6 +159,10 @@ const acpHistory = {
 					normalized.turnStops.length > 0
 						? normalized.turnStops
 						: current.turnStops,
+				userMessageSnapshots:
+					normalized.userMessageSnapshots.length > 0
+						? normalized.userMessageSnapshots
+						: current.userMessageSnapshots,
 				createdAt: current.createdAt,
 				updatedAt: normalized.updatedAt || new Date().toISOString(),
 			};

src/lib/acp/models.ts

@@ -2,6 +2,7 @@ import type {
 	Plan as ACPPlan,
 	StopReason as ACPStopReason,
 	ToolCall as ACPToolCall,
+	AvailableCommand,
 	ContentBlock,
 	PlanEntry,
 } from "@agentclientprotocol/sdk";
@@ -67,6 +68,7 @@ export interface Plan extends ACPPlan {
 }
 
 export type { PlanEntry };
+export type { AvailableCommand };
 
 export interface ChatMessage {
 	id: string;

src/lib/acp/session.ts

@@ -1,4 +1,5 @@
 import type {
+	AvailableCommand,
 	ContentBlock,
 	RequestPermissionRequest as PermissionRequest,
 	SessionUpdate,
@@ -23,6 +24,7 @@ type SessionEventType =
 	| "timeline_update"
 	| "tool_call"
 	| "tool_call_update"
+	| "available_commands"
 	| "plan"
 	| "permission_request"
 	| "session_end";
@@ -36,6 +38,7 @@ export class ACPSession {
 	readonly timeline: TimelineEntry[] = [];
 	readonly toolCalls: Map<string, ToolCall> = new Map();
 	readonly turnStops: TurnStop[] = [];
+	availableCommands: AvailableCommand[] = [];
 	plan: Plan | null = null;
 	title: string | null = null;
 	updatedAt: string | null = null;
@@ -120,6 +123,9 @@ export class ACPSession {
 			case "plan":
 				this.handlePlan(update.entries);
 				break;
+			case "available_commands_update":
+				this.handleAvailableCommandsUpdate(update.availableCommands);
+				break;
 			case "session_info_update":
 				this.handleSessionInfoUpdate(update);
 				break;
@@ -202,30 +208,13 @@ export class ACPSession {
 		}
 
 		if (content.type === "text") {
-			if (role === "agent") {
-				this.agentTextBuffer += content.text;
-			} else if (role === "thought") {
-				this.thoughtTextBuffer += content.text;
-			} else {
-				this.userTextBuffer += content.text;
-			}
-			const existingText = message.content.find((c) => c.type === "text");
-			if (existingText && existingText.type === "text") {
-				existingText.text =
-					role === "agent"
-						? this.agentTextBuffer
-						: role === "thought"
-							? this.thoughtTextBuffer
-							: this.userTextBuffer;
+			const lastBlock = message.content[message.content.length - 1];
+			if (lastBlock && lastBlock.type === "text") {
+				lastBlock.text += content.text;
 			} else {
 				message.content.push({
 					type: "text",
-					text:
-						role === "agent"
-							? this.agentTextBuffer
-							: role === "thought"
-								? this.thoughtTextBuffer
-								: this.userTextBuffer,
+					text: content.text,
 				});
 			}
 		} else {
@@ -325,6 +314,15 @@ export class ACPSession {
 		this.emit("plan", this.plan);
 	}
 
+	private handleAvailableCommandsUpdate(
+		availableCommands: AvailableCommand[] | null | undefined,
+	): void {
+		this.availableCommands = Array.isArray(availableCommands)
+			? [...availableCommands]
+			: [];
+		this.emit("available_commands", this.availableCommands);
+	}
+
 	private handleSessionInfoUpdate(update: {
 		title?: string | null;
 		updatedAt?: string | null;
@@ -475,6 +473,7 @@ export class ACPSession {
 	dispose(): void {
 		this.listeners.clear();
 		this.pendingPermissions.length = 0;
+		this.availableCommands = [];
 		this.currentAgentMessageId = null;
 		this.currentThoughtMessageId = null;
 		this.currentUserMessageId = null;