惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

Hugging Face - Blog
Hugging Face - Blog
GbyAI
GbyAI
Engineering at Meta
Engineering at Meta
有赞技术团队
有赞技术团队
博
博客园 - 【当耐特】
H
Hackread – Cybersecurity News, Data Breaches, AI and More
WordPress大学
WordPress大学
博
博客园_首页
美
美团技术团队
H
Help Net Security
MongoDB | Blog
MongoDB | Blog
宝玉的分享
宝玉的分享
大猫的无限游戏
大猫的无限游戏
小众软件
小众软件
J
Java Code Geeks
A
About on SuperTechFans
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
IT之家
IT之家
T
The Blog of Author Tim Ferriss
Microsoft Azure Blog
Microsoft Azure Blog
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
B
Blog
雷峰网
雷峰网
爱范儿
爱范儿

Recent Commits to openclaw:main

test: merge chat side-result checks · openclaw/openclaw@ddd2c2a test: merge cron history checks · openclaw/openclaw@f7eb746 test: merge responsive navigation shell checks · openclaw/openclaw@c2e4b47 docs(changelog): add codex oauth fixes · openclaw/openclaw@628e6cd test: merge navigation routing cases · openclaw/openclaw@5d8cecb Tests: mock channel registry bundled fallback · openclaw/openclaw@2b08233 Secrets: avoid broad web search discovery for single plugin config · openclaw/openclaw@a464f59 test: merge config view browser checks · openclaw/openclaw@20cf511 fix(status): align oauth health with runtime · openclaw/openclaw@eed7116 feat: add macOS screen snapshots for monitor preview (#67954) thanks … · openclaw/openclaw@f377db1 fix: report shared auth scopes in hello-ok (#67810) thanks @BunsDev · openclaw/openclaw@0b6c39b Auto-reply: avoid eager bundled route fallback · openclaw/openclaw@3ea1bf4 Tests: narrow session binding contract setup · openclaw/openclaw@54e4e16 fix(macOS): enable undo/redo in webchat composer text input (#34962) · openclaw/openclaw@00951dc Tests: speed up channel setup promotion · openclaw/openclaw@82b529a Docs: refresh agent instructions · openclaw/openclaw@5775fe2 fix(auth): serialize OAuth refresh across agents to fix #26322 (#67876) · openclaw/openclaw@8e79080 test: allow ollama public surface boundary test · openclaw/openclaw@7d4f1a6 Docs: add test performance guardrails · openclaw/openclaw@89706d3 Tests: restore context-engine usage proof · openclaw/openclaw@e4c4f95 Tests: slim context engine runtime coverage · openclaw/openclaw@74c198f ci: retry failed custom checkouts · openclaw/openclaw@0ee5baf test: trim duplicate provider auth onboarding cases · openclaw/openclaw@1ffc02e matrix: fix sessions_spawn --thread subagent session spawning (#67643) · openclaw/openclaw@1ce2596 test: reduce auth choice fixture churn · openclaw/openclaw@857b9cd test: mock health status config boundaries · openclaw/openclaw@9d5ab4a test: mock onboard config io boundary · openclaw/openclaw@299694d test: mock legacy state plugin boundaries · openclaw/openclaw@2713089 test: mock channel install boundaries · openclaw/openclaw@b945248 test: mock doctor preview channel boundaries · openclaw/openclaw@b1a3ad4
test: speed discord queue waits · openclaw/openclaw@2c701ab
steipete · 2026-04-24 · via Recent Commits to openclaw:main

@@ -21,6 +21,12 @@ function createDeferred<T = void>() {

2121

return { promise, resolve };

2222

}

232324+

async function flushQueueWork(): Promise<void> {

25+

for (let i = 0; i < 40; i += 1) {

26+

await Promise.resolve();

27+

}

28+

}

29+2430

function createMessageData(messageId: string, channelId = "ch-1") {

2531

return {

2632

channel_id: channelId,

@@ -148,9 +154,8 @@ async function createLifecycleStopScenario(params: {

148154

const { handler, stop } = params.createHandler(setStatus);

149155150156

await expect(handler(createMessageData("m-1") as never, {} as never)).resolves.toBeUndefined();

151-

await vi.waitFor(() => {

152-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

153-

});

157+

await flushQueueWork();

158+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

154159155160

const callsBeforeStop = setStatus.mock.calls.length;

156161

stop();

@@ -200,9 +205,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

200205201206

await expect(handler(createMessageData("m-1") as never, {} as never)).resolves.toBeUndefined();

202207203-

await vi.waitFor(() => {

204-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

205-

});

208+

await flushQueueWork();

209+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

206210

expect(setStatus).toHaveBeenCalledWith(

207211

expect.objectContaining({

208212

activeRuns: 1,

@@ -212,29 +216,26 @@ describe("createDiscordMessageHandler queue behavior", () => {

212216213217

await expect(handler(createMessageData("m-2") as never, {} as never)).resolves.toBeUndefined();

214218215-

await vi.waitFor(() => {

216-

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(2);

217-

});

219+

await flushQueueWork();

220+

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(2);

218221

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

219222220223

firstRun.resolve();

221224

await firstRun.promise;

222225223-

await vi.waitFor(() => {

224-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

225-

});

226+

await flushQueueWork();

227+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

226228227229

secondRun.resolve();

228230

await secondRun.promise;

229231230-

await vi.waitFor(() => {

231-

expect(setStatus).toHaveBeenLastCalledWith(

232-

expect.objectContaining({

233-

activeRuns: 0,

234-

busy: false,

235-

}),

236-

);

237-

});

232+

await flushQueueWork();

233+

expect(setStatus).toHaveBeenLastCalledWith(

234+

expect.objectContaining({

235+

activeRuns: 0,

236+

busy: false,

237+

}),

238+

);

238239

});

239240240241

it("drops duplicate inbound message deliveries before they reach preflight", async () => {

@@ -247,9 +248,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

247248

await expect(handler(duplicate as never, {} as never)).resolves.toBeUndefined();

248249

await expect(handler(duplicate as never, {} as never)).resolves.toBeUndefined();

249250250-

await vi.waitFor(() => {

251-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

252-

});

251+

await flushQueueWork();

252+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

253253

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(1);

254254

});

255255

@@ -266,21 +266,17 @@ describe("createDiscordMessageHandler queue behavior", () => {

266266

const duplicate = createMessageData("m-retry");

267267268268

await expect(handler(duplicate as never, {} as never)).resolves.toBeUndefined();

269-

await vi.waitFor(() => {

270-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

271-

});

272-

await vi.waitFor(() => {

273-

expect(params.runtime.error).toHaveBeenCalledWith(

274-

expect.stringContaining(

275-

"discord inbound worker failed: DiscordRetryableInboundError: retry me",

276-

),

277-

);

278-

});

269+

await flushQueueWork();

270+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

271+

expect(params.runtime.error).toHaveBeenCalledWith(

272+

expect.stringContaining(

273+

"discord inbound worker failed: DiscordRetryableInboundError: retry me",

274+

),

275+

);

279276280277

await expect(handler(duplicate as never, {} as never)).resolves.toBeUndefined();

281-

await vi.waitFor(() => {

282-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

283-

});

278+

await flushQueueWork();

279+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

284280

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(2);

285281

});

286282

@@ -299,14 +295,11 @@ describe("createDiscordMessageHandler queue behavior", () => {

299295

const duplicate = createMessageData("m-fail");

300296301297

await expect(handler(duplicate as never, {} as never)).resolves.toBeUndefined();

302-

await vi.waitFor(() => {

303-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

304-

});

305-

await vi.waitFor(() => {

306-

expect(params.runtime.error).toHaveBeenCalledWith(

307-

expect.stringContaining("discord inbound worker failed: Error: post-send failure"),

308-

);

309-

});

298+

await flushQueueWork();

299+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

300+

expect(params.runtime.error).toHaveBeenCalledWith(

301+

expect.stringContaining("discord inbound worker failed: Error: post-send failure"),

302+

);

310303311304

await expect(handler(duplicate as never, {} as never)).resolves.toBeUndefined();

312305

await Promise.resolve();

@@ -322,9 +315,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

322315

const { handlerParams } = await queueTimedMessages();

323316324317

await vi.advanceTimersByTimeAsync(60);

325-

await vi.waitFor(() => {

326-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

327-

});

318+

await flushQueueWork();

319+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

328320329321

const firstCtx = processDiscordMessageMock.mock.calls[0]?.[0] as

330322

| { abortSignal?: AbortSignal }

@@ -365,9 +357,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

365357

});

366358367359

await vi.advanceTimersByTimeAsync(60);

368-

await vi.waitFor(() => {

369-

expect(deliverDiscordReplyMock).toHaveBeenCalledTimes(1);

370-

});

360+

await flushQueueWork();

361+

expect(deliverDiscordReplyMock).toHaveBeenCalledTimes(1);

371362372363

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

373364

expect(handlerParams.runtime.error).toHaveBeenCalledWith(

@@ -377,9 +368,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

377368

deliverTimeoutReply.resolve();

378369

await deliverTimeoutReply.promise;

379370380-

await vi.waitFor(() => {

381-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

382-

});

371+

await flushQueueWork();

372+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

383373

} finally {

384374

vi.useRealTimers();

385375

}

@@ -485,9 +475,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

485475

await expect(

486476

handler(createMessageData("m-1") as never, {} as never),

487477

).resolves.toBeUndefined();

488-

await vi.waitFor(() => {

489-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

490-

});

478+

await flushQueueWork();

479+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

491480492481

await vi.advanceTimersByTimeAsync(60);

493482

await Promise.resolve();

@@ -580,9 +569,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

580569

handler(createMessageData("m-1") as never, {} as never),

581570

).resolves.toBeUndefined();

582571583-

await vi.waitFor(() => {

584-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

585-

});

572+

await flushQueueWork();

573+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

586574587575

expect(capturedHeartbeat).toBe(true);

588576

const busyCallsBefore = setStatus.mock.calls.filter(

@@ -599,9 +587,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

599587

runInFlight.resolve();

600588

await runInFlight.promise;

601589602-

await vi.waitFor(() => {

603-

expect(clearIntervalSpy).toHaveBeenCalled();

604-

});

590+

await flushQueueWork();

591+

expect(clearIntervalSpy).toHaveBeenCalled();

605592

} finally {

606593

setIntervalSpy.mockRestore();

607594

clearIntervalSpy.mockRestore();

@@ -660,9 +647,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

660647661648

const handler = createDiscordMessageHandler(createDiscordHandlerParams());

662649

await expect(handler(createMessageData("m-1") as never, {} as never)).resolves.toBeUndefined();

663-

await vi.waitFor(() => {

664-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

665-

});

650+

await flushQueueWork();

651+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(1);

666652667653

await expect(handler(createMessageData("m-2") as never, {} as never)).resolves.toBeUndefined();

668654

handler.deactivate();

@@ -705,18 +691,16 @@ describe("createDiscordMessageHandler queue behavior", () => {

705691

await handler(createMessageData("m-2") as never, {} as never);

706692

})();

707693708-

await vi.waitFor(() => {

709-

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(1);

710-

});

694+

await flushQueueWork();

695+

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(1);

711696

await Promise.resolve();

712697

expect(preflightDiscordMessageMock).toHaveBeenCalledTimes(1);

713698714699

firstPreflight.resolve();

715700

await sequentialDispatch;

716701717-

await vi.waitFor(() => {

718-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

719-

});

702+

await flushQueueWork();

703+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

720704

expect(processedMessageIds).toEqual(["m-1", "m-2"]);

721705

});

722706

@@ -745,13 +729,8 @@ describe("createDiscordMessageHandler queue behavior", () => {

745729

firstRun.resolve();

746730

await firstRun.promise.catch(() => undefined);

747731748-

await vi.waitFor(() => {

749-

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

750-

});

751-

await vi.waitFor(() => {

752-

expect(setStatus).toHaveBeenCalledWith(

753-

expect.objectContaining({ activeRuns: 0, busy: false }),

754-

);

755-

});

732+

await flushQueueWork();

733+

expect(processDiscordMessageMock).toHaveBeenCalledTimes(2);

734+

expect(setStatus).toHaveBeenCalledWith(expect.objectContaining({ activeRuns: 0, busy: false }));

756735

});

757736

});

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。