feat: sync all recent changes (AI, whatsapp, redis passwords, script fixes)

apps/api/src/routes/ai.ts

@@ -52,4 +52,32 @@ export async function aiRoutes(fastify: FastifyInstance) {
 
         return { success: true, url: downloadUrl, data: deckData };
     });
+
+    // 3. Personalize Lesson Content (Dynamic Rewriting)
+    fastify.post('/personalize-lesson', async (request) => {
+        const bodySchema = z.object({
+            lessonText: z.string(),
+            userActivity: z.string()
+        });
+        const { lessonText, userActivity } = bodySchema.parse(request.body);
+
+        console.log(`Personalizing lesson for activity: ${userActivity}`);
+
+        const personalizedText = await aiService.generatePersonalizedLesson(lessonText, userActivity);
+
+        return { success: true, text: personalizedText };
+    });
+
+    // 4. Generate TTS Audio for a lesson
+    fastify.post('/tts', async (request) => {
+        const bodySchema = z.object({ text: z.string() });
+        const { text } = bodySchema.parse(request.body);
+
+        console.log(`Generating TTS audio...`);
+
+        const audioBuffer = await aiService.generateSpeech(text);
+        const downloadUrl = await mockS3Upload(audioBuffer, `lesson-audio-${Date.now()}.mp3`);
+
+        return { success: true, url: downloadUrl };
+    });
 }

apps/api/src/routes/whatsapp.ts

@@ -27,9 +27,44 @@ export async function whatsappRoutes(fastify: FastifyInstance) {
             const value = changes?.value;
             const message = value?.messages?.[0];
 
-            if (message && message.type === 'text') {
+            if (message) {
                 const phone = message.from; // WhatsApp ID
-                const text = message.text?.body;
+                let text = '';
+
+                if (message.type === 'text') {
+                    text = message.text?.body;
+                } else if (message.type === 'audio') {
+                    // 🌟 Support Multi-language Audio (STT) 🌟
+                    const audioId = message.audio?.id;
+                    if (audioId) {
+                        try {
+                            console.log(`[WEBHOOK] Downloading audio message ${audioId}...`);
+                            const token = process.env.WHATSAPP_ACCESS_TOKEN; // Ensure this env is accessible
+
+                            // 1. Get media URL
+                            const metaRes = await fetch(`https://graph.facebook.com/v18.0/${audioId}`, {
+                                headers: { 'Authorization': `Bearer ${token}` }
+                            });
+                            const meta = await metaRes.json();
+
+                            // 2. Download binary media
+                            if (meta.url) {
+                                const mediaRes = await fetch(meta.url, {
+                                    headers: { 'Authorization': `Bearer ${token}` }
+                                });
+                                const arrayBuffer = await mediaRes.arrayBuffer();
+                                const buffer = Buffer.from(arrayBuffer);
+
+                                // 3. Transcribe with Whisper (via AIService)
+                                const { aiService } = await import('../services/ai');
+                                text = await aiService.transcribeAudio(buffer, 'message.ogg');
+                                console.log(`[STT] Transcribed audio: "${text}"`);
+                            }
+                        } catch (err) {
+                            console.error('[WEBHOOK] Failed to process audio message:', err);
+                        }
+                    }
+                }
 
                 if (phone && text) {
                     await WhatsAppService.handleIncomingMessage(phone, text);

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

@@ -1,4 +1,4 @@
-import { LLMProvider, OnePagerData, OnePagerSchema, PitchDeckData, PitchDeckSchema } from './types';
+import { LLMProvider, OnePagerData, OnePagerSchema, PitchDeckData, PitchDeckSchema, PersonalizedLessonSchema } from './types';
 import { MockLLMProvider } from './mock-provider';
 import { OpenAIProvider } from './openai-provider';
 
@@ -45,6 +45,37 @@ class AIService {
 
         return this.provider.generateStructuredData(prompt, PitchDeckSchema);
     }
+
+    /**
+     * Rewrites a daily lesson to use analogies relevant to the user's business sector.
+     */
+    async generatePersonalizedLesson(lessonText: string, userActivity: string): Promise<string> {
+        const prompt = `
+        You are an expert business coach. Rewrite the following daily lesson to specifically target an entrepreneur in the following business sector/activity: "${userActivity}". 
+        Keep the core educational value exactly the same, but use analogies, examples, and a tone that resonates directly with their specific industry.
+        Do NOT make the lesson significantly longer than the original. Maintain a friendly, direct WhatsApp formatting (use *bold* and emojis appropriately).
+        
+        ORIGINAL LESSON:
+        ${lessonText}
+        `;
+
+        const result = await this.provider.generateStructuredData(prompt, PersonalizedLessonSchema);
+        return result.lessonText;
+    }
+
+    /**
+     * Transcribes an audio buffer to text (useful for Wolof/FR voice messages).
+     */
+    async transcribeAudio(audioBuffer: Buffer, filename: string): Promise<string> {
+        return this.provider.transcribeAudio(audioBuffer, filename);
+    }
+
+    /**
+     * Converts text into an audio MP3 buffer (TTS).
+     */
+    async generateSpeech(text: string): Promise<Buffer> {
+        return this.provider.generateSpeech(text);
+    }
 }
 
 // Export a singleton instance

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

@@ -1,4 +1,4 @@
-import { LLMProvider, OnePagerSchema, PitchDeckSchema } from './types';
+import { LLMProvider, OnePagerSchema, PitchDeckSchema, PersonalizedLessonSchema } from './types';
 
 /**
  * A Provider for local development that doesn't require an API Key.
@@ -40,6 +40,23 @@ export class MockLLMProvider implements LLMProvider {
             return schema.parse(mockDeck) as any;
         }
 
+        if (schema === PersonalizedLessonSchema) {
+            const mockPersonalized = {
+                lessonText: "Voici une leçon adaptée: Pensez à votre ferme comme..."
+            };
+            return schema.parse(mockPersonalized) as any;
+        }
+
         throw new Error("MockLLMProvider does not support this schema.");
     }
+
+    async transcribeAudio(_audioBuffer: Buffer, filename: string): Promise<string> {
+        console.log(`[MOCK LLM] Transcribing audio from ${filename}...`);
+        return "INSCRIPTION";
+    }
+
+    async generateSpeech(text: string): Promise<Buffer> {
+        console.log(`[MOCK LLM] Generating speech for text: ${text.substring(0, 30)}...`);
+        return Buffer.from("mock_audio_data");
+    }
 }

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

@@ -36,4 +36,31 @@ export class OpenAIProvider implements LLMProvider {
 
         return result as T;
     }
+
+    async transcribeAudio(audioBuffer: Buffer, filename: string): Promise<string> {
+        console.log(`[OPENAI] Transcribing audio file ${filename}...`);
+
+        // Convert Buffer to File for OpenAI SDK
+        const { toFile } = await import('openai');
+        const file = await toFile(audioBuffer, filename);
+
+        const response = await this.openai.audio.transcriptions.create({
+            file: file,
+            model: 'whisper-1',
+        });
+
+        return response.text;
+    }
+
+    async generateSpeech(text: string): Promise<Buffer> {
+        console.log('[OPENAI] Generating speech TTS...');
+
+        const mp3 = await this.openai.audio.speech.create({
+            model: 'tts-1',
+            voice: 'alloy',
+            input: text,
+        });
+
+        return Buffer.from(await mp3.arrayBuffer());
+    }
 }

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

@@ -3,6 +3,8 @@ import { z } from 'zod';
 // Base interface for all LLM Providers
 export interface LLMProvider {
     generateStructuredData<T>(prompt: string, schema: z.ZodSchema<T>): Promise<T>;
+    transcribeAudio(audioBuffer: Buffer, filename: string): Promise<string>;
+    generateSpeech(text: string): Promise<Buffer>;
 }
 
 // -----------------------------------------------------
@@ -29,6 +31,7 @@ export const SlideSchema = z.object({
 });
 export type SlideData = z.infer<typeof SlideSchema>;
 
+
 // Schema for the V1 Pitch Deck (PPTX)
 export const PitchDeckSchema = z.object({
     title: z.string(),
@@ -36,3 +39,9 @@ export const PitchDeckSchema = z.object({
     slides: z.array(SlideSchema).min(5).max(12).describe("The sequence of slides for the pitch deck")
 });
 export type PitchDeckData = z.infer<typeof PitchDeckSchema>;
+
+// Schema for personalized WhatsApp lesson
+export const PersonalizedLessonSchema = z.object({
+    lessonText: z.string().describe("The rewritten lesson text adapted to the user's business sector.")
+});
+export type PersonalizedLessonData = z.infer<typeof PersonalizedLessonSchema>;

apps/api/src/services/queue.ts

@@ -3,6 +3,8 @@ import { Queue } from 'bullmq';
 const connection = {
     host: process.env.REDIS_HOST || 'localhost',
     port: parseInt(process.env.REDIS_PORT || '6379'),
+    password: process.env.REDIS_PASSWORD || undefined,
+    tls: process.env.REDIS_TLS === 'true' ? {} : undefined,
 };
 
 export const whatsappQueue = new Queue('whatsapp-queue', { connection });
@@ -25,3 +27,10 @@ export async function scheduleTrackDay(userId: string, trackId: string, dayNumbe
         delay: delayMs
     });
 }
+
+export async function enrollUser(userId: string, trackId: string) {
+    await whatsappQueue.add('enroll-user', {
+        userId,
+        trackId
+    });
+}

apps/api/src/services/renderers/pdf-renderer.ts

@@ -116,6 +116,7 @@ export class PdfOnePagerRenderer implements DocumentRenderer<OnePagerData> {
         `;
 
         const browser = await puppeteer.launch({
+            executablePath: process.env.PUPPETEER_EXECUTABLE_PATH || undefined,
             headless: true,
             args: ['--no-sandbox', '--disable-setuid-sandbox'], // Required for running as root in Docker/HF
         });

apps/api/src/services/whatsapp.ts

@@ -1,4 +1,5 @@
 import { prisma } from './prisma';
+import { scheduleMessage, enrollUser } from './queue';
 
 export class WhatsAppService {
     static async handleIncomingMessage(phone: string, text: string) {
@@ -13,17 +14,63 @@ export class WhatsAppService {
                 user = await prisma.user.create({
                     data: { phone }
                 });
-                // TODO: Send welcome message & ask for name
-                console.log('New user created, starting onboarding...');
+                await scheduleMessage(user.id, "Bienvenue sur SafeTrack Edu ! 🎉\nChoisissez votre langue / Tànnal sa làkk:\n1. Français 🇫🇷\n2. Wolof 🇸🇳");
+                console.log('New user created, asked for language.');
                 return;
             } else {
-                // TODO: Send "Type INSCRIPTION to start"
-                console.log('User not found, waiting for INSCRIPTION');
+                // Not registered yet, hasn't typed INSCRIPTION. We ignore or prompt:
+                console.log(`Unregistered user ${phone} sent a message. Need INSCRIPTION.`);
                 return;
             }
         }
 
-        // 2. Check Active Enrollment
+        // 2. Check Onboarding State (Missing Language -> Missing Activity)
+        if (!user.city) {
+            // First time after INSCRIPTION they should answer 1 or 2
+            if (normalizedText === '1' || normalizedText === '2') {
+                const lang = normalizedText === '1' ? 'FR' : 'WOLOF';
+                user = await prisma.user.update({
+                    where: { id: user.id },
+                    data: { language: lang, city: 'SET' } // Using city as a step flag for MVP
+                });
+
+                const prompt = lang === 'FR'
+                    ? "Parfait ! Pour personnaliser votre expérience, quel est votre secteur d'activité ou projet professionnel ? (ex: Agriculture, Commerce, Tech...)"
+                    : "Baax na ! Ngir gën a waajal sa njàng, ban mbir ngay def ? (Mbay, Njaay, Tech...)";
+                await scheduleMessage(user.id, prompt);
+                return;
+            } else {
+                await scheduleMessage(user.id, "Veuillez choisir votre langue / Tànnal sa làkk:\n1. Français 🇫🇷\n2. Wolof 🇸🇳");
+                return;
+            }
+        }
+
+        if (!user.activity) {
+            // Whatever they type now (or dictated via audio) is their activity
+            user = await prisma.user.update({
+                where: { id: user.id },
+                data: { activity: text.trim() }
+            });
+
+            const welcomeMsg = user.language === 'FR'
+                ? `Merci ! Nous avons noté votre secteur : *${user.activity}*.\nJe vous inscris maintenant à notre formation d'introduction !`
+                : `Jërëjëf ! Bind nanu la ci: *${user.activity}*.\nLéegi dinanu la dugal ci njàng mi !`;
+
+            await scheduleMessage(user.id, welcomeMsg);
+
+            // Find default track
+            const defaultTrack = await prisma.track.findFirst({
+                where: { title: "Business Model Express" } // Assuming this exists from seed
+            });
+
+            if (defaultTrack) {
+                // Delegate to worker which handles premium vs free checks!
+                await enrollUser(user.id, defaultTrack.id);
+            }
+            return;
+        }
+
+        // 3. Check Active Enrollment
         const activeEnrollment = await prisma.enrollment.findFirst({
             where: { userId: user.id, status: 'ACTIVE' },
             include: { track: true }
@@ -43,48 +90,15 @@ export class WhatsAppService {
                 }
             });
 
-            // TODO: Schedule next day or send immediate feedback
-            // For MVP, just acknowledge reception
-            // await sendMessage(phone, "Réponse enregistrée ! À demain pour la suite.");
-
+            await scheduleMessage(user.id, "✅ Réponse enregistrée ! À demain pour la suite.");
             return;
         }
 
-        // 3. Handle Commands
+        // 4. Default Handle Commands
         if (normalizedText === 'INSCRIPTION') {
-            console.log('Processing new enrollment...');
-
-            // Find default track (Business Model Express)
-            const defaultTrack = await prisma.track.findFirst({
-                where: { title: "Business Model Express" }
-            });
-
-            if (!defaultTrack) {
-                console.error('Default track not found!');
-                return;
-            }
-
-            // Create enrollment
-            await prisma.enrollment.create({
-                data: {
-                    userId: user.id,
-                    trackId: defaultTrack.id,
-                    startedAt: new Date(),
-                    status: 'ACTIVE',
-                    currentDay: 1
-                }
-            });
-
-            console.log(`User ${user.id} enrolled in ${defaultTrack.title}`);
-
-            // Schedule Day 1 Content immediately (or short delay)
-            // Import dynamically to avoid circular deps if necessary, or just import at top
-            const { scheduleTrackDay } = await import('./queue');
-            await scheduleTrackDay(user.id, defaultTrack.id, 1, 0);
-
+            await scheduleMessage(user.id, "Vous avez déjà complété l'inscription. Consultez le portail ou attendez nos prochaines formations !");
         } else {
-            console.log('Unknown command, sending menu...');
-            // TODO: Send "Envoyez INSCRIPTION pour commencer"
+            console.log('Unknown command from fully onboarded user without active enrollment.');
         }
     }
 }

apps/whatsapp-worker/src/index.ts

@@ -9,6 +9,8 @@ const prisma = new PrismaClient();
 const connection = {
     host: process.env.REDIS_HOST || 'localhost',
     port: parseInt(process.env.REDIS_PORT || '6379'),
+    password: process.env.REDIS_PASSWORD || undefined,
+    tls: process.env.REDIS_TLS === 'true' ? {} : undefined,
 };
 
 const worker = new Worker('whatsapp-queue', async (job: Job) => {
@@ -67,13 +69,60 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
         else if (job.name === 'send-content') {
             const { userId, trackId, dayNumber } = job.data;
 
+            const user = await prisma.user.findUnique({ where: { id: userId } });
             const trackDay = await prisma.trackDay.findFirst({
                 where: { trackId, dayNumber }
             });
 
             if (trackDay && trackDay.textContent) {
-                // TODO: Call WhatsApp Cloud API
-                console.log(`[MOCK SEND CONTENT] To User ${userId}: "${trackDay.textContent}"`);
+                let finalContent = trackDay.textContent;
+
+                // 🌟 Personalize Lesson Content 🌟
+                if (user && user.activity) {
+                    try {
+                        console.log(`[WORKER] Personalizing lesson for User ${userId}'s activity: ${user.activity}`);
+                        const API_URL = process.env.VITE_API_URL || 'http://localhost:3001';
+                        const personalizeRes = await fetch(`${API_URL}/v1/ai/personalize-lesson`, {
+                            method: 'POST',
+                            headers: { 'Content-Type': 'application/json' },
+                            body: JSON.stringify({ lessonText: trackDay.textContent, userActivity: user.activity })
+                        });
+
+                        if (personalizeRes.ok) {
+                            const personalizeData = await personalizeRes.json();
+                            if (personalizeData.text) {
+                                finalContent = personalizeData.text;
+                            }
+                        }
+                    } catch (err) {
+                        console.error('[WORKER] Failed to personalize lesson:', err);
+                    }
+                }
+
+                // 🌟 Generate TTS Audio (Multi-language Support) 🌟
+                let audioUrl = null;
+                try {
+                    console.log(`[WORKER] Generating TTS Audio for User ${userId}...`);
+                    const API_URL = process.env.VITE_API_URL || 'http://localhost:3001';
+                    const ttsRes = await fetch(`${API_URL}/v1/ai/tts`, {
+                        method: 'POST',
+                        headers: { 'Content-Type': 'application/json' },
+                        body: JSON.stringify({ text: finalContent })
+                    });
+
+                    if (ttsRes.ok) {
+                        const ttsData = await ttsRes.json();
+                        audioUrl = ttsData.url;
+                    }
+                } catch (err) {
+                    console.error('[WORKER] Failed to generate TTS:', err);
+                }
+
+                // TODO: Call WhatsApp Cloud API with finalContent and audioUrl
+                console.log(`[MOCK SEND CONTENT] To User ${userId}: "${finalContent}"`);
+                if (audioUrl) {
+                    console.log(`[MOCK SEND AUDIO] To User ${userId}: 🎵 ${audioUrl}`);
+                }
 
                 // Update enrollment progress
                 await prisma.enrollment.updateMany({
@@ -96,9 +145,8 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
                 // 🌟 Trigger AI Document Generation 🌟
                 console.log(`[WORKER] Triggering AI Document Generation for User ${userId}...`);
                 try {
-                    // In a real scenario, we'd fetch the user's responses from the DB to build the context.
-                    // For now, we pass a dummy userContext to trigger the generation flow.
-                    const userContext = `User ${userId} completed the Business Pitch track. They want to build an AgTech SaaS.`;
+                    // Update userContext to explicitly reference the user's sector/activity
+                    const userContext = `User ${userId} completed the Business Pitch track. Their business activity/sector is: ${user?.activity || 'Unknown'}. They want to build a business in this sector using the concepts learned in the track.`;
 
                     const API_URL = process.env.VITE_API_URL || 'http://localhost:3001';
 

scripts/start-backend.sh

@@ -1,13 +1,25 @@
-#!/bin/sh
+#!/bin/bash
+set -ex
 
-# Migrate database
 echo "Running database migrations..."
 pnpm --filter @repo/database db:push
 
-# Start Worker in background
 echo "Starting WhatsApp Worker..."
-node apps/whatsapp-worker/dist/index.js &
+# The TypeScript build might output to dist/src/index.js or dist/index.js depending on rootDir
+if [ -f "apps/whatsapp-worker/dist/src/index.js" ]; then
+    node apps/whatsapp-worker/dist/src/index.js &
+elif [ -f "apps/whatsapp-worker/dist/index.js" ]; then
+    node apps/whatsapp-worker/dist/index.js &
+else
+    echo "ERROR: WhatsApp Worker build output missing (dist/index.js or dist/src/index.js)"
+fi
 
-# Start API in foreground
 echo "Starting API..."
-node apps/api/dist/index.js
+if [ -f "apps/api/dist/src/index.js" ]; then
+    exec node apps/api/dist/src/index.js
+elif [ -f "apps/api/dist/index.js" ]; then
+    exec node apps/api/dist/index.js
+else
+    echo "ERROR: API build output missing (dist/index.js or dist/src/index.js)!"
+    exit 1
+fi