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

推荐订阅源

IT之家
IT之家
Microsoft Azure Blog
Microsoft Azure Blog
人人都是产品经理
人人都是产品经理
博客园 - 聂微东
博客园_首页
阮一峰的网络日志
阮一峰的网络日志
V
V2EX
小众软件
小众软件
F
Fortinet All Blogs
Microsoft Security Blog
Microsoft Security Blog
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
H
Hackread – Cybersecurity News, Data Breaches, AI and More
量子位
Google DeepMind News
Google DeepMind News
Jina AI
Jina AI
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
aimingoo的专栏
aimingoo的专栏
B
Blog RSS Feed
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
宝玉的分享
宝玉的分享
有赞技术团队
有赞技术团队
J
Java Code Geeks
WordPress大学
WordPress大学
The Cloudflare 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
perf(test): split gateway server control-plane shard · op...
steipete · 2026-05-01 · via Recent Commits to openclaw:main

@@ -3,14 +3,14 @@ import { createServer } from "node:net";

33

import path from "node:path";

44

import { afterAll, beforeAll, describe, expect, test } from "vitest";

55

import { WebSocket } from "ws";

6-

import { resetModelCatalogCacheForTest } from "../agents/model-catalog.js";

76

import type { ChannelOutboundAdapter } from "../channels/plugins/types.js";

87

import { clearConfigCache, clearRuntimeConfigSnapshot } from "../config/config.js";

98

import { resolveCanvasHostUrl } from "../infra/canvas-host-url.js";

109

import { createOutboundTestPlugin } from "../test-utils/channel-plugins.js";

1110

import { withEnvAsync } from "../test-utils/env.js";

1211

import { createTempHomeEnv } from "../test-utils/temp-home.js";

1312

import { GATEWAY_CLIENT_MODES, GATEWAY_CLIENT_NAMES } from "../utils/message-channel.js";

13+

import { __resetModelCatalogCacheForTest as resetGatewayModelCatalogCacheForTest } from "./server-model-catalog.js";

1414

import { createRegistry } from "./server.e2e-registry-helpers.js";

1515

import {

1616

connectOk,

@@ -89,6 +89,8 @@ type ModelCatalogRpcEntry = {

8989

provider: string;

9090

alias?: string;

9191

contextWindow?: number;

92+

input?: string[];

93+

reasoning?: boolean;

9294

};

93959496

type PiCatalogFixtureEntry = {

@@ -154,14 +156,14 @@ describe("gateway server models + voicewake", () => {

154156

: await rpcReq<{ models: ModelCatalogRpcEntry[] }>(ws, "models.list"),

155157

);

156158157-

const setPiCatalog = (entries: PiCatalogFixtureEntry[]) => {

159+

const setPiCatalog = async (entries: PiCatalogFixtureEntry[]) => {

158160

piSdkMock.enabled = true;

159161

piSdkMock.models = entries;

160-

resetModelCatalogCacheForTest();

162+

await resetGatewayModelCatalogCacheForTest();

161163

};

162164163-

const seedPiCatalog = () => {

164-

setPiCatalog(buildPiCatalogFixture());

165+

const seedPiCatalog = async () => {

166+

await setPiCatalog(buildPiCatalogFixture());

165167

};

166168167169

const withModelsConfig = async <T>(config: unknown, run: () => Promise<T>): Promise<T> => {

@@ -220,7 +222,7 @@ describe("gateway server models + voicewake", () => {

220222

},

221223

},

222224

async () => {

223-

seedPiCatalog();

225+

await seedPiCatalog();

224226

const res = await listModels();

225227

expect(res.ok).toBe(true);

226228

expect(res.payload?.models).toEqual(options.expected);

@@ -472,7 +474,7 @@ describe("gateway server models + voicewake", () => {

472474

});

473475474476

test("models.list all view returns model catalog", async () => {

475-

seedPiCatalog();

477+

await seedPiCatalog();

476478477479

const res1 = await listModels({ view: "all" });

478480

const res2 = await listModels({ view: "all" });

@@ -499,18 +501,18 @@ describe("gateway server models + voicewake", () => {

499501

},

500502

},

501503

async () => {

502-

setPiCatalog([

504+

await setPiCatalog([

503505

{ id: "remote-a", provider: "unauth-a", name: "Remote A" },

504506

{ id: "remote-b", provider: "unauth-b", name: "Remote B" },

505507

]);

506508

const res = await listModels();

507509

expect(res.ok).toBe(true);

508510

expect(res.payload?.models).toEqual([

509-

{

511+

expect.objectContaining({

510512

id: "MiniMax-M2.7-highspeed",

511513

name: "MiniMax M2.7 Highspeed",

512514

provider: "minimax",

513-

},

515+

}),

514516

]);

515517

},

516518

);

@@ -525,7 +527,7 @@ describe("gateway server models + voicewake", () => {

525527

},

526528

async () => {

527529

await withModelsConfig({}, async () => {

528-

seedPiCatalog();

530+

await seedPiCatalog();

529531

const res = await listModels({ view: "configured" });

530532

expect(res.ok).toBe(true);

531533

expect(res.payload?.models).toEqual([

@@ -563,24 +565,24 @@ describe("gateway server models + voicewake", () => {

563565

},

564566

},

565567

async () => {

566-

setPiCatalog([

568+

await setPiCatalog([

567569

{ id: "remote-a", provider: "unauth-a", name: "Remote A" },

568570

{ id: "remote-b", provider: "unauth-b", name: "Remote B" },

569571

]);

570572

const res = await listModels({ view: "configured" });

571573

expect(res.ok).toBe(true);

572574

expect(res.payload?.models).toEqual([

573-

{

575+

expect.objectContaining({

574576

id: "MiniMax-M2.7-highspeed",

575577

name: "MiniMax M2.7 Highspeed",

576578

provider: "minimax",

577-

},

578-

{

579+

}),

580+

expect.objectContaining({

579581

id: "glm-4.5-air",

580582

name: "GLM 4.5 Air",

581583

provider: "zhipu",

582584

reasoning: true,

583-

},

585+

}),

584586

]);

585587

},

586588

);

@@ -607,7 +609,7 @@ describe("gateway server models + voicewake", () => {

607609

},

608610

},

609611

async () => {

610-

seedPiCatalog();

612+

await seedPiCatalog();

611613

const res = await listModels({ view: "configured" });

612614

expect(res.ok).toBe(true);

613615

expect(res.payload?.models).toEqual([

@@ -634,7 +636,7 @@ describe("gateway server models + voicewake", () => {

634636

},

635637

},

636638

async () => {

637-

seedPiCatalog();

639+

await seedPiCatalog();

638640

const res = await listModels({ view: "all" });

639641

expect(res.ok).toBe(true);

640642

expect(res.payload?.models).toEqual(expectedSortedCatalog());

@@ -708,17 +710,17 @@ describe("gateway server models + voicewake", () => {

708710

},

709711

},

710712

async () => {

711-

seedPiCatalog();

713+

await seedPiCatalog();

712714

const res = await listModels();

713715

expect(res.ok).toBe(true);

714716

expect(res.payload?.models).toEqual([

715-

{

717+

expect.objectContaining({

716718

id: "moonshotai/kimi-k2.5",

717719

name: "Kimi K2.5 (Configured)",

718720

alias: "Kimi K2.5 (NVIDIA)",

719721

provider: "nvidia",

720722

contextWindow: 32_000,

721-

},

723+

}),

722724

]);

723725

},

724726

);

@@ -751,17 +753,17 @@ describe("gateway server models + voicewake", () => {

751753

},

752754

},

753755

async () => {

754-

seedPiCatalog();

756+

await seedPiCatalog();

755757

const res = await listModels();

756758

expect(res.ok).toBe(true);

757759

expect(res.payload?.models).toEqual([

758-

{

760+

expect.objectContaining({

759761

id: "gpt-test-z",

760762

name: "Configured GPT Test Z",

761763

alias: "GPT Test Z Alias",

762764

provider: "openai",

763765

contextWindow: 64_000,

764-

},

766+

}),

765767

]);

766768

},

767769

);