Vamé Touré • Architecture & AI Sales Automation (20x System)

SECTION 1 • FLUX SÉQUENTIEL

L'Ordre d'Orchestration : Pipeline de bout en bout

Flux strict en 5 étapes séquentielles agissant comme des filtres déterministes dégradants.

flowchart TD
    A["1. Déclencheur / Point d'Entrée
Poller, Webhook Unipile, Launchd, Routine"] --> B["2. Contextualisation & Rapprochement
Canal instancié, CRM Notion, Contexte Decelo, Fil"]
    B --> C["3. Cerveau Rédactionnel
lib/brain.py → Prompt enrichi → Sortie JSON"]
    C --> D["4. Verrou de Sécurité
lib/escalade.py:decider
canal + scope + enjeux + Decelo + nuit"]
    D -->|"Auto = True"| E["5A. Envoi Direct
canal.envoyer + maj CRM + log envoi_auto"]
    D -->|"Auto = False"| F["5B. File d'Attente HITL
queue_store.creer + Carte Telegram + Revue Web"]
    F -->|"Action Humaine
Valider / Corriger / Refuser"| G["5C. Exécution Dérivée
lib/execution.py → canal.envoyer + maj CRM"]

    classDef trigger fill:#181C21,stroke:#E5AC54,stroke-width:2px,color:#F0F3F6;
    classDef context fill:#181C21,stroke:#38bdf8,stroke-width:2px,color:#F0F3F6;
    classDef brain fill:#181C21,stroke:#818cf8,stroke-width:2px,color:#F0F3F6;
    classDef lock fill:#2D2416,stroke:#f59e0b,stroke-width:2px,color:#F0F3F6;
    classDef auto fill:#064e3b,stroke:#10b981,stroke-width:2px,color:#d1fae5;
    classDef hitl fill:#450a0a,stroke:#ef4444,stroke-width:2px,color:#fee2e2;
    classDef exec fill:#181C21,stroke:#A2AAB3,stroke-width:2px,color:#F0F3F6;

    class A trigger;
    class B context;
    class C brain;
    class D lock;
    class E auto;
    class F hitl;
    class G exec;

Déclencheur

Webhook Unipile, Poller (cron), launchd ou routine manuelle.

poller.py, webhook_server.py

Contextualisation

Certification canal, extraction CRM Notion, fil passé & statut Decelo.

canaux.py, notion_crm.py, decelo.py

Cerveau (LLM)

Génération du brouillon, qualification du statut CRM & autonomie proposée.

lib/brain.py (Anthropic API)

Verrou Escalade

Filtre déterministe non négociable : canal, 8h-22h, enjeux, Decelo, nuit.

lib/escalade.py:decider

Aiguillage

5A: Envoi direct auto. 5B: File d'attente HITL Telegram/Web. 5C: Exécution validée.

queue_store.py, execution.py

RÈGLE NON NÉGOCIABLE • FAIL-SAFE

Le Verrou de Sécurité Déterministe (lib/escalade.py)

Le modèle ne peut jamais forcer l'autonomie, il ne peut que la suggérer. Tout doute dégrade vers l'approbation humaine.

flowchart TD
    In(["Brouillon Généré"]) --> C1{"1. Canal Autorisé ?
LinkedIn uniquement"}
    C1 -->|"Non (Mail, WhatsApp)"| R1["Refus Auto : Validation Canal"]
    C1 -->|"Oui"| C2{"2. Config AUTONOMIE ?
True dans .env"}
    C2 -->|"Non"| R2["Refus Auto : Autonomie Désactivée"]
    C2 -->|"Oui"| C3{"3. Plage Horaire ?
Entre 8h et 22h"}
    C3 -->|"Non (Nuit)"| R3["Refus Auto : Hors Plage Horaire"]
    C3 -->|"Oui"| C4{"4. Proposition Cerveau ?
autonomie_proposee == True"}
    C4 -->|"Non"| R4["Refus Auto : Validation Demandée"]
    C4 -->|"Oui"| C5{"5. Garde Decelo Action ?
action_decelo == aucune"}
    C5 -->|"Non"| R5["Refus Auto : Action Decelo Déclarée"]
    C5 -->|"Oui"| C6{"6. Garde Testeur Decelo ?
Testeur Connu ou Base Illisible"}
    C6 -->|"Oui"| R6["Refus Auto : Testeur Decelo Connu"]
    C6 -->|"Non"| C7{"7. Garde Scope Decelo ?
Scope ouvert à l'outil"}
    C7 -->|"Oui"| R7["Refus Auto : Scope Decelo Éligible"]
    C7 -->|"Non"| C8{"8. Garde Brouillon Decelo ?
Brouillon nomme ou amène l'outil"}
    C8 -->|"Oui"| R8["Refus Auto : Brouillon Mentionne Outil"]
    C8 -->|"Non"| C9{"9. Enjeux Détectés ?
TJM, RDV, CV, Coordonnées, etc."}
    C9 -->|"Oui"| R9["Refus Auto : Enjeu Détecté"]
    C9 -->|"Non"| C10{"10. Scope Sans Enjeu ?
freelance / reseau"}
    C10 -->|"Non"| R10["Refus Auto : Hors Périmètre"]
    C10 -->|"Oui"| C11{"11. Relation Existante ?
Plus de 6 messages, appel passé, Vamé a écrit"}
    C11 -->|"Oui"| R11["Refus Auto : Contact Chaud Établi"]
    C11 -->|"Non"| OK(["✅ ENVOI AUTOMATIQUE VALIDE"])

    classDef okNode fill:#064e3b,stroke:#10b981,stroke-width:2px,color:#d1fae5;
    classDef refuseNode fill:#450a0a,stroke:#ef4444,stroke-width:1px,color:#fca5a5;
    classDef checkNode fill:#181C21,stroke:#A2AAB3,stroke-width:1px,color:#F0F3F6;

    class OK okNode;
    class R1,R2,R3,R4,R5,R6,R7,R8,R9,R10,R11 refuseNode;
    class C1,C2,C3,C4,C5,C6,C7,C8,C9,C10,C11 checkNode;

Détail des Enjeux Forçant l'Escalade

Tableau des catégories d'enjeux détectés qui forcent l'escalade vers une décision humaine
Catégorie d'Enjeu	Mots-clés Détectés	Raison d'Escalade
argent	tjm, tarif, salaire, remuneration, budget, prix, facturation, k euros, day rate, rate	Négociation tarifaire réservée à Vamé
mission	mission, poste, opportunite, offre, recrut, contrat, cdi, besoin client, role, vacancy	Qualification d'opportunité d'affaires
engagement	cv, resume, portfolio, dispo, calendrier, agenda, rdv, call, visio, entretien, creneau	Prise de rendez-vous ou partage de document
mise en relation	mise en relation, mettre en relation, presenter a, apport d'affaires, commission	Introduction de tiers dans l'échange
teletravail	teletravail, remote, sur site, presentiel, hybride, on-site	Modalités d'exécution contractuelle
coordonnees	numero, telephone, tel, whatsapp, mon mail, email, phone number, votre mail	Échange d'informations de contact direct

RÉTROACTION & APPRENTISSAGE

Les 3 Niveaux de Feedback Interconnectés

Apprentissage continu supervisé, traçabilité produit et observabilité proactive du système.

flowchart LR
    subgraph F1["A. Feedback Humain Opérationnel (HITL)"]
        H_Act["Refus / Correction
(Telegram / Établi Web)"] --> H_Machine["Machine à États
lib/decision.py"]
        H_Machine --> H_Journal["Journal d'Événements
state/journal.jsonl"]
        H_Journal --> H_Motifs["Motifs de Refus
scripts/motifs_refus.py"]
        H_Journal --> H_Hygiene["Hygiène Hebdo (Dimanche 18h)
hygiene.py"]
        H_Hygiene --> H_LLM["Génération Règles Candidates
(LLM Anthropic)"]
        H_LLM --> H_Approb["Validation Telegram de Vamé
(Garde Anti-Dérive)"]
        H_Approb --> H_Rules["Règles Actives Durables
method/regles-apprises.md"]
    end

    subgraph F2["B. Feedback Produit (Decelo Testeurs)"]
        D_Supabase["Tables Supabase
feedback et contact_feedback"] --> D_Extract["Extraction Cache
lib/decelo.py"]
        D_Extract --> D_CRM["Mise à jour Notion CRM
lib/notion_crm.py"]
        D_CRM --> D_Cycle["Proposé → Testeur actif
→ Feedback reçu → Réactivé"]
        D_Extract --> D_Lock["Garde Escalade lib/escalade.py
(Exclusion Autonomie)"]
    end

    subgraph F3["C. Feedback Télémétrie & Observabilité"]
        T_Logs["Logs d'Exécution
lib/journal.py"] --> T_Health["Rapport de Santé
scripts/rapport_sante.py"]
        T_Logs --> T_Daily["Rapport Quotidien
lib/rapport.py"]
        T_Logs --> T_Watchdog["Watchdog Dérive
lib/watchdog.py"]
        T_Watchdog --> T_Alert["Pause Technique et
Alerte Telegram Prioritaire"]
    end

    classDef hitlBox fill:#181C21,stroke:#E5AC54,stroke-width:1px,color:#F0F3F6;
    classDef prodBox fill:#181C21,stroke:#10b981,stroke-width:1px,color:#F0F3F6;
    classDef teleBox fill:#181C21,stroke:#38bdf8,stroke-width:1px,color:#F0F3F6;

    class H_Act,H_Machine,H_Journal,H_Motifs,H_Hygiene,H_LLM,H_Approb,H_Rules hitlBox;
    class D_Supabase,D_Extract,D_CRM,D_Cycle,D_Lock prodBox;
    class T_Logs,T_Health,T_Daily,T_Watchdog,T_Alert teleBox;

👤 A. Feedback Humain (HITL)

Refus & Consignes : Capture des motifs (`hors_sujet`, `timing`, `voix`, `plus_pertinent`) et des consignes libres.
Hygiène Hebdo : Synthèse le dimanche à 18h via `hygiene.py` pour isoler 1 à 4 règles généralisables.
Validation Vamé : Aucune règle n'entre sans approbation Telegram. Zéro apprentissage aveugle.
Réversibilité : Annulation possible sur carte pending ; envoi physique consigné et irréversible.

🚀 B. Feedback Produit (Decelo)

Tables Supabase : Lecture seule de `feedback` et `contact_feedback` via service-role du trousseau macOS.
Cycle de Vie CRM : Transition stricte des fiches Notion : Proposé → Testeur actif → Feedback reçu → Réactivé.
Garde Sanctuaire : Exclusion systématique de tout envoi autonome pour les testeurs (validation humaine requise).

📊 C. Feedback Télémétrie

Rapport Quotidien : Suivi du ratio envoi auto vs escalade, du taux de refus (~49%) et des temps de cycle.
Watchdog & Circuit Breaker : Détection de blocages de boucle ou d'échecs API consécutifs.
Résilience Proactive : Mise en pause technique automatique et notification Telegram avant épuisement des quotas.

TOPOGRAPHIE FACTUELLE

Cartographie des Modules & Rôles Codebase

Inventaire 100% ancré des composants réels composant l'orchestrateur et les gardes.

Inventaire des modules clés de la codebase et de leurs gardes critiques
Fichier / Module	Couche & Rôle	Fonctions Principales	Garde Critique
lib/escalade.py	Verrou Sécurité	decider(), eligibilite_decelo(), normaliser()	Ne peut que dégrader vers l'humain (8h-22h)
lib/brain.py	Cerveau LLM	rediger(), _brut(), _parser(), bloc_decelo	Sortie JSON stricte, prompt système stable
lib/decelo.py	Contexte Produit	contexte(), lire_base(), SCOPES_PROPOSITION	Lecture seule Supabase, cache 20h
lib/decision.py	Machine à États	valider(), refuser(), corriger(), annuler()	Unification Telegram & Établi web
lib/queue_store.py	File d'Attente	creer(), lister(), modifier(), transition()	Persistance locale state/queue.json & Supabase Cloud
lib/supabase_store.py	Cloud Storage	creer_action(), lister_actions(), marquer_fait()	Persistance PostgREST & Idempotence Cloud
lib/telegram_hitl.py	Interface Humaine	envoyer(), _rendu(), editer()	Une action = une carte unique éditée
lib/execution.py	Exécuteur Physique	executer_action(), _envoyer_canal()	Contrôle d'idempotence avant envoi
lib/jours_feries.py	Calendrier Fériés	est_jour_ferie(), prochain_matin_ouvre()	Replanifie les emails au prochain ouvré à 08h00
hygiene.py	Boucle d'Hygiène	signaux(), extraire(), proposer_regles()	Validation Vamé obligatoire sur Telegram
scripts/motifs_refus.py	Observabilité HITL	lire(), OU_CORRIGER	Mesure du taux de refus (~49%)
lib/watchdog.py	Résilience	verifier(), verifier_etat()	Pause technique en cas de boucle anormale

ACADÉMIE 20X & FONDATIONS

Glossaire de l'Expert en AI Automation

Les 12 concepts fondamentaux indispensables pour concevoir des systèmes d'agents autonomes robustes.

Orchestration #01

Pipeline Déterministe vs Probabiliste

En clair : Le code traditionnel est déterministe (1+1=2 à chaque exécution). L'IA est probabiliste (elle prédit les mots et peut varier ou halluciner). Un bon système automatise avec l'IA tout en la cadenassant avec du code déterministe.

📍 Dans notre Agent : lib/brain.py (IA) encadré par lib/escalade.py (règles strictes).

💡 Réflexe 20x : Ne confiez JAMAIS la sécurité ou les droits d'écriture à un LLM sans filtre déterministe.

Orchestration #02

Idempotence & Registre d'État

En clair : Propriété d'une action qui, même exécutée 10 fois par accident (webhook renvoyé, crash réseau, double clic), ne produit son effet physique qu'une seule fois.

📍 Dans notre Agent : lib/journal.py:marquer_fait stocke chaque ID dans le registre. Double clic = 0 envoi.

💡 Réflexe 20x : Tout appel avec effet de bord (email, paiement, message LinkedIn) doit avoir une clé d'idempotence.

HITL #03

Human-in-the-Loop (HITL)

En clair : Architecture hybride où l'IA fait 95% du travail chronophage (contexte, rédaction, qualification) mais où l'humain garde le contrôle final d'un simple clic (Valider / Corriger / Refuser).

📍 Dans notre Agent : Cartes Telegram interactives (lib/telegram_hitl.py) et Établi web (lib/revue_web.py).

💡 Réflexe 20x : Le HITL permet d'automatiser immédiatement sans risque d'erreur publique destructrice de réputation.

Ingénierie LLM #04

Dégradation Asymétrique (Fail-Safe)

En clair : En cas de doute, d'ambiguïté ou de panne, le système bascule TOUJOURS vers la sécurité (demander l'approbation humaine), jamais vers le risque (envoi automatique).

📍 Dans notre Agent : lib/escalade.py ne peut que dégrader vers l'humain. Une panne Supabase = arrêt de l'autonomie.

💡 Réflexe 20x : Un faux positif (message erroné envoyé) coûte un client ; un faux négatif (notification de trop) coûte 5 secondes.

Ingénierie LLM #05

Prompt Caching & Discipline de Coût

En clair : Mettre en cache les instructions stables du système (profil Vamé, méthodes commerciales, règles de voix) pour réduire la latence de 80% et diviser la facture API par 10.

📍 Dans notre Agent : lib/brain.py place le préfixe fixe en tête et n'injecte les données variables qu'en toute fin.

💡 Réflexe 20x : Ne mettez jamais d'horodatage dynamique en tête de prompt, sous peine de détruire le cache à chaque appel.

Ingénierie LLM #06

Structured Output (JSON Strict)

En clair : Forcer le LLM à répondre dans une structure de données typée et normalisée (JSON) plutôt qu'en texte libre, rendant le résultat manipulable sans erreur par le code Python.

📍 Dans notre Agent : lib/brain.py:_parser() valide la présence des clés action, message, commentaire.

💡 Réflexe 20x : N'utilisez jamais de texte brut pour faire communiquer deux agents ; imposez des schémas stricts.

HITL #07

Boucle d'Hygiène & Méta-Apprentissage

En clair : Analyser les corrections et refus humains de la semaine pour en synthétiser de nouvelles règles durables, sans ré-entraîner les poids du modèle.

📍 Dans notre Agent : hygiene.py (dimanche 18h) soumet max 4 règles sur Telegram avant écriture dans method/regles-apprises.md.

💡 Réflexe 20x : L'IA s'améliore grâce à ses logs d'usage supervisés, pas par des devinettes de prompts.

HITL #08

Model Drift & Télémétrie d'Alignement

En clair : Phénomène où un agent commence à dériver de son ton ou de sa précision cible au fil du temps. On le détecte en mesurant des ratios de rejet en continu.

📍 Dans notre Agent : scripts/motifs_refus.py surveille le taux de refus (~49%) et identifie la cause exacte (hors_sujet, voix, timing).

💡 Réflexe 20x : « Une métrique non surveillée est une panne en attente ». Suivez les refus comme vos erreurs HTTP.

Orchestration #09

Circuit Breaker & Watchdog (Résilience)

En clair : Coupe-circuit qui disjoncte et met l'agent en pause technique dès qu'un taux d'anomalie ou une boucle infinie est détectée, évitant de brûler les quotas API ou d'inonder des clients.

📍 Dans notre Agent : lib/watchdog.py coupe la routine et envoie une alerte Telegram d'urgence si 4 échecs consécutifs surviennent.

💡 Réflexe 20x : Tout agent autonome doit avoir un Kill Switch instantané et un disjoncteur automatique.

Infrastructure #10

Webhook vs Poller (Ingestion Hybride)

En clair : Le Webhook est un appel temps réel poussé par le service tiers (Push instantané). Le Poller est une vérification régulière programmée (Pull, ex: 60s) pour garantir qu'aucun événement n'est perdu en cas de panne réseau.

📍 Dans notre Agent : webhook_server.py (FastAPI) pour l'instantanéité, épaulé par poller.py pour la robustesse.

💡 Réflexe 20x : Couplez toujours un webhook réactif à un poller de réconciliation pour une disponibilité à 99.9%.

Infrastructure #11

Launchd & Daemons d'Arrière-Plan

En clair : Gestionnaire système natif de macOS (équivalent de `systemd` sous Linux) qui maintient vos agents actifs, relance les processus en cas de crash (`KeepAlive`) et gère le calendrier d'exécution.

📍 Dans notre Agent : 9 fichiers .plist dans launchd/ cadencent la routine (7h30, 12h30, 17h30) et le poller.

💡 Réflexe 20x : Ne lancez jamais de scripts d'automatisation dans un terminal ouvert : passez par des daemons d'OS.

Ingénierie LLM #12

Grounding Factuel & Zéro-Hallucination

En clair : Forcer l'agent à n'affirmer que des données strictement sourcées dans des bases réelles (Supabase, Notion CRM). S'il y a un doute ou un homonyme, l'agent répond « Je ne sais pas » au lieu d'inventer.

📍 Dans notre Agent : lib/decelo.py apparie par URL LinkedIn ; un homonyme en base vaut None, jamais une déduction hâtive.

💡 Réflexe 20x : « Préférer l'abstention à l'hallucination ». En B2B, une certitude erronée brise instantanément le contrat de confiance.

Diapositive 1 / 4 Naviguez au clavier avec [←] et [→]

VUE SYNTHÉTIQUE

Pipeline d'Orchestration en 5 Étapes

Chaque message entrant ou action de relance traverse 5 filtres déterministes. Le système sépare rigoureusement la proposition du LLM (lib/brain.py) et la décision d'autonomie (lib/escalade.py).

1. Déclencheur

2. Contexte

3. Cerveau

4. Verrou Escalade

5. Aiguillage

Agent Prospection B2B