fix(budget): une table sans aucune ligne datée n'est jamais « 0 € vérifié »

Passe /autofeedback (angle checkpoint) : si NocoDB renvoie des lignes
sans timestamp, CreatedAt ni created_at, checkBudget rendait
verified=true à 0 €, soit le fail-open silencieux d'avant sous une autre
forme. Désormais verified=false et avertissement au journal. 17/17.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_0174RrDEQFQTtySXkTcsUKuv

PIPE-IA-DOC.md

@@ -204,6 +204,8 @@ cout_eur = ((tokens_in × 0.02 + tokens_out × 0.04) / 1_000_000) × 0.93
 
 Le filtre NocoDB par date (`gte,YYYY-MM-DD`) n'est pas supporté en v0.301.5. Contournement : récupération de tous les records stats_usage (limit=1000) et filtre JavaScript par mois/année.
 
+**Côté chatbot (AF5, 29/09)** : `server/utils/circuitBreaker.ts` n'appliquait pas ce contournement. Il envoyait `where=(timestamp,gte,…)&fields=cout_eur,timestamp` et recevait un 422 à chaque appel : fail-open silencieux, budget jamais vérifié depuis la V2. Il suit désormais le worker : **aucune colonne nommée dans la requête** (ni `where`, ni `fields`, ni `sort`), lecture paginée (`limit`/`offset` 1000), mois filtré en JS sur `timestamp`, sinon `CreatedAt`, sinon `created_at`. Chaque lecture écrit au journal `[circuitBreaker] budget lu : X € / 20 € (n lignes AAAA-MM sur N lues)` ; un échec écrit `budget NON vérifié`. Test : `node scripts/test-circuit-breaker.mjs` (faux NocoDB qui rejette en 422 toute colonne absente). Seule `/api/chatbot` vérifie le budget ; `-reseaux` et `-taff` ne le lisent ni ne l'écrivent (asymétrie pré-existante), et les appels servis par un tier gratuit s'inscrivent à 0 €.
+
 ---
 
 ## 7. Infrastructure
@@ -365,7 +367,7 @@ fait ici pour ne pas tester un ALTER contre la prod sans l'avoir vérifié.
 
 | Sujet | NAV V2 (§1-10 ci-dessus) | AEP B5 |
 |---|---|---|
-| LLM | Mistral Nemo, appel direct | **Bifrost** (`${BIFROST_URL}/v1/chat/completions`, header `x-bf-vk`), modèle `WORKER_MODEL` (défaut `groq/llama-3.1-8b-instant`) |
+| LLM | Mistral Nemo, appel direct | **Bifrost** (`${BIFROST_URL}/v1/chat/completions`, header `x-bf-vk`), modèle `WORKER_MODEL` (défaut `groq/openai/gpt-oss-20b` depuis le 28/09, voir §11.3) |
 | Scrape | crawl4ai (Python, `AsyncHTTPCrawlerStrategy`) | **fetch natif Node 22** — timeout 8 s, corps plafonné 500 Ko, extraction titre + meta description + `og:*` + texte visible tronqué à 4000 caractères, `User-Agent: AEP/2.0 contact@trans-former.fr` |
 | Notification | Resend (email Jules) | **ntfy** (`POST https://ntfy.sh/$NTFY_TOPIC`) — le message ne contient JAMAIS l'email ni le texte libre du contributeur, seulement id NocoDB / nom suggéré / type / confiance |
 | Seuil « 5 fiches pending » | Email si ≥ 5 en attente | **Retiré** (décision MOE : volume faible, une notif par fiche traitée suffit — à réactiver si le volume monte) |
@@ -381,3 +383,40 @@ Le mode `--dry-run` (`node enrich.js --dry-run`) lit
 `worker/fixtures/dry-run-rows.json` au lieu de NocoDB, n'écrit rien, et par
 défaut mock aussi le scrape et l'appel Bifrost (`DRY_RUN_LIVE=1` pour
 forcer de vrais appels réseau sans jamais toucher NocoDB).
