🤖 refactor: move auto-compaction & auto-retry from frontend to backend

mobile/src/messages/normalizeChatEvent.test.ts

@@ -105,6 +105,22 @@ describe("createChatEventExpander", () => {
     });
   });
 
+  it("ignores desktop-only compaction and retry status events", () => {
+    const expander = createChatEventExpander();
+
+    const events = expander.expand([
+      { type: "idle-compaction-needed" } as WorkspaceChatEvent,
+      { type: "idle-compaction-started" } as WorkspaceChatEvent,
+      { type: "auto-compaction-triggered" } as WorkspaceChatEvent,
+      { type: "auto-compaction-completed" } as WorkspaceChatEvent,
+      { type: "auto-retry-scheduled" } as WorkspaceChatEvent,
+      { type: "auto-retry-starting" } as WorkspaceChatEvent,
+      { type: "auto-retry-abandoned" } as WorkspaceChatEvent,
+    ]);
+
+    expect(events).toEqual([]);
+  });
+
   it("emits displayable entries for mux messages replayed from history", () => {
     const expander = createChatEventExpander();
 

mobile/src/messages/normalizeChatEvent.ts

@@ -416,8 +416,15 @@ export function createChatEventExpander(): ChatEventExpander {
         // Usage delta: mobile app doesn't display usage, silently ignore
         "usage-delta": () => [],
 
-        // Idle compaction signal: desktop auto-triggers; mobile currently ignores.
+        // Compaction/retry status signals: desktop-only affordances for now.
+        // Mobile intentionally drops these to avoid noisy "unsupported event" rows.
         "idle-compaction-needed": () => [],
+        "idle-compaction-started": () => [],
+        "auto-compaction-triggered": () => [],
+        "auto-compaction-completed": () => [],
+        "auto-retry-scheduled": () => [],
+        "auto-retry-starting": () => [],
+        "auto-retry-abandoned": () => [],
 
         // Pass-through events: return unchanged
         "caught-up": () => [payload as WorkspaceChatEvent],

src/browser/App.tsx

@@ -21,7 +21,6 @@ import { matchesKeybind, KEYBINDS } from "./utils/ui/keybinds";
 import { handleLayoutSlotHotkeys } from "./utils/ui/layoutSlotHotkeys";
 import { buildSortedWorkspacesByProject } from "./utils/ui/workspaceFiltering";
 import { getVisibleWorkspaceIds } from "./utils/ui/workspaceDomNav";
-import { useResumeManager } from "./hooks/useResumeManager";
 import { useUnreadTracking } from "./hooks/useUnreadTracking";
 import { useWorkspaceStoreRaw, useWorkspaceRecency } from "./stores/WorkspaceStore";
 
@@ -244,9 +243,6 @@ function AppInner() {
     }
   }, [refreshWorkspaceMetadata, setSelectedWorkspace]);
 
-  // Auto-resume interrupted streams on app startup and when failures occur
-  useResumeManager();
-
   // Update window title based on selected workspace
   // URL syncing is now handled by RouterContext
   useEffect(() => {

src/browser/components/AppLoader.tsx

@@ -12,7 +12,6 @@ import { ProjectProvider, useProjectContext } from "../contexts/ProjectContext";
 import { PolicyProvider, usePolicy } from "@/browser/contexts/PolicyContext";
 import { PolicyBlockedScreen } from "@/browser/components/PolicyBlockedScreen";
 import { APIProvider, useAPI, type APIClient } from "@/browser/contexts/API";
-import { useIdleCompactionHandler } from "@/browser/hooks/useIdleCompactionHandler";
 import { WorkspaceProvider, useWorkspaceContext } from "../contexts/WorkspaceContext";
 import { RouterProvider } from "../contexts/RouterContext";
 import { TelemetryEnabledProvider } from "../contexts/TelemetryEnabledContext";
@@ -64,13 +63,6 @@ function AppLoaderInner() {
   const apiState = useAPI();
   const api = apiState.api;
 
-  // Idle compaction should be registered at the app level so it can serialize across
-  // all workspaces (and won't reset when switching workspaces).
-  //
-  // Avoid triggering background compactions when mux is blocked by policy.
-  const idleCompactionApi = policyState.status.state === "blocked" ? null : api;
-  useIdleCompactionHandler({ api: idleCompactionApi });
-
   // Get store instances
   const workspaceStoreInstance = useWorkspaceStoreRaw();
   const gitStatusStore = useGitStatusStoreRaw();

src/browser/components/ChatInput/index.tsx

@@ -51,13 +51,11 @@ import {
   getWorkspaceLastReadKey,
 } from "@/common/constants/storage";
 import {
-  executeCompaction,
   prepareCompactionMessage,
   processSlashCommand,
   type SlashCommandContext,
 } from "@/browser/utils/chatCommands";
 import { Button } from "../ui/button";
-import { shouldTriggerAutoCompaction } from "@/browser/utils/compaction/shouldTriggerAutoCompaction";
 import { CUSTOM_EVENTS } from "@/common/constants/events";
 import { findAtMentionAtCursor } from "@/common/utils/atMentions";
 import {
@@ -98,7 +96,7 @@ import type { AgentAiDefaults } from "@/common/types/agentAiDefaults";
 import { coerceThinkingLevel, type ThinkingLevel } from "@/common/types/thinking";
 import { resolveThinkingInput } from "@/common/utils/thinking/policy";
 import {
-  type MuxFrontendMetadata,
+  type MuxMessageMetadata,
   type ReviewNoteDataForDisplay,
   prepareUserMessageForSend,
 } from "@/common/types/message";
@@ -181,8 +179,6 @@ const ChatInputInner: React.FC<ChatInputProps> = (props) => {
   const editingMessage = variant === "workspace" ? props.editingMessage : undefined;
   const isStreamStarting = variant === "workspace" ? (props.isStreamStarting ?? false) : false;
   const isCompacting = variant === "workspace" ? (props.isCompacting ?? false) : false;
-  const hasQueuedCompaction =
-    variant === "workspace" ? (props.hasQueuedCompaction ?? false) : false;
   const [isMobileTouch, setIsMobileTouch] = useState(
     () =>
       typeof window !== "undefined" &&
@@ -1868,89 +1864,6 @@ const ChatInputInner: React.FC<ChatInputProps> = (props) => {
       const preSendDraft = getDraft();
       const preSendReviews = draftReviews;
 
-      // Auto-compaction check (workspace variant only)
-      // Check if we should auto-compact before sending this message
-      // Result is computed in parent (AIView) and passed down to avoid duplicate calculation
-      if (
-        variant === "workspace" &&
-        shouldTriggerAutoCompaction(
-          props.autoCompactionCheck,
-          isCompacting || isStreamStarting,
-          !!editingMessage,
-          hasQueuedCompaction
-        )
-      ) {
-        // Prepare file parts for the continue message
-        const fileParts = chatAttachmentsToFileParts(attachments);
-
-        // Prepare reviews data for the continue message
-        const reviewsData = reviewData;
-
-        // Capture review IDs for marking as checked on success
-        const sentReviewIds = reviewIdsForCheck;
-
-        // Clear input immediately for responsive UX
-        setInput("");
-        setDraftReviews(null);
-
-        const compactionSendMessageOptions: SendMessageOptions = {
-          ...sendMessageOptions,
-        };
-
-        setAttachments([]);
-        setHideReviewsDuringSend(true);
-
-        try {
-          const result = await executeCompaction({
-            api,
-            workspaceId: props.workspaceId,
-            followUpContent: {
-              text: messageTextForSend,
-              fileParts,
-              reviews: reviewsData,
-              muxMetadata: skillMuxMetadata,
-            },
-            sendMessageOptions: compactionSendMessageOptions,
-          });
-
-          if (!result.success) {
-            // Restore on error
-            setDraft(preSendDraft);
-            setDraftReviews(preSendReviews);
-            pushToast({
-              type: "error",
-              title: "Auto-Compaction Failed",
-              message: result.error ?? "Failed to start auto-compaction",
-            });
-          } else {
-            // Mark reviews as checked on success
-            if (sentReviewIds.length > 0) {
-              props.onCheckReviews?.(sentReviewIds);
-            }
-            pushToast({
-              type: "success",
-              message: "Context threshold reached - auto-compacting...",
-            });
-            props.onMessageSent?.();
-          }
-        } catch (error) {
-          // Restore on unexpected error
-          setDraft(preSendDraft);
-          setDraftReviews(preSendReviews);
-          pushToast({
-            type: "error",
-            title: "Auto-Compaction Failed",
-            message:
-              error instanceof Error ? error.message : "Unexpected error during auto-compaction",
-          });
-        } finally {
-          setSendingCount((c) => c - 1);
-          setHideReviewsDuringSend(false);
-        }
-
-        return; // Skip normal send
-      }
-
       try {
         // Prepare file parts if any
         const fileParts = chatAttachmentsToFileParts(attachments, { validate: true });
@@ -1965,7 +1878,7 @@ const ChatInputInner: React.FC<ChatInputProps> = (props) => {
 
         // When editing a /compact command, regenerate the actual summarization request
         let actualMessageText = messageTextForSend;
-        let muxMetadata: MuxFrontendMetadata | undefined = skillMuxMetadata;
+        let muxMetadata: MuxMessageMetadata | undefined = skillMuxMetadata;
         let compactionOptions: Partial<SendMessageOptions> = {};
 
         if (editingMessage && actualMessageText.startsWith("/")) {

src/browser/components/ChatInput/types.ts

@@ -1,6 +1,5 @@
 import type { FrontendWorkspaceMetadata } from "@/common/types/workspace";
 import type { TelemetryRuntimeType } from "@/common/telemetry/payload";
-import type { AutoCompactionCheckResult } from "@/browser/utils/compaction/autoCompactionCheck";
 import type { Review } from "@/common/types/review";
 import type { EditingMessageState, PendingUserMessage } from "@/browser/utils/chatEditing";
 
@@ -37,9 +36,6 @@ export interface ChatInputWorkspaceVariant {
   /** Optional explanation displayed when input is disabled */
   disabledReason?: string;
   onReady?: (api: ChatInputAPI) => void;
-  autoCompactionCheck?: AutoCompactionCheckResult; // Computed in parent (AIView) to avoid duplicate calculation
-  /** True if there's already a compaction request queued (prevents double-compaction) */
-  hasQueuedCompaction?: boolean;
   /** Reviews currently attached to chat (from useReviews hook) */
   attachedReviews?: Review[];
   /** Detach a review from chat input (sets status to pending) */

src/browser/components/ChatInput/utils.ts

@@ -4,7 +4,7 @@ import type { APIClient } from "@/browser/contexts/API";
 import type { AgentSkillDescriptor } from "@/common/types/agentSkill";
 import type { SendMessageError } from "@/common/types/errors";
 import type { ParsedRuntime } from "@/common/types/runtime";
-import { buildAgentSkillMetadata, type MuxFrontendMetadata } from "@/common/types/message";
+import { buildAgentSkillMetadata, type MuxMessageMetadata } from "@/common/types/message";
 import type { FilePart } from "@/common/orpc/types";
 import type { ChatAttachment } from "../ChatAttachments";
 import type { Review } from "@/common/types/review";
@@ -50,7 +50,7 @@ function isUnknownSlashCommand(value: ParsedCommand): value is UnknownSlashComma
 export function buildSkillInvocationMetadata(
   rawCommand: string,
   descriptor: AgentSkillDescriptor
-): MuxFrontendMetadata {
+): MuxMessageMetadata {
   return buildAgentSkillMetadata({
     rawCommand,
     commandPrefix: `/${descriptor.name}`,