lanyuanxiaoyao
bb6b2bc20b
将 checker 架构重构为完全内聚模式：每个 checker 目录包含自身的 types、schema、validate、execute、expect 和 index，新增 checker 只需创建一个目录并在 runner/index.ts 添加一行注册。 主要变更： - runner/shared/ 拆分：断言基础设施迁入 checker/expect/， body.ts 迁入 http/，text.ts 迁入 command/ - config-contract/ 重命名为 schema/，schema.ts → builder.ts - size.ts + parseDuration 合并为 utils.ts - 顶层 types.ts 改为 base interface + index signature， checker 专属类型下沉到各自 types.ts - runner/index.ts 改为显式数组注册模式 - 更新 DEVELOPMENT.md 项目结构和开发新 Checker 指南
78 lines
2.7 KiB
TypeScript
78 lines
2.7 KiB
TypeScript
import { Type } from "@sinclair/typebox";
|
|
import { describe, expect, test } from "bun:test";
|
|
|
|
import type { Checker } from "../../../../src/server/checker/runner/types";
|
|
import type { CheckResult, ResolvedTargetBase } from "../../../../src/server/checker/types";
|
|
|
|
import { createDefaultCheckerRegistry } from "../../../../src/server/checker/runner";
|
|
import { CheckerRegistry } from "../../../../src/server/checker/runner/registry";
|
|
|
|
function createChecker(type: string): Checker {
|
|
return {
|
|
configKey: type,
|
|
execute: () => Promise.resolve<CheckResult>({} as unknown as CheckResult),
|
|
resolve: () => ({}) as unknown as ResolvedTargetBase,
|
|
schemas: {
|
|
config: Type.Object({}, { additionalProperties: false }),
|
|
defaults: Type.Object({}, { additionalProperties: false }),
|
|
expect: Type.Object({}, { additionalProperties: false }),
|
|
},
|
|
serialize: () => ({ config: "", target: "" }),
|
|
type,
|
|
validate: () => [],
|
|
};
|
|
}
|
|
|
|
describe("CheckerRegistry", () => {
|
|
test("注册并获取 Checker", () => {
|
|
const registry = new CheckerRegistry();
|
|
const checker = createChecker("http");
|
|
registry.register(checker);
|
|
expect(registry.get("http")).toBe(checker);
|
|
});
|
|
|
|
test("获取未注册的 type 抛出错误", () => {
|
|
const registry = new CheckerRegistry();
|
|
expect(() => registry.get("unknown")).toThrow("不支持的 probe type");
|
|
});
|
|
|
|
test("重复注册同一 type 抛出错误", () => {
|
|
const registry = new CheckerRegistry();
|
|
registry.register(createChecker("http"));
|
|
expect(() => registry.register(createChecker("http"))).toThrow("已注册");
|
|
});
|
|
|
|
test("查询支持的 type 列表", () => {
|
|
const registry = new CheckerRegistry();
|
|
registry.register(createChecker("http"));
|
|
registry.register(createChecker("command"));
|
|
expect(registry.supportedTypes).toEqual(["http", "command"]);
|
|
});
|
|
|
|
test("definitions 返回注册定义", () => {
|
|
const registry = new CheckerRegistry();
|
|
const checker = createChecker("http");
|
|
registry.register(checker);
|
|
expect(registry.definitions).toEqual([checker]);
|
|
});
|
|
|
|
test("tryGet 未注册返回 undefined", () => {
|
|
const registry = new CheckerRegistry();
|
|
expect(registry.tryGet("missing")).toBeUndefined();
|
|
});
|
|
|
|
test("默认 registry 创建 fresh 实例且互不污染", () => {
|
|
const first = createDefaultCheckerRegistry();
|
|
const second = createDefaultCheckerRegistry();
|
|
first.register(createChecker("custom"));
|
|
|
|
expect(first.supportedTypes).toEqual(["http", "command", "custom"]);
|
|
expect(second.supportedTypes).toEqual(["http", "command"]);
|
|
expect(
|
|
first.definitions.every(
|
|
(checker) => checker.schemas.config && checker.schemas.defaults && checker.schemas.expect,
|
|
),
|
|
).toBe(true);
|
|
});
|
|
});
|