+
+### 11.3 Modèles Groq retirés — bascule sur gpt-oss (2026-09-28)
+
+Groq ne sert plus `llama-3.1-8b-instant` ni `llama-3.3-70b-versatile`
+(404 `model_not_found` via Bifrost, constaté au test M3 du 28/09).
+
+| Consommateur | Avant | Après | Où |
+|---|---|---|---|
+| Worker (`worker/enrich.js`) | `groq/llama-3.1-8b-instant` | `groq/openai/gpt-oss-20b` | prod : `WORKER_MODEL` dans `/opt/aep/.env` depuis le 28/09 ; défaut du code aligné |
+| Chatbots, tier RAPIDE | `groq/llama-3.1-8b-instant` | `groq/openai/gpt-oss-20b` | `server/utils/bifrost.ts`, replis inchangés |
+| Chatbots, tier APPROFONDI | `groq/llama-3.3-70b-versatile` | `groq/openai/gpt-oss-120b` | `server/utils/bifrost.ts`, replis inchangés |
+| RAG Pensées (LightRAG) | `gemini-oai/models/gemini-2.5-flash-lite` | inchangé | `/opt/lightrag/.env`, hors de ce routage |
+
+Entre le retrait et ce correctif, chaque appel chatbot partait sur le
+premier repli Gemini (`stats_usage` depuis le 23/09 environ) : service
+rendu, modèle primaire jamais servi.
+
+**gpt-oss est un modèle à raisonnement.** Deux conséquences :
+- la réponse porte `choices[0].message.reasoning` à côté de `content`. Les
+  trois routes (`chatbot`, `chatbot-reseaux`, `chatbot-taff`) et le worker ne
+  lisent que `content` (JSON), `usage` et `extra_fields` : le champ est
+  ignoré, rien n'en dépend. `chatbot-pensees` lit la réponse de LightRAG
+  (`response`, `references`), pas celle de Bifrost ;
+- les tokens de raisonnement sont décomptés de `max_tokens`. Si le
+  fournisseur rend un JSON tronqué en HTTP 200, Bifrost ne bascule pas et
+  l'usager lit « Je n'ai pas pu analyser ta demande » (s'il le rejette en
+  400, le repli Gemini prend le relais : dégradé, pas cassé). Les routes chatbot ajoutent donc
+  `REASONING_MARGIN_TOKENS` (800) à leur budget de contenu (600 ou 700), et
+  `bifrostContent()` écrit un avertissement au journal quand
+  `finish_reason` vaut `length`. Le worker garde `max_tokens: 800` (sortie
+  courte, M3 passé en 1,6 s) ; à relever si `tokens_out` approche 800 dans
+  `stats_usage`.
+
+**Non testé depuis Windows** (Bifrost écoute sur le loopback du VPS). Test
+réel au checkpoint : un appel par route, relever `extra_fields` (modèle
+réellement servi), `usage.completion_tokens`, `finish_reason`, et le
+modèle inscrit dans `stats_usage` pour `/api/chatbot`.

components/Chip.vue

@@ -77,8 +77,12 @@ const emit = defineEmits<{
   }
 }
 
