Files
OmniRoute/tests/unit/intercept-fetch-resolver.test.ts
Diego Rodrigues de Sa e Souza 93265eede3 test(infra): retry recursive temp-dir removal on main (main twin of #11968) (#12246)
* test(infra): retry recursive temp-dir removal on main (main twin of #11968)

`main` has been red since b342c1a361 on the vitest and integration gates:

  ✖ tests/unit/autoCombo/provider-family-combos.test.ts > auto/<family>
  ✖ chat pipeline applies Codex OAuth fingerprint and priority tier inside combos

Both call resetStorage() from beforeEach, which does an fs.rmSync(TEST_DATA_DIR,
{recursive: true, force: true}) with no retry, and intermittently loses the race
with a not-yet-released SQLite handle (ENOTEMPTY).

release/v3.8.51 fixed this in #11968 with a mechanical codemod adding
maxRetries/retryDelay to every recursive rm/rmSync/rmdirSync under tests/, but
that PR landed only on the release branch. Because main only receives work at
the release squash, it stayed broken for the whole cycle — and repo-wide gates
then turn every open PR into main red on checks unrelated to their diff.

This is the --base main twin: re-runs the same codemod that already shipped on
the release branch (scripts/ad-hoc/codemod-rm-maxretries.mjs), so the two
branches converge on identical test-teardown semantics. Test-only; no product
logic is touched.

The remaining three failures reported on #12133 (unit full suite exceeding its
4800s ceiling, package-artifact exceeding 1200s, and the boot-smoke that is
skipped as a consequence) are runner-contention timeouts, not code defects —
validate-release-green.mjs runs those heavy gates concurrently on one shared
hosted runner. There is no fix to port for those.

* chore(scripts): carry the rm-maxretries codemod onto main alongside its output

The codemod that generated the previous commit lives in the repo on
release/v3.8.51 (added by #11968) but was never on main. Bringing it over keeps
the tool next to the change it produced, so the transformation stays
reproducible and auditable from either branch.
2026-09-01 01:48:00 -03:00

64 lines
2.6 KiB
TypeScript

import { describe, it, beforeEach, after } from "node:test";
import assert from "node:assert/strict";
import os from "node:os";
import path from "node:path";
import fs from "node:fs";
// Set DATA_DIR to a temp dir before any imports that touch the DB.
const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), "omniroute-test-intercept-fetch-resolver-"));
process.env.DATA_DIR = tmpDir;
const core = await import("../../src/lib/db/core.ts");
const { setInterceptionRules, resolveInterceptFetch } = await import(
"../../src/lib/db/interceptionRules.ts"
);
// #7339 — resolveInterceptFetch, a structural twin of resolveInterceptSearch
// (tests/unit/interception-rules.test.ts), covering Phase 3 of #3384.
describe("db/interceptionRules — resolveInterceptFetch precedence (#7339)", () => {
function resetDb() {
core.resetDbInstance();
fs.rmSync(tmpDir, { recursive: true, force: true, maxRetries: 5, retryDelay: 100 });
fs.mkdirSync(tmpDir, { recursive: true });
}
beforeEach(() => {
resetDb();
});
after(() => {
core.resetDbInstance();
fs.rmSync(tmpDir, { recursive: true, force: true, maxRetries: 5, retryDelay: 100 });
});
it("returns undefined when no provider/model rule exists", () => {
assert.equal(resolveInterceptFetch("anthropic", "claude-opus-4"), undefined);
});
it("returns the provider-level interceptFetch value when only a provider rule is set", () => {
setInterceptionRules("anthropic", { interceptFetch: true });
assert.equal(resolveInterceptFetch("anthropic", "claude-opus-4"), true);
assert.equal(resolveInterceptFetch("anthropic", "claude-haiku-4"), true);
});
it("model-level interceptFetch wins over the provider-level rule when both are set", () => {
setInterceptionRules("anthropic", {
interceptFetch: false,
models: { "claude-opus-4": { interceptFetch: true } },
});
assert.equal(resolveInterceptFetch("anthropic", "claude-opus-4"), true);
assert.equal(resolveInterceptFetch("anthropic", "claude-haiku-4"), false);
});
it("does not read interceptSearch when resolving interceptFetch (fields stay independent)", () => {
setInterceptionRules("anthropic", { interceptSearch: true, interceptFetch: false });
assert.equal(resolveInterceptFetch("anthropic", "claude-opus-4"), false);
});
it("returns undefined for an empty/missing provider", () => {
assert.equal(resolveInterceptFetch("", "claude-opus-4"), undefined);
assert.equal(resolveInterceptFetch(null, "claude-opus-4"), undefined);
assert.equal(resolveInterceptFetch(undefined, "claude-opus-4"), undefined);
});
});