Files
wehub-resource-sync d68f003000
CI / Change detection (push) Has been cancelled
CI / Version drift (push) Has been cancelled
CI / Lint (push) Has been cancelled
CI / Workflow RLM cache (push) Has been cancelled
CI / Test (macos-latest) (push) Has been cancelled
CI / Test (ubuntu-latest) (push) Has been cancelled
CI / Test (windows-latest) (push) Has been cancelled
CI / npm wrapper smoke (push) Has been cancelled
CI / Mobile runtime smoke (push) Has been cancelled
CI / Workflow lint (push) Has been cancelled
CI / Documentation (push) Has been cancelled
Web Frontend / Lint & Type Check (push) Failing after 1s
Auto-close harvested PRs / close (push) Failing after 1s
cargo-deny / cargo-deny (bans licenses sources) (push) Failing after 1s
Security audit / cargo-audit (push) Failing after 1s
Sync to CNB / sync (push) Failing after 1s
cargo-deny / cargo-deny (advisories) (push) Failing after 3s
Web Frontend / Deploy to Cloudflare (push) Has been cancelled
chore: import upstream snapshot with attribution
2026-07-13 12:08:23 +08:00

150 lines
5.4 KiB
JavaScript

import assert from "node:assert/strict";
import { mkdtemp, rm, stat } from "node:fs/promises";
import { tmpdir } from "node:os";
import path from "node:path";
import test from "node:test";
import { ThreadStore, validateBridgeConfig, isApprovalResponse, isDenyResponse } from "../src/lib.mjs";
// ─── ThreadStore ─────────────────────────────────────────────────
test("ThreadStore writes private state files", async () => {
const dir = await mkdtemp(path.join(tmpdir(), "codewhale-wecom-"));
try {
const statePath = path.join(dir, "nested", "thread-map.json");
const store = await ThreadStore.open(statePath);
await store.setChat("single:user-a", {
threadId: "thread-a",
lastSeq: 1,
activeTurnId: null
});
const saved = await ThreadStore.open(statePath);
assert.equal((await saved.getChat("single:user-a")).threadId, "thread-a");
if (process.platform !== "win32") {
assert.equal((await stat(path.dirname(statePath))).mode & 0o777, 0o700);
assert.equal((await stat(statePath)).mode & 0o777, 0o600);
}
} finally {
await rm(dir, { recursive: true, force: true });
}
});
// ─── Config validation ──────────────────────────────────────────
test("validateBridgeConfig rejects placeholder secrets", () => {
const result = validateBridgeConfig({
WECOM_BOT_ID: "your-bot-id",
WECOM_BOT_SECRET: "your-bot-secret",
CODEWHALE_RUNTIME_TOKEN: "replace-with-long-random-token",
CODEWHALE_RUNTIME_URL: "http://127.0.0.1:7878"
});
assert.equal(result.ok, false);
assert.deepEqual(
result.errors.map((item) => item.code),
["placeholder_runtime_token"]
);
});
// ─── isApprovalResponse ─────────────────────────────────────────
test("isApprovalResponse: single-word Chinese keywords", () => {
for (const kw of ["允许", "可以", "好", "同意", "批准"]) {
assert.equal(isApprovalResponse(kw), true, `"${kw}" should be approval`);
}
});
test("isApprovalResponse: single-word English keywords", () => {
for (const kw of ["yes", "ok", "y", "approve", "allow"]) {
assert.equal(isApprovalResponse(kw), true, `"${kw}" should be approval`);
}
});
test("isApprovalResponse: two-character Chinese keywords", () => {
for (const kw of ["好的", "可以", "没问题", "批准了", "同意"]) {
assert.equal(isApprovalResponse(kw), true, `"${kw}" should be approval`);
}
});
test("isApprovalResponse: case-insensitive", () => {
assert.equal(isApprovalResponse("YES"), true);
assert.equal(isApprovalResponse("Ok"), true);
assert.equal(isApprovalResponse("Allow"), true);
});
test("isApprovalResponse: trims whitespace", () => {
assert.equal(isApprovalResponse(" 允许 "), true);
assert.equal(isApprovalResponse(" yes "), true);
});
test("isApprovalResponse: rejects non-approval text", () => {
assert.equal(isApprovalResponse("帮我查一下"), false);
assert.equal(isApprovalResponse("/allow abc123"), false);
assert.equal(isApprovalResponse("run prompt"), false);
});
test("isApprovalResponse: handles null/empty/undefined", () => {
assert.equal(isApprovalResponse(null), false);
assert.equal(isApprovalResponse(""), false);
assert.equal(isApprovalResponse(undefined), false);
});
// ─── isDenyResponse ─────────────────────────────────────────────
test("isDenyResponse: single-word Chinese keywords", () => {
for (const kw of ["拒绝", "不行", "不要", "取消", "否"]) {
assert.equal(isDenyResponse(kw), true, `"${kw}" should be denial`);
}
});
test("isDenyResponse: single-word English keywords", () => {
for (const kw of ["no", "n", "deny", "reject", "stop"]) {
assert.equal(isDenyResponse(kw), true, `"${kw}" should be denial`);
}
});
test("isDenyResponse: two-character Chinese keywords", () => {
for (const kw of ["不可以", "不同意", "不要执行"]) {
assert.equal(isDenyResponse(kw), true, `"${kw}" should be denial`);
}
});
test("isDenyResponse: case-insensitive and trims whitespace", () => {
assert.equal(isDenyResponse(" NO "), true);
assert.equal(isDenyResponse("No"), true);
});
test("isDenyResponse: rejects non-denial text", () => {
assert.equal(isDenyResponse("让我想想"), false);
assert.equal(isDenyResponse("/deny abc123"), false);
assert.equal(isDenyResponse("继续"), false);
});
test("isDenyResponse: handles null/empty/undefined", () => {
assert.equal(isDenyResponse(null), false);
assert.equal(isDenyResponse(""), false);
assert.equal(isDenyResponse(undefined), false);
});
// ─── Mutual exclusivity ─────────────────────────────────────────
test("no keyword is both approval and denial", () => {
const all = [
"允许", "可以", "好", "同意", "批准",
"好的", "没问题", "批准了",
"yes", "ok", "y", "approve", "allow",
"拒绝", "不行", "不要", "取消", "否",
"不可以", "不同意", "不要执行",
"no", "n", "deny", "reject", "stop"
];
for (const kw of all) {
assert.notEqual(
isApprovalResponse(kw), isDenyResponse(kw),
`"${kw}" should not be both approval and denial`
);
}
});