feat: add per-chat verbose controls

Author: MackDing

README.md

@@ -133,6 +133,7 @@ General:
 - `/auto <task>` - force a one-off `codex exec --full-auto`
 - `/plan <task>` - ask Codex for a plan only, without direct file modification intent
 - `/model [name|reset]` - show or set the model override for the current chat
+- `/verbose [on|off]` - show or toggle system notices for the current chat
 - `/skill list` - show skill switches for the current chat
 - `/skill status` - alias of `/skill list`
 - `/skill on <name>` - enable a skill for the current chat
@@ -175,6 +176,7 @@ Telegram adaptation notes:
 - `/sh` is implemented by the bot, never invokes a shell interpreter, and only accepts configured command prefixes
 - `/sh` is read-only by default; dangerous prefixes can be configured and require `--confirm` when writable mode is enabled
 - `/plan` translates to a planning-only prompt instead of passing a raw `/plan` slash command to Codex
+- `/verbose off` keeps Telegram output quiet by hiding fallback, startup, and session-exit notices for the current chat
 
 ## Streaming and Reasoning Visualization
 

src/bot/handlers.js

@@ -108,6 +108,7 @@ export function registerHandlers({
         "/auto <task> - 强制用 codex exec --full-auto 运行任务",
         "/plan <task> - 仅生成执行计划，不直接修改代码",
         "/model [name|reset] - 查看或设置当前 chat 的模型",
+        "/verbose [on|off] - 查看或切换系统提示输出",
         "/skill list - 查看当前 chat 的 skill 开关",
         "/skill status - 同 /skill list",
         "/skill on <name> - 启用 skill",
@@ -140,6 +141,7 @@ export function registerHandlers({
           status.ptySupported === null ? "unknown" : status.ptySupported ? "yes" : "no (exec fallback)"
         }`,
         `preferred model: ${status.preferredModel || "inherit codex default"}`,
+        `verbose: ${status.verboseOutput ? "on" : "off"}`,
         `command: ${status.command}`,
         `workspace root: ${status.workspaceRoot}`,
         `workdir: ${status.workdir}`,
@@ -506,6 +508,31 @@ export function registerHandlers({
     );
   });
 
+  bot.command("verbose", async (ctx) => {
+    const value = extractCommandPayload(ctx.message.text, "verbose");
+    if (!value) {
+      await sendChunkedMarkdown(
+        ctx,
+        `当前系统提示输出: ${ptyManager.isVerbose(ctx.chat.id) ? "on" : "off"}`
+      );
+      return;
+    }
+
+    if (/^(on|true|1)$/i.test(value)) {
+      ptyManager.setVerbose(ctx.chat.id, true);
+      await sendChunkedMarkdown(ctx, "系统提示输出已开启。");
+      return;
+    }
+
+    if (/^(off|false|0)$/i.test(value)) {
+      ptyManager.setVerbose(ctx.chat.id, false);
+      await sendChunkedMarkdown(ctx, "系统提示输出已关闭。");
+      return;
+    }
+
+    await sendChunkedMarkdown(ctx, "用法: /verbose [on|off]");
+  });
+
   bot.command("interrupt", async (ctx) => {
     const ok = ptyManager.interrupt(ctx.chat.id);
     await sendChunkedMarkdown(ctx, ok ? "已发送 Ctrl+C。" : "当前 chat 没有活动 PTY 会话。");

src/runner/ptyManager.js

@@ -36,6 +36,7 @@ export class PtyManager {
 
     const state = {
       preferredModel: null,
+      verboseOutput: false,
       currentWorkdir: this.config.runner.cwd,
       recentWorkdirs: [this.config.runner.cwd],
       ptySupported: null,
@@ -83,6 +84,18 @@ export class PtyManager {
     return args;
   }
 
+  isVerbose(chatId) {
+    const state = this.ensureChatState(chatId);
+    return Boolean(state.verboseOutput);
+  }
+
+  setVerbose(chatId, enabled) {
+    const state = this.ensureChatState(chatId);
+    state.verboseOutput = Boolean(enabled);
+    this.onChange?.(this.exportState());
+    return state.verboseOutput;
+  }
+
   getWorkdir(chatId) {
     const state = this.ensureChatState(chatId);
     return state.currentWorkdir || this.config.runner.cwd;
@@ -305,12 +318,14 @@ export class PtyManager {
       this.onChange?.(this.exportState());
 
       this.enqueueFlush(session.chatId);
-      await this.bot.telegram
-        .sendMessage(
-          session.chatId,
-          `Codex session exited (mode=${session.mode}, code=${exitCode}, signal=${signal}).`
-        )
-        .catch(() => {});
+      if (this.isVerbose(session.chatId)) {
+        await this.bot.telegram
+          .sendMessage(
+            session.chatId,
+            `Codex session exited (mode=${session.mode}, code=${exitCode}, signal=${signal}).`
+          )
+          .catch(() => {});
+      }
       session.throttledFlush?.cancel();
       this.sessions.delete(session.chatId);
     });
@@ -480,7 +495,7 @@ export class PtyManager {
         trackConversation: false
       });
 
-      if (options.notice) {
+      if (options.notice && this.isVerbose(chatId)) {
         await this.bot.telegram.sendMessage(chatId, options.notice);
       }
 
@@ -527,12 +542,14 @@ export class PtyManager {
         workdir: this.getWorkdir(chatId),
         resumeSessionId: projectState.lastSessionId || ""
       });
-      await this.bot.telegram.sendMessage(
-        chatId,
-        projectState.lastSessionId
-          ? "PTY unavailable on this host. Restoring the current project's Codex conversation in `codex exec resume` mode."
-          : "PTY unavailable on this host. Falling back to `codex exec` mode for this request."
-      );
+      if (this.isVerbose(chatId)) {
+        await this.bot.telegram.sendMessage(
+          chatId,
+          projectState.lastSessionId
+            ? "PTY unavailable on this host. Restoring the current project's Codex conversation in `codex exec resume` mode."
+            : "PTY unavailable on this host. Falling back to `codex exec` mode for this request."
+        );
+      }
       return {
         started: true,
         mode: "exec",
@@ -541,7 +558,7 @@ export class PtyManager {
       };
     }
 
-    if (!session.streamMessageIds.length) {
+    if (!session.streamMessageIds.length && this.isVerbose(chatId)) {
       const sent = await this.bot.telegram.sendMessage(
         chatId,
         projectState.lastSessionId
@@ -647,6 +664,7 @@ export class PtyManager {
 
       chats[chatId] = {
         preferredModel: state.preferredModel,
+        verboseOutput: Boolean(state.verboseOutput),
         currentWorkdir: this.serializeWorkdir(state.currentWorkdir),
         recentWorkdirs: (state.recentWorkdirs || []).map((workdir) => this.serializeWorkdir(workdir)),
         projects
@@ -704,6 +722,7 @@ export class PtyManager {
 
       this.chatState.set(String(chatId), {
         preferredModel: rawState?.preferredModel?.trim?.() || null,
+        verboseOutput: Boolean(rawState?.verboseOutput),
         currentWorkdir,
         recentWorkdirs: [currentWorkdir, ...recentWorkdirs.filter((workdir) => workdir !== currentWorkdir)].slice(0, 6),
         ptySupported: null,
@@ -726,6 +745,7 @@ export class PtyManager {
       lastExitSignal: projectState.lastExitSignal,
       projectSessionId: projectState.lastSessionId || null,
       preferredModel: state.preferredModel,
+      verboseOutput: Boolean(state.verboseOutput),
       ptySupported: state.ptySupported,
       workdir: this.getWorkdir(key),
       relativeWorkdir: this.getRelativeWorkdir(key),

tests/ptyManager.test.js

@@ -8,11 +8,13 @@ import { PtyManager } from "../src/runner/ptyManager.js";
 function createManager(overrides = {}) {
   const runnerCwd = overrides.runnerCwd || process.cwd();
   const workspaceRoot = overrides.workspaceRoot || runnerCwd;
+  const telegram =
+    overrides.telegram || {
+      sendMessage: async () => ({})
+    };
   return new PtyManager({
     bot: {
-      telegram: {
-        sendMessage: async () => ({})
-      }
+      telegram
     },
     config: {
       runner: {
@@ -48,6 +50,15 @@ test("pty manager stores model preference per chat", () => {
   assert.equal(manager.getStatus(123).preferredModel, null);
 });
 
+test("pty manager stores verbose preference per chat", () => {
+  const manager = createManager();
+
+  assert.equal(manager.isVerbose(123), false);
+  manager.setVerbose(123, true);
+  assert.equal(manager.isVerbose(123), true);
+  assert.equal(manager.getStatus(123).verboseOutput, true);
+});
+
 test("pty manager status exposes runner workdir and MCP server names", () => {
   const manager = createManager();
   const status = manager.getStatus(456);
@@ -185,3 +196,61 @@ test("pty manager exports and restores per-project conversation state", () => {
   restored.switchWorkdir(99, "project-a");
   assert.equal(restored.getStatus(99).projectSessionId, "aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa");
 });
+
+test("pty manager exports and restores verbose preference", () => {
+  const manager = createManager();
+  manager.setVerbose(42, true);
+
+  const restored = createManager();
+  restored.restoreState(manager.exportState());
+
+  assert.equal(restored.isVerbose(42), true);
+});
+
+test("pty manager hides exec fallback notices when verbose output is off", async () => {
+  const sentMessages = [];
+  const manager = createManager({
+    telegram: {
+      sendMessage: async (chatId, text) => {
+        sentMessages.push({ chatId, text });
+        return { message_id: sentMessages.length };
+      }
+    }
+  });
+
+  manager.ensureSession = () => null;
+  manager.startExecSessionWithOptions = () => ({
+    mode: "exec",
+    streamMessageIds: [],
+    chatId: "77"
+  });
+
+  await manager.sendPrompt({ chat: { id: 77 } }, "who are u");
+
+  assert.equal(sentMessages.length, 0);
+});
+
+test("pty manager shows exec fallback notices when verbose output is on", async () => {
+  const sentMessages = [];
+  const manager = createManager({
+    telegram: {
+      sendMessage: async (chatId, text) => {
+        sentMessages.push({ chatId, text });
+        return { message_id: sentMessages.length };
+      }
+    }
+  });
+
+  manager.setVerbose(77, true);
+  manager.ensureSession = () => null;
+  manager.startExecSessionWithOptions = () => ({
+    mode: "exec",
+    streamMessageIds: [],
+    chatId: "77"
+  });
+
+  await manager.sendPrompt({ chat: { id: 77 } }, "who are u");
+
+  assert.equal(sentMessages.length, 1);
+  assert.match(sentMessages[0].text, /PTY unavailable/);
+});

tests/runtimeStateStore.test.js

@@ -23,6 +23,7 @@ test("runtime state store saves and loads MCP and skill state", async () => {
     runner: {
       chats: {
         "42": {
+          verboseOutput: true,
           currentWorkdir: "project-a",
           recentWorkdirs: ["project-a", "project-b"],
           projects: {
@@ -50,6 +51,7 @@ test("runtime state store saves and loads MCP and skill state", async () => {
   assert.deepEqual(state.runner, {
     chats: {
       "42": {
+        verboseOutput: true,
         currentWorkdir: "project-a",
         recentWorkdirs: ["project-a", "project-b"],
         projects: {