summaryrefslogtreecommitdiffhomepage
path: root/packages/cli/src/main.ts
diff options
context:
space:
mode:
authorAdam Malczewski <[email protected]>2026-06-22 02:53:20 +0900
committerAdam Malczewski <[email protected]>2026-06-22 02:53:20 +0900
commit20db60b0705ab65b6ade67ff614d347e13dc9803 (patch)
tree02361b6b94d6a397355b42e7208b1c3ba39fb692 /packages/cli/src/main.ts
parentd233842752d32659bba6f0e47b536e50d03145aa (diff)
downloaddispatch-20db60b0705ab65b6ade67ff614d347e13dc9803.tar.gz
dispatch-20db60b0705ab65b6ade67ff614d347e13dc9803.zip
feat: stop generation mid-turn (POST /conversations/:id/stop)
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
Diffstat (limited to 'packages/cli/src/main.ts')
-rw-r--r--packages/cli/src/main.ts22
1 files changed, 22 insertions, 0 deletions
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 },