🤖 fix: make compaction crash-safe and recover via resume manager

Author: ammar-agent

src/browser/hooks/useResumeManager.ts

@@ -1,14 +1,18 @@
 import { useEffect, useRef } from "react";
 import { useWorkspaceStoreRaw, type WorkspaceState } from "@/browser/stores/WorkspaceStore";
 import { CUSTOM_EVENTS, type CustomEventType } from "@/common/constants/events";
-import { getAutoRetryKey, getRetryStateKey } from "@/common/constants/storage";
+import {
+  getAutoRetryKey,
+  getRetryStateKey,
+  getCancelledCompactionKey,
+} from "@/common/constants/storage";
 import { getSendOptionsFromStorage } from "@/browser/utils/messages/sendOptions";
 import { readPersistedState, updatePersistedState } from "./usePersistedState";
 import {
   isEligibleForAutoRetry,
   isNonRetryableSendError,
 } from "@/browser/utils/messages/retryEligibility";
-import { applyCompactionOverrides } from "@/browser/utils/messages/compactionOptions";
+import { executeCompaction } from "@/browser/utils/chatCommands";
 import type { SendMessageError } from "@/common/types/errors";
 import {
   createFailedRetryState,
@@ -23,6 +27,15 @@ export interface RetryState {
   lastError?: SendMessageError;
 }
 
+/**
+ * Persisted marker for user-cancelled compaction.
+ * Used to distinguish intentional cancellation (Ctrl+C) from crash/force-exit.
+ */
+export interface CancelledCompactionMarker {
+  messageId: string;
+  timestamp: number;
+}
+
 /**
  * Centralized auto-resume manager for interrupted streams
  *
@@ -163,44 +176,77 @@ export function useResumeManager() {
     );
 
     try {
+      if (!api) {
+        retryingRef.current.delete(workspaceId);
+        return;
+      }
+
       // Start with workspace defaults
-      let options = getSendOptionsFromStorage(workspaceId);
+      const options = getSendOptionsFromStorage(workspaceId);
 
       // Check if last user message was a compaction request
       const state = workspaceStatesRef.current.get(workspaceId);
-      if (state) {
-        const lastUserMsg = [...state.messages].reverse().find((msg) => msg.type === "user");
-        if (lastUserMsg?.compactionRequest) {
-          // Apply compaction overrides using shared function (same as ChatInput)
-          // This ensures custom model/tokens are preserved across resume
-          options = applyCompactionOverrides(options, {
-            model: lastUserMsg.compactionRequest.parsed.model,
-            maxOutputTokens: lastUserMsg.compactionRequest.parsed.maxOutputTokens,
-            continueMessage: {
-              text: lastUserMsg.compactionRequest.parsed.continueMessage?.text ?? "",
-              imageParts: lastUserMsg.compactionRequest.parsed.continueMessage?.imageParts,
-              model: lastUserMsg.compactionRequest.parsed.continueMessage?.model ?? options.model,
-            },
-          });
+      const lastUserMsg = state?.messages
+        ? [...state.messages].reverse().find((msg) => msg.type === "user")
+        : undefined;
+
+      if (lastUserMsg?.compactionRequest) {
+        // Check if this compaction was user-cancelled (Ctrl+C)
+        const cancelledMarker = readPersistedState<CancelledCompactionMarker | null>(
+          getCancelledCompactionKey(workspaceId),
+          null
+        );
+
+        if (cancelledMarker && cancelledMarker.messageId === lastUserMsg.id) {
+          // User explicitly cancelled this compaction - don't auto-retry
+          // Clear the marker (one-shot) so manual retry works
+          updatePersistedState(getCancelledCompactionKey(workspaceId), () => null);
+          console.debug(
+            `[retry] ${workspaceId} skipping cancelled compaction (messageId=${lastUserMsg.id})`
+          );
+          return;
         }
-      }
 
-      if (!api) {
-        retryingRef.current.delete(workspaceId);
-        return;
-      }
-      const result = await api.workspace.resumeStream({ workspaceId, options });
+        // Retry compaction via executeCompaction (re-sends the compaction request)
+        // This properly rebuilds the compaction-specific behavior including continueMessage queuing
+        console.debug(`[retry] ${workspaceId} retrying interrupted compaction`);
+        const { parsed } = lastUserMsg.compactionRequest;
+        const result = await executeCompaction({
+          api,
+          workspaceId,
+          sendMessageOptions: options,
+          model: parsed.model,
+          maxOutputTokens: parsed.maxOutputTokens,
+          continueMessage: parsed.continueMessage,
+          editMessageId: lastUserMsg.id, // Edit the existing compaction request message
+        });
 
-      if (!result.success) {
-        // Store error in retry state so RetryBarrier can display it
-        const newState = createFailedRetryState(attempt, result.error);
-        console.debug(
-          `[retry] ${workspaceId} resumeStream failed: attempt ${attempt} → ${newState.attempt}`
-        );
-        updatePersistedState(getRetryStateKey(workspaceId), newState);
+        if (!result.success) {
+          const errorData: SendMessageError = {
+            type: "unknown",
+            raw: result.error ?? "Failed to retry compaction",
+          };
+          const newState = createFailedRetryState(attempt, errorData);
+          console.debug(
+            `[retry] ${workspaceId} compaction failed: attempt ${attempt} → ${newState.attempt}`
+          );
+          updatePersistedState(getRetryStateKey(workspaceId), newState);
+        }
+      } else {
+        // Normal stream resume (non-compaction)
+        const result = await api.workspace.resumeStream({ workspaceId, options });
+
+        if (!result.success) {
+          // Store error in retry state so RetryBarrier can display it
+          const newState = createFailedRetryState(attempt, result.error);
+          console.debug(
+            `[retry] ${workspaceId} resumeStream failed: attempt ${attempt} → ${newState.attempt}`
+          );
+          updatePersistedState(getRetryStateKey(workspaceId), newState);
+        }
       }
       // Note: Don't clear retry state on success - stream-end event will handle that
-      // resumeStream success just means "stream initiated", not "stream completed"
+      // resumeStream/executeCompaction success just means "stream initiated", not "stream completed"
       // Clearing here causes backoff reset bug when stream starts then immediately fails
     } catch (error) {
       // Store error in retry state for display

src/browser/utils/chatCommands.ts

@@ -26,6 +26,8 @@ import {
   resolveCompactionModel,
   isValidModelFormat,
 } from "@/browser/utils/messages/compactionModelPreference";
+import { getCancelledCompactionKey } from "@/common/constants/storage";
+import { updatePersistedState } from "@/browser/hooks/usePersistedState";
 import type { ImageAttachment } from "../components/ImageAttachments";
 import { dispatchWorkspaceSwitch } from "./workspaceEvents";
 import { getRuntimeKey, copyWorkspaceStorage } from "@/common/constants/storage";
@@ -691,6 +693,10 @@ export function prepareCompactionMessage(options: CompactionOptions): {
 export async function executeCompaction(
   options: CompactionOptions & { api: RouterClient<AppRouter> }
 ): Promise<CompactionResult> {
+  // Clear any cancelled-compaction marker since we're (re-)starting compaction
+  // This allows auto-retry to work if this attempt is interrupted by crash/force-exit
+  updatePersistedState(getCancelledCompactionKey(options.workspaceId), () => null);
+
   const { messageText, metadata, sendOptions } = prepareCompactionMessage(options);
 
   const result = await options.api.workspace.sendMessage({

src/browser/utils/compaction/handler.ts

@@ -7,6 +7,9 @@
 
 import type { StreamingMessageAggregator } from "@/browser/utils/messages/StreamingMessageAggregator";
 import type { APIClient } from "@/browser/contexts/API";
+import { getCancelledCompactionKey } from "@/common/constants/storage";
+import { updatePersistedState } from "@/browser/hooks/usePersistedState";
+import type { CancelledCompactionMarker } from "@/browser/hooks/useResumeManager";
 
 /**
  * Check if the workspace is currently in a compaction stream
@@ -76,6 +79,14 @@ export async function cancelCompaction(
     return false;
   }
 
+  // Mark this compaction as user-cancelled so auto-retry doesn't pick it up
+  // This distinguishes intentional Ctrl+C from crash/force-exit
+  const marker: CancelledCompactionMarker = {
+    messageId: compactionRequestMsg.id,
+    timestamp: Date.now(),
+  };
+  updatePersistedState(getCancelledCompactionKey(workspaceId), () => marker);
+
   // Interrupt stream with abandonPartial flag
   // Backend detects this and skips compaction (Ctrl+C flow)
   await client.workspace.interruptStream({ workspaceId, options: { abandonPartial: true } });

src/common/orpc/schemas/stream.ts

@@ -322,7 +322,7 @@ export const WorkspaceChatMessageSchema = z.discriminatedUnion("type", [
   UsageDeltaEventSchema,
   QueuedMessageChangedEventSchema,
   RestoreToInputEventSchema,
-  // Idle compaction notification
+  // Compaction notifications
   IdleCompactionNeededEventSchema,
   // Init events
   ...WorkspaceInitEventSchema.def.options,

src/node/services/agentSession.ts

@@ -39,7 +39,6 @@ import type { PostCompactionAttachment, PostCompactionExclusions } from "@/commo
 import { TURNS_BETWEEN_ATTACHMENTS } from "@/common/constants/attachments";
 import { extractEditedFileDiffs } from "@/common/utils/messages/extractEditedFiles";
 import { isValidModelFormat } from "@/common/utils/ai/models";
-
 /**
  * Tracked file state for detecting external edits.
  * Uses timestamp-based polling with diff injection.
@@ -298,6 +297,8 @@ export class AgentSession {
         workspaceId: this.workspaceId,
         message: { type: "caught-up" },
       });
+      // Note: Aborted compaction recovery is handled by useResumeManager on the frontend,
+      // which detects interrupted compaction-request messages and retries via executeCompaction.
     }
   }