-.chip:hover {
-  transform: translateY(-1px);
+/* Survol : uniquement sur pointeur capable de survol. Sur tactile, :hover
+   reste collé après un tap (chip « allumé » sans être actif). */
+@media (hover: hover) {
+  .chip:hover {
+    transform: translateY(-1px);
+  }
 }
 
 .chip:focus-visible {
@@ -92,19 +96,21 @@ const emit = defineEmits<{
   color: var(--text);
   background: transparent;
 }
-.chip--echelle:hover {
-  background: var(--primary-hover);
-  border-color: var(--primary-hover);
-  color: var(--on-primary);
+@media (hover: hover) {
+  .chip--echelle:hover {
+    background: var(--primary-hover);
+    border-color: var(--primary-hover);
+    color: var(--on-primary);
+  }
 }
+/* Actif = fond PLEIN. --primary est translucide dans le thème AEP
+   (rgba(26,34,56,.6) : 4,16:1 sur le fond de page, sous AA) ; le couple
+   --nav-primary-solid / --nav-text-on-primary (≈14,6:1) reste lisible aussi
+   en sombre. Le survol d'un chip actif ne change pas de fond. */
 .chip--echelle.chip--active {
-  background: var(--primary);
-  border-color: var(--primary);
-  color: var(--on-primary);
-}
-.chip--echelle.chip--active:hover {
-  background: var(--primary-hover);
-  border-color: var(--primary-hover);
+  background: var(--nav-primary-solid);
+  border-color: var(--nav-primary-solid);
+  color: var(--nav-text-on-primary);
 }
 
 /* ── Fonction/hashtag : pleine bleu, inactif = bg-alt ────────────────────── */
@@ -113,16 +119,15 @@ const emit = defineEmits<{
   background: var(--bg-alt);
   color: var(--text);
 }
-.chip--fonction:hover {
-  background: var(--primary-hover);
-  color: var(--on-primary);
+@media (hover: hover) {
+  .chip--fonction:hover {
+    background: var(--primary-hover);
+    color: var(--on-primary);
+  }
 }
 .chip--fonction.chip--active {
-  background: var(--primary);
-  color: var(--on-primary);
-}
-.chip--fonction.chip--active:hover {
-  background: var(--primary-hover);
+  background: var(--nav-primary-solid);
+  color: var(--nav-text-on-primary);
 }
 
 /* ── Posture (préparée pour plus tard) : outline safran ──────────────────── */
@@ -131,9 +136,11 @@ const emit = defineEmits<{
   color: var(--text);
   background: transparent;
 }
-.chip--posture:hover {
-  background: var(--accent);
-  color: var(--on-accent);
+@media (hover: hover) {
+  .chip--posture:hover {
+    background: var(--accent);
+    color: var(--on-accent);
+  }
 }
 .chip--posture.chip--active {
   background: var(--accent);

components/FormLibre.vue

@@ -46,12 +46,21 @@
           :label="TYPES_SUGGERES_LABELS[t]"
           variant="fonction"
           :active="typeSuggere === t || typeSecondaire === t"
+          :class="{ 'chip--secondaire': typeSecondaire === t }"
           @toggle="toggleType(t)"
         />
       </ChipGroup>
       <span id="libre-type-hint" class="label-hint">
         Écosystème : {{ TYPES_SUGGERES_HINTS.ecosysteme }} · Réseau : {{ TYPES_SUGGERES_HINTS.reseau }} · Jobs : {{ TYPES_SUGGERES_HINTS.jobs }} · Outils : {{ TYPES_SUGGERES_HINTS.outils }} · Références : {{ TYPES_SUGGERES_HINTS.references }}
       </span>
+      <!-- Distinction non visuelle premier choix / second choix pour lecteurs d'écran :
+           les deux chips actifs partagent le même aria-pressed, sans quoi rien ne dit
+           lequel est principal. -->
+      <span class="sr-only" aria-live="polite">
+        <template v-if="typeSuggere && typeSecondaire">
+          Principal : {{ TYPES_SUGGERES_LABELS[typeSuggere] }} · second choix : {{ TYPES_SUGGERES_LABELS[typeSecondaire] }}
+        </template>
+      </span>
     </div>
 
     <div class="field-group" :class="{ 'field-error': errors.submitted_by_email }">
@@ -264,4 +273,38 @@ async function submit() {
   clip: rect(0 0 0 0);
   white-space: nowrap;
 }
+
+.sr-only {
+  position: absolute;
+  width: 1px;
+  height: 1px;
+  overflow: hidden;
+  clip: rect(0 0 0 0);
+  white-space: nowrap;
+}
+
+/* ── B5-M2c : distinction principal / second choix ──
+   Le principal actif (fond plein, ≈14,6:1) et le survol gardé par
+   @media (hover: hover) viennent de Chip.vue depuis AF5 : les surcharges
+   locales de AF4 (principal plein, survol collant neutralisé sur tactile)
+   ont été retirées. */
+
+/* Chip secondaire (deuxième choix) : contour au lieu de plein, pour ne
+   jamais se confondre avec le principal — ni à l'œil ni au clic. Texte
+   --nav-text sur le fond de page : contraste très large (>10:1), stable
+   dans tous les états. */
+.field-group :deep(.chip--secondaire.chip--active) {
+  background: transparent !important;
+  border-color: var(--nav-primary-solid) !important;
+  color: var(--nav-text) !important;
+}
+/* Survol du secondaire : pointeur capable de survol seulement, comme Chip.vue
+   (sur tactile, :hover reste collé après un tap). */
+@media (hover: hover) {
+  .field-group :deep(.chip--secondaire.chip--active:hover) {
+    background: rgba(var(--nav-primary-raw), 0.08) !important;
+    border-color: var(--nav-primary-solid) !important;
+    color: var(--nav-text) !important;
+  }
+}
 </style>

scripts/test-circuit-breaker.mjs

@@ -0,0 +1,179 @@
+#!/usr/bin/env node
+/**
+ * Test du circuit breaker budget (server/utils/circuitBreaker.ts), AF5.
+ * Charge le VRAI module TS via jiti (comme test-submit-libre.mjs).
+ *
+ * Le faux NocoDB ci-dessous se comporte comme le vrai sur le point qui a cassé :
+ * toute colonne nommée dans `where`, `fields` ou `sort` et absente du schéma
+ * renvoie un 422. Réintroduire un filtre sur un champ absent fait donc échouer
+ * le cas « schéma sans timestamp ».
+ * Usage : node scripts/test-circuit-breaker.mjs
+ */
+
+import { createJiti } from 'jiti'
+import { fileURLToPath } from 'node:url'
+import { dirname, join } from 'node:path'
+
+const __dirname = dirname(fileURLToPath(import.meta.url))
+const jiti = createJiti(import.meta.url)
+
+const { checkBudget, BUDGET_MAX_EUR } = await jiti.import(
+  join(__dirname, '..', 'server', 'utils', 'circuitBreaker.ts'),
+)
+
+const NOW = new Date('2026-09-29T10:00:00Z')
+
+/** Colonnes référencées par une requête NocoDB v2 (where, fields, sort). */
+function colonnesReferencees(query) {
+  const cols = []
+  if (query.where) {
+    for (const m of String(query.where).matchAll(/\(([^,()]+),/g)) cols.push(m[1].trim())
+  }
+  if (query.fields) cols.push(...String(query.fields).split(',').map((s) => s.trim()))
+  if (query.sort) cols.push(...String(query.sort).split(',').map((s) => s.trim().replace(/^-/, '')))
+  return cols.filter(Boolean)
+}
+
+/** Faux NocoDB : schéma de colonnes + lignes ; 422 sur colonne inconnue ; pagination limit/offset. */
+function fauxNocodb({ schema, rows, panne = false }) {
+  const appels = []
+  const fetchJson = async (url, { headers, query }) => {
+    appels.push({ url, query })
+    if (panne) throw Object.assign(new Error('[GET] 500 Internal Server Error'), { statusCode: 500 })
+    if (headers['xc-token'] !== 'tok') throw Object.assign(new Error('401'), { statusCode: 401 })
+    const inconnues = colonnesReferencees(query).filter((c) => !schema.includes(c))
+    if (inconnues.length) {
+      throw Object.assign(new Error(`[GET] 422 Field '${inconnues[0]}' not found`), { statusCode: 422 })
+    }
+    const limit = Number(query.limit ?? 25)
+    const offset = Number(query.offset ?? 0)
+    const list = rows.slice(offset, offset + limit)
+    return { list, pageInfo: { isLastPage: offset + limit >= rows.length } }
+  }
+  return { fetchJson, appels }
+}
+
+const base = { nocodbUrl: 'http://noco', nocodbToken: 'tok', statsTableId: 'mbbq7n47ixy19mc', now: NOW }
+
+// Schéma supposé de la prod : pas de colonne `timestamp`, date système `CreatedAt`.
+const SCHEMA_SANS_TS = ['Id', 'model', 'endpoint', 'tokens_in', 'tokens_out', 'cout_eur', 'orga_id', 'CreatedAt', 'UpdatedAt']
+const SCHEMA_AVEC_TS = [...SCHEMA_SANS_TS, 'timestamp']
+
+const results = []
+function check(name, cond, detail = '') {
+  results.push({ name, ok: !!cond, detail })
+}
+
+// Journal capturé pour vérifier la ligne de budget
+const logs = []
+const origInfo = console.info
+const origWarn = console.warn
+console.info = (...a) => logs.push(['info', a.join(' ')])
+console.warn = (...a) => logs.push(['warn', a.join(' ')])
+
+try {
+  // 0. Le faux NocoDB rejette bien l'ancienne requête (sinon le test ne prouverait rien)
+  {
+    const { fetchJson } = fauxNocodb({ schema: SCHEMA_SANS_TS, rows: [] })
+    let status = null
+    try {
+      await fetchJson('x', {
+        headers: { 'xc-token': 'tok' },
+        query: { where: '(timestamp,gte,2026-09-01T00:00:00.000Z)', limit: 1000, fields: 'cout_eur,timestamp' },
+      })
+    } catch (e) {
+      status = e.statusCode
+    }
+    check('faux NocoDB : ancienne requête (where/fields sur timestamp) → 422', status === 422, `statut ${status}`)
+  }
+
+  // 1. Schéma sans timestamp : lu, mois courant seul, aucune colonne nommée
+  {
+    const rows = [
+      { Id: 1, cout_eur: 0.5, CreatedAt: '2026-09-03T08:00:00.000Z' },
+      { Id: 2, cout_eur: '1.25', CreatedAt: '2026-09-28 22:10:00+00:00' },
+      { Id: 3, cout_eur: 7, CreatedAt: '2026-08-31T23:59:00.000Z' }, // mois précédent
+      { Id: 4, cout_eur: null, CreatedAt: '2026-09-10T00:00:00.000Z' },
+    ]
+    const { fetchJson, appels } = fauxNocodb({ schema: SCHEMA_SANS_TS, rows })
+    logs.length = 0
+    const s = await checkBudget({ ...base, fetchJson })
+    check('sans timestamp : budget vérifié (pas de 422)', s.verified === true, JSON.stringify(s))
+    check('sans timestamp : cumul = 1,75 € (août exclu)', Math.abs(s.cumulEur - 1.75) < 1e-9, `cumul ${s.cumulEur}`)
+    check('sans timestamp : 3 lignes du mois sur 4', s.lignesMois === 3 && s.lignesLues === 4)
+    check('aucune colonne nommée dans la requête', appels.every((a) => colonnesReferencees(a.query).length === 0),
+      JSON.stringify(appels.map((a) => a.query)))
+    const ligne = logs.find(([niv, t]) => niv === 'info' && t.includes('[circuitBreaker] budget lu'))
+    check('journal : ligne « budget lu » avec le cumul', ligne && ligne[1].includes('1.7500 €'), ligne?.[1] ?? 'absente')
+  }
+
+  // 2. Schéma avec timestamp : timestamp prioritaire sur CreatedAt (ordre du worker)
+  {
+    const rows = [
+      { Id: 1, cout_eur: 2, timestamp: '2026-09-15T12:00:00.000Z', CreatedAt: '2026-08-15T12:00:00.000Z' },
+      { Id: 2, cout_eur: 3, timestamp: '2026-08-15T12:00:00.000Z', CreatedAt: '2026-09-15T12:00:00.000Z' },
+    ]
+    const { fetchJson } = fauxNocodb({ schema: SCHEMA_AVEC_TS, rows })
+    const s = await checkBudget({ ...base, fetchJson })
+    check('avec timestamp : timestamp prioritaire (cumul 2 €)', s.verified && s.cumulEur === 2, `cumul ${s.cumulEur}`)
+  }
+
+  // 3. Lignes sans aucune date : ignorées et comptées
+  {
+    const rows = [{ Id: 1, cout_eur: 9 }, { Id: 2, cout_eur: 1, CreatedAt: '2026-09-02T00:00:00Z' }]
+    const { fetchJson } = fauxNocodb({ schema: SCHEMA_SANS_TS, rows })
+    logs.length = 0
+    const s = await checkBudget({ ...base, fetchJson })
+    check('sans date : ignorée, comptée', s.cumulEur === 1 && s.lignesSansDate === 1)
+    check('journal : lignes sans date signalées', logs.some(([, t]) => t.includes('1 sans date ignorées')))
+  }
+
+  // 3bis. Aucune ligne datée : jamais « 0 € vérifié »
+  {
+    const rows = [{ Id: 1, cout_eur: 30 }, { Id: 2, cout_eur: 1 }]
+    const { fetchJson } = fauxNocodb({ schema: ['Id', 'cout_eur'], rows })
+    logs.length = 0
+    const s = await checkBudget({ ...base, fetchJson })
+    check('aucune date : verified=false, pas 0 € vérifié', s.verified === false && s.lignesSansDate === 2)
+    check('aucune date : avertissement « NON vérifié »', logs.some(([niv, t]) => niv === 'warn' && t.includes('NON vérifié')))
+  }
+
+  // 4. Pagination : 2 500 lignes du mois à 0,01 € → 25 € → bloqué
+  {
+    const rows = Array.from({ length: 2500 }, (_, i) => ({ Id: i + 1, cout_eur: 0.01, CreatedAt: '2026-09-20T00:00:00Z' }))
+    const { fetchJson, appels } = fauxNocodb({ schema: SCHEMA_SANS_TS, rows })
+    logs.length = 0
+    const s = await checkBudget({ ...base, fetchJson })
+    check('pagination : 2 500 lignes lues en 3 pages', s.lignesLues === 2500 && appels.length === 3, `${s.lignesLues} lignes, ${appels.length} appels`)
+    check(`seuil : 25 € ≥ ${BUDGET_MAX_EUR} € → blocked`, s.blocked === true && s.warning === true)
+    check('journal : BLOQUÉ', logs.some(([, t]) => t.includes('BLOQUÉ')))
+  }
+
+  // 5. Alerte entre 18 et 20 €
+  {
+    const rows = [{ Id: 1, cout_eur: 18.5, CreatedAt: '2026-09-20T00:00:00Z' }]
+    const { fetchJson } = fauxNocodb({ schema: SCHEMA_SANS_TS, rows })
+    const s = await checkBudget({ ...base, fetchJson })
+    check('18,5 € → warning sans blocage', s.warning === true && s.blocked === false)
+  }
+
+  // 6. Panne NocoDB : fail-open, mais verified=false et avertissement au journal
+  {
+    const { fetchJson } = fauxNocodb({ schema: SCHEMA_SANS_TS, rows: [], panne: true })
+    logs.length = 0
+    const s = await checkBudget({ ...base, fetchJson })
+    check('panne : fail-open, verified=false', s.blocked === false && s.verified === false)
+    check('panne : avertissement « NON vérifié »', logs.some(([niv, t]) => niv === 'warn' && t.includes('NON vérifié')))
+  }
+} finally {
+  console.info = origInfo
+  console.warn = origWarn
+}
+
+let failed = 0
+for (const r of results) {
+  if (!r.ok) failed++
+  console.log(`${r.ok ? 'ok  ' : 'FAIL'} ${r.name}${r.ok ? '' : `  → ${r.detail}`}`)
+}
+console.log(failed ? `\nÉCHEC — ${failed}/${results.length} tests en échec` : `\nPASS — ${results.length}/${results.length} tests passés`)
+process.exit(failed ? 1 : 0)

server/api/chatbot-reseaux.post.ts

@@ -1,12 +1,12 @@
 /**
  * POST /api/chatbot-reseaux
  * Chatbot Réseaux AEP — Carte 2 "Réseaux de bifurcation"
- * Keyword search sur reseaux-bifurcation.json + Mistral Small.
+ * Keyword search sur reseaux-bifurcation.json + LLM via Bifrost (server/utils/bifrost.ts).
  */
 // @ts-ignore — JSON import résolu par Rollup
 import reseauxData from '../../public/data/reseaux-bifurcation.json'
 import { checkRateLimitJson } from '~/server/utils/rateLimitJson'
-import { pickBifrostTier, type BifrostChatResponse } from '~/server/utils/bifrost'
+import { pickBifrostTier, bifrostContent, REASONING_MARGIN_TOKENS, type BifrostChatResponse } from '~/server/utils/bifrost'
 
 interface Structure {
   id: string
@@ -99,7 +99,7 @@ export default defineEventHandler(async (event) => {
           model: tier.model,
           fallbacks: tier.fallbacks,
           temperature: 0.3,
-          max_tokens: 700,
+          max_tokens: 700 + REASONING_MARGIN_TOKENS,
           response_format: { type: 'json_object' },
           messages: [
             { role: 'system', content: systemPrompt },
@@ -108,7 +108,7 @@ export default defineEventHandler(async (event) => {
         }),
       }
     )
-    mistralRaw = res.choices?.[0]?.message?.content ?? '{}'
+    mistralRaw = bifrostContent(res, 'chatbot-reseaux')
   } catch {
     throw createError({ statusCode: 502, message: 'Erreur IA — réessaie dans quelques instants.' })
   }

server/api/chatbot-taff.post.ts

@@ -1,13 +1,13 @@
 /**
  * POST /api/chatbot-taff
  * Chatbot d'aiguillage — Carte 3 "Trouver du taf"
- * Lit plateformes-taff.json, appelle Mistral Small, retourne recommandations.
+ * Lit plateformes-taff.json, appelle un LLM via Bifrost (server/utils/bifrost.ts), retourne recommandations.
  */
 
 // @ts-ignore — JSON import résolu par Vite/Rollup
 import taffData from '../../public/data/plateformes-taff.json'
 import { checkRateLimitJson } from '~/server/utils/rateLimitJson'
-import { pickBifrostTier, type BifrostChatResponse } from '~/server/utils/bifrost'
+import { pickBifrostTier, bifrostContent, REASONING_MARGIN_TOKENS, type BifrostChatResponse } from '~/server/utils/bifrost'
 
 interface PlateformeMinimal {
   id: string
@@ -110,7 +110,7 @@ export default defineEventHandler(async (event) => {
           model: tier.model,
           fallbacks: tier.fallbacks,
           temperature: 0.3,
-          max_tokens: 700,
+          max_tokens: 700 + REASONING_MARGIN_TOKENS,
           response_format: { type: 'json_object' },
           messages: [
             { role: 'system', content: systemPrompt },
@@ -119,7 +119,7 @@ export default defineEventHandler(async (event) => {
         }),
       }
     )
-    mistralRaw = res.choices?.[0]?.message?.content ?? '{}'
+    mistralRaw = bifrostContent(res, 'chatbot-taff')
   } catch {
     throw createError({ statusCode: 502, statusMessage: 'Erreur IA — réessaie dans quelques instants.' })
   }

server/api/chatbot.post.ts

@@ -1,14 +1,14 @@
 /**
  * POST /api/chatbot
  *
- * Chatbot recherche sémantique — Mistral Small
+ * Chatbot recherche sémantique — LLM via Bifrost (tiers et replis : server/utils/bifrost.ts)
  * Spec : F §7 (endpoint), F §8 (rate limit), E-spec §6 (détails chatbot)
  *
  * Flow :
  *   1. Rate limit : 10 req/IP/jour (JSON fichier, SHA-256)
  *   2. Circuit breaker : budget 20€/mois
  *   3. Fetch top-N fiches (keyword match sur nom+description+fonctions)
- *   4. Appel Mistral Small avec contexte JSON compact
+ *   4. Appel Bifrost (tier RAPIDE par défaut) avec contexte JSON compact
  *   5. Parse JSON → { reponse_texte, fiches_recommandees }
  *   6. Log stats_usage
  *
@@ -19,7 +19,7 @@
 
 import { checkRateLimitJson } from '~/server/utils/rateLimitJson'
 import { checkBudget, calcCoutMistralSmall } from '~/server/utils/circuitBreaker'
-import { pickBifrostTier, type BifrostChatResponse } from '~/server/utils/bifrost'
+import { pickBifrostTier, bifrostContent, REASONING_MARGIN_TOKENS, type BifrostChatResponse } from '~/server/utils/bifrost'
 
 // ── Types ──────────────────────────────────────────────────────────────────────
 
@@ -277,7 +277,7 @@ export default defineEventHandler(async (event) => {
         model: tier.model,
         fallbacks: tier.fallbacks,
         temperature: 0.3,
-        max_tokens: 600,
+        max_tokens: 600 + REASONING_MARGIN_TOKENS,
         response_format: { type: 'json_object' },
         messages: [
           { role: 'system', content: systemPrompt },
@@ -286,7 +286,7 @@ export default defineEventHandler(async (event) => {
       }),
     })
 
-    mistralRaw = bifrostRes.choices?.[0]?.message?.content ?? '{}'
+    mistralRaw = bifrostContent(bifrostRes, 'chatbot')
     tokensIn = bifrostRes.usage?.prompt_tokens ?? 0
     tokensOut = bifrostRes.usage?.completion_tokens ?? 0
     realModel =

server/utils/bifrost.ts

@@ -3,10 +3,24 @@
  * Endpoint OpenAI-compatible : POST {bifrostUrl}/v1/chat/completions
  * Auth : header x-bf-vk
  *
- * 2 tiers validés (Mission M3, build Bifrost) :
+ * 2 tiers (Mission M3 du build Bifrost ; modèles primaires changés le 28/09, session AEP front 4) :
  *   RAPIDE     — défaut, pas de toggle UI mode rapide/approfondi sur le site actuellement
  *   APPROFONDI — activable via body.mode === 'approfondi' (prêt pour un futur toggle front)
  *
+ * ⚠ 28/09 : Groq a retiré groq/llama-3.1-8b-instant (RAPIDE) et groq/llama-3.3-70b-versatile
+ *   (APPROFONDI) — 404 model_not_found via Bifrost. Depuis le 23/09 environ, chaque appel
+ *   chatbot tombait sur le premier repli Gemini (stats_usage). Primaires passés sur
+ *   groq/openai/gpt-oss-20b et groq/openai/gpt-oss-120b ; replis inchangés. Le worker
+ *   /opt/aep-worker tourne sur gpt-oss-20b en prod depuis le 28/09 (WORKER_MODEL, json_object) :
+ *   Bifrost accepte ce nom de modèle à slash côté Groq.
+ * ⚠ gpt-oss est un modèle à raisonnement :
+ *   - la réponse porte un champ message.reasoning à côté de message.content. Les routes
+ *     chatbot ne lisent que content (JSON), usage et extra_fields : le champ est ignoré ;
+ *   - les tokens de raisonnement sont décomptés de max_tokens. Sans marge, le JSON de la
+ *     réponse peut être tronqué ; rendu en HTTP 200, Bifrost ne bascule pas, JSON.parse
+ *     échoue → « Je n'ai pas pu analyser ta demande ». Déjà vu le 15/07 : gpt-oss-120b (via Cerebras), 3 appels
+ *     corrects sur 4, « tronque parfois à max_tokens 700 ». D'où REASONING_MARGIN_TOKENS, ajouté par
+ *     chaque route à son budget de contenu.
  * ⚠ openrouter-oai exclu (bug Bifrost confirmé — 404 HTML sur modèles avec slash)
  * ⚠ gemini-oai exige le préfixe "models/" (sinon 403 silencieux)
  * ⚠ cerebras/gemma-4-31b RETIRÉ du tier RAPIDE (M4, 15/07) : en JSON mode avec un contexte
@@ -19,7 +33,7 @@
  */
 
 export const BIFROST_TIER_RAPIDE = {
-  model: 'groq/llama-3.1-8b-instant',
+  model: 'groq/openai/gpt-oss-20b',
   fallbacks: [
     'gemini-oai/models/gemini-2.5-flash-lite',
     'cohere/command-r-08-2024',
@@ -27,7 +41,7 @@ export const BIFROST_TIER_RAPIDE = {
 }
 
 export const BIFROST_TIER_APPROFONDI = {
-  model: 'groq/llama-3.3-70b-versatile',
+  model: 'groq/openai/gpt-oss-120b',
   fallbacks: [
     'gemini-oai/models/gemini-2.5-flash',
     'mistral/mistral-large-latest',
@@ -35,13 +49,34 @@ export const BIFROST_TIER_APPROFONDI = {
   ],
 }
 
+/**
+ * Tokens ajoutés au budget de contenu de chaque route (max_tokens = contenu + marge) pour
+ * absorber le raisonnement de gpt-oss. Plafond seulement : les replis sans raisonnement
+ * n'écrivent pas plus long, les prompts bornent la réponse (200-250 mots). Rester modeste :
+ * la limite de tokens par minute d'une clé Groq peut compter max_tokens avec le prompt.
+ */
+export const REASONING_MARGIN_TOKENS = 800
+
 /** Sélectionne le tier selon le param optionnel body.mode. */
 export function pickBifrostTier(mode?: string) {
   return mode === 'approfondi' ? BIFROST_TIER_APPROFONDI : BIFROST_TIER_RAPIDE
 }
 
 export interface BifrostChatResponse {
-  choices: { message: { content: string } }[]
+  /** reasoning : présent avec gpt-oss, jamais lu (la réponse utile est dans content). */
+  choices: { message: { content: string; reasoning?: string }; finish_reason?: string }[]
   usage?: { prompt_tokens: number; completion_tokens: number }
   extra_fields?: { provider?: string; resolved_model_used?: string }
 }
+
+/**
+ * Contenu JSON de la réponse. Une troncature (finish_reason 'length') ne lève aucune erreur
+ * et finit en message générique côté usager : on la signale au journal pour la voir.
+ */
+export function bifrostContent(res: BifrostChatResponse, route: string): string {
+  const choice = res.choices?.[0]
+  if (choice?.finish_reason === 'length') {
+    console.warn(`[${route}] réponse tronquée (finish_reason=length) : relever REASONING_MARGIN_TOKENS`)
+  }
+  return choice?.message?.content ?? '{}'
+}

server/utils/circuitBreaker.ts

@@ -19,53 +19,126 @@ export interface BudgetStatus {
   cumulEur: number
   blocked: boolean
   warning: boolean
+  /** false si stats_usage n'a pas pu être lu : le budget n'est alors PAS vérifié (fail-open). */
+  verified: boolean
+  /** Lignes lues dans stats_usage (toutes dates). */
+  lignesLues: number
+  /** Lignes retenues pour le mois courant. */
+  lignesMois: number
+  /** Lignes sans aucun champ date reconnu (ignorées, comme dans le worker). */
+  lignesSansDate: number
+}
+
+/** Page NocoDB v2 : seuls les champs lus ici sont typés. */
+interface StatsPage {
+  list?: Record<string, unknown>[]
+  pageInfo?: { isLastPage?: boolean }
+}
+
+type FetchJson = (
+  url: string,
+  opts: { headers: Record<string, string>; query: Record<string, string | number> },
+) => Promise<StatsPage>
+
+const PAGE_SIZE = 1000
+const MAX_PAGES = 20 // 20 000 lignes : garde-fou contre une boucle, pas une limite métier
+
+/**
+ * Date d'une ligne de stats_usage, dans l'ordre du worker (`worker/enrich.js`,
+ * getBudgetMoisCourant) : `timestamp` écrit par les routes et le worker, sinon
+ * la colonne système de NocoDB (`CreatedAt`, ou `created_at` selon la version).
+ */
+export function dateLigne(row: Record<string, unknown>): Date | null {
+  const brut = row.timestamp ?? row.CreatedAt ?? row.created_at
+  if (brut === null || brut === undefined || brut === '') return null
+  const d = new Date(brut as string)
+  return Number.isNaN(d.getTime()) ? null : d
 }
 
 /**
  * Calcule le cumul de dépenses IA du mois courant depuis stats_usage NocoDB.
  * Retourne blocked=true si le budget est atteint.
+ *
+ * AF5 (29/09) : la requête ne nomme plus AUCUNE colonne (ni `where`, ni `fields`,
+ * ni `sort`). L'ancienne version filtrait sur `timestamp` côté NocoDB et recevait
+ * un 422 à chaque appel : budget jamais vérifié côté chatbot, en silence
+ * (fail-open). On lit la table page par page et on filtre le mois en JS,
+ * comme le worker, qui lit la même table sans erreur.
  */
 export async function checkBudget(config: {
   nocodbUrl: string
   nocodbToken: string
   statsTableId: string
+  /** Injecté par les tests ; `$fetch` de Nitro sinon. */
+  fetchJson?: FetchJson
+  /** Injecté par les tests ; maintenant sinon. */
+  now?: Date
 }): Promise<BudgetStatus> {
   const { nocodbUrl, nocodbToken, statsTableId } = config
+  const fetchJson: FetchJson = config.fetchJson ?? ((url, opts) => $fetch<StatsPage>(url, opts))
+  const now = config.now ?? new Date()
+  const annee = now.getUTCFullYear()
+  const mois = now.getUTCMonth()
 
-  // Premier du mois courant à minuit UTC
-  const now = new Date()
-  const monthStart = new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth(), 1))
-  const monthStartIso = monthStart.toISOString()
+  const url = `${nocodbUrl}/api/v2/tables/${statsTableId}/records`
+  let cumulEur = 0
+  let lignesLues = 0
+  let lignesMois = 0
+  let lignesSansDate = 0
 
   try {
-    // Fetch toutes les entrées du mois courant (NocoDB v2)
-    const url = `${nocodbUrl}/api/v2/tables/${statsTableId}/records`
-
-    const res = await $fetch<{ list: { cout_eur: number | null; timestamp: string }[] }>(
-      url,
-      {
+    for (let page = 0; page < MAX_PAGES; page++) {
+      const res = await fetchJson(url, {
         headers: { 'xc-token': nocodbToken },
-        query: {
-          where: `(timestamp,gte,${monthStartIso})`,
-          limit: 1000,
-          fields: 'cout_eur,timestamp',
-        },
-      },
-    )
-
-    const rows = res?.list ?? []
-    const cumulEur = rows.reduce((sum, row) => sum + (Number(row.cout_eur) || 0), 0)
-
-    return {
-      cumulEur,
-      blocked: cumulEur >= BUDGET_MAX_EUR,
-      warning: cumulEur >= BUDGET_WARN_EUR,
+        query: { limit: PAGE_SIZE, offset: page * PAGE_SIZE },
+      })
+      const rows = res?.list ?? []
+      for (const row of rows) {
+        lignesLues++
+        const d = dateLigne(row)
+        if (!d) {
+          lignesSansDate++
+          continue
+        }
+        if (d.getUTCFullYear() === annee && d.getUTCMonth() === mois) {
+          lignesMois++
+          cumulEur += Number(row.cout_eur) || 0
+        }
+      }
+      if (rows.length < PAGE_SIZE || res?.pageInfo?.isLastPage) break
     }
   } catch (e) {
     // En cas d'erreur de lecture, on ne bloque PAS pour ne pas pénaliser les utilisateurs
-    console.warn('[circuitBreaker] Erreur lecture stats_usage — budget non vérifié:', (e as Error).message)
-    return { cumulEur: 0, blocked: false, warning: false }
+    console.warn('[circuitBreaker] Erreur lecture stats_usage — budget NON vérifié:', (e as Error).message)
+    return { cumulEur: 0, blocked: false, warning: false, verified: false, lignesLues, lignesMois, lignesSansDate }
   }
+
+  // Des lignes, mais aucune datée : on ne sait pas ce qui relève du mois.
+  // Rendre « 0 € vérifié » reproduirait le fail-open silencieux d'avant AF5.
+  if (lignesLues > 0 && lignesSansDate === lignesLues) {
+    console.warn(
+      `[circuitBreaker] budget NON vérifié : ${lignesLues} lignes stats_usage sans timestamp, CreatedAt ni created_at`,
+    )
+    return { cumulEur: 0, blocked: false, warning: false, verified: false, lignesLues, lignesMois, lignesSansDate }
+  }
+
+  const status: BudgetStatus = {
+    cumulEur,
+    blocked: cumulEur >= BUDGET_MAX_EUR,
+    warning: cumulEur >= BUDGET_WARN_EUR,
+    verified: true,
+    lignesLues,
+    lignesMois,
+    lignesSansDate,
+  }
+  const mm = String(mois + 1).padStart(2, '0')
+  const suffixe = status.blocked ? ' — BLOQUÉ' : status.warning ? ' — alerte' : ''
+  const sansDate = lignesSansDate ? `, ${lignesSansDate} sans date ignorées` : ''
+  console.info(
+    `[circuitBreaker] budget lu : ${cumulEur.toFixed(4)} € / ${BUDGET_MAX_EUR} € ` +
+      `(${lignesMois} lignes ${annee}-${mm} sur ${lignesLues} lues${sansDate})${suffixe}`,
+  )
+  return status
 }
 
 /**

worker/enrich.js

@@ -33,7 +33,7 @@ const NOCODB_TABLE_STATS = process.env.NOCODB_TABLE_STATS;
 
 const BIFROST_URL = process.env.BIFROST_URL || 'http://127.0.0.1:8080';
 const BIFROST_VK = process.env.BIFROST_VK;
-const WORKER_MODEL = process.env.WORKER_MODEL || 'groq/llama-3.1-8b-instant';
+const WORKER_MODEL = process.env.WORKER_MODEL || 'groq/openai/gpt-oss-20b'; // llama-3.1-8b-instant retiré par Groq (28/09)
 
 const NTFY_TOPIC = process.env.NTFY_TOPIC;