feat: stabilize AI engine, harden Zod schemas, and implement UX guardrails

apps/api/src/services/ai/gemini-provider.ts

@@ -11,7 +11,7 @@ export class GeminiProvider implements LLMProvider {
         console.log('[GEMINI] Initializing Google AI SDK...');
         this.genAI = new GoogleGenerativeAI(apiKey);
         this.flashModel = this.genAI.getGenerativeModel({ model: 'gemini-2.0-flash' });
-        this.proModel = this.genAI.getGenerativeModel({ model: 'gemini-1.5-pro-latest' });
+        this.proModel = this.genAI.getGenerativeModel({ model: 'gemini-1.5-pro' });
     }
 
     async generateStructuredData<T>(prompt: string, _schema: z.ZodSchema<T>): Promise<T> {

apps/api/src/services/ai/index.ts

@@ -165,6 +165,13 @@ class AIService {
         isDeepDive: boolean = false,
         iterationCount: number = 0
     ): Promise<FeedbackData & { searchResults?: any[] }> {
+        // 🚀 Question Detection Logic (Lead AI Engineer Requirement)
+        const questionKeywords = ['?', 'avis', 'penses', 'conseil', 'aider', 'comment', 'pourquoi', 'idée', 'prix', 'standard'];
+        const lowerInput = userInput.toLowerCase();
+        const hasQuestion = questionKeywords.some(kw => lowerInput.includes(kw));
+
+        console.log(`[AI_INTERACTION] User asked a question: ${hasQuestion}`);
+
         const activityLabel = userActivity || businessProfile?.activityLabel || 'non précisé';
         const region = userRegion || businessProfile?.region || 'Sénégal';
         const customer = businessProfile?.mainCustomer || '';
@@ -244,6 +251,12 @@ class AIService {
             MISSIONS STRATÉGIQUES "SENIOR BUSINESS COACH" (CORRECTION RADICALE) :
             Tu es un consultant pragmatique, pas un professeur pointilleux. Rédige un feedback d'au minimum 15 lignes de haute densité.
             
+            ${hasQuestion ? `
+            🚨 DOUBLE INTENTION DÉTECTÉE : L'utilisateur a posé une question ou sollicité un avis stratégique.
+            - TU DOIS répondre spécifiquement à sa question dans la section "🚀 Version Enrichée".
+            - Compare son idée ou sa question (ex: prix, cible, stratégie) avec les standards du marché trouvés via tes recherches.
+            - Sois tranché et expert.` : ''}
+
             LES 3 PILIERS OBLIGATOIRES DU FEEDBACK :
             1. 🌟 Validation (Pilier 1) : Félicite et valide l'idée de l'utilisateur avec l'enthousiasme d'un investisseur.
             2. 🚀 Version Enrichie (Pilier 2) : Réécris sa phrase de manière exécutive en y intégrant OBLIGATOIREMENT des données chiffrées réelles trouvées dans ta recherche (ex: taille du marché ANSD, nombre de boutiques) et des termes stratégiques (supply chain, B2B, rétention). 
@@ -255,6 +268,7 @@ class AIService {
             - Tu es là pour ENRICHIR sa vision, pas pour lui faire passer un interrogatoire. Ne pose AUCUNE question bloquante à la fin.
             
             INVITATION DEEP-DIVE OBLIGATOIRE :
+            ${hasQuestion ? `L'utilisateur ayant posé une question, tu DOIS systématiquement proposer l'option d'approfondissement pour explorer des alternatives stratégiques.` : ''}
             Termine EXACTEMENT ton pilier 3 par cette phrase selon la langue :
             (FR): "Si tu veux affiner ce point avec une donnée de ton propre terrain, tape 1️⃣ APPROFONDIR, sinon tape 2️⃣ SUITE."
             (WO): "Su nga bëggee yokk leneen ci li nga xam, bindal 1️⃣ APPROFONDIR, wala nga bind 2️⃣ SUITE."

apps/api/src/services/ai/types.ts

@@ -26,9 +26,9 @@ export const OnePagerSchema = z.object({
     targetAudience: z.string().describe("Who this is for"),
     businessModel: z.string().describe("How the project makes money (e.g., Vente directe, Prestation)"),
     callToAction: z.string().describe("The next step for the reader (e.g., 'Contact us', 'Try the beta')"),
-    mainImage: z.string().optional().describe("URL of the main brand image"),
-    marketSources: z.string().optional().describe("Sources des données de marché utilisées (ex: ANSD 2024)"),
-    aiSource: z.string().optional().describe("The AI provider used (GEMINI, OPENAI, MOCK)")
+    mainImage: z.string().nullable().optional().describe("URL of the main brand image"),
+    marketSources: z.string().nullable().optional().describe("Sources des données de marché utilisées (ex: ANSD 2024)"),
+    aiSource: z.string().nullable().optional().describe("The AI provider used (GEMINI, OPENAI, MOCK)")
 });
 export type OnePagerData = z.infer<typeof OnePagerSchema>;
 
@@ -36,8 +36,8 @@ export const SlideSchema = z.object({
     title: z.string().describe("Slide title (max 5 words)"),
     content: z.array(z.string()).max(4).describe("Narrative storytelling blocks for the slide (15-25 words each). STRICTLY MAX 4 BLOCKS."),
     notes: z.string().describe("Speaker notes (use empty string if none)"),
-    visualType: z.enum(["NONE", "PIE_CHART", "BAR_CHART", "IMAGE", "ICON"]).optional().describe("Type of visual to add on the right side"),
-    visualData: z.any().optional().describe("Data for the chart (if any) or image prompt")
+    visualType: z.enum(["NONE", "PIE_CHART", "BAR_CHART", "IMAGE", "ICON"]).nullable().optional().describe("Type of visual to add on the right side"),
+    visualData: z.any().nullable().optional().describe("Data for the chart (if any) or image prompt")
 });
 export type SlideData = z.infer<typeof SlideSchema>;
 
@@ -55,20 +55,20 @@ export const FeedbackSchema = z.object({
     enrichedVersion: z.string().describe("Réécriture de la phrase y intégrant des données chiffrées réelles et stratégiques issues de la recherche (Pilier 2)"),
     actionableAdvice: z.string().describe("Conseil terrain concret, actionnable et documenté pour cette étape (Pilier 3)"),
     isQualified: z.boolean().describe("Whether the answer meets the lesson's criteria"),
-    isForcedClosure: z.boolean().optional().describe("True if the user has reached the 3-loop limit and the AI must force-close the deep dive"),
+    isForcedClosure: z.boolean().nullable().optional().describe("True if the user has reached the 3-loop limit and the AI must force-close the deep dive"),
     missingElements: z.array(z.string()).describe("List of IDs from criteria that were not met"),
     confidence: z.number().min(0).max(100).describe("AI confidence in the evaluation"),
     notes: z.string().describe("Internal notes for the system"),
 
     // Strategic Enrichment Fields (Sprint 34)
-    competitorList: z.array(z.string()).optional().describe("List of competitors identified (Day 10)"),
+    competitorList: z.array(z.string()).nullable().optional().describe("List of competitors identified (Day 10)"),
     financialProjections: z.object({
-        revenueY1: z.string().optional(),
-        revenueY3: z.string().optional(),
-        growthRate: z.string().optional()
-    }).optional().describe("3-year growth metrics (Day 11)"),
-    fundingAsk: z.string().optional().describe("The Ask: amount and purpose (Day 12)"),
-    aiSource: z.string().optional().describe("The AI provider used (GEMINI, OPENAI, MOCK)")
+        revenueY1: z.string().nullable().optional(),
+        revenueY3: z.string().nullable().optional(),
+        growthRate: z.string().nullable().optional()
+    }).nullable().optional().describe("3-year growth metrics (Day 11)"),
+    fundingAsk: z.string().nullable().optional().describe("The Ask: amount and purpose (Day 12)"),
+    aiSource: z.string().nullable().optional().describe("The AI provider used (GEMINI, OPENAI, MOCK)")
 });
 export type FeedbackData = z.infer<typeof FeedbackSchema>;
 

apps/api/src/services/whatsapp.ts

@@ -62,7 +62,7 @@ export class WhatsAppService {
         let user = await prisma.user.findUnique({ where: { phone } });
 
         if (!user) {
-            const isInscription = this.isFuzzyMatch(normalizedText, 'INSCRIPTION') || normalizedText.includes('INSCRI');
+            const isInscription = this.isFuzzyMatch(normalizedText, 'INSCRIPTION') || normalizedText.includes('INSCRI') || normalizedText.includes('INSCRI');
 
             if (isInscription) {
                 console.log(`${traceId} New user registration triggered for ${phone}`);
@@ -149,6 +149,18 @@ export class WhatsAppService {
             return;
         }
 
+        // 🚨 Guardrail "Contenu Vide" / Gibberish (UX Engineer Requirement)
+        const wordCount = (text || '').trim().split(/\s+/).length;
+        const systemCommands = ['1', '2', 'SUITE', 'APPROFONDIR', 'INSCRIPTION', 'SEED'];
+        const isSystemCommand = systemCommands.some(cmd => this.isFuzzyMatch(normalizedText, cmd)) || normalizedText.includes('INSCRI');
+
+        if (wordCount < 3 && !isSystemCommand) {
+             await scheduleMessage(user.id, user.language === 'WOLOF'
+                ? "Dama lay xaar nga wax ma lu gën a yaatu ci sa mbir (mbebetu 3 baat). Waxtaanal ak man !"
+                : "Je n'ai pas bien compris ton activité. Peux-tu me réexpliquer en quelques mots ce que tu fais ? (Minimum 3 mots)");
+             return;
+        }
+
         if (this.isFuzzyMatch(normalizedText, 'SEED')) {
             // Reply immediately so the webhook doesn't time out
             console.log(`[SEED] Triggered by user ${user.id}`);
@@ -422,6 +434,14 @@ export class WhatsAppService {
             }
 
             // Fallback to Exercise Response if nothing else matched
+            // 🚨 COACHING GUARDRAIL: AI Coach only activated if profile (sector + language) is complete
+            if (!user.activity) {
+                await scheduleMessage(user.id, user.language === 'WOLOF'
+                    ? "Danga wara tànn sa mbiru liggeey balaa ñuy tàmbali coaching bi."
+                    : "Tu dois d'abord définir ton activité avant que le coach AI ne puisse t'aider.");
+                return;
+            }
+
             const pendingProgress = await prisma.userProgress.findFirst({
                 where: { userId: user.id, exerciseStatus: { in: ['PENDING', 'PENDING_REMEDIATION', 'PENDING_DEEPDIVE'] }, trackId: activeEnrollment.trackId },
             });

apps/api/tsconfig.json

@@ -11,6 +11,9 @@
         "lib": [
             "ES2020"
         ],
+        "types": [
+            "node"
+        ],
         "esModuleInterop": true,
         "allowSyntheticDefaultImports": true
     },

apps/whatsapp-worker/src/index.ts

@@ -160,15 +160,24 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                         if (extractRes.ok) {
                             const { data } = await extractRes.json() as any;
                             // Clean up undefined/null values
-                            const profileData = Object.fromEntries(Object.entries(data).filter(([_, v]) => v != null && v !== ''));
-
-                            if (Object.keys(profileData).length > 0 || feedbackData?.searchResults) {
-                                console.log(`[WORKER] Updating BusinessProfile for User ${userId}:`, profileData);
+                                const profileData = Object.fromEntries(Object.entries(data).filter(([_, v]) => v != null && v !== ''));
+
+                                // 🚨 Sector Locking (Lead AI Engineer Requirement)
+                                const lockedSectors = ["Organisation d'événements / PWA"];
+                                if (lockedSectors.includes(user.activity || "")) {
+                                    if (profileData.activityLabel || profileData.activityType) {
+                                        console.log(`[WORKER] Sector Locked for User ${userId}. Blocking activity update.`);
+                                        delete profileData.activityLabel;
+                                        delete profileData.activityType;
+                                    }
+                                }
 
-                                const updatePayload: any = {
-                                    ...profileData,
-                                    lastUpdatedFromDay: currentDay
-                                };
+                                if (Object.keys(profileData).length > 0 || feedbackData?.searchResults) {
+                                    console.log(`[WORKER] Updating BusinessProfile for User ${userId}:`, profileData);
+                                    const updatePayload: any = {
+                                        ...profileData,
+                                        lastUpdatedFromDay: currentDay
+                                    };
 
                                 if (feedbackData?.searchResults) {
                                     updatePayload.marketData = feedbackData.searchResults;