fix(agents): stabilize queue, steer, and timeline ordering

apps/web/app/api/agent-sessions/[id]/route.test.ts

@@ -236,28 +236,27 @@ describe("agent session route", () => {
     expect(mocks.updateAgentSessionMetadata).not.toHaveBeenCalled();
   });
 
-  it("forwards steering as an active-turn command", async () => {
-    const response = await POST(
+  it("rejects delivery modes that bypass the connector-owned queue", async () => {
+    const steer = await POST(
       request("POST", {
         type: "steer",
         message: "Focus on the failing test",
         clientMessageId: "steer-message",
       }),
       context,
     );
-
-    expect(response.status).toBe(200);
-    expect(mocks.daemonRequest).toHaveBeenCalledWith(
-      "connector",
-      expect.objectContaining({
-        commandId: "steer-message",
-        command: expect.objectContaining({ type: "steer" }),
+    const interrupt = await POST(
+      request("POST", {
+        type: "interrupt",
+        message: "Replace the current approach",
+        clientMessageId: "interrupt-message",
       }),
+      context,
     );
-    expect(mocks.updateAgentSessionMetadata).toHaveBeenCalledWith(
-      "session",
-      { providerModifiedAt: expect.any(Date) },
-    );
+
+    expect(steer.status).toBe(400);
+    expect(interrupt.status).toBe(400);
+    expect(mocks.daemonRequest).not.toHaveBeenCalled();
   });
 
   it("creates a new connector-owned workspace session", async () => {

apps/web/app/api/agent-sessions/[id]/route.ts

@@ -141,7 +141,6 @@ export async function POST(
     if (
       command.type === "prompt" ||
       command.type === "implement_plan" ||
-      command.type === "steer" ||
       command.type === "steer_queued_message"
     ) {
       await updateAgentSessionMetadata(id, {