Skip to content

feat(message): 实现消息合并 #5878

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: develop
Choose a base branch
from
Open

feat(message): 实现消息合并 #5878

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
245 changes: 245 additions & 0 deletions packages/components/message/__tests__/message.test.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,56 @@ describe('Message', () => {
MessagePlugin.closeAll();
});

it('should reset timer when messages are merged', async () => {
vi.useFakeTimers();
MessagePlugin.closeAll();
await nextTick();

// 发送第一条消息，设置较短的duration
MessagePlugin.info({
content: '定时器测试',
mergeIdentical: true,
duration: 2000, // 2秒后消失
});

await nextTick();

let messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);

// 等待1500ms，第一条消息即将消失
vi.advanceTimersByTime(1500);
await nextTick();

messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);

// 发送第二条相同消息，duration为5000ms，应该重置定时器
MessagePlugin.info({
content: '定时器测试',
mergeIdentical: true,
duration: 5000, // 5秒后消失
});

await nextTick();

// 应该仍然只有1条消息，但计数为2
messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('(×2)');

// 再等待1000ms（总共2500ms），如果定时器没有重置，消息应该已经消失了
// 但是因为定时器被重置为5000ms，所以消息应该还存在
vi.advanceTimersByTime(1000);
await nextTick();

messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1); // 这里应该通过，证明定时器被重置了

vi.useRealTimers();
MessagePlugin.closeAll();
});

it('should create only one instance per placement', async () => {
MessagePlugin.info('msg1', 0);
MessagePlugin.info('msg2', 0);
Expand Down Expand Up @@ -100,5 +150,200 @@ describe('Message', () => {

expect(document.querySelectorAll('.t-message').length).toBe(0);
});

it('should merge identical messages correctly when count > 2', async () => {
MessagePlugin.closeAll();
await nextTick();

// 测试基本的2条消息合并
MessagePlugin.info({
content: '测试合并消息',
mergeIdentical: true,
duration: 0,
});

await nextTick();

MessagePlugin.info({
content: '测试合并消息',
mergeIdentical: true,
duration: 0,
});

await nextTick();

// 检查是否合并为1条消息
const messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('(×2)');

MessagePlugin.closeAll();
});

it('should handle merge with different content correctly', async () => {
MessagePlugin.closeAll();
await nextTick();

// 发送不同内容的消息，不应该合并
MessagePlugin.info({
content: '消息1',
mergeIdentical: true,
duration: 0,
});

MessagePlugin.info({
content: '消息2',
mergeIdentical: true,
duration: 0,
});

await nextTick();

// 应该有2条不同的消息
const messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(2);

MessagePlugin.closeAll();
});

it('should merge multiple identical messages step by step', async () => {
MessagePlugin.closeAll();
await nextTick();

// 逐步发送相同消息并验证每一步
MessagePlugin.info({
content: '步骤测试',
mergeIdentical: true,
duration: 0,
});

await nextTick();

let messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('步骤测试');
expect(messages[0].textContent).not.toContain('×');

// 第2条消息
MessagePlugin.info({
content: '步骤测试',
mergeIdentical: true,
duration: 0,
});

await nextTick();

messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('(×2)');

// 第3条消息
MessagePlugin.info({
content: '步骤测试',
mergeIdentical: true,
duration: 0,
});

await nextTick();

messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('(×3)');

MessagePlugin.closeAll();
});

it('should merge messages with custom merge window', async () => {
vi.useFakeTimers();

MessagePlugin.closeAll();
await nextTick();

// 发送第一条消息
MessagePlugin.info({
content: '长窗口合并测试',
mergeIdentical: true,
mergeWindow: 2000,
duration: 0,
});

await nextTick();

// 1.5秒后发送第二条相同消息，应该能合并
vi.advanceTimersByTime(1500);
MessagePlugin.info({
content: '长窗口合并测试',
mergeIdentical: true,
mergeWindow: 2000,
duration: 0,
});

await nextTick();
vi.runOnlyPendingTimers();
await nextTick();

// 应该只有1条消息（合并后的）
const messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('(×2)');

vi.useRealTimers();
MessagePlugin.closeAll();
});

it('should not merge messages with different themes', async () => {
MessagePlugin.closeAll();
await nextTick();

// 发送相同内容但不同主题的消息
MessagePlugin.info({
content: '相同内容不同主题',
mergeIdentical: true,
duration: 0,
});

MessagePlugin.error({
content: '相同内容不同主题',
mergeIdentical: true,
duration: 0,
});

await nextTick();

// 应该有2条消息（不同主题不合并）
const messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(2);

MessagePlugin.closeAll();
});

it('should merge messages with custom merge key', async () => {
MessagePlugin.closeAll();
await nextTick();

// 发送不同内容但相同 mergeKey 的消息
MessagePlugin.info({
content: '消息内容1',
mergeKey: 'custom-key',
mergeIdentical: true,
duration: 0,
});

MessagePlugin.warning({
content: '消息内容2',
mergeKey: 'custom-key',
mergeIdentical: true,
duration: 0,
});

await nextTick();

// 应该只有1条消息（相同 mergeKey 会合并）
const messages = document.querySelectorAll('.t-message');
expect(messages.length).toBe(1);
expect(messages[0].textContent).toContain('(×2)');

MessagePlugin.closeAll();
});
});
});
Loading
Loading