H3CoF6
8fbddf67bf
* feat(onebot): implement send tuwen ark * test: add unit tests for send_ark action * test(onebot): update canonical action docs count expectation to 191 * refactor(protocol,onebot): update 0xdc2_34 ark implementation and test coverage - Rename action send_ark -> send_tuwen_ark to distinguish from structmsg and contact-share arks. - Clarify SSO command mapping (OidbSvcTrpcTcp.0xdc2_34) and default param behavior in comments/docs. - Adjust peerType, field3, and previewUrl to pb_optional to preserve 0/empty values during proton encoding. - Update OneBot handler, tests, and auto-generated MCP tool catalog specs. * style(protocol): fix indentation in rich-body-decoder tests
98 lines
2.3 KiB
TypeScript
98 lines
2.3 KiB
TypeScript
import type { PacketInfo } from '@snowluma/common/protocol-types';
|
|
import {
|
|
protobuf_encode,
|
|
type pb,
|
|
type pb_repeated,
|
|
type uint_32,
|
|
} from '@snowluma/proton';
|
|
import { describe, expect, it } from 'vitest';
|
|
|
|
import type { IdentityService } from '../../src/identity-service';
|
|
import { parseMsgPush } from '../../src/msg-push';
|
|
|
|
interface TextFixture {
|
|
str?: pb<1, string>;
|
|
}
|
|
|
|
interface ElemFixture {
|
|
text?: pb<1, TextFixture>;
|
|
}
|
|
|
|
interface RichTextFixture {
|
|
elems?: pb_repeated<2, ElemFixture>;
|
|
}
|
|
|
|
interface MessageBodyFixture {
|
|
richText?: pb<1, RichTextFixture>;
|
|
}
|
|
|
|
interface TempSessionFixture {
|
|
previousGroup?: pb<4, uint_32>;
|
|
sourceGroup?: pb<5, uint_32>;
|
|
}
|
|
|
|
interface ResponseHeadFixture {
|
|
fromUin?: pb<1, uint_32>;
|
|
fromUid?: pb<2, string>;
|
|
tempSession?: pb<7, TempSessionFixture>;
|
|
}
|
|
|
|
interface ContentHeadFixture {
|
|
msgType?: pb<1, uint_32>;
|
|
sequence?: pb<5, uint_32>;
|
|
timestamp?: pb<6, uint_32>;
|
|
ntMsgSeq?: pb<11, uint_32>;
|
|
}
|
|
|
|
interface PushBodyFixture {
|
|
responseHead?: pb<1, ResponseHeadFixture>;
|
|
contentHead?: pb<2, ContentHeadFixture>;
|
|
body?: pb<3, MessageBodyFixture>;
|
|
}
|
|
|
|
interface PushFixture {
|
|
message?: pb<1, PushBodyFixture>;
|
|
}
|
|
|
|
const identity = { findFriend: () => undefined } as unknown as IdentityService;
|
|
|
|
function tempMessagePacket(previousGroup: number, sourceGroup: number): PacketInfo {
|
|
return {
|
|
pid: 1,
|
|
uin: '2000000001',
|
|
serviceCmd: 'trpc.msg.olpush.OlPushService.MsgPush',
|
|
seqId: 1,
|
|
retCode: 0,
|
|
fromClient: false,
|
|
body: protobuf_encode<PushFixture>({
|
|
message: {
|
|
responseHead: {
|
|
fromUin: 10001,
|
|
fromUid: 'u_peer',
|
|
tempSession: { previousGroup, sourceGroup },
|
|
},
|
|
contentHead: {
|
|
msgType: 141,
|
|
sequence: 7,
|
|
timestamp: 1_710_000_000,
|
|
ntMsgSeq: 8,
|
|
},
|
|
body: { richText: { elems: [{ text: { str: 'hello' } }] } },
|
|
},
|
|
}),
|
|
};
|
|
}
|
|
|
|
describe('parseMsgPush — temporary-session source (#308)', () => {
|
|
it('keeps a passive reply bound to the group that opened the current session', () => {
|
|
const events = parseMsgPush(tempMessagePacket(11111, 22222), identity);
|
|
|
|
expect(events).toMatchObject([{
|
|
kind: 'temp_message',
|
|
senderUin: 10001,
|
|
groupId: 22222,
|
|
elements: [{ type: 'text', text: 'hello' }],
|
|
}]);
|
|
});
|
|
});
|