Merge pull request #60 from LAN-SHH/fix/qq-c2c-markdown-replies

fix(qq): deliver C2C replies as markdown

src/channels/qq/qq-bridge.mjs

@@ -776,16 +776,8 @@ export class QqHarnessBridge {
       const content = hasImages
         ? await promptContentForMessage(promptMessage, { signal: this.#signal })
         : undefined;
-      // QQ C2C keeps one stream bubble. Progress is collected but never submitted:
+      // QQ stream_messages can acknowledge a final frame without rendering it in
-      // some clients reject replacing an already visible stream frame, which would
+      // some C2C clients. Standard Markdown delivery is the reliable reply path.
-      // otherwise leave a stale progress bubble plus a separate fallback answer.
-      if (message.kind === 'c2c' && target?.msgId && typeof this.#bot.openStream === 'function') {
-        try {
-          stream = this.#bot.openStream({ target });
-        } catch (error) {
-          this.#logger.warn?.('[dsh-im:qq] unable to start a QQ stream; using markdown fallback:', error);
-        }
-      }
       const toolErrors = [];
       let answer;
       let artifacts = [];

test/channels/qq/bridge.test.mjs

@@ -808,18 +808,14 @@ test('QQ remembers any authorized private inbound as a connection-test target',
   assert.equal(sent.length, 2);
 });
 
-test('QQ private messages produce one final stream bubble', async () => {
+test('QQ private messages deliver the final answer as Markdown without opening a stream', async () => {
   const sent = [];
-  const frames = [];
+  let streamCalls = 0;
   const seen = new Set();
   const bridge = new QqHarnessBridge({
     bot: {
       sendText: async (_target, text) => sent.push(text),
-      openStream: () => ({
+      openStream: () => { streamCalls += 1; },
-        update: async (text) => frames.push(text),
-        complete: async () => frames.push('DONE'),
-        cancel() {},
-      }),
     },
     ownerUserOpenid: 'owner-openid',
     harness: {
@@ -843,45 +839,12 @@ test('QQ private messages produce one final stream bubble', async () => {
   });
 
   await bridge.accept(message());
-  assert.deepEqual(frames, ['最终回答', 'DONE']);
+  assert.deepEqual(sent, ['最终回答']);
-  assert.deepEqual(sent, []);
+  assert.equal(streamCalls, 0);
   assert.equal(seen.has('msg-1'), true);
   assert.equal(bridge.status.messagesReplied, 1);
 });
 
-test('QQ does not duplicate a visible private answer when stream completion fails', async () => {
-  const frames = [];
-  const sent = [];
-  const bridge = new QqHarnessBridge({
-    bot: {
-      sendText: async (_target, text) => sent.push(text),
-      openStream: () => ({
-        update: async (text) => frames.push(text),
-        complete: async () => { throw new Error('already submitted'); },
-        cancel() {},
-      }),
-    },
-    ownerUserOpenid: 'owner-openid',
-    harness: {
-      sessionExists: async () => true,
-      ask: async () => '最终回答',
-    },
-    state: {
-      hasSeen: () => false,
-      markSeen: async () => {},
-      sessionFor: () => 'session-stream-complete-failure',
-      setSession: async () => {},
-      clearSession: async () => {},
-    },
-    logger: { warn() {}, error() {} },
-  });
-
-  await bridge.accept(message({ messageId: 'msg-stream-complete-failure' }));
-  assert.deepEqual(frames, ['最终回答']);
-  assert.deepEqual(sent, []);
-  assert.equal(bridge.status.messagesReplied, 1);
-});
-
 test('QQ group messages suppress every successful progress update', async () => {
   const sent = [];
   let streamCalls = 0;