🥁 test: Stabilize Host Edit Responsiveness Assertions

packages/api/src/agents/files/processing.spec.ts

@@ -177,6 +177,35 @@ describe('worker lifecycle', () => {
     }
   });
 
+  it.each([false, true])(
+    'keeps timers running while a worker reply is pending, warm=%s',
+    async (warm) => {
+      const processor = createHostEditProcessor(fixture);
+      const controller = new AbortController();
+      try {
+        if (warm) await processor.apply('ready', [edit]);
+        let settled = false;
+        const pending = processor.apply('wait', [edit], undefined, controller.signal).then(
+          () => {
+            settled = true;
+            return 'completed';
+          },
+          (error: Error) => {
+            settled = true;
+            return error.name;
+          },
+        );
+        await new Promise<void>((resolve) => setTimeout(resolve, 0));
+        expect(settled).toBe(false);
+        controller.abort();
+        await expect(pending).resolves.toBe('AbortError');
+      } finally {
+        controller.abort();
+        await processor.close();
+      }
+    },
+  );
+
   it('has no queue and releases capacity only after cancellation terminates the worker', async () => {
     const processor = createHostEditProcessor(fixture);
     const controller = new AbortController();

packages/api/src/agents/handlers.spec.ts

@@ -5545,7 +5545,7 @@ describe('createToolExecuteHandler', () => {
     ];
 
     it.each(['SKILL.md', 'references/a.md'])(
-      'rejects compact amplification atomically for %s without starving timers',
+      'rejects compact amplification atomically for %s',
       async (file) => {
         const updateSkill = jest.fn();
         const saveSkillFileContent = jest.fn();
@@ -5570,21 +5570,15 @@ describe('createToolExecuteHandler', () => {
           updateSkill,
           saveSkillFileContent,
         });
-        let timerFired = false;
-        const timer = setTimeout(() => {
-          timerFired = true;
-        }, 0);
         const [result] = await invokeHandler(handler, [
           {
             id: 'amplification',
             name: 'edit_file',
             args: { path: `skills/bounded-skill/${file}`, edits: amplificationEdits() },
           },
         ]);
-        clearTimeout(timer);
         expect(result.status).toBe('error');
         expect(result.errorMessage).toContain('budget exceeded');
-        expect(timerFired).toBe(true);
         expect(updateSkill).not.toHaveBeenCalled();
         expect(saveSkillFileContent).not.toHaveBeenCalled();
       },