From 20db60b0705ab65b6ade67ff614d347e13dc9803 Mon Sep 17 00:00:00 2001
From: Adam Malczewski <github@tradam.dev>
Date: Mon, 22 Jun 2026 02:53:20 +0900
Subject: feat: stop generation mid-turn (POST /conversations/:id/stop)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Add stopTurn to the orchestrator: aborts the in-flight turn's
AbortController without changing conversation status. The turn
seals normally (finishReason: 'aborted'), partial messages are
persisted, and the conversation transitions active → idle via the
normal settle path.

Distinct from closeConversation which marks the conversation closed.

- POST /conversations/:id/stop endpoint
- dispatch stop <id> CLI command
- FE handoff: frontend-stop-generation-handoff.md
---
 packages/cli/src/main.ts | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)

(limited to 'packages/cli/src/main.ts')

diff --git a/packages/cli/src/main.ts b/packages/cli/src/main.ts
index 4e07da9..5935bab 100644
--- a/packages/cli/src/main.ts
+++ b/packages/cli/src/main.ts
@@ -16,6 +16,7 @@ import {
 	fetchModels,
 	openConversation,
 	resolveConversationId,
+	stopTurn,
 	streamChat,
 } from "./http.js";
 import { buildChatRequest, composeMessage } from "./message.js";
@@ -24,6 +25,7 @@ import { extractLastText, formatConversationList, renderEvent } from "./render.j
 const USAGE = `Usage:
   dispatch models [--server <url>]
   dispatch list [<prefix>] [--status <active|idle|closed>] [--all] [--server <url>]
+  dispatch stop <conversationId> [--server <url>]
   dispatch compact <conversationId> [--server <url>]
   dispatch read <conversationId> [--server <url>]
   dispatch open <conversationId> [--server <url>]
@@ -99,6 +101,26 @@ async function main(): Promise<void> {
 			);
 			break;
 		}
+		case "stop": {
+			const resolved = await resolveConversationId(
+				{ fetchImpl: globalThis.fetch },
+				{ server: parsed.server, shortId: parsed.conversationId },
+			);
+			if (typeof resolved !== "string") {
+				process.stderr.write(`${resolved.error}\n`);
+				process.exit(1);
+			}
+			const result = await stopTurn(
+				{ fetchImpl: globalThis.fetch },
+				{ server: parsed.server, conversationId: resolved },
+			);
+			process.stdout.write(
+				result.abortedTurn
+					? `Stopped generation for ${resolved}\n`
+					: `No active generation for ${resolved}\n`,
+			);
+			break;
+		}
 		case "open": {
 			const resolved = await resolveConversationId(
 				{ fetchImpl: globalThis.fetch },
-- 
cgit v1.2.3