hansjone/dsh-im-ops
1
0
Fork 0
mirror of https://github.com/hansjone/dsh-im-ops.git synced 2026-10-09 03:03:24 +08:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(qq): deliver C2C replies as markdown

Browse source
This commit is contained in:
LAN-SHH 2026-08-25 21:52:49 +08:00
parent 892e18db77
commit 9d3700b1cd
3 changed files with 8 additions and 53 deletions
Download patch file Download diff file Expand all files Collapse all files

47
test/channels/qq/bridge.test.mjs
View file

@ -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: () => ({
update: async (text) => frames.push(text),
complete: async () => frames.push('DONE'),
cancel() {},
}),
openStream: () => { streamCalls += 1; },
},
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;