fix(qqbot): streaming improvements — idle flush, remove splitText, replyMsgId TTL, markdown pipe

docs/superpowers/plans/2026-06-30-channel-loop.md

@@ -29,6 +29,7 @@
 ## Task 1: Core Exports And Store
 
 **Files:**
+
 - Modify: `packages/core/src/index.ts`
 - Modify: `packages/channels/base/src/paths.ts`
 - Create: `packages/channels/base/src/ChannelLoopStore.ts`
@@ -80,7 +81,9 @@ describe('ChannelLoopStore', () => {
       runCount: 0,
       createdAt: '2026-06-30T09:00:00.000Z',
     });
-    await expect(store.listForTarget('telegram-main', target)).resolves.toHaveLength(1);
+    await expect(
+      store.listForTarget('telegram-main', target),
+    ).resolves.toHaveLength(1);
   });
 
   it('enforces target quotas atomically through createForTarget', async () => {
@@ -100,32 +103,37 @@ describe('ChannelLoopStore', () => {
       createdBy: 'Alice',
     };
 
-    await expect(store.createForTarget(input, 1)).resolves.toMatchObject({ id: 'loop-1' });
+    await expect(store.createForTarget(input, 1)).resolves.toMatchObject({
+      id: 'loop-1',
+    });
     await expect(store.createForTarget(input, 1)).resolves.toBeUndefined();
   });
 
   it('loads pre-lifecycle loop JSON with runCount defaulted to 0', async () => {
     const dir = await mkdtemp(join(tmpdir(), 'channel-loop-legacy-'));
     const filePath = join(dir, 'loops.json');
-    await writeFile(filePath, JSON.stringify([
-      {
-        id: 'loop-legacy',
-        channelName: 'telegram-main',
-        target,
-        cwd: '/repo',
-        cron: '0 9 * * *',
-        prompt: 'post summary',
-        recurring: true,
-        enabled: true,
-        createdBy: 'Alice',
-        createdAt: '2026-06-30T09:00:00.000Z',
-        consecutiveFailures: 0,
-      },
-    ]));
-
-    await expect(new ChannelLoopStore({ filePath }).list()).resolves.toMatchObject([
-      { id: 'loop-legacy', runCount: 0 },
-    ]);
+    await writeFile(
+      filePath,
+      JSON.stringify([
+        {
+          id: 'loop-legacy',
+          channelName: 'telegram-main',
+          target,
+          cwd: '/repo',
+          cron: '0 9 * * *',
+          prompt: 'post summary',
+          recurring: true,
+          enabled: true,
+          createdBy: 'Alice',
+          createdAt: '2026-06-30T09:00:00.000Z',
+          consecutiveFailures: 0,
+        },
+      ]),
+    );
+
+    await expect(
+      new ChannelLoopStore({ filePath }).list(),
+    ).resolves.toMatchObject([{ id: 'loop-legacy', runCount: 0 }]);
   });
 
   it('refuses corrupt JSON instead of treating it as empty state', async () => {
@@ -334,7 +342,9 @@ export class ChannelLoopStore {
     }
     for (const [index, value] of parsed.entries()) {
       if (!isChannelLoop(value)) {
-        throw new Error(`Invalid channel loop at index ${index} in ${this.filePath}.`);
+        throw new Error(
+          `Invalid channel loop at index ${index} in ${this.filePath}.`,
+        );
       }
     }
     return parsed.map(normalizeLoop);
@@ -401,7 +411,8 @@ function isChannelLoop(value: unknown): value is ChannelLoop {
     (loop['lastStatus'] === undefined ||
       loop['lastStatus'] === 'ok' ||
       loop['lastStatus'] === 'error') &&
-    (loop['lastError'] === undefined || typeof loop['lastError'] === 'string') &&
+    (loop['lastError'] === undefined ||
+      typeof loop['lastError'] === 'string') &&
     typeof loop['consecutiveFailures'] === 'number' &&
     (loop['runningSince'] === undefined ||
       typeof loop['runningSince'] === 'string') &&
@@ -430,7 +441,11 @@ Export from `index.ts` and export cron helpers from `packages/core/src/index.ts`
 
 ```ts
 export { ChannelLoopStore } from './ChannelLoopStore.js';
-export type { ChannelLoop, ChannelLoopInput, ChannelLoopPatch } from './ChannelLoopStore.js';
+export type {
+  ChannelLoop,
+  ChannelLoopInput,
+  ChannelLoopPatch,
+} from './ChannelLoopStore.js';
 export { channelLoopPath } from './paths.js';
 export { nextFireTime, parseCron } from './utils/cronParser.js';
 ```
@@ -448,6 +463,7 @@ Expected: all tests pass.
 ## Task 2: Channel Loop Scheduler
 
 **Files:**
+
 - Create: `packages/channels/base/src/ChannelLoopScheduler.ts`
 - Create: `packages/channels/base/src/ChannelLoopScheduler.test.ts`
 - Modify: `packages/channels/base/src/index.ts`
@@ -509,6 +525,7 @@ Expected: all tests pass.
 ## Task 3: ChannelBase `/loop` Command Surface
 
 **Files:**
+
 - Modify: `packages/channels/base/src/ChannelBase.ts`
 - Modify: `packages/channels/base/src/ChannelBase.test.ts`
 
@@ -541,8 +558,14 @@ Add:
 ```ts
 export interface ChannelLoopController {
   create(input: ChannelLoopInput): Promise<ChannelLoop>;
-  createForTarget?(input: ChannelLoopInput, maxEnabledLoops: number): Promise<ChannelLoop | undefined>;
-  listForTarget(channelName: string, target: SessionTarget): Promise<ChannelLoop[]>;
+  createForTarget?(
+    input: ChannelLoopInput,
+    maxEnabledLoops: number,
+  ): Promise<ChannelLoop | undefined>;
+  listForTarget(
+    channelName: string,
+    target: SessionTarget,
+  ): Promise<ChannelLoop[]>;
   disable(id: string): Promise<boolean>;
   validateCron(cron: string): void;
   nextFireTime?(loop: ChannelLoop): Date;
@@ -611,6 +634,7 @@ Expected: all ChannelBase tests pass.
 ## Task 4: Loop Prompt Execution
 
 **Files:**
+
 - Modify: `packages/channels/base/src/ChannelBase.ts`
 - Modify: `packages/channels/base/src/ChannelBase.test.ts`
 
@@ -671,6 +695,7 @@ Expected: all ChannelBase tests pass.
 ## Task 5: Adapter Opt-In
 
 **Files:**
+
 - Modify: `packages/channels/telegram/src/TelegramAdapter.ts`
 - Modify: `packages/channels/telegram/src/TelegramAdapter.test.ts`
 - Modify: `packages/channels/feishu/src/FeishuAdapter.ts`
@@ -715,6 +740,7 @@ Expected: all adapter tests pass.
 ## Task 6: CLI Startup Wiring
 
 **Files:**
+
 - Modify: `packages/cli/src/commands/channel/start.ts`
 - Modify: `packages/cli/src/commands/channel/start.test.ts`
 
@@ -787,6 +813,7 @@ Expected: all CLI start tests pass.
 ## Task 7: Verification And PR
 
 **Files:**
+
 - Modify: `.qwen/pr-drafts/channel-loop.md`
 
 - [ ] **Step 1: Run focused verification**

docs/users/features/channels/qqbot.md

@@ -62,7 +62,7 @@ export QQ_APP_SECRET=<your-app-secret>
       "senderPolicy": "open",
       "sessionScope": "user",
       "cwd": "/path/to/your/project",
-      "instructions": "你是一个通过 QQ Bot 对话的 AI 助手。回复控制在 2000 字符以内。",
+      "instructions": "你是一个通过 QQ Bot 对话的 AI 助手。",
       "blockStreaming": "on",
       "groupPolicy": "disabled",
       "groups": {

packages/channels/base/src/index.ts

@@ -47,8 +47,8 @@ export type { SenderCheckResult } from './SenderGate.js';
 export { SessionRouter } from './SessionRouter.js';
 export {
   sanitizeSenderName,
-  sanitizePromptText,
   sanitizeLogText,
+  sanitizePromptText,
 } from './sanitize.js';
 export type {
   Attachment,

packages/channels/base/src/sanitize.ts

@@ -72,6 +72,10 @@ export function sanitizePromptText(text: string): string {
   return (
     text
       .replace(PROMPT_UNSAFE_INVISIBLES, ' ')
+      // Strip injection-style bracket tags like [SYSTEM]: only at the
+      // start of a line (possibly indented with spaces/tabs) — not mid-
+      // sentence brackets like "see [docs] please". The m flag makes ^
+      // match after each line break.
       .replace(/^([ \t]*)\[([^\]\r\n]{1,64})\](:?)/gm, '$1$2$3')
       // Fold ASCII C0/DEL, including CR/LF/TAB, so attacker-controlled group
       // text cannot create prompt lines outside the adapter's sender attribution.

packages/channels/feishu/src/adapter.test.ts

@@ -867,9 +867,9 @@ describe('FeishuChannel', () => {
         token: 'tenant-token',
         expiresAt: Date.now() + 3600_000,
       };
-      const fetchSpy = vi.spyOn(global, 'fetch').mockResolvedValue(
-        new Response('{}', { status: 200 }),
-      );
+      const fetchSpy = vi
+        .spyOn(global, 'fetch')
+        .mockResolvedValue(new Response('{}', { status: 200 }));
 
       await channel.pushLoop(
         {