Remove unused queue logic

Author: huntercaron

packages/code-link-cli/src/controller.test.ts

@@ -13,8 +13,6 @@ function disconnectedState() {
         mode: "disconnected" as const,
         socket: null,
         pendingRemoteChanges: [],
-        pendingOperations: new Map(),
-        nextOperationId: 1,
     }
 }
 
@@ -23,8 +21,6 @@ function watchingState() {
         mode: "watching" as const,
         socket: mockSocket,
         pendingRemoteChanges: [],
-        pendingOperations: new Map(),
-        nextOperationId: 1,
     }
 }
 
@@ -33,8 +29,6 @@ function handshakingState() {
         mode: "handshaking" as const,
         socket: mockSocket,
         pendingRemoteChanges: [],
-        pendingOperations: new Map(),
-        nextOperationId: 1,
     }
 }
 
@@ -43,8 +37,6 @@ function snapshotProcessingState() {
         mode: "snapshot_processing" as const,
         socket: mockSocket,
         pendingRemoteChanges: [],
-        pendingOperations: new Map(),
-        nextOperationId: 1,
     }
 }
 
@@ -64,8 +56,6 @@ function conflictResolutionState(
         socket: mockSocket,
         pendingConflicts,
         pendingRemoteChanges: [],
-        pendingOperations: new Map(),
-        nextOperationId: 1,
     }
 }
 
@@ -249,16 +239,17 @@ describe("Code Link", () => {
             expect(result.effects.some(e => e.type === "WRITE_FILES")).toBe(true)
         })
 
-        it("queues changes during initial sync", () => {
-            // Changes arriving during snapshot processing are queued, not applied immediately
+        it("ignores changes during initial sync", () => {
+            // Changes arriving during snapshot processing are ignored - snapshot handles reconciliation
             const state = snapshotProcessingState()
             const result = transition(state, {
                 type: "REMOTE_FILE_CHANGE",
                 file: { name: "Button.tsx", content: "late arrival", modifiedAt: Date.now() },
             })
 
-            expect(result.state.pendingRemoteChanges).toHaveLength(1)
+            expect(result.state.pendingRemoteChanges).toHaveLength(0)
             expect(result.effects.some(e => e.type === "WRITE_FILES")).toBe(false)
+            expect(result.effects.some(e => e.type === "LOG")).toBe(true)
         })
 
         it("creates new local file and uploads to Framer", () => {

packages/code-link-cli/src/controller.ts

@@ -50,20 +50,11 @@ import { hashFileContent } from "./utils/state-persistence.ts"
  */
 export type SyncMode = "disconnected" | "handshaking" | "snapshot_processing" | "conflict_resolution" | "watching"
 
-/**
- * Pending operation for echo suppression and replay
- */
-type PendingOperation =
-    | { id: string; type: "write"; file: string; hash: string }
-    | { id: string; type: "delete"; file: string; previousHash?: string }
-
 /**
  * Shared state that persists across all lifecycle modes
  */
 interface SyncStateBase {
     pendingRemoteChanges: FileInfo[]
-    pendingOperations: Map<string, PendingOperation>
-    nextOperationId: number
 }
 
 type DisconnectedState = SyncStateBase & {
@@ -380,15 +371,9 @@ function transition(state: SyncState, event: SyncEvent): { state: SyncState; eff
             const validation = validateIncomingChange(event.fileMeta, state.mode)
 
             if (validation.action === "queue") {
-                effects.push(log("debug", `Queueing file change: ${event.file.name} (${validation.reason})`))
-
-                return {
-                    state: {
-                        ...state,
-                        pendingRemoteChanges: [...state.pendingRemoteChanges, event.file],
-                    },
-                    effects,
-                }
+                // Changes during initial sync are ignored - the snapshot handles reconciliation
+                effects.push(log("debug", `Ignoring file change during sync: ${event.file.name}`))
+                return { state, effects }
             }
 
             if (validation.action === "reject") {
@@ -996,8 +981,6 @@ export async function start(config: Config): Promise<void> {
         mode: "disconnected",
         socket: null,
         pendingRemoteChanges: [],
-        pendingOperations: new Map(),
-        nextOperationId: 1,
     }
 
     const userActions = new PluginUserPromptCoordinator()