Adds an agent swarm / multi-agent execution mode to Step-Realtime-CLI, plus related cleanups.

knip.config.ts

@@ -38,7 +38,16 @@ const config: KnipConfig = {
     // (see realtime-vad-silero/silero-adapter.ts); knip can't see the indirect
     // specifier.
     "avr-vad",
+    // @step-cli/agent-sdk is consumed by extensions/realtime-voice (not matched by
+    // the root workspace's src/**/*.ts project glob), so knip flags it as unused
+    // from the root perspective even though it is a valid workspace dependency.
+    "@step-cli/agent-sdk",
   ],
+  ignoreIssues: {
+    // rg (ripgrep) is an external system binary spawned by shell-tools.ts;
+    // not a Node.js package binary declared in package.json.
+    "packages/core/src/tools/native-impls/shell-tools.ts": ["binaries"],
+  },
   ignoreExportsUsedInFile: true,
   treatConfigHintsAsErrors: false,
 };

package.json

@@ -40,6 +40,7 @@
   "dependencies": {
     "@opentui/core": "^0.1.90",
     "@opentui/react": "^0.1.90",
+    "@step-cli/agent-sdk": "workspace:*",
     "@step-cli/core": "workspace:*",
     "@step-cli/llm": "workspace:*",
     "@step-cli/mcp": "workspace:*",

packages/core/src/agent/harness.ts

@@ -63,6 +63,7 @@ export interface AgentHarnessOptions {
   allowedTools?: string[];
   hooks?: AgentLoopOptions["hooks"];
   signal?: AbortSignal;
+  model?: string;
 }
 
 export interface AgentHarnessState {
@@ -450,7 +451,7 @@ export class AgentHarnessFactory {
     }
 
     const agent = new AgentLoop({
-      model: this.model,
+      model: options.model ?? this.model,
       client: this.client,
       memory,
       tools,

packages/protocol/src/index.ts

@@ -1065,6 +1065,22 @@ export interface StepCliSessionClarificationSubmissionResult {
   response: UserClarificationResponse;
 }
 
+/**
+ * Result of executing a slash command through the gateway.
+ *
+ * - `handled`: Whether the gateway recognized and handled the command.
+ * - `message`: Human-readable summary of the command result (may be null when
+ *   the gateway already displayed output via the interactive UI).
+ * - `taskText`: When non-null, the caller should submit this text as a regular
+ *   prompt (e.g. `/swarm <task>` enters swarm mode and returns the task text
+ *   for the caller to run through the normal turn queue).
+ */
+export interface StepCliSlashCommandResult {
+  handled: boolean;
+  message: string | null;
+  taskText: string | null;
+}
+
 export interface StepGateway {
   listSessions(): Promise<StepCliSessionDescriptor[]>;
   getSession(sessionId: string): Promise<StepCliSessionDescriptor | null>;
@@ -1122,6 +1138,10 @@ export interface StepGateway {
     prompt: string | UserTurnInput,
     signal?: AbortSignal,
   ): Promise<StepCliSessionRunResult>;
+  executeSlashCommand(
+    sessionId: string,
+    commandLine: string,
+  ): Promise<StepCliSlashCommandResult>;
   getPendingClarification(
     sessionId: string,
   ): Promise<StepCliSessionClarificationResult | null>;

packages/sdk/src/index.ts

@@ -12,6 +12,7 @@ import type {
   StepCliSessionDescriptor,
   StepCliSessionRunResult,
   StepCliSessionSnapshotResult,
+  StepCliSlashCommandResult,
   StepCliSessionWakeReceipt,
   StepCliSessionWakeRequest,
   StepCliStartGoalRequest,
@@ -117,6 +118,13 @@ export class StepCliSdk {
     return await this.gateway.runPrompt(sessionId, prompt, signal);
   }
 
+  async executeSlashCommand(
+    sessionId: string,
+    commandLine: string,
+  ): Promise<StepCliSlashCommandResult> {
+    return await this.gateway.executeSlashCommand(sessionId, commandLine);
+  }
+
   async getPendingClarification(
     sessionId: string,
   ): Promise<StepCliSessionClarificationResult | null> {