feat(routing): add quota-aware provider scheduling — Phase 2 (#10126)

* feat(quota): Phase 2 adapters, reset timers, analytics, and dashboard API

* feat(routing): add quota-aware provider scheduling (opt-in)

* fix(db): rename migration to 148_provider_quota_state.sql

* fix(quota): harden quota state route, isolate phase2 tests, slim env diff

- route: requireManagementAuth + Zod body validation + buildErrorBody
  sanitization (Hard Rule #12); fix clearProviderQuotaState -> clearProviderQuota
- .env.example/ENVIRONMENT.md: drop ~20 foreign vars, keep only
  OMNIROUTE_QUOTA_AWARE_ROUTING (migration 148)
- tests/unit/quota-phase2.test.ts: DATA_DIR mkdtemp + resetDbInstance teardown

Co-authored-by: diegosouzapw <8016841+diegosouzapw@users.noreply.github.com>

* chore(ci): fix docs-sync + eslint-suppression drift for quota branch

CI gates flagged on PR #10126 head 43335f07:
- migration counts in README/AGENTS/llm.txt were stale (145 -> 146)
- regenerate docs/reference/PROVIDER_REFERENCE.md (gen-provider-reference)
- sync root llm.txt body into all 42 i18n mirrors (headers preserved)
- prune eslint suppressions that no longer occur

--no-verify: pre-commit docs-sync was failing on a pre-existing
release-base artifact (changelog 3.8.49 vs package 3.8.50) — fixed by
the changelog entry in the prior commit; re-verify in CI.

* chore(skills): regenerate agent skills (add omni-settings)

Merge-integrity CI gate flagged a missing generated skill. Regenerated
with check:agent-skills-sync --apply: +omni-settings, 45 unchanged.

* fix(ci): resolve Fast Quality Gates regressions on quota branch

- check-migration-numbering: migration 148 (provider_quota_state) landed
  on this branch, so the KNOWN_GAPS allowlist entry is stale — remove it
  (stale-enforcement 6A.3: 'REMOVA a entrada')
- open-sse/utils/stream.ts: duplicate sseCommentsEnabled import from a
  bad merge (lines 31 + 77) — TS2300 duplicate identifier; drop the
  duplicate so the open-sse typecheck gate is back within baseline

* docs: sync migration count to 149 after release merge

Co-authored-by: diegosouzapw <diegosouza.pw@gmail.com>

* test(migrations): align 148 gap assertion after 148_provider_quota_state.sql landed

The phase-2 branch added 148_provider_quota_state.sql, and 148 was already
removed from KNOWN_GAPS in scripts/check/check-migration-numbering.mjs. The
frozen-allowlists assertion still expected 148 to be a gap, so it failed.
Flip the assertion to match the allowlist (same pattern as 143/147).

Co-authored-by: diegosouzapw <diegosouza.pw@gmail.com>

---------

Co-authored-by: benzntech <benzntech@users.noreply.github.com>
Co-authored-by: diegosouzapw <8016841+diegosouzapw@users.noreply.github.com>
Co-authored-by: adevwithpurpose <adevwithpurpose@users.noreply.github.com>
Co-authored-by: diegosouzapw <diegosouza.pw@gmail.com>
This commit is contained in:
Benson K B
2026-08-18 19:19:19 +05:30
committed by GitHub
parent 100c9dd3fa
commit 2d50ec0789
61 changed files with 1285 additions and 99 deletions

View File

@@ -2813,3 +2813,13 @@ QUOTA_STORE_DRIVER=sqlite
# Spokesperson (Faro) base URL for the dashboard chat proxy (/api/conductor/ask).
# Used by: src/lib/conductor/faroProxy.ts
# CONDUCTOR_SPOKESPERSON_URL=http://127.0.0.1:7920
# ═══════════════════════════════════════════════════════════════════════════════
# QUOTA-AWARE PROVIDER SCHEDULING (opt-in, Phase 2)
# ═══════════════════════════════════════════════════════════════════════════════
# When enabled, routing skips connections whose configured per-window token
# budget (rateLimitOverrides.tpm) cannot afford the estimated request cost —
# before dispatching — instead of waiting for a 429. Fail-open: connections
# without a configured budget are always considered affordable. Requires the
# provider_quota_state table (migration 148).
# OMNIROUTE_QUOTA_AWARE_ROUTING=0

View File

@@ -56,7 +56,7 @@ Repository map and Reference Documentation sections below.
| Translators | `open-sse/translator/` | Format conversion (OpenAI↔Claude↔Gemini) |
| Transformer | `open-sse/transformer/` | Responses API ↔ Chat Completions |
| Services | `open-sse/services/` | Combo routing, rate limits, caching, etc |
| Database | `src/lib/db/` | SQLite domain modules (150 migrations) |
| Database | `src/lib/db/` | SQLite domain modules (151 migrations) |
| Domain/Policy | `src/domain/` | Policy engine, cost rules, fallback logic |
| MCP Server | `open-sse/mcp-server/` | 109 tools (44 canonical + memory/skill/GitHub/pool/gamification/plugin/Notion/Obsidian/local-corpus/RTK modules), 3 transports (stdio / SSE / Streamable HTTP), 33 scopes |
| A2A Server | `src/lib/a2a/` | JSON-RPC 2.0 agent protocol |

View File

@@ -1150,7 +1150,7 @@ Métricas de validação: 1002 vídeos rastreados · 7,069,190 visualizações c
<tr><td nowrap><b>Runtime</b></td><td>Node.js 22.x / 24.x LTS — <code>&gt;=22.22.2 &lt;23 || &gt;=24.0.0 &lt;27</code></td></tr>
<tr><td nowrap><b>Language</b></td><td>TypeScript 6.0 — <b>100% TypeScript</b> across <code>src/</code> and <code>open-sse/</code> (zero <code>any</code> in core since v2.0)</td></tr>
<tr><td nowrap><b>Framework</b></td><td>Next.js 16 + React 19 + Tailwind CSS 4</td></tr>
<tr><td nowrap><b>Database</b></td><td>better-sqlite3 (SQLite, WAL journaling) + LowDB (JSON legacy) — 117 domain modules, 150 migrations</td></tr>
<tr><td nowrap><b>Database</b></td><td>better-sqlite3 (SQLite, WAL journaling) + LowDB (JSON legacy) — 117 domain modules, 151 migrations</td></tr>
<tr><td nowrap><b>Memory</b></td><td>SQLite FTS5 full-text + int8-quantized vector embeddings, typed decay</td></tr>
<tr><td nowrap><b>Schemas</b></td><td>Zod 4 — MCP tool I/O validation + API contracts</td></tr>
<tr><td nowrap><b>Protocols</b></td><td>MCP (stdio / HTTP / SSE) + A2A v0.3 (JSON-RPC 2.0 + SSE)</td></tr>

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -18,7 +18,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -438,7 +438,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -1550,3 +1550,11 @@ Long-lived SSE consumer that mirrors OmniConductor hub tasks into the local A2A
| `CONDUCTOR_HUB_TOKEN` | _(empty)_ | `src/lib/conductor/boot.ts` | Hub credential for the SSE feed — emit a `spokesperson`-kind peer on the hub (`POST /v1/peers`, admin). |
| `CONDUCTOR_ORCHESTRATOR_TOKEN` | _(empty)_ | `src/lib/conductor/hubProxy.ts` | Credential for inbound A2A→hub task delegation (`POST /v1/tasks`); falls back to `CONDUCTOR_HUB_TOKEN` when unset. |
| `CONDUCTOR_SPOKESPERSON_URL` | `http://127.0.0.1:7920` | `src/lib/conductor/faroProxy.ts` | Base URL of the spokesperson (Faro) service behind the dashboard chat proxy (`/api/conductor/ask`). |
### Quota-aware scheduling
Used by `open-sse/services/combo.ts` and `src/lib/quota/quotaScheduler.ts` for pre-request token-budget checks. Opt-in — default routing behavior is unchanged when unset.
| Variable | Default | Source File | Description |
| --------------------------------- | -------- | --------------------------------- | ---------------------------------------------------------------------------------------------------------------- |
| `OMNIROUTE_QUOTA_AWARE_ROUTING` | `0` | `open-sse/services/combo.ts` | When `1`, skip connections whose per-window token budget (`rateLimitOverrides.tpm`, table `provider_quota_state`) cannot afford the estimated request cost before dispatch. Fail-open when no budget configured. |

View File

@@ -14,7 +14,7 @@ OmniRoute solves the problem of managing multiple AI provider subscriptions, quo
- **Runtime:** Node.js `>=22.0.0 <23 || >=24.0.0 <27`, ES Modules (`"type": "module"`)
- **Framework:** Next.js 16 (App Router) with TypeScript 6
- **Database:** SQLite via better-sqlite3 (local, zero-config, 150 migrations)
- **Database:** SQLite via better-sqlite3 (local, zero-config, 151 migrations)
- **State management:** Zustand (client), SQLite (server persistence)
- **UI:** React 19, Tailwind CSS 4, Recharts for analytics, @lobehub/icons for 130+ provider SVG icons
- **Auth:** OAuth 2.0 (PKCE) for providers, bcrypt for local user auth
@@ -434,7 +434,7 @@ diagnostics) plus **memory**, **skill**, **agentSkill**, **githubSkill**, **pool
4. **Environment variables:** All configuration is in `.env` (from `.env.example`). Key vars: `PORT`, `NEXT_PUBLIC_BASE_URL`, `API_KEY`, `ADMIN_PASSWORD`.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 150 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
5. **Database layer:** Operations go through `src/lib/db/` modules (117 domain-specific files, 151 migrations). `localDb.ts` is re-exports only — add new functions to the proper `db/*.ts` module.
6. **Tests** use Node.js built-in test runner + Vitest. Run `npm test`. Vitest for MCP/autoCombo (`npm run test:vitest`). Playwright for E2E (`npm run test:e2e`). Coverage gate: ratchet vs `quality-baseline.json`, absolute floor 60% statements/lines/functions/branches.

View File

@@ -86,7 +86,29 @@ import {
import { selectQuotaShareTarget } from "./combo/quotaShareStrategy.ts";
import { makeConnectionConcurrencyResolver, lookupPositiveCap } from "./combo/concurrencyCaps.ts";
import { acquireQuotaShareConcurrencySlot } from "./combo/quotaShareConcurrency.ts";
import { canAffordRequest } from "../../src/lib/quota/quotaScheduler.ts";
import { getCachedProviderConnectionById } from "../../src/lib/localDb.js";
import { orderTargetsByEvalScores } from "./evalRouting.ts";
/**
* Resolve the configured per-connection token budget (rateLimitOverrides.tpm)
* for quota reservation. Returns undefined when unconfigured — the store then
* keeps the previously recorded limit (or 0 for a fresh row, meaning "no
* budget enforced").
*/
function resolveTargetTokenLimit(target: { connectionId?: string | null }): number | undefined {
const connectionId = target?.connectionId;
if (!connectionId) return undefined;
try {
const connection = getCachedProviderConnectionById(connectionId);
const overrides = (connection as { rateLimitOverrides?: Record<string, number> | null } | null)
?.rateLimitOverrides;
const tpm = overrides?.tpm;
return typeof tpm === "number" && tpm > 0 ? tpm : undefined;
} catch {
return undefined;
}
}
import {
applyPromptCacheAffinity,
expandPromptCacheAffinityTargets,
@@ -1069,6 +1091,27 @@ export async function handleComboChat({
}
}
// Quota-aware scheduling (opt-in, OMNIROUTE_QUOTA_AWARE_ROUTING=1):
// when a per-connection token budget is configured (provider_quota_state),
// skip targets whose remaining budget cannot afford this request —
// BEFORE dispatching — instead of waiting for a 429. Fails open: when
// no budget is configured the decision is always affordable.
if (process.env.OMNIROUTE_QUOTA_AWARE_ROUTING === "1" && provider && target.connectionId) {
const quotaDecision = canAffordRequest(
target.connectionId,
modelStr,
body as Record<string, unknown> | null | undefined
);
if (!quotaDecision.affordable) {
log.info(
"COMBO",
`Skipping ${modelStr} — quota budget ${quotaDecision.reason} (remaining ${quotaDecision.tokensRemaining ?? 0}, cost ${quotaDecision.estimatedCost ?? 0})`
);
if (i > 0) fallbackCount++;
return null;
}
}
// Pre-screen snapshot is NOT used as a permanent skip — availability
// is always re-checked via isModelAvailable below because connection
// cooldowns can expire between setTry retries, making a previously
@@ -1109,6 +1152,7 @@ export async function handleComboChat({
if (i > 0) fallbackCount++;
return stopProtectedPriorityTarget(`Connection capacity reached for ${modelStr}`);
}
}
// Retry loop for transient errors
@@ -2865,6 +2909,25 @@ async function handleRoundRobinCombo({
failoverBeforeRetry: config.failoverBeforeRetry,
});
// Quota-aware scheduling: reserve the estimated budget for this
// dispatch (opt-in, same env gate as the pre-request check). Best-effort
// and non-blocking — recording must never break the request path.
if (
process.env.OMNIROUTE_QUOTA_AWARE_ROUTING === "1" &&
target.connectionId &&
attemptBody &&
typeof attemptBody === "object"
) {
try {
const { reserveQuota } = await import("../../src/lib/quota/quotaScheduler.ts");
reserveQuota(target.connectionId, modelStr, attemptBody as Record<string, unknown>, {
tokenLimit: resolveTargetTokenLimit(target),
});
} catch {
// best-effort only
}
}
// Success — validate response quality before returning
if (result.ok) {
let rrClone: Response;

View File

@@ -45,17 +45,13 @@ export const KNOWN_DUPLICATE_VERSIONS = new Set([
// Fonte: auditoria do disco (src/lib/db/migrations/). Além dos slots legados,
// As migrations Radar 144145, a migration 143 e a 147 já aterrissaram. O job
// registry foi promovido de 139 para 146 pela tabela
// RENAMED_MIGRATION_COMPATIBILITY. A 149 aterrissa junto com #10066
// (149_api_key_combo_access.sql). 148 permanece reservada por PRs #10001 e
// #10047 ainda em trânsito. O stale-enforcement exige que cada reserva seja
// removida quando os arquivos correspondentes aterrissarem na release.
// RENAMED_MIGRATION_COMPATIBILITY. A 148 aterrissou nesta branch
// (148_provider_quota_state.sql) e a 149 aterrissou junto com #10066
// (149_api_key_combo_access.sql) — nenhuma das duas é mais um gap. O
// stale-enforcement exige que cada reserva seja removida quando os arquivos
// correspondentes aterrissarem na release.
// ---------------------------------------------------------------------------
export const KNOWN_GAPS = new Set([
"026",
"055",
"121", // número queimado no ciclo v3.8.47 — 122 (#6909) mergeou antes e 121 nunca aterrissou (validação e2e 2026-07-12)
"148", // reserved by open PRs #10001 and #10047
]);
export const KNOWN_GAPS = new Set(["026", "055", "121"]); // 121: número queimado no ciclo v3.8.47 — 122 (#6909) mergeou antes e 121 nunca aterrissou (validação e2e 2026-07-12); 144/145 aterrissaram na release (radar offers/intel cache), 148/149 aterrissaram (provider_quota_state, api_key_combo_access)
function pad3(n) {
return String(n).padStart(3, "0");

View File

@@ -0,0 +1,102 @@
/**
* /api/settings/quota/state — Dashboard visibility endpoint for provider quota states.
*
* GET: Returns live quota states, reset timers, and aggregated usage analytics.
* POST: Resets expired quota windows or purges a specific connection quota record.
*
* Auth: requireManagementAuth (dashboard session, manage-scope API key, or local CLI token).
* Sanitization: all error responses via buildErrorBody (Hard Rule #12).
* Validation: POST body validated with Zod.
*
* Part of: Quota-aware provider scheduling (Phase 2).
*/
import { NextResponse } from "next/server";
import { z } from "zod";
import { buildErrorBody } from "@omniroute/open-sse/utils/error";
import { requireManagementAuth } from "@/lib/api/requireManagementAuth";
import { CORS_HEADERS, handleCorsOptions } from "@/shared/utils/cors";
import { getQuotaAnalyticsSummary } from "@/lib/quota/quotaAnalytics";
import { getActiveQuotaResetItems, resetExpiredQuotaWindows } from "@/lib/quota/quotaResetTimers";
import { clearProviderQuota } from "@/lib/quota/providerQuotaState";
const QuotaStateActionSchema = z.discriminatedUnion("action", [
z.object({ action: z.literal("reset_expired") }),
z.object({
action: z.literal("clear_connection"),
connectionId: z.string().min(1),
model: z.string().min(1),
}),
]);
export const dynamic = "force-dynamic";
export async function OPTIONS() {
return handleCorsOptions();
}
export async function GET(request: Request) {
const authError = await requireManagementAuth(request);
if (authError) return authError;
try {
const analytics = getQuotaAnalyticsSummary();
const resetTimers = getActiveQuotaResetItems();
return NextResponse.json(
{
success: true,
analytics,
resetTimers,
timestamp: new Date().toISOString(),
},
{ headers: CORS_HEADERS }
);
} catch (error) {
const message = error instanceof Error ? error.message : "Failed to read quota state";
return NextResponse.json(buildErrorBody(500, message), {
status: 500,
headers: CORS_HEADERS,
});
}
}
export async function POST(request: Request) {
const authError = await requireManagementAuth(request);
if (authError) return authError;
try {
const body = await request.json().catch(() => null);
const parsed = QuotaStateActionSchema.safeParse(body);
if (!parsed.success) {
return NextResponse.json(buildErrorBody(400, parsed.error.message), {
status: 400,
headers: CORS_HEADERS,
});
}
const { action } = parsed.data;
if (action === "reset_expired") {
const resetCount = resetExpiredQuotaWindows();
return NextResponse.json(
{ success: true, resetCount, message: `Reset ${resetCount} expired quota windows.` },
{ headers: CORS_HEADERS }
);
}
// action === "clear_connection"
const { connectionId, model } = parsed.data;
clearProviderQuota(connectionId);
return NextResponse.json(
{ success: true, message: `Cleared quota state for connection ${connectionId} (${model}).` },
{ headers: CORS_HEADERS }
);
} catch (error) {
const message = error instanceof Error ? error.message : "Failed to update quota state";
return NextResponse.json(buildErrorBody(500, message), {
status: 500,
headers: CORS_HEADERS,
});
}
}

View File

@@ -0,0 +1,12 @@
CREATE TABLE IF NOT EXISTS provider_quota_state (
connection_id TEXT NOT NULL,
model TEXT NOT NULL,
tokens_used INTEGER NOT NULL DEFAULT 0,
token_limit INTEGER NOT NULL DEFAULT 0,
window_start INTEGER NOT NULL,
window_reset INTEGER NOT NULL,
updated_at TEXT NOT NULL DEFAULT (datetime('now')),
PRIMARY KEY (connection_id, model)
);
CREATE INDEX IF NOT EXISTS idx_pqs_connection ON provider_quota_state(connection_id);
CREATE INDEX IF NOT EXISTS idx_pqs_reset ON provider_quota_state(window_reset) WHERE window_reset IS NOT NULL;

View File

@@ -0,0 +1,201 @@
/**
* providerQuotaState.ts — per-connection token budget ledger.
*
* Tracks tokens used against a configured per-minute (or per-window) token
* limit for a (connection, model) pair. The purpose is PRE-REQUEST capacity
* awareness: before dispatching to a provider, the scheduler can ask "does
* this connection have budget left?" and skip exhausted connections instead
* of waiting for a 429.
*
* Design notes:
* - Window semantics: fixed windows keyed by `window_start` (epoch ms).
* When `window_reset` passes, usage resets to 0 for the new window.
* - Fail-open: reads return `{ known: false }` when the store is missing
* or empty — the scheduler treats unknown budget as available (existing
* routing behavior is preserved when quota tracking is not configured).
* - Writes are best-effort: recording usage must never break the request
* path (catch + log + return).
*
* Part of: Quota-aware provider scheduling (feat/quota-aware-scheduling).
*/
import { getDbInstance } from "@/lib/db/core";
import { createLogger } from "@/shared/utils/logger";
const log = createLogger("quota:provider-state");
export interface ProviderQuotaRow {
connectionId: string;
model: string;
tokensUsed: number;
tokenLimit: number;
windowStart: number;
windowReset: number;
updatedAt: string;
}
export interface ProviderQuotaSnapshot {
/** true when the store has a fresh record for this window */
known: boolean;
tokensUsed: number;
tokenLimit: number;
/** remaining tokens in the current window (clamped >= 0) */
tokensRemaining: number;
/** 0..1 ratio of the window budget still available */
remainingRatio: number;
windowReset: number;
}
interface RowLike {
connection_id?: string;
model?: string;
tokens_used?: number;
token_limit?: number;
window_start?: number;
window_reset?: number;
updated_at?: string;
}
function normalizeRow(row: RowLike): ProviderQuotaRow {
return {
connectionId: String(row.connection_id ?? ""),
model: String(row.model ?? ""),
tokensUsed: Number(row.tokens_used ?? 0),
tokenLimit: Number(row.token_limit ?? 0),
windowStart: Number(row.window_start ?? 0),
windowReset: Number(row.window_reset ?? 0),
updatedAt: String(row.updated_at ?? ""),
};
}
/**
* Read the current quota snapshot for (connectionId, model).
* When the record is stale (its window expired) the caller sees
* `known: false` — usage for the new window is implicitly zero.
*/
export function getProviderQuota(
connectionId: string,
model: string
): ProviderQuotaSnapshot | null {
if (!connectionId || !model) return null;
try {
const db = getDbInstance();
const row = db
.prepare("SELECT * FROM provider_quota_state WHERE connection_id = ? AND model = ?")
.get(connectionId, model) as RowLike | undefined;
if (!row) return null;
const normalized = normalizeRow(row);
const now = Date.now();
if (normalized.windowReset > 0 && now > normalized.windowReset) {
return {
known: false,
tokensUsed: 0,
tokenLimit: 0,
tokensRemaining: 0,
remainingRatio: 1,
windowReset: normalized.windowReset,
};
}
const tokenLimit = normalized.tokenLimit > 0 ? normalized.tokenLimit : 0;
const tokensUsed = Math.max(0, normalized.tokensUsed);
const tokensRemaining = tokenLimit > 0 ? Math.max(0, tokenLimit - tokensUsed) : 0;
const remainingRatio =
tokenLimit > 0 ? Math.min(1, Math.max(0, tokensRemaining / tokenLimit)) : 1;
return {
known: true,
tokensUsed,
tokenLimit,
tokensRemaining,
remainingRatio,
windowReset: normalized.windowReset,
};
} catch (err) {
log.warn(
{ err: (err as Error)?.message, connectionId, model },
"getProviderQuota failed — fail-open"
);
return null;
}
}
/**
* Record token usage for (connectionId, model) in the current window.
*
* If no row exists, seeds one with the configured tokenLimit. If the window
* has rolled over, resets usage to the new usage. Best-effort: never throws.
*/
export function recordProviderQuotaUsage(
connectionId: string,
model: string,
tokensUsedDelta: number,
opts: { tokenLimit?: number; windowMs?: number } = {}
): void {
if (!connectionId || !model || !(tokensUsedDelta > 0)) return;
try {
const db = getDbInstance();
const existing = db
.prepare("SELECT * FROM provider_quota_state WHERE connection_id = ? AND model = ?")
.get(connectionId, model) as RowLike | undefined;
const now = Date.now();
const windowMs = opts.windowMs ?? 60_000; // default: per-minute window
const windowStart = Math.floor(now / windowMs) * windowMs;
const windowReset = windowStart + windowMs;
if (!existing) {
db.prepare(
`INSERT OR REPLACE INTO provider_quota_state
(connection_id, model, tokens_used, token_limit, window_start, window_reset, updated_at)
VALUES (?, ?, ?, ?, ?, ?, ?)`
).run(
connectionId,
model,
tokensUsedDelta,
opts.tokenLimit ?? 0,
windowStart,
windowReset,
new Date().toISOString()
);
return;
}
const normalized = normalizeRow(existing);
const windowRolledOver = normalized.windowReset > 0 && now > normalized.windowReset;
const nextUsed = windowRolledOver ? tokensUsedDelta : normalized.tokensUsed + tokensUsedDelta;
const nextLimit =
opts.tokenLimit && opts.tokenLimit > 0 ? opts.tokenLimit : normalized.tokenLimit;
db.prepare(
`UPDATE provider_quota_state
SET tokens_used = ?, token_limit = ?, window_start = ?, window_reset = ?, updated_at = ?
WHERE connection_id = ? AND model = ?`
).run(
nextUsed,
nextLimit,
windowStart,
windowReset,
new Date().toISOString(),
connectionId,
model
);
} catch (err) {
log.warn(
{ err: (err as Error)?.message, connectionId, model },
"recordProviderQuotaUsage failed — best-effort"
);
}
}
/** Delete all quota state for a connection (used on connection removal). */
export function clearProviderQuota(connectionId: string): void {
if (!connectionId) return;
try {
getDbInstance()
.prepare("DELETE FROM provider_quota_state WHERE connection_id = ?")
.run(connectionId);
} catch {
// best-effort
}
}

View File

@@ -0,0 +1,128 @@
/**
* quotaAdapters.ts — Provider-specific quota header adapters.
*
* Extracts and normalizes rate limit & token budget headers from provider HTTP responses
* (OpenAI, Anthropic, Gemini, OpenRouter, ModelScope, Generic) into standardized
* provider quota states.
*
* Part of: Quota-aware provider scheduling (Phase 2).
*/
import { recordProviderQuotaUsage, getProviderQuota } from "./providerQuotaState";
export interface ParsedQuotaHeaderResult {
tokensUsed?: number;
tokenLimit?: number;
tokensRemaining?: number;
windowResetMs?: number;
}
/**
* Parse rate-limit headers from an HTTP Response or Headers object into a normalized quota result.
*/
export function parseProviderQuotaHeaders(
headers: Headers | Record<string, string | string[] | undefined>,
provider?: string
): ParsedQuotaHeaderResult | null {
if (!headers) return null;
const getHeader = (name: string): string | null => {
if (typeof (headers as Headers).get === "function") {
return (headers as Headers).get(name);
}
const record = headers as Record<string, string | string[] | undefined>;
const val = record[name] ?? record[name.toLowerCase()] ?? record[name.toUpperCase()];
if (Array.isArray(val)) return val[0] ?? null;
return val ?? null;
};
const parseNum = (val: string | null): number | undefined => {
if (!val) return undefined;
const cleaned = val.replace(/[^0-9.]/g, "");
const num = parseFloat(cleaned);
return isNaN(num) ? undefined : num;
};
const parseResetMs = (val: string | null): number | undefined => {
if (!val) return undefined;
const now = Date.now();
// Check if ISO date string
if (val.includes("T") || val.includes("Z")) {
const parsed = Date.parse(val);
if (!isNaN(parsed)) return Math.max(0, parsed - now);
}
// Check if seconds / ms string (e.g. "60s", "100ms", "0.5s", or raw number)
if (val.endsWith("ms")) return parseNum(val);
if (val.endsWith("s")) return (parseNum(val) ?? 0) * 1000;
if (val.endsWith("m")) return (parseNum(val) ?? 0) * 60 * 1000;
if (val.endsWith("h")) return (parseNum(val) ?? 0) * 3600 * 1000;
const rawNum = parseNum(val);
if (rawNum !== undefined) {
// If epoch timestamp (> 1e9), convert to remaining ms
if (rawNum > 1_000_000_000) {
return Math.max(0, rawNum * 1000 - now);
}
return rawNum * 1000; // assume relative seconds
}
return undefined;
};
const prov = (provider || "").toLowerCase();
// 1. Anthropic Headers
if (prov === "anthropic" || getHeader("anthropic-ratelimit-input-tokens-limit")) {
const limit = parseNum(getHeader("anthropic-ratelimit-input-tokens-limit"));
const remaining = parseNum(getHeader("anthropic-ratelimit-input-tokens-remaining"));
const resetStr = getHeader("anthropic-ratelimit-input-tokens-reset");
const windowResetMs = parseResetMs(resetStr);
if (limit !== undefined || remaining !== undefined) {
const tokensUsed = limit !== undefined && remaining !== undefined ? Math.max(0, limit - remaining) : undefined;
return { tokenLimit: limit, tokensRemaining: remaining, tokensUsed, windowResetMs };
}
}
// 2. OpenAI / Standard x-ratelimit-*
const limitTokens = parseNum(getHeader("x-ratelimit-limit-tokens"));
const remainingTokens = parseNum(getHeader("x-ratelimit-remaining-tokens"));
const resetTokens = getHeader("x-ratelimit-reset-tokens");
if (limitTokens !== undefined || remainingTokens !== undefined) {
const tokensUsed = limitTokens !== undefined && remainingTokens !== undefined ? Math.max(0, limitTokens - remainingTokens) : undefined;
return { tokenLimit: limitTokens, tokensRemaining: remainingTokens, tokensUsed, windowResetMs: parseResetMs(resetTokens) };
}
// 3. OpenRouter / Generic Request level headers
const genericLimit = parseNum(getHeader("x-ratelimit-limit"));
const genericRemaining = parseNum(getHeader("x-ratelimit-remaining"));
const genericReset = getHeader("x-ratelimit-reset");
if (genericLimit !== undefined || genericRemaining !== undefined) {
const tokensUsed = genericLimit !== undefined && genericRemaining !== undefined ? Math.max(0, genericLimit - genericRemaining) : undefined;
return { tokenLimit: genericLimit, tokensRemaining: genericRemaining, tokensUsed, windowResetMs: parseResetMs(genericReset) };
}
return null;
}
/**
* Apply parsed quota headers directly to the provider quota state ledger.
*/
export function applyQuotaHeadersToState(
connectionId: string,
model: string,
headers: Headers | Record<string, string | string[] | undefined>,
provider?: string
): void {
const parsed = parseProviderQuotaHeaders(headers, provider);
if (!parsed || (!parsed.tokensUsed && !parsed.tokenLimit)) return;
const now = Date.now();
const windowReset = parsed.windowResetMs ? now + parsed.windowResetMs : now + 60_000;
const tokenLimit = parsed.tokenLimit ?? 0;
const tokensUsed = parsed.tokensUsed ?? (parsed.tokenLimit && parsed.tokensRemaining ? parsed.tokenLimit - parsed.tokensRemaining : 0);
recordProviderQuotaUsage(connectionId, model, tokensUsed, {
tokenLimit,
windowMs: Math.max(0, windowReset - now),
});
}

View File

@@ -0,0 +1,114 @@
/**
* quotaAnalytics.ts — Usage analytics for provider quota state & remaining capacity.
*
* Computes aggregated capacity metrics, average remaining ratios, exhausted connection counts,
* and per-connection quota usage summaries for dashboard visibility.
*
* Part of: Quota-aware provider scheduling (Phase 2).
*/
import { getDbInstance } from "@/lib/db/core";
import { createLogger } from "@/shared/utils/logger";
const log = createLogger("quota:analytics");
export interface QuotaAnalyticsSummary {
totalConnectionsTracked: number;
exhaustedConnections: number;
healthyConnections: number;
averageRemainingRatio: number;
totalTokensUsed: number;
totalTokenLimit: number;
connections: Array<{
connectionId: string;
model: string;
tokensUsed: number;
tokenLimit: number;
tokensRemaining: number;
remainingRatio: number;
windowReset: number;
isExhausted: boolean;
}>;
}
/**
* Compute real-time quota analytics across all provider connections.
*/
export function getQuotaAnalyticsSummary(): QuotaAnalyticsSummary {
try {
const db = getDbInstance();
const rows = db.prepare("SELECT * FROM provider_quota_state").all() as Array<{
connection_id: string;
model: string;
tokens_used: number;
token_limit: number;
window_start: number;
window_reset: number;
}>;
const now = Date.now();
let totalTokensUsed = 0;
let totalTokenLimit = 0;
let exhaustedConnections = 0;
let healthyConnections = 0;
let ratioSum = 0;
const connections = rows.map((r) => {
const tokensUsed = Number(r.tokens_used ?? 0);
const tokenLimit = Number(r.token_limit ?? 0);
const windowReset = Number(r.window_reset ?? 0);
const isExpired = windowReset > 0 && now > windowReset;
const effectiveUsed = isExpired ? 0 : tokensUsed;
const effectiveLimit = isExpired ? 0 : tokenLimit;
const tokensRemaining = Math.max(0, effectiveLimit - effectiveUsed);
const remainingRatio = effectiveLimit > 0 ? tokensRemaining / effectiveLimit : 1.0;
const isExhausted = effectiveLimit > 0 && remainingRatio <= 0.05;
totalTokensUsed += effectiveUsed;
totalTokenLimit += effectiveLimit;
ratioSum += remainingRatio;
if (isExhausted) {
exhaustedConnections++;
} else {
healthyConnections++;
}
return {
connectionId: String(r.connection_id),
model: String(r.model),
tokensUsed: effectiveUsed,
tokenLimit: effectiveLimit,
tokensRemaining,
remainingRatio,
windowReset,
isExhausted,
};
});
const count = connections.length;
const averageRemainingRatio = count > 0 ? ratioSum / count : 1.0;
return {
totalConnectionsTracked: count,
exhaustedConnections,
healthyConnections,
averageRemainingRatio,
totalTokensUsed,
totalTokenLimit,
connections,
};
} catch (error) {
log.error("Failed to compute quota analytics summary", error);
return {
totalConnectionsTracked: 0,
exhaustedConnections: 0,
healthyConnections: 0,
averageRemainingRatio: 1.0,
totalTokensUsed: 0,
totalTokenLimit: 0,
connections: [],
};
}
}

View File

@@ -0,0 +1,69 @@
/**
* quotaResetTimers.ts — Automated quota window reset timers and capacity recovery.
*
* Tracks window reset timestamps and automatically clears exhausted provider quota
* states when their reset windows elapse.
*
* Part of: Quota-aware provider scheduling (Phase 2).
*/
import { getDbInstance } from "@/lib/db/core";
import { createLogger } from "@/shared/utils/logger";
const log = createLogger("quota:reset-timers");
export interface QuotaResetItem {
connectionId: string;
model: string;
tokensUsed: number;
tokenLimit: number;
windowReset: number;
timeRemainingMs: number;
}
/**
* Get all active quota states and their remaining window reset times.
*/
export function getActiveQuotaResetItems(): QuotaResetItem[] {
try {
const db = getDbInstance();
const rows = db.prepare("SELECT * FROM provider_quota_state WHERE window_reset > 0").all() as Array<{
connection_id: string;
model: string;
tokens_used: number;
token_limit: number;
window_reset: number;
}>;
const now = Date.now();
return rows.map((r) => ({
connectionId: String(r.connection_id),
model: String(r.model),
tokensUsed: Number(r.tokens_used),
tokenLimit: Number(r.token_limit),
windowReset: Number(r.window_reset),
timeRemainingMs: Math.max(0, Number(r.window_reset) - now),
}));
} catch (error) {
log.error("Failed to query active quota reset items", error);
return [];
}
}
/**
* Purge or reset all expired quota windows in SQLite.
* Returns the count of reset connections.
*/
export function resetExpiredQuotaWindows(): number {
try {
const db = getDbInstance();
const now = Date.now();
const result = db
.prepare("DELETE FROM provider_quota_state WHERE window_reset > 0 AND window_reset <= ?")
.run(now);
return result.changes ?? 0;
} catch (error) {
log.error("Failed to reset expired quota windows", error);
return 0;
}
}

View File

@@ -0,0 +1,102 @@
/**
* quotaScheduler.ts — pre-request capacity decision.
*
* Combines the per-connection token budget ledger (providerQuotaState) with
* the request cost estimate (tokenEstimator) to answer one question:
*
* "Can this connection afford this request without exceeding its
* configured per-window token budget?"
*
* The scheduler NEVER throws and NEVER blocks the request path when quota
* tracking is unconfigured — it fails open (returns `affordable: true`),
* preserving existing routing behavior. When a budget IS configured and the
* estimated cost exceeds the remaining budget, it returns
* `affordable: false` with the reason, and the caller should prefer another
* connection (the same failover machinery used for 429s).
*
* Part of: Quota-aware provider scheduling (feat/quota-aware-scheduling).
*/
import { getProviderQuota, recordProviderQuotaUsage } from "./providerQuotaState";
import { estimateChatTokenCost } from "./tokenEstimator";
export interface QuotaDecision {
affordable: boolean;
reason?: "exhausted" | "insufficient_budget" | "unconfigured";
/** remaining tokens in the window when known */
tokensRemaining?: number;
/** estimated cost of this request */
estimatedCost?: number;
/** 0..1 remaining ratio when known (1 when unknown) */
remainingRatio: number;
}
/**
* Decide whether (connectionId, model) can afford a request.
*
* @param connectionId provider connection id
* @param model model string (as routed)
* @param requestBody parsed chat body (used for the cost estimate)
* @returns a decision — always resolves, never throws
*/
export function canAffordRequest(
connectionId: string,
model: string,
requestBody: Record<string, unknown> | null | undefined
): QuotaDecision {
if (!connectionId || !model) {
return { affordable: true, reason: "unconfigured", remainingRatio: 1 };
}
const snapshot = getProviderQuota(connectionId, model);
if (!snapshot || !snapshot.known || snapshot.tokenLimit <= 0) {
// No configured budget → nothing to enforce → affordable.
return { affordable: true, reason: "unconfigured", remainingRatio: 1 };
}
const cost = estimateChatTokenCost(requestBody);
const remaining = snapshot.tokensRemaining;
const remainingRatio = snapshot.remainingRatio;
if (remaining <= 0) {
return {
affordable: false,
reason: "exhausted",
tokensRemaining: 0,
estimatedCost: cost.totalTokens,
remainingRatio: 0,
};
}
if (cost.totalTokens > remaining) {
return {
affordable: false,
reason: "insufficient_budget",
tokensRemaining: remaining,
estimatedCost: cost.totalTokens,
remainingRatio,
};
}
return {
affordable: true,
tokensRemaining: remaining,
estimatedCost: cost.totalTokens,
remainingRatio,
};
}
/**
* Reserve budget for a request (call AFTER a successful dispatch decision,
* before/around the upstream call). Best-effort: never throws.
*/
export function reserveQuota(
connectionId: string,
model: string,
requestBody: Record<string, unknown> | null | undefined,
opts: { tokenLimit?: number; windowMs?: number } = {}
): void {
if (!connectionId || !model) return;
const cost = estimateChatTokenCost(requestBody);
if (cost.totalTokens <= 0) return;
recordProviderQuotaUsage(connectionId, model, cost.totalTokens, opts);
}

View File

@@ -0,0 +1,97 @@
/**
* tokenEstimator.ts — cheap, deterministic request token-cost estimation.
*
* Estimates the token cost of a chat request (input + reserved output) so
* the quota scheduler can decide whether a connection has budget before
* dispatching. Not a model — a heuristic:
* - chars / 4 approximates tokens for most latin text (OpenAI's classic
* heuristic); CJK and code skew higher, so the estimate is a floor.
* - max_tokens / max_completion_tokens reserves the output budget when
* present; otherwise a small default output allowance is used.
*
* The estimate deliberately OVER-provisions input (×1.1) so an exhausted
* budget is not misjudged as available. Errors never throw — a broken
* estimate degrades to "unknown cost" (scheduler treats as affordable).
*/
export interface TokenCostEstimate {
/** estimated input tokens (may be 0 when body is unparseable) */
inputTokens: number;
/** reserved output budget (max_tokens or default) */
outputTokens: number;
/** input + output */
totalTokens: number;
}
const DEFAULT_OUTPUT_ALLOWANCE = 1024;
const CHARS_PER_TOKEN = 4;
const OVER_PROVISION = 1.1;
/** Count a string's tokens by chars/4 (floor). */
export function estimateStringTokens(text: string): number {
if (!text) return 0;
return Math.ceil(text.length / CHARS_PER_TOKEN);
}
/**
* Estimate the token cost of an OpenAI-style chat body.
* Accepts both `messages` (chat.completions) and `input` (Responses API).
*/
export function estimateChatTokenCost(
body: Record<string, unknown> | null | undefined
): TokenCostEstimate {
if (!body || typeof body !== "object") {
return {
inputTokens: 0,
outputTokens: DEFAULT_OUTPUT_ALLOWANCE,
totalTokens: DEFAULT_OUTPUT_ALLOWANCE,
};
}
let inputTokens = 0;
const messages = body.messages;
if (Array.isArray(messages)) {
for (const msg of messages) {
if (!msg || typeof msg !== "object") continue;
const content = (msg as Record<string, unknown>).content;
if (typeof content === "string") {
inputTokens += estimateStringTokens(content);
} else if (Array.isArray(content)) {
for (const part of content) {
if (part && typeof part === "object") {
const text = (part as Record<string, unknown>).text;
if (typeof text === "string") inputTokens += estimateStringTokens(text);
}
}
}
}
}
const input = body.input;
if (Array.isArray(input)) {
for (const item of input) {
if (!item || typeof item !== "object") continue;
const text = (item as Record<string, unknown>).text;
if (typeof text === "string") inputTokens += estimateStringTokens(text);
}
}
if (typeof body.system === "string") {
inputTokens += estimateStringTokens(body.system);
}
// Reserved output budget: max_tokens / max_completion_tokens win; fall back
// to the default allowance.
const rawMax =
typeof body.max_tokens === "number"
? body.max_tokens
: typeof body.max_completion_tokens === "number"
? body.max_completion_tokens
: undefined;
const outputTokens =
typeof rawMax === "number" && rawMax > 0 ? Math.ceil(rawMax) : DEFAULT_OUTPUT_ALLOWANCE;
const totalTokens = Math.ceil(inputTokens * OVER_PROVISION) + outputTokens;
return { inputTokens, outputTokens, totalTokens };
}

View File

@@ -108,7 +108,8 @@ test("frozen allowlists match the documented legacy and stacked-series gaps", ()
assert.equal((KNOWN_GAPS as Set<string>).has("145"), false);
// 147 left the gap list when 147_api_keys_model_access_mode.sql landed (same pattern as 143).
assert.equal((KNOWN_GAPS as Set<string>).has("147"), false);
assert.ok((KNOWN_GAPS as Set<string>).has("148"));
// 148 left the gap list when 148_provider_quota_state.sql landed on this branch (same pattern as 143/147).
assert.equal((KNOWN_GAPS as Set<string>).has("148"), false);
// 149 left the gap list when 149_api_key_combo_access.sql landed (#10066).
assert.equal((KNOWN_GAPS as Set<string>).has("149"), false);
// "041" was removed from KNOWN_DUPLICATE_VERSIONS in 6A.3 (stale: no physical

View File

@@ -0,0 +1,111 @@
import { test } from "node:test";
import assert from "node:assert/strict";
import fs from "node:fs";
import os from "node:os";
import path from "node:path";
const TEST_DATA_DIR = fs.mkdtempSync(path.join(os.tmpdir(), "omni-quota-phase2-"));
process.env.DATA_DIR = TEST_DATA_DIR;
const coreDb = await import("../../src/lib/db/core.ts");
const { parseProviderQuotaHeaders, applyQuotaHeadersToState } = await import(
"../../src/lib/quota/quotaAdapters"
);
const { getQuotaAnalyticsSummary } = await import("../../src/lib/quota/quotaAnalytics");
const { getActiveQuotaResetItems, resetExpiredQuotaWindows } = await import(
"../../src/lib/quota/quotaResetTimers"
);
const { recordProviderQuotaUsage, getProviderQuota } = await import(
"../../src/lib/quota/providerQuotaState"
);
const { getDbInstance } = coreDb;
async function resetStorage() {
coreDb.resetDbInstance();
fs.rmSync(TEST_DATA_DIR, { recursive: true, force: true });
fs.mkdirSync(TEST_DATA_DIR, { recursive: true });
}
test.beforeEach(async () => {
await resetStorage();
});
test.after(() => {
coreDb.resetDbInstance();
fs.rmSync(TEST_DATA_DIR, { recursive: true, force: true });
});
test("parseProviderQuotaHeaders: parses OpenAI rate limit headers", () => {
const headers = new Headers({
"x-ratelimit-limit-tokens": "100000",
"x-ratelimit-remaining-tokens": "80000",
"x-ratelimit-reset-tokens": "60s",
});
const parsed = parseProviderQuotaHeaders(headers, "openai");
assert.ok(parsed);
assert.equal(parsed?.tokenLimit, 100000);
assert.equal(parsed?.tokensRemaining, 80000);
assert.equal(parsed?.tokensUsed, 20000);
assert.equal(parsed?.windowResetMs, 60000);
});
test("parseProviderQuotaHeaders: parses Anthropic rate limit headers", () => {
const headers = new Headers({
"anthropic-ratelimit-input-tokens-limit": "50000",
"anthropic-ratelimit-input-tokens-remaining": "10000",
"anthropic-ratelimit-input-tokens-reset": "30s",
});
const parsed = parseProviderQuotaHeaders(headers, "anthropic");
assert.ok(parsed);
assert.equal(parsed?.tokenLimit, 50000);
assert.equal(parsed?.tokensRemaining, 10000);
assert.equal(parsed?.tokensUsed, 40000);
assert.equal(parsed?.windowResetMs, 30000);
});
test("applyQuotaHeadersToState & getQuotaAnalyticsSummary: records and aggregates quota analytics", () => {
const connId = "test-conn-p2-01";
const model = "gpt-4o";
const headers = {
"x-ratelimit-limit-tokens": "100000",
"x-ratelimit-remaining-tokens": "20000",
"x-ratelimit-reset-tokens": "120s",
};
applyQuotaHeadersToState(connId, model, headers, "openai");
const snapshot = getProviderQuota(connId, model);
assert.ok(snapshot);
assert.equal(snapshot?.tokensUsed, 80000);
assert.equal(snapshot?.tokenLimit, 100000);
const analytics = getQuotaAnalyticsSummary();
assert.ok(analytics.totalConnectionsTracked > 0);
assert.ok(analytics.connections.some((c) => c.connectionId === connId));
});
test("quotaResetTimers: tracks active reset items and purges expired windows", () => {
const connId = "test-conn-expired";
const model = "claude-sonnet-4-6";
const now = Date.now();
// Seed an already-expired window directly (recordProviderQuotaUsage always
// computes windows from Date.now(), so it cannot create a past window).
const db = getDbInstance();
db.prepare(
`INSERT OR REPLACE INTO provider_quota_state
(connection_id, model, tokens_used, token_limit, window_start, window_reset, updated_at)
VALUES (?, ?, ?, ?, ?, ?, ?)`
).run(
connId,
model,
5000,
5000,
now - 10_000,
now - 1_000,
new Date().toISOString()
);
const expiredCount = resetExpiredQuotaWindows();
assert.ok(expiredCount >= 1);
});

View File

@@ -0,0 +1,89 @@
import { test } from "node:test";
import assert from "node:assert/strict";
import fs from "node:fs";
import os from "node:os";
import path from "node:path";
const TEST_DATA_DIR = fs.mkdtempSync(path.join(os.tmpdir(), "omni-quota-sched-"));
process.env.DATA_DIR = TEST_DATA_DIR;
const coreDb = await import("../../src/lib/db/core.ts");
const { canAffordRequest } = await import("../../src/lib/quota/quotaScheduler");
const { clearProviderQuota, getProviderQuota, recordProviderQuotaUsage } =
await import("../../src/lib/quota/providerQuotaState");
async function resetStorage() {
coreDb.resetDbInstance();
fs.rmSync(TEST_DATA_DIR, { recursive: true, force: true });
fs.mkdirSync(TEST_DATA_DIR, { recursive: true });
}
test.beforeEach(async () => {
await resetStorage();
});
test.after(() => {
coreDb.resetDbInstance();
fs.rmSync(TEST_DATA_DIR, { recursive: true, force: true });
});
const CONN = "test-conn-quota";
const MODEL = "test-model";
test("canAffordRequest: fails open when no budget configured", () => {
clearProviderQuota(CONN);
const decision = canAffordRequest(CONN, MODEL, { messages: [{ role: "user", content: "hi" }] });
assert.equal(decision.affordable, true);
assert.equal(decision.reason, "unconfigured");
});
test("canAffordRequest: skips exhausted budget", () => {
clearProviderQuota(CONN);
recordProviderQuotaUsage(CONN, MODEL, 10_000, { tokenLimit: 10_000, windowMs: 60_000 });
const decision = canAffordRequest(CONN, MODEL, {
messages: [{ role: "user", content: "hello world this is a request" }],
});
assert.equal(decision.affordable, false);
assert.equal(decision.reason, "exhausted");
});
test("canAffordRequest: blocks when cost exceeds remaining", () => {
clearProviderQuota(CONN);
recordProviderQuotaUsage(CONN, MODEL, 9_000, { tokenLimit: 10_000, windowMs: 60_000 });
const decision = canAffordRequest(CONN, MODEL, {
messages: [{ role: "user", content: "x".repeat(4 * 800) }], // ~800 tokens
max_tokens: 2000,
});
assert.equal(decision.affordable, false);
assert.equal(decision.reason, "insufficient_budget");
});
test("canAffordRequest: allows within budget", () => {
clearProviderQuota(CONN);
recordProviderQuotaUsage(CONN, MODEL, 1_000, { tokenLimit: 10_000, windowMs: 60_000 });
const decision = canAffordRequest(CONN, MODEL, { messages: [{ role: "user", content: "hi" }] });
assert.equal(decision.affordable, true);
assert.ok((decision.tokensRemaining ?? 0) > 0);
});
test("recordProviderQuotaUsage: seeds a row and accumulates", () => {
clearProviderQuota(CONN);
recordProviderQuotaUsage(CONN, MODEL, 100, { tokenLimit: 1_000, windowMs: 60_000 });
recordProviderQuotaUsage(CONN, MODEL, 150, { tokenLimit: 1_000, windowMs: 60_000 });
const snap = getProviderQuota(CONN, MODEL);
assert.ok(snap);
assert.equal(snap.tokensUsed, 250);
assert.equal(snap.tokenLimit, 1_000);
assert.equal(snap.tokensRemaining, 750);
});
test("getProviderQuota: returns null for unknown pair", () => {
clearProviderQuota(CONN);
assert.equal(getProviderQuota(CONN, "nope-model"), null);
});
test("getProviderQuota: ignores non-positive deltas", () => {
clearProviderQuota(CONN);
recordProviderQuotaUsage(CONN, MODEL, 0, { tokenLimit: 1_000 });
assert.equal(getProviderQuota(CONN, MODEL), null);
});

View File

@@ -0,0 +1,83 @@
import { test } from "node:test";
import assert from "node:assert/strict";
import { estimateChatTokenCost, estimateStringTokens } from "../../src/lib/quota/tokenEstimator";
test("estimateStringTokens: chars/4 heuristic", () => {
assert.equal(estimateStringTokens(""), 0);
assert.equal(estimateStringTokens("abcd"), 1);
assert.equal(estimateStringTokens("abcdefgh"), 2);
});
test("estimateChatTokenCost: sums message content strings", () => {
const cost = estimateChatTokenCost({
messages: [
{ role: "user", content: "Hello world, this is a test message" },
{ role: "assistant", content: "A shorter reply" },
],
});
assert.ok(cost.inputTokens > 0);
// total = input × 1.1 (over-provision) + output budget
assert.equal(cost.totalTokens, Math.ceil(cost.inputTokens * 1.1) + cost.outputTokens);
});
test("estimateChatTokenCost: includes system prompt", () => {
const withoutSystem = estimateChatTokenCost({
messages: [{ role: "user", content: "hi there" }],
});
const withSystem = estimateChatTokenCost({
system: "You are a helpful assistant with a fairly long system prompt to count",
messages: [{ role: "user", content: "hi there" }],
});
assert.ok(withSystem.inputTokens > withoutSystem.inputTokens);
});
test("estimateChatTokenCost: honors max_tokens as output budget", () => {
const cost = estimateChatTokenCost({
messages: [{ role: "user", content: "hi" }],
max_tokens: 2000,
});
assert.equal(cost.outputTokens, 2000);
});
test("estimateChatTokenCost: honors max_completion_tokens (Responses API)", () => {
const cost = estimateChatTokenCost({
messages: [{ role: "user", content: "hi" }],
max_completion_tokens: 500,
});
assert.equal(cost.outputTokens, 500);
});
test("estimateChatTokenCost: defaults output allowance when unset", () => {
const cost = estimateChatTokenCost({ messages: [{ role: "user", content: "hi" }] });
assert.equal(cost.outputTokens, 1024);
});
test("estimateChatTokenCost: handles multimodal content arrays", () => {
const cost = estimateChatTokenCost({
messages: [
{
role: "user",
content: [
{ type: "text", text: "Describe this image" },
{ type: "image_url", image_url: { url: "data:image/png;base64,xxx" } },
],
},
],
});
assert.ok(cost.inputTokens > 0);
});
test("estimateChatTokenCost: handles Responses API input array", () => {
const cost = estimateChatTokenCost({
input: [{ role: "user", text: "What is the capital of France" }],
});
assert.ok(cost.inputTokens > 0);
});
test("estimateChatTokenCost: never throws on malformed bodies", () => {
for (const bad of [null, undefined, {}, { messages: "nope" }, { messages: [null, 42] }]) {
const cost = estimateChatTokenCost(bad as Record<string, unknown>);
assert.ok(cost.totalTokens >= 0);
}
});