test: wait for qqbot queue drain · openclaw/openclaw@d0347f9
steipete
·
2026-05-12
·
via Recent Commits to openclaw:main
File tree
extensions/qqbot/src/engine/gateway
| Original file line number | Diff line number | Diff line change |
|---|
|
1 | | -import { describe, expect, it } from "vitest"; |
| 1 | +import { describe, expect, it, vi } from "vitest"; |
2 | 2 | import { createMessageQueue, mergeGroupMessages, type QueuedMessage } from "./message-queue.js"; |
3 | 3 | |
4 | 4 | function groupMsg(overrides: Partial<QueuedMessage> = {}): QueuedMessage { |
@@ -206,7 +206,9 @@ describe("engine/gateway/message-queue", () => {
|
206 | 206 | throw new Error("Expected QQBot queue gate callback to be initialized"); |
207 | 207 | } |
208 | 208 | gate(); |
209 | | -await new Promise((res) => setTimeout(res, 0)); |
| 209 | +await vi.waitFor(() => { |
| 210 | +expect(seen.length).toBeGreaterThan(1); |
| 211 | +}); |
210 | 212 | const seenIds = seen.map((m) => m.messageId); |
211 | 213 | expect(seenIds).toContain("First"); |
212 | 214 | // The bot message should NOT have been processed — it was evicted. |
|
此内容由惯性聚合(RSS阅读器)自动聚合整理,仅供阅读参考。 原文来自 — 版权归原作者所有。