Console mode support

agents/src/cli.ts

@@ -220,5 +220,51 @@ export const runApp = (opts: WorkerOptions) => {
         });
     });
 
+  program
+    .command('console')
+    .description('Start a new conversation inside the console')
+    .action(async () => {
+      const options = program.optsWithGlobals();
+      initializeLogger({ pretty: true, level: options.logLevel });
+      const logger = log();
+
+      if (!process.env.LIVEKIT_ENABLE_CONSOLE_MODE) {
+        logger.fatal('Console mode is disabled. Set LIVEKIT_ENABLE_CONSOLE_MODE=true to enable.');
+        process.exit(1);
+      }
+
+      try {
+        const mod = await import(new URL(opts.agent, import.meta.url).href);
+        const agentDef = mod?.default;
+
+        if (!agentDef?.entry) {
+          logger.fatal('default export must have an entry() function');
+          process.exit(1);
+        }
+
+        const { CurrentJobContext } = await import('./job.js');
+
+        const mockCtx = {
+          room: undefined,
+          proc: { userData: {} },
+          connect: async () => {},
+          inferenceExecutor: {
+            doInference: async () => ({}), // Mock inference executor for now to keep things simple
+          },
+        };
+
+        new CurrentJobContext(mockCtx as any);
+
+        if (agentDef.prewarm) {
+          await agentDef.prewarm(mockCtx.proc as any);
+        }
+
+        await agentDef.entry(mockCtx as any);
+      } catch (error) {
+        logger.fatal(error);
+        process.exit(1);
+      }
+    });
+
   program.parse();
 };

agents/src/voice/agent_session.ts

@@ -169,7 +169,7 @@ export class AgentSession<
     outputOptions,
   }: {
     agent: Agent;
-    room: Room;
+    room?: Room;
     inputOptions?: Partial<RoomInputOptions>;
     outputOptions?: Partial<RoomOutputOptions>;
   }): Promise<void> {
@@ -180,30 +180,38 @@ export class AgentSession<
     this.agent = agent;
     this._updateAgentState('initializing');
 
-    // Check for existing input/output configuration and warn if needed
-    if (this.input.audio && inputOptions?.audioEnabled !== false) {
-      this.logger.warn('RoomIO audio input is enabled but input.audio is already set, ignoring..');
-    }
+    if (!room) {
+      const { ChatCLI } = await import('./chat_cli.js');
+      const chatCli = new ChatCLI(this);
+      await chatCli.start();
+    } else {
+      // Room mode
+      if (this.input.audio && inputOptions?.audioEnabled !== false) {
+        this.logger.warn(
+          'RoomIO audio input is enabled but input.audio is already set, ignoring..',
+        );
+      }
 
-    if (this.output.audio && outputOptions?.audioEnabled !== false) {
-      this.logger.warn(
-        'RoomIO audio output is enabled but output.audio is already set, ignoring..',
-      );
-    }
+      if (this.output.audio && outputOptions?.audioEnabled !== false) {
+        this.logger.warn(
+          'RoomIO audio output is enabled but output.audio is already set, ignoring..',
+        );
+      }
 
-    if (this.output.transcription && outputOptions?.transcriptionEnabled !== false) {
-      this.logger.warn(
-        'RoomIO transcription output is enabled but output.transcription is already set, ignoring..',
-      );
-    }
+      if (this.output.transcription && outputOptions?.transcriptionEnabled !== false) {
+        this.logger.warn(
+          'RoomIO transcription output is enabled but output.transcription is already set, ignoring..',
+        );
+      }
 
-    this.roomIO = new RoomIO({
-      agentSession: this,
-      room,
-      inputOptions,
-      outputOptions,
-    });
-    this.roomIO.start();
+      this.roomIO = new RoomIO({
+        agentSession: this,
+        room,
+        inputOptions,
+        outputOptions,
+      });
+      this.roomIO.start();
+    }
 
     this.updateActivity(this.agent);