tlr-codexia — bundle cœur Telaria

tlr-codexia est le bundle applicatif central de l'écosystème Telaria. Il regroupe quatre domaines :

Code : domaine veille in-app src/Veille/ de telaria-app (pas encore extrait en bundle autonome). Extraction (telaria/veille-bundle) si un second projet en a besoin — pas avant. Spec fonctionnelle : specs/ia-veille.md Schéma BDD complet : ../bdd/schema.md

Flux d'exécution — Veille

[VeilleSchedule] ── cadence 15 min ──▶ dispatch [RunVeilleCycleMessage]
                                              │
                                    worker scheduler_veille
                                              │
                                    [RunVeilleCycleHandler]
                                     Pour chaque VeilleSource active :
                                     ├─ SourceFetcher    fetch flux RSS/Atom
                                     ├─ Deduplicator     filtre url OU content_hash
                                     └─ dispatch [ProcessVeilleItemMessage] ×N
                                              │
                                         worker async
                                              │
                                    [ProcessVeilleItemHandler]
                                     ├─ ArticleFetcher   fetch DOM article
                                     ├─ ClassifierInterface  score mots-clés
                                     ├─ Summarizer       Claude Haiku (résumé + source + lien)
                                     ├─ VeilleWriter     var/veille/proposals/*.md
                                     ├─ VeilleAttempt    journal fetch+LLM persisté
                                     └─ VeilleItem.status → proposed

Workers à maintenir actifs :

php bin/console messenger:consume scheduler_veille   # déclencheur Scheduler
php bin/console messenger:consume async              # traitement items
# ou via systemd :
sudo systemctl status telaria-veille-scheduler
sudo systemctl status telaria-messenger-async

⚠️ Piège déploiement. Les workers ne rechargent pas le code PHP au git pull. Un déploiement sans redémarrage des workers laisse la veille tourner sur l'ancien code — vécu : 12 jours sans token, 5 500 items en backlog (incident 2026-06-02). Toujours redémarrer après un déploiement. Voir runbook.md.

Entités

veille_source — Sources RSS/Atom

Administrée via /admin/veille/sources. Pilote la liste des flux collectés.

Standby automatique : seuil VEILLE_SOURCE_STANDBY_THRESHOLD (défaut 3 échecs consécutifs). Lever via le back-office — réinitialise le compteur. standby ≠ is_active : ne pas confondre.

veille_item — Items collectés

Journal de déduplication + cycle de vie de chaque article.

Cycle de vie : pending (collecté) → proposed (résumé Claude OK) → accepted | rejected (humain) | failed (erreur pipeline).

veille_attempt — Journal tentatives

Trace chaque passage du pipeline sur un item (fetch + LLM). Permet le diagnostic sans logs.

Usage diagnostic :

-- Tokens consommés par jour (vérifie que la veille tourne)
SELECT DATE(attempted_at) as day,
       COUNT(*) as attempts,
       SUM(CASE WHEN outcome='success' THEN 1 ELSE 0 END) as success,
       SUM(tokens_input) as tok_in,
       SUM(tokens_output) as tok_out
FROM veille_attempt
WHERE attempted_at >= DATE_SUB(NOW(), INTERVAL 7 DAY)
GROUP BY day ORDER BY day DESC;

veille_read — État de lecture

Absence de ligne = non lu. Contrainte UNIQUE(user_id, item_id).

app_setting — Paramétrage clé/valeur

Singleton par clé. PK naturelle (name VARCHAR 128, pas d'auto-increment).

chat_config — Configuration chat public

Singleton (une seule ligne). Paramétrage administré en BO.

metrics_usage — Usage tokens dimensionnel

Alimenté depuis l'Admin API Anthropic. Granularité : (jour, modèle, clé API, service tier). Contrainte : UNIQUE(day, model, api_key_id, service_tier).

metrics_daily — Snapshot quotidien

Agrégé org-wide (tokens + coûts). Contrainte : UNIQUE(day, label).

metrics_alert — Alertes de coût

Seuil en USD, période daily | monthly, anti-spam (1 mail/franchissement/période).

metrics_api_key — Cache clés API Anthropic

PK naturelle = id Anthropic (VARCHAR 64). Stocke id → nom lisible.

Commandes CLI

# Indexation RAG (source-of-truth : telaria-doc)
php bin/console app:rag:ingest

# Statistiques RAG (nb documents, chunks, état index)
php bin/console app:rag:stats

# Synchronisation métriques depuis Admin API Anthropic
php bin/console app:sync:metrics

# Consommation workers (lancer manuellement en dev)
php bin/console messenger:consume scheduler_veille --time-limit=300
php bin/console messenger:consume async --time-limit=300

Dépannage

Veille silencieuse — 0 token, 0 résumé

Symptôme : API Anthropic → 0$ depuis N jours, items restent en pending.

Diagnostic :

# 1. État des workers
systemctl is-active telaria-veille-scheduler
systemctl is-active telaria-messenger-async
journalctl -u telaria-messenger-async -n 30

# 2. Tokens en base (si workers OK mais 0 résumé)
# → requête SQL veille_attempt ci-dessus

# 3. Items pending en attente
SELECT COUNT(*) FROM veille_item WHERE status='pending';

Causes et remèdes :

503 après upgrade PHP

Vhosts manuels ont php8.X-fpm.sock hardcodé. Voir runbook.md §Incidents.

RAG vide — 0 document

Vérifier que telaria-embeddings tourne (systemctl is-active telaria-embeddings) puis relancer php bin/console app:rag:ingest. Si le service crashe, reconstruire le venv Python (voir vps/09-ia-embeddings.md).

Patterns Doctrine notables

• resolve_target_entities : VeilleReaderInterface → App\Entity\User (résolu dans doctrine.yaml de l'app). Le bundle ne dépend pas de l'entité User directement.
• Lifecycle callbacks : created_at / updated_at via #[PrePersist] / #[PreUpdate].
• Auto-mapping : zéro fichier XML/YAML de mapping, zéro migration au bootstrap.

Voir aussi

• specs/ia-veille.md — spécification fonctionnelle complète
• specs/ia-veille-sources.md — catalogue des flux V1
• ../bdd/schema.md — schéma BDD complet (types exacts)
• ../guides/runbook.md — déploiement et incidents
• ../tutos/ia/veille-automatisee-symfony.md — tuto Scheduler + Messenger
• ../tutos/ia/rag-bout-en-bout.md — pipeline RAG complet