test(combo): gate-level regression for stale persisted-cooldown skip (#13694) (#13767)

Merged. Test-only and worth it: the production mechanism is already fixed on this base (#12168 grace-bounded the persisted-`unavailable` skip, #12899 fixed combo-name allow-listing), but nothing stopped it from regressing. Your cases pin both directions — a stale/orphan persisted cooldown proceeds through the gates, a genuinely fresh one still skips.

Validated as a combined board first (this PR merged with the 21 siblings of the same wave on the release tip): eslint with the frozen suppressions, typecheck:core, check:open-sse-typecheck, complexity, cognitive-complexity, changelog-integrity, i18n new-key coverage, docs-counts, docs-sync, migration-numbering, provider-consistency and a duplicate-identifier audit all green, plus 176 passing / 0 failing focused node:test cases across the 25 test files the wave touches and the dashboard test under Vitest (2/0). Then re-validated alone on the fresh tip before this merge: conflicts re-resolved, file sizes rebaselined for this PR's own growth, eslint and this PR's focused tests re-run.

Thank you.
This commit is contained in:
lorenzozane
2026-09-17 00:14:37 +08:00
committed by GitHub
parent ed2e22197a
commit 1510fb0d62

View File

@@ -197,6 +197,82 @@ test("proceed stamps fallbackAttempts from the ordered-target index", async () =
}
});
/**
* #13694 — combos 503d with ALL_TARGETS_SKIPPED after the 3.8.49→3.8.50
* upgrade, with zero upstream attempts and no recovery after reboot.
*
* The 3.8.50 persisted-connection-cooldown gate (#11360) read SQLite rows
* that 3.8.49 had written but never consulted pre-dispatch, so upgrade-shaped
* state (stale `unavailable` labels) skipped every target before dispatch.
* #12168 bounded the bare-label skip with a grace window; these tests pin the
* gate — not just the predicate — so a whole pool of stale/orphan rows can
* never again produce a zero-attempt 503, while a genuinely fresh cooldown
* still skips (burst protection intact).
*/
async function seedCooldownConnection(input: {
provider: string;
testStatus: string;
lastErrorAt?: string | null;
rateLimitedUntil?: string | null;
}): Promise<string> {
const providersDb = await import("../../../src/lib/db/providers.ts");
const readCache = await import("../../../src/lib/db/readCache.ts");
const connection = (await providersDb.createProviderConnection({
provider: input.provider,
authType: "apikey",
name: `gates-13694-${Date.now()}-${Math.random().toString(16).slice(2)}`,
apiKey: "[REDACTED]",
testStatus: input.testStatus,
lastErrorAt: input.lastErrorAt ?? null,
rateLimitedUntil: input.rateLimitedUntil ?? null,
} as unknown as Record<string, unknown>)) as { id: string };
readCache.invalidateDbCache("connections");
return connection.id;
}
test("#13694: stale persisted unavailable label proceeds through pre-dispatch gates", async () => {
const { evaluateExecuteTargetGates } =
await import("../../../open-sse/services/combo/executeTargetGates.ts");
const provider = `openai-gates-13694-stale-${Date.now()}`;
const connectionId = await seedCooldownConnection({
provider,
testStatus: "unavailable",
// Well past the 60s unavailable-label grace window (#12168): the label is
// upgrade-shaped stale state, not a live cooldown.
lastErrorAt: new Date(Date.now() - 10 * 60 * 1000).toISOString(),
});
const target = modelTarget({ provider, modelStr: `${provider}/gpt-4o-mini`, connectionId });
const state = emptyState({ orderedTargets: [target] });
const decision = await evaluateExecuteTargetGates({ index: 0, state, deps: baseDeps() });
assert.equal(decision.kind, "proceed");
});
test("#13694: orphan persisted unavailable label (no timestamps) proceeds", async () => {
const { evaluateExecuteTargetGates } =
await import("../../../open-sse/services/combo/executeTargetGates.ts");
const provider = `openai-gates-13694-orphan-${Date.now()}`;
const connectionId = await seedCooldownConnection({ provider, testStatus: "unavailable" });
const target = modelTarget({ provider, modelStr: `${provider}/gpt-4o-mini`, connectionId });
const state = emptyState({ orderedTargets: [target] });
const decision = await evaluateExecuteTargetGates({ index: 0, state, deps: baseDeps() });
assert.equal(decision.kind, "proceed");
});
test("#13694 control: recent persisted unavailable label still skips", async () => {
const { evaluateExecuteTargetGates } =
await import("../../../open-sse/services/combo/executeTargetGates.ts");
const provider = `openai-gates-13694-fresh-${Date.now()}`;
const connectionId = await seedCooldownConnection({
provider,
testStatus: "unavailable",
lastErrorAt: new Date().toISOString(),
});
const target = modelTarget({ provider, modelStr: `${provider}/gpt-4o-mini`, connectionId });
const state = emptyState({ orderedTargets: [target] });
const decision = await evaluateExecuteTargetGates({ index: 0, state, deps: baseDeps() });
assert.equal(decision.kind, "skip");
});
test("injection: dropping fallbackAttempts from targetForAttempt goes red", async () => {
const { evaluateExecuteTargetGates } =
await import("../../../open-sse/services/combo/executeTargetGates.ts");