feat: implement inbound audio/image transcription, secure media proxy, and client-side bulk contact import

apps/admin/package.json

@@ -19,7 +19,8 @@
         "react-dom": "^18.2.0",
         "react-i18next": "^17.0.4",
         "react-router-dom": "^6.20.0",
-        "recharts": "^3.8.1"
+        "recharts": "^3.8.1",
+        "xlsx": "^0.18.5"
     },
     "devDependencies": {
         "@repo/tsconfig": "workspace:*",

apps/admin/src/components/crm/CrmAIAssistant.tsx

@@ -1,11 +1,12 @@
 import { useRef, useEffect } from 'react';
-import { Upload, Send, Bot, User, Loader2, FileText, CheckCircle2 } from 'lucide-react';
+import { Upload, Send, Bot, User, Loader2, FileText, CheckCircle2, Mic } from 'lucide-react';
 import { motion } from 'framer-motion';
 
 interface Message {
     id: string;
     role: 'user' | 'assistant';
     content: string;
+    type?: 'campaign' | 'support';
     timestamp: Date;
 }
 
@@ -22,6 +23,9 @@ interface CrmAIAssistantProps {
     onDrop: (e: React.DragEvent) => void;
     onSendMessage: (e?: React.FormEvent) => void;
     onValidateAndSend: (message: string) => void;
+    isRecording: boolean;
+    onStartRecording: () => void;
+    onStopRecording: () => void;
     suggestions?: Array<{
         id: string;
         label: string;
@@ -45,6 +49,9 @@ export default function CrmAIAssistant({
     onDrop,
     onSendMessage,
     onValidateAndSend,
+    isRecording,
+    onStartRecording,
+    onStopRecording,
     suggestions = []
 }: CrmAIAssistantProps) {
     const messagesEndRef = useRef<HTMLDivElement>(null);
@@ -144,7 +151,7 @@ export default function CrmAIAssistant({
                                     }`}>
                                         {msg.content}
                                     </div>
-                                    {msg.role === 'assistant' && msg.id !== '1' && !isGenerating && messages[messages.length - 1].id === msg.id && (
+                                    {msg.role === 'assistant' && msg.id !== '1' && !isGenerating && messages[messages.length - 1].id === msg.id && msg.type === 'campaign' && (
                                         <motion.button 
                                             initial={{ opacity: 0, scale: 0.9 }}
                                             animate={{ opacity: 1, scale: 1 }}
@@ -216,13 +223,27 @@ export default function CrmAIAssistant({
                                 value={input}
                                 onChange={(e) => setInput(e.target.value)}
                             />
-                            <button 
-                                type="submit"
-                                className="w-14 h-14 bg-indigo-600 text-white rounded-[1.8rem] flex items-center justify-center hover:bg-indigo-700 hover:rotate-6 transition-all shadow-xl shadow-indigo-100 disabled:opacity-50 disabled:rotate-0"
-                                disabled={!input.trim()}
-                            >
-                                <Send className="w-6 h-6" />
-                            </button>
+                            <div className="flex items-center gap-2 pr-2">
+                                <button 
+                                    type="button"
+                                    onClick={isRecording ? onStopRecording : onStartRecording}
+                                    className={`p-3 rounded-2xl transition-all ${
+                                        isRecording 
+                                        ? 'bg-red-50 text-red-500 animate-pulse shadow-inner' 
+                                        : 'text-slate-400 hover:text-indigo-600 hover:bg-indigo-50'
+                                    }`}
+                                    title={isRecording ? "Arrêter l'enregistrement" : "Dictée vocale"}
+                                >
+                                    <Mic className={`w-5 h-5 ${isRecording ? 'fill-current' : ''}`} />
+                                </button>
+                                <button 
+                                    type="submit"
+                                    className="w-14 h-14 bg-indigo-600 text-white rounded-[1.8rem] flex items-center justify-center hover:bg-indigo-700 hover:rotate-6 transition-all shadow-xl shadow-indigo-100 disabled:opacity-50 disabled:rotate-0"
+                                    disabled={!input.trim() || isRecording}
+                                >
+                                    <Send className="w-6 h-6" />
+                                </button>
+                            </div>
                         </div>
                     </form>
                 </div>

apps/admin/src/components/crm/CrmInbox.tsx

@@ -77,7 +77,33 @@ export default function CrmInbox({
                                                     {msg.direction === 'INBOUND' ? 'REÇU' : 'ENVOYÉ'}
                                                 </span>
                                             </div>
-                                            <p className="text-sm text-slate-500 font-medium line-clamp-1">{msg.content}</p>
+                                            
+                                            {/* Media Proxy (Audio or Image) */}
+                                            {msg.mediaType === 'audio' && (
+                                                <div className="mb-2 mt-2 w-64">
+                                                    <audio 
+                                                        controls 
+                                                        src={`${import.meta.env.VITE_API_URL}/v1/organizations/${msg.organizationId}/messages/${msg.id}/media`} 
+                                                        className="w-full h-8"
+                                                        controlsList="nodownload"
+                                                    />
+                                                </div>
+                                            )}
+
+                                            {msg.mediaType === 'image' && (
+                                                <div className="mb-3 mt-2 relative rounded-2xl overflow-hidden border border-slate-200 bg-slate-50 w-full max-w-sm">
+                                                    <img 
+                                                        src={`${import.meta.env.VITE_API_URL}/v1/organizations/${msg.organizationId}/messages/${msg.id}/media`} 
+                                                        alt="Média WhatsApp"
+                                                        className="w-full h-auto max-h-80 object-cover hover:scale-105 transition-transform duration-500"
+                                                        loading="lazy"
+                                                    />
+                                                </div>
+                                            )}
+
+                                            <p className={`text-sm text-slate-500 font-medium ${msg.mediaType ? '' : 'line-clamp-1'}`}>
+                                                {msg.content}
+                                            </p>
                                         </div>
                                     </div>
                                     <div className="text-right">

apps/admin/src/pages/CrmConversationalDashboard.tsx

@@ -1,7 +1,8 @@
-import { useState, useEffect } from 'react';
+import { useState, useEffect, useRef } from 'react';
 import { useAuth } from '@/lib/auth';
 import { useTenant } from '@/lib/tenant';
 import { Megaphone, Bot, FileSignature, BarChart3 } from 'lucide-react';
+import { read, utils } from 'xlsx';
 import CrmStatsHeader from '@/components/crm/CrmStatsHeader';
 import CrmAIAssistant from '@/components/crm/CrmAIAssistant';
 import CrmInbox from '@/components/crm/CrmInbox';
@@ -10,6 +11,7 @@ interface Message {
     id: string;
     role: 'user' | 'assistant';
     content: string;
+    type?: 'campaign' | 'support';
     timestamp: Date;
 }
 
@@ -70,6 +72,9 @@ export default function CrmConversationalDashboard() {
     const [isGenerating, setIsGenerating] = useState(false);
     const [isDragging, setIsDragging] = useState(false);
     const [uploadedFile, setUploadedFile] = useState<{ name: string, listId: string, listName: string } | null>(null);
+    const [isRecording, setIsRecording] = useState(false);
+    const mediaRecorderRef = useRef<MediaRecorder | null>(null);
+    const audioChunksRef = useRef<Blob[]>([]);
 
     const fetchInbox = async () => {
         if (!token || !selectedOrgId) return;
@@ -97,38 +102,53 @@ export default function CrmConversationalDashboard() {
         if (!token || !selectedOrgId) return;
         
         setIsUploading(true);
-        const formData = new FormData();
-        formData.append('file', file);
+        const reader = new FileReader();
 
-        try {
-            const res = await fetch(`${import.meta.env.VITE_API_URL}/v1/organizations/${selectedOrgId}/lists/import`, {
-                method: 'POST',
-                headers: {
-                    'Authorization': `Bearer ${token}`
-                },
-                body: formData
-            });
+        reader.onload = async (event) => {
+            try {
+                // 1. Parse Excel/CSV on the client side
+                const data = new Uint8Array(event.target?.result as ArrayBuffer);
+                const workbook = read(data, { type: 'array' });
+                const firstSheetName = workbook.SheetNames[0];
+                const worksheet = workbook.Sheets[firstSheetName];
+                const jsonData = utils.sheet_to_json(worksheet);
 
-            if (res.ok) {
-                const data = await res.json();
-                setUploadedFile({ name: file.name, listId: data.listId, listName: data.listName });
-                
-                const aiMsg: Message = {
-                    id: Date.now().toString(),
-                    role: 'assistant',
-                    content: `Votre liste de diffusion "${data.listName}" a bien été créée avec ${data.results.created + data.results.updated} contacts ! Que souhaitez-vous envoyer à ces contacts ?`,
-                    timestamp: new Date()
-                };
-                setMessages(prev => [...prev, aiMsg]);
-            } else {
-                alert("Erreur lors de l'importation du fichier.");
+                // 2. Send JSON to the new bulk endpoint
+                const res = await fetch(`${import.meta.env.VITE_API_URL}/v1/organizations/${selectedOrgId}/contacts/bulk`, {
+                    method: 'POST',
+                    headers: {
+                        'Content-Type': 'application/json',
+                        'Authorization': `Bearer ${token}`
+                    },
+                    body: JSON.stringify({ 
+                        contacts: jsonData,
+                        listName: file.name.split('.')[0]
+                    })
+                });
+
+                if (res.ok) {
+                    const data = await res.json();
+                    setUploadedFile({ name: file.name, listId: data.listId, listName: data.listName });
+                    
+                    const aiMsg: Message = {
+                        id: Date.now().toString(),
+                        role: 'assistant',
+                        content: `Votre liste de diffusion "${data.listName}" a bien été créée avec ${data.results.created} contacts ! Que souhaitez-vous envoyer à ces contacts ?`,
+                        timestamp: new Date()
+                    };
+                    setMessages(prev => [...prev, aiMsg]);
+                } else {
+                    alert("Erreur lors de l'importation des contacts.");
+                }
+            } catch (err) {
+                console.error("Parsing/Upload failed:", err);
+                alert("Une erreur technique est survenue.");
+            } finally {
+                setIsUploading(false);
             }
-        } catch (err) {
-            console.error("Upload failed:", err);
-            alert("Une erreur technique est survenue.");
-        } finally {
-            setIsUploading(false);
-        }
+        };
+
+        reader.readAsArrayBuffer(file);
     };
 
     const handleSendMessage = async (e?: React.FormEvent) => {
@@ -165,6 +185,7 @@ export default function CrmConversationalDashboard() {
                     id: Date.now().toString(),
                     role: 'assistant',
                     content: data.message,
+                    type: data.type,
                     timestamp: new Date()
                 };
                 setMessages(prev => [...prev, aiMsg]);
@@ -253,6 +274,68 @@ export default function CrmConversationalDashboard() {
         }
     };
 
+    const startRecording = async () => {
+        try {
+            const stream = await navigator.mediaDevices.getUserMedia({ audio: true });
+            const mediaRecorder = new MediaRecorder(stream);
+            mediaRecorderRef.current = mediaRecorder;
+            audioChunksRef.current = [];
+
+            mediaRecorder.ondataavailable = (event) => {
+                if (event.data.size > 0) {
+                    audioChunksRef.current.push(event.data);
+                }
+            };
+
+            mediaRecorder.onstop = async () => {
+                const audioBlob = new Blob(audioChunksRef.current, { type: 'audio/webm' });
+                await sendAudioToTranscription(audioBlob);
+                stream.getTracks().forEach(track => track.stop());
+            };
+
+            mediaRecorder.start();
+            setIsRecording(true);
+        } catch (err) {
+            console.error("Failed to start recording:", err);
+            alert("Impossible d'accéder au micro.");
+        }
+    };
+
+    const stopRecording = () => {
+        if (mediaRecorderRef.current && isRecording) {
+            mediaRecorderRef.current.stop();
+            setIsRecording(false);
+        }
+    };
+
+    const sendAudioToTranscription = async (blob: Blob) => {
+        if (!token || !selectedOrgId) return;
+
+        const formData = new FormData();
+        formData.append('file', blob, 'recording.webm');
+
+        try {
+            const res = await fetch(`${import.meta.env.VITE_API_URL}/v1/organizations/${selectedOrgId}/campaigns/transcribe`, {
+                method: 'POST',
+                headers: {
+                    'Authorization': `Bearer ${token}`
+                },
+                body: formData
+            });
+
+            if (res.ok) {
+                const data = await res.json();
+                if (data.text) {
+                    setInput(data.text);
+                }
+            } else {
+                console.error("Transcription failed");
+            }
+        } catch (err) {
+            console.error("Error sending audio:", err);
+        }
+    };
+
     return (
         <div className="flex flex-col h-[calc(100vh-64px)] bg-slate-50">
             <CrmStatsHeader 
@@ -286,6 +369,9 @@ export default function CrmConversationalDashboard() {
                         }}
                         onSendMessage={handleSendMessage}
                         onValidateAndSend={handleValidateAndSend}
+                        isRecording={isRecording}
+                        onStartRecording={startRecording}
+                        onStopRecording={stopRecording}
                         suggestions={SUGGESTED_ACTIONS}
                     />
                 ) : (

apps/api/src/index.ts

@@ -1,6 +1,8 @@
 import 'dotenv/config';
 import fastify, { FastifyInstance } from 'fastify';
 import cors from '@fastify/cors';
+import multipart from '@fastify/multipart';
+import jwt from '@fastify/jwt';
 import { logger } from './logger';
 import { prisma } from './services/prisma';
 import { runWithTenant } from '@repo/database';
@@ -27,7 +29,7 @@ const server: FastifyInstance = fastify({
 });
 
 // Attach prisma to server instance for global access in routes
-server.decorate('prisma', prisma);
+server.decorate('prisma', prisma as any);
 
 // ── Middleware & Plugins ──────────────────────────────────────────────────────
 server.register(cors as any, {
@@ -42,11 +44,11 @@ server.register(cors as any, {
     credentials: true
 });
 
-server.register(require('@fastify/multipart'), {
+server.register(multipart, {
     limits: { fileSize: 10 * 1024 * 1024 } // 10MB
 });
 
-server.register(require('@fastify/jwt'), {
+server.register(jwt, {
     secret: process.env.JWT_SECRET ?? (() => { throw new Error('[STARTUP] JWT_SECRET environment variable is required'); })()
 });
 
@@ -78,7 +80,7 @@ const registerRoutes = async () => {
             }
 
             // Multi-Tenant Enforcement
-            const user = request.user;
+            const user = request.user as any;
             const requestedOrgId = request.headers['x-organization-id'] as string;
 
             if (user && user.role !== 'SUPER_ADMIN') {
@@ -92,7 +94,7 @@ const registerRoutes = async () => {
             }
 
             // Centralized property for routes to use
-            request.organizationId = request.headers['x-organization-id'] as string;
+            (request as any).organizationId = request.headers['x-organization-id'] as string;
         });
 
         scope.addHook('preHandler', (request, _reply, done) => {

apps/api/src/routes/admin.ts

@@ -3,6 +3,11 @@ import { prisma } from '../services/prisma';
 import { whatsappQueue } from '../services/queue';
 import { z } from 'zod';
 import { calculateWER, formatError } from '../utils/metrics';
+import { getOrganizationId } from '@repo/database';
+import fs from 'fs';
+import path from 'path';
+import * as diff from 'diff';
+import { normalizeWolof } from '../scripts/normalizeWolof';
 
 // ─── Zod Schemas ───────────────────────────────────────────────────────────────
 const TrackSchema = z.object({
@@ -171,10 +176,11 @@ export async function adminRoutes(fastify: FastifyInstance) {
 
         const currentDay = enrollment ? Math.floor(enrollment.currentDay) : 0;
 
+        const organizationId = getOrganizationId() || 'default-org-id';
         await prisma.businessProfile.upsert({
             where: { userId },
-            update: { lastUpdatedFromDay: currentDay },
-            create: { userId, lastUpdatedFromDay: currentDay }
+            update: { lastUpdatedFromDay: currentDay, organizationId },
+            create: { userId, lastUpdatedFromDay: currentDay, organizationId }
         });
 
         // 3. Dispatch Background Job (Audio Delivery + Next Day Increment)
@@ -244,7 +250,8 @@ export async function adminRoutes(fastify: FastifyInstance) {
     fastify.post('/tracks', async (req, reply) => {
         const body = TrackSchema.safeParse(req.body);
         if (!body.success) return reply.code(400).send({ error: body.error.flatten() });
-        const track = await prisma.track.create({ data: body.data });
+        const organizationId = getOrganizationId() || 'default-org-id';
+        const track = await prisma.track.create({ data: { ...body.data, organizationId } });
         return reply.code(201).send(track);
     });
 
@@ -273,8 +280,6 @@ export async function adminRoutes(fastify: FastifyInstance) {
 
     // ── STT Quality Calibration Endpoint ───────────────────────────────────────
     fastify.get('/stats/confidence-distribution', async (_req, reply) => {
-        const fs = require('fs');
-        const path = require('path');
         const statsPath = path.join(__dirname, '../../data/calibration_stats.json');
 
         try {
@@ -305,10 +310,12 @@ export async function adminRoutes(fastify: FastifyInstance) {
     fastify.post<{ Params: { trackId: string } }>('/tracks/:trackId/days', async (req, reply) => {
         const body = TrackDaySchema.safeParse(req.body);
         if (!body.success) return reply.code(400).send({ error: body.error.flatten() });
+        const organizationId = getOrganizationId() || 'default-org-id';
         const day = await prisma.trackDay.create({
             data: {
                 ...body.data,
                 trackId: req.params.trackId,
+                organizationId,
                 audioUrl: body.data.audioUrl || null,
                 buttonsJson: body.data.buttonsJson ? body.data.buttonsJson : undefined
             }
@@ -373,7 +380,6 @@ export async function adminRoutes(fastify: FastifyInstance) {
         if (!body.success) return reply.code(400).send({ error: body.error.flatten() });
 
 
-        const { normalizeWolof } = require('../scripts/normalizeWolof');
         const normResult = normalizeWolof(body.data.transcription);
 
         const rawWER = calculateWER(body.data.manualCorrection, body.data.transcription);
@@ -408,7 +414,6 @@ export async function adminRoutes(fastify: FastifyInstance) {
 
     // Suggest new dictionary rules from TrainingData
     fastify.get('/training/suggestions', async (_req, reply) => {
-        const diff = require('diff');
         const trainingData = await prisma.trainingData.findMany({
             where: { status: 'REVIEWED' }
         });
@@ -475,7 +480,6 @@ export async function adminRoutes(fastify: FastifyInstance) {
 
         const { normalizationService } = await import('../services/normalization');
         const customRules = await normalizationService.getRules('WOLOF');
-        const { normalizeWolof } = require('../scripts/normalizeWolof');
 
         let totalRawWER = 0;
         let totalNormalizedWER = 0;

apps/api/src/routes/ai.ts

@@ -6,6 +6,7 @@ import { PptxDeckRenderer } from '../services/renderers/pptx-renderer';
 import { uploadFile } from '../services/storage';
 import { convertToMp3IfNeeded } from '../services/ai/ffmpeg';
 import { z } from 'zod';
+import { prisma } from '../services/prisma';
 
 
 export async function aiRoutes(fastify: FastifyInstance) {
@@ -323,7 +324,6 @@ export async function aiRoutes(fastify: FastifyInstance) {
         const { contact, objective, language } = bodySchema.parse(request.body);
 
         const organizationId = request.headers['x-organization-id'] as string;
-        const { prisma } = fastify;
         
         const org = await prisma.organization.findUnique({
             where: { id: organizationId },
@@ -353,7 +353,6 @@ export async function aiRoutes(fastify: FastifyInstance) {
         });
         const { query } = bodySchema.parse(request.body);
         const organizationId = request.headers['x-organization-id'] as string;
-        const prisma = (fastify as any).prisma;
 
         // Step 1: Detect intent using a lightweight prompt
         const systemPrompt = `You are a CRM Command Interpreter. Your job is to classify the user's intent into one of these:
@@ -466,7 +465,6 @@ export async function aiRoutes(fastify: FastifyInstance) {
 
         const { messages } = bodySchema.parse(request.body);
         const organizationId = request.headers['x-organization-id'] as string;
-        const prisma = (fastify as any).prisma;
 
         // 1. Fetch Org Credentials
         const org = await prisma.organization.findUnique({

apps/api/src/routes/auth.ts

@@ -2,6 +2,7 @@ import { FastifyInstance } from 'fastify';
 
 import { AuthService } from '../services/auth';
 import { logger } from '../logger';
+import { prisma } from '../services/prisma';
 
 export async function authRoutes(fastify: FastifyInstance) {
     
@@ -61,7 +62,7 @@ export async function authRoutes(fastify: FastifyInstance) {
     fastify.get('/me', async (request, reply) => {
         const { id } = request.user as any;
         
-        const user = await fastify.prisma.user.findUnique({
+        const user = await prisma.user.findUnique({
             where: { id },
             include: { organization: true }
         });

apps/api/src/routes/campaigns.ts

@@ -11,11 +11,12 @@ export default async function campaignRoutes(fastify: FastifyInstance) {
         }
 
         try {
-            const { text, aiSource } = await aiService.generateBroadcastMessage(prompt);
+            const { text, type, aiSource } = await aiService.generateBroadcastMessage(prompt);
 
             return {
                 ok: true,
                 message: text,
+                type,
                 aiSource,
                 listId // Echoing back the listId for frontend use
             };
@@ -48,4 +49,25 @@ export default async function campaignRoutes(fastify: FastifyInstance) {
             return reply.code(500).send({ error: 'Failed to enqueue campaign' });
         }
     });
+
+    // Transcribe Audio for Campaign Command
+    fastify.post('/:id/campaigns/transcribe', async (req, reply) => {
+        const data = await req.file();
+        if (!data) {
+            return reply.code(400).send({ error: 'Audio file is required' });
+        }
+
+        try {
+            const buffer = await data.toBuffer();
+            const { text } = await aiService.transcribeAudio(buffer, data.filename);
+
+            return {
+                ok: true,
+                text
+            };
+        } catch (err) {
+            fastify.log.error(err);
+            return reply.code(500).send({ error: 'Transcription failed' });
+        }
+    });
 }

apps/api/src/routes/organizations.ts

@@ -437,4 +437,125 @@ export async function organizationRoutes(fastify: FastifyInstance) {
             return reply.code(500).send({ error: 'Failed to process reply' });
         }
     });
+    
+    // 13. CRM: Media Proxy for WhatsApp (Audio & Images)
+    fastify.get('/:id/messages/:messageId/media', async (req, reply) => {
+        const { id: organizationId, messageId } = req.params as { id: string; messageId: string };
+
+        try {
+            // 1. Verify message and organization ownership
+            const message = await prisma.message.findUnique({
+                where: { id: messageId, organizationId }
+            });
+
+            if (!message || !message.mediaId) {
+                return reply.code(404).send({ error: 'Media message not found' });
+            }
+
+            // 2. Get decrypted secrets for the organization
+            const { getTenantSecrets } = await import('../services/organization');
+            const secrets = await getTenantSecrets(organizationId);
+            
+            if (!secrets || !secrets.systemUserToken) {
+                return reply.code(401).send({ error: 'WhatsApp configuration missing' });
+            }
+
+            // 3. Download media from Meta
+            const { downloadMedia } = await import('../services/whatsapp-utils');
+            const { buffer, mimeType } = await downloadMedia(message.mediaId, secrets.systemUserToken);
+
+            // 4. Stream back to client
+            reply.type(mimeType).send(buffer);
+        } catch (err: any) {
+            logger.error({ err, messageId }, '[CRM-MEDIA-PROXY] Failed to proxy media');
+            return reply.code(500).send({ error: 'Failed to retrieve media' });
+        }
+    });
+
+    // 14. CRM: Bulk Contact Import from JSON (Parsed by Frontend)
+    fastify.post('/:id/contacts/bulk', async (req, reply) => {
+        const { id: organizationId } = req.params as { id: string };
+        const { contacts, listName } = req.body as { contacts: any[], listName?: string };
+
+        if (!contacts || !Array.isArray(contacts)) {
+            return reply.code(400).send({ error: 'Invalid contacts data' });
+        }
+
+        const date = new Date().toLocaleDateString('fr-FR');
+        const finalListName = listName || `Import du ${date}`;
+
+        logger.info(`[CRM-BULK-IMPORT] Importing ${contacts.length} contacts for Org: ${organizationId}`);
+
+        try {
+            // 1. Create the Broadcast List first
+            const broadcastList = await prisma.broadcastList.create({
+                data: {
+                    name: finalListName,
+                    organizationId
+                }
+            });
+
+            const results = { created: 0, updated: 0, errors: 0 };
+
+            // We use a sequential loop for stability or chunking for performance
+            // Here we use a transaction for the whole batch for safety
+            for (const row of contacts) {
+                try {
+                    // Heuristic for phone and name (reuse from legacy import)
+                    const phoneKey = Object.keys(row).find(k => 
+                        k.toLowerCase().includes('phone') || 
+                        k.toLowerCase().includes('téléphone') || 
+                        k.toLowerCase().includes('tel') ||
+                        k.toLowerCase().includes('num')
+                    );
+                    const nameKey = Object.keys(row).find(k => 
+                        k.toLowerCase().includes('name') || 
+                        k.toLowerCase().includes('nom')
+                    );
+
+                    let phoneNumber = phoneKey ? String(row[phoneKey]).replace(/\s+/g, '').replace(/^\+/, '').replace(/\D/g, '') : null;
+                    const name = nameKey ? String(row[nameKey]).trim() : null;
+
+                    if (!phoneNumber || phoneNumber.length < 7) {
+                        results.errors++;
+                        continue;
+                    }
+
+                    if (phoneNumber.length === 9) phoneNumber = `221${phoneNumber}`;
+
+                    const attributes: any = { ...row };
+                    if (phoneKey) delete attributes[phoneKey];
+                    if (nameKey) delete attributes[nameKey];
+
+                    // Upsert contact and connect to list
+                    await prisma.contact.upsert({
+                        where: {
+                            phoneNumber_organizationId: { phoneNumber, organizationId }
+                        },
+                        update: { 
+                            name, 
+                            attributes,
+                            broadcastLists: { connect: { id: broadcastList.id } }
+                        },
+                        create: { 
+                            phoneNumber, 
+                            name, 
+                            attributes, 
+                            organizationId,
+                            broadcastLists: { connect: { id: broadcastList.id } }
+                        }
+                    });
+
+                    results.created++;
+                } catch (err) {
+                    results.errors++;
+                }
+            }
+
+            return { ok: true, listId: broadcastList.id, listName: finalListName, results };
+        } catch (err) {
+            logger.error({ err }, '[CRM-BULK-IMPORT] Master failed');
+            return reply.code(500).send({ error: 'Failed to process bulk import' });
+        }
+    });
 }

apps/api/src/routes/payments.ts

@@ -134,19 +134,22 @@ export async function stripeWebhookRoute(fastify: FastifyInstance) {
             const orgId = session.metadata?.organizationId; // If it's an org sub, it has this
 
             if (userId && trackId) {
-                // ... logic for student enrollment (already exists)
+                // Determine organization context (mandatory for hardened schema)
+                const targetOrgId = orgId || session.metadata?.targetOrganizationId || 'default-org-id';
+
                 try {
                     await prisma.$transaction(async (tx) => {
                         await tx.payment.upsert({
                             where: { stripeSessionId: session.id },
-                            update: {}, // Idempotent: do nothing if already exists
+                            update: { organizationId: targetOrgId }, 
                             create: {
                                 userId,
                                 trackId,
                                 amount: session.amount_total,
                                 status: 'COMPLETED',
                                 stripeSessionId: session.id,
-                                currency: session.currency || 'XOF'
+                                currency: session.currency || 'XOF',
+                                organizationId: targetOrgId
                             }
                         });
 
@@ -160,7 +163,8 @@ export async function stripeWebhookRoute(fastify: FastifyInstance) {
                                     userId,
                                     trackId,
                                     status: 'ACTIVE',
-                                    currentDay: 1
+                                    currentDay: 1,
+                                    organizationId: targetOrgId
                                 }
                             });
                         }

apps/api/src/routes/whatsapp.ts

@@ -95,7 +95,8 @@ export async function whatsappRoutes(fastify: FastifyInstance) {
                         await prisma.analyticsLog.create({
                             data: {
                                 campaignHistoryId: history.id,
-                                eventType: 'READ'
+                                eventType: 'READ',
+                                organizationId: history.organizationId
                             }
                         });
                     }

apps/api/src/scripts/migrate-json-to-sql.ts

@@ -46,43 +46,11 @@ async function migrate() {
     }
   }
 
+  /* 
   // 2. Migrate Team Members (BusinessProfile.teamMembers -> TeamMember)
-  const profilesWithTeam = await prisma.businessProfile.findMany({
-    where: {
-      teamMembers: { not: undefined }
-    }
-  });
-
-  logger.info(`Found ${profilesWithTeam.length} BusinessProfile records with teamMembers JSON.`);
-
-  for (const profile of profilesWithTeam) {
-    const team = profile.teamMembers as any;
-    if (Array.isArray(team)) {
-      for (const member of team) {
-        if (!member || typeof member !== 'object') continue;
-        
-        const name = member.name || member.fullName || 'Unknown';
-        const existing = await (prisma as any).teamMember.findFirst({
-          where: {
-            businessProfileId: profile.id,
-            name: name
-          }
-        });
-
-        if (!existing) {
-          await (prisma as any).teamMember.create({
-            data: {
-              businessProfileId: profile.id,
-              name: name,
-              role: member.role || member.position,
-              bio: member.bio || member.description
-            }
-          });
-          logger.info(`Migrated team member "${name}" for profile ${profile.id}`);
-        }
-      }
-    }
-  }
+  // DEPRECATED: Field removed from schema
+  ...
+  */
 
   logger.info('✅ Neon data migration completed successfully!');
 }

apps/api/src/scripts/test-e2e-journey.ts

@@ -72,11 +72,13 @@ async function runTests() {
         const track = await prisma.track.findFirst({ where: { title: { contains: 'Comprendre son business' } } });
         if (!track) throw new Error("Could not find T1 Track in DB.");
 
+        const organizationId = 'default-org-id';
         const user = await prisma.user.create({
             data: {
                 phone: TEST_PHONE,
                 language: 'WOLOF',
                 activity: 'Couture',
+                organizationId
             }
         });
 
@@ -85,7 +87,8 @@ async function runTests() {
                 userId: user.id,
                 trackId: track.id,
                 currentDay: 1,
-                status: 'ACTIVE'
+                status: 'ACTIVE',
+                organizationId: 'default-org-id'
             }
         });
 
@@ -120,7 +123,7 @@ async function runTests() {
         await prisma.userProgress.upsert({
             where: { userId_trackId: { userId: user.id, trackId: track.id } },
             update: { exerciseStatus: 'PENDING_REVIEW' as any },
-            create: { userId: user.id, trackId: track.id, exerciseStatus: 'PENDING_REVIEW' as any }
+            create: { userId: user.id, trackId: track.id, exerciseStatus: 'PENDING_REVIEW' as any, organizationId: 'default-org-id' }
         });
 
         const preReview = await prisma.userProgress.findUnique({ where: { userId_trackId: { userId: user.id, trackId: track.id } } });

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

@@ -284,9 +284,24 @@ export class AIService {
         return { ...data, aiSource: source };
     }
 
-    async generateBroadcastMessage(userPrompt: string): Promise<{ text: string, aiSource: string }> {
-        const systemPrompt = "Tu es un expert en marketing WhatsApp. Rédige un message court, percutant, avec des emojis pertinents, basé sur les instructions de l'utilisateur. Le message doit être prêt à être envoyé à une liste de diffusion.";
-        return this.generateText(systemPrompt, userPrompt, 0.8);
+    async generateBroadcastMessage(userPrompt: string): Promise<{ text: string, type: 'campaign' | 'support', aiSource: string }> {
+        const systemPrompt = `Tu es l'Assistant CRM intelligent de la plateforme XAMLÉ. Tu dois analyser la demande de l'utilisateur et choisir entre deux comportements :
+Cas 1 (Création de campagne) : Si l'utilisateur demande explicitement d'écrire une offre, une promotion ou un message à envoyer à ses clients, rédige un message WhatsApp percutant avec des emojis.
+Cas 2 (Support et Configuration) : Si l'utilisateur pose une question, demande comment configurer un message d'absence, comment créer un template Meta, ou demande une analyse, agis comme un expert technique. Explique la procédure étape par étape de manière claire. Dans ce cas précis, NE rédige PAS de message destiné à être envoyé aux clients. Ne fais pas de publicité pour tes services.
+
+IMPORTANT: Tu dois impérativement répondre au format JSON suivant :
+{
+  "type": "campaign" | "support",
+  "content": "Le texte de ta réponse ici"
+}`;
+        
+        const schema = z.object({
+            type: z.enum(['campaign', 'support']),
+            content: z.string()
+        });
+
+        const { data, source } = await this.callWithFailover(systemPrompt + "\n\nInstruction utilisateur: " + userPrompt, schema, 0.7);
+        return { text: data.content, type: data.type, aiSource: source };
     }
 
     async extractBusinessProfile(userInput: string, dayNumber: number, userLanguage: string = 'FR'): Promise<any> {

apps/api/src/services/whatsapp-utils.ts

@@ -1,3 +1,5 @@
+import axios from 'axios';
+
 export function normalizeCommand(text: string): string {
     return text
         .trim()
@@ -48,3 +50,36 @@ export function isFuzzyMatch(text: string, target: string, threshold = 0.8): boo
     const similarity = 1 - distance / maxLength;
     return similarity >= threshold;
 }
+
+/**
+ * Download a WhatsApp media file from the Graph API.
+ * @param mediaId - The media ID from the WhatsApp webhook payload
+ * @param accessToken - WHATSAPP_ACCESS_TOKEN
+ * @returns { buffer, mimeType, fileSize }
+ */
+export async function downloadMedia(
+    mediaId: string,
+    accessToken: string
+): Promise<{ buffer: Buffer; mimeType: string; fileSize: number }> {
+    // Step 1: Get the media URL
+    const metaRes = await axios.get(
+        `https://graph.facebook.com/v18.0/${mediaId}`,
+        { headers: { Authorization: `Bearer ${accessToken}` } }
+    );
+    const { url, mime_type, file_size } = metaRes.data;
+
+    if (!url) throw new Error(`[downloadMedia] No URL returned for media ${mediaId}`);
+
+    // Step 2: Download the binary content
+    const mediaRes = await axios.get(url, {
+        headers: { Authorization: `Bearer ${accessToken}` },
+        responseType: 'arraybuffer',
+        timeout: 30_000
+    });
+
+    return {
+        buffer: Buffer.from(mediaRes.data),
+        mimeType: mime_type || 'audio/ogg',
+        fileSize: file_size || mediaRes.data.byteLength
+    };
+}

apps/api/src/types/fastify.d.ts

@@ -1,25 +1,19 @@
-import { FastifyInstance, FastifyRequest } from 'fastify';
 import { PrismaClient } from '@repo/database';
-import '@fastify/multipart';
 
 declare module 'fastify' {
-    interface FastifyInstance {
-        jwt: any;
-        prisma: any; // Using any here because the extended Prisma client has a complex dynamic type
-    }
-    
-    interface FastifyRequest {
-        jwtVerify(): Promise<void>;
-        rawBody?: Buffer;
-        organizationId?: string; // For internal forwarding context
-        user: {
-            id: string;
-            organizationId: string;
-            role: string;
-        };
-    }
-
-    interface FastifyContextConfig {
-        requireAuth?: boolean;
-    }
+  interface FastifyInstance {
+    prisma: PrismaClient;
+  }
+  interface FastifyRequest {
+    user: {
+      id: string;
+      role: string;
+      organizationId: string;
+    };
+    organizationId?: string;
+    rawBody?: Buffer;
+  }
+  interface FastifyContextConfig {
+    requireAuth?: boolean;
+  }
 }

apps/whatsapp-worker/src/handlers/InboundHandler.ts

@@ -2,13 +2,67 @@ import { Job } from 'bullmq';
 import { JobHandler, JobData } from './types';
 import { logger } from '../logger';
 import { WhatsAppLogic } from '../services/whatsapp-logic';
+import { aiService } from '../services/ai';
+import { prisma } from '../services/prisma';
 
 export class InboundHandler implements JobHandler {
     async handle(job: Job<JobData>): Promise<void> {
-        const { phone, text, audioUrl, imageUrl, organizationId } = job.data;
+        let { phone, text, audioUrl, imageUrl, organizationId } = job.data;
         
-        if (!phone || text === undefined) {
-            logger.error(`[INBOUND_HANDLER] Missing data: phone=${phone}, text=${text}`);
+        if (!phone) {
+            logger.error(`[INBOUND_HANDLER] Missing phone number`);
+            return;
+        }
+
+        organizationId = organizationId || 'default-org-id';
+
+        // 🎙️ Handle Inbound Audio Transcription
+        if (audioUrl && (!text || text.trim() === '')) {
+            const mediaId = audioUrl; // In our bridge, audioUrl often carries the mediaId
+            logger.info(`[INBOUND_HANDLER] Detected audio inbound (${mediaId}). Starting transcription...`);
+            
+            try {
+                // ... (transcription logic same)
+                let accessToken = process.env.WHATSAPP_ACCESS_TOKEN;
+                if (!accessToken) {
+                    const org = await prisma.organization.findUnique({
+                        where: { id: organizationId },
+                        select: { systemUserToken: true }
+                    });
+                    accessToken = org?.systemUserToken || undefined;
+                }
+
+                if (accessToken) {
+                    const mediaRes = await fetch(`https://graph.facebook.com/v19.0/${mediaId}`, {
+                        headers: { Authorization: `Bearer ${accessToken}` }
+                    });
+                    const mediaData = await mediaRes.json() as { url?: string };
+
+                    if (mediaData.url) {
+                        const audioRes = await fetch(mediaData.url, {
+                            headers: { Authorization: `Bearer ${accessToken}` }
+                        });
+                        const audioBuffer = await audioRes.arrayBuffer();
+                        const transcribedText = await aiService.transcribeAudio(Buffer.from(audioBuffer), `msg_${mediaId}.ogg`);
+                        
+                        if (transcribedText) {
+                            text = `🎤 Transcription : ${transcribedText}`;
+                        }
+                    }
+                }
+            } catch (err) {
+                logger.error({ err, mediaId }, '[INBOUND_HANDLER] Transcription flow failed');
+                text = text || "🎤 [Message vocal reçu]";
+            }
+        }
+
+        // 🖼️ Handle Inbound Images (Fallback content if caption is missing)
+        if (imageUrl && (!text || text.trim() === '')) {
+            text = "[Image reçue]";
+        }
+
+        if (text === undefined) {
+            logger.error(`[INBOUND_HANDLER] Missing text/content for ${phone}`);
             return;
         }
 
@@ -19,7 +73,9 @@ export class InboundHandler implements JobHandler {
             text, 
             audioUrl, 
             imageUrl, 
-            organizationId
+            organizationId,
+            audioUrl ? 'audio' : imageUrl ? 'image' : undefined,
+            audioUrl || imageUrl || undefined
         );
     }
 }

apps/whatsapp-worker/src/handlers/MediaHandler.ts

@@ -123,7 +123,14 @@ export class MediaHandler implements JobHandler {
                                 await prisma.userProgress.upsert({
                                     where: { userId_trackId: { userId: user.id, trackId: activeEnrollment.trackId } },
                                     update: { exerciseStatus: 'PENDING_REVIEW' as any, adminTranscription: transcribedText, confidenceScore: confidence },
-                                    create: { userId: user.id, trackId: activeEnrollment.trackId, exerciseStatus: 'PENDING_REVIEW' as any, adminTranscription: transcribedText, confidenceScore: confidence }
+                                    create: { 
+                                        userId: user.id, 
+                                        trackId: activeEnrollment.trackId, 
+                                        organizationId: organizationId as string,
+                                        exerciseStatus: 'PENDING_REVIEW' as any, 
+                                        adminTranscription: transcribedText, 
+                                        confidenceScore: confidence 
+                                    }
                                 });
                                 await sendTextMessage(phone, "🎙️ Nyangi jaxas sa kàddu. Xamle dina la tontu ci kanam !", tenantConfig);
                                 return;
@@ -132,11 +139,11 @@ export class MediaHandler implements JobHandler {
                     }
 
                     if (transcribedText) {
-                        await WhatsAppLogic.handleIncomingMessage(phone, transcribedText, audioUrl, undefined, organizationId);
+                        await WhatsAppLogic.handleIncomingMessage(phone, transcribedText, audioUrl, undefined, organizationId, 'audio', mediaId);
                     }
                 }
             } else if (mimeType?.startsWith('image/')) {
-                await WhatsAppLogic.handleIncomingMessage(phone, job.data.caption || 'Image reçue', undefined, audioUrl, organizationId);
+                await WhatsAppLogic.handleIncomingMessage(phone, job.data.caption || 'Image reçue', undefined, audioUrl, organizationId, 'image', mediaId);
             }
         } catch (err) {
             logger.error(`[MEDIA_HANDLER] download-media failed:`, err);

apps/whatsapp-worker/src/index.ts

@@ -138,18 +138,35 @@ server.post('/v1/internal/whatsapp/inbound', async (req: FastifyRequest, reply:
                 backoff: { type: 'exponential', delay: 1000 }
             });
         } else if (msg.mediaId) {
-            // Handle media (simplified for now, following existing logic)
+            // 🎙️ Handle media (Images and Audio)
+            const isImage = msg.mediaType === 'image';
+            
+            logger.info(`[BRIDGE] Enqueuing inbound media (${msg.mediaType}) from ${msg.phone}`);
+            
+            // 1. Traditional Media Processing (for training/pedagogy)
             await whatsappQueue.add('download-media', {
                 mediaId: msg.mediaId,
-                mimeType: msg.mediaType === 'image' ? 'image/jpeg' : 'audio/ogg',
+                mimeType: isImage ? 'image/jpeg' : 'audio/ogg',
                 phone: msg.phone,
                 organizationId,
                 caption: msg.caption
             }, { priority: 1, attempts: 3, backoff: { type: 'exponential', delay: 2000 } });
 
+            // 2. New CRM Inbox flow
+            await whatsappQueue.add('handle-inbound', {
+                phone: msg.phone,
+                text: msg.caption || '', // Use caption as text if available
+                audioUrl: !isImage ? msg.mediaId : undefined,
+                imageUrl: isImage ? msg.mediaId : undefined,
+                organizationId
+            }, {
+                attempts: 3,
+                backoff: { type: 'exponential', delay: 1000 }
+            });
+
             await whatsappQueue.add('send-message-direct', {
                 phone: msg.phone,
-                text: msg.mediaType === 'image' ? "⏳ J'analyse ton image..." : "⏳ J'analyse ton audio...",
+                text: isImage ? "⏳ J'analyse ton image..." : "⏳ J'analyse ton audio...",
                 organizationId
             });
         }

apps/whatsapp-worker/src/services/ai.ts

@@ -0,0 +1,38 @@
+import { logger } from '../logger';
+import { getApiUrl, getAdminApiKey } from '../config';
+
+export class AIService {
+    static async transcribeAudio(audioBuffer: Buffer, filename: string = 'audio.ogg'): Promise<string> {
+        try {
+            const AI_API_BASE_URL = getApiUrl();
+            const apiKey = getAdminApiKey();
+            
+            // Create a FormData-like structure or just send base64 if the API supports it
+            // Based on MediaHandler.ts, the API expects { audioBase64, filename, language }
+            const res = await fetch(`${AI_API_BASE_URL.replace(/\/$/, "")}/v1/ai/transcribe`, {
+                method: 'POST',
+                headers: { 
+                    'Content-Type': 'application/json', 
+                    'Authorization': `Bearer ${apiKey}`
+                },
+                body: JSON.stringify({
+                    audioBase64: audioBuffer.toString('base64'),
+                    filename: filename
+                })
+            });
+
+            if (res.ok) {
+                const data = await res.json() as { text: string };
+                return data.text || '';
+            } else {
+                const error = await res.text();
+                logger.error(`[AI_SERVICE] Transcription API error: ${error}`);
+            }
+        } catch (err) {
+            logger.error(`[AI_SERVICE] Transcription failed: ${err}`);
+        }
+        return '';
+    }
+}
+
+export const aiService = AIService;

apps/whatsapp-worker/src/services/whatsapp-logic.ts

@@ -40,7 +40,15 @@ export class WhatsAppLogic {
             .toUpperCase();
     }
 
-    static async handleIncomingMessage(phone: string, text: string, audioUrl?: string, imageUrl?: string, organizationId: string = 'default-org-id') {
+    static async handleIncomingMessage(
+        phone: string, 
+        text: string, 
+        audioUrl?: string, 
+        imageUrl?: string, 
+        organizationId: string = 'default-org-id',
+        mediaType?: string,
+        mediaId?: string
+    ) {
         const traceId = audioUrl ? `[STT-FLOW-${phone.slice(-4)}]` : imageUrl ? `[IMG-FLOW-${phone.slice(-4)}]` : `[TXT-FLOW-${phone.slice(-4)}]`;
         const normalizedText = this.normalizeCommand(text);
         logger.info(`${traceId} Orchestrating Inbound: ${normalizedText}`);
@@ -54,6 +62,8 @@ export class WhatsAppLogic {
                 data: {
                     content: text,
                     mediaUrl: audioUrl || imageUrl,
+                    mediaType: mediaType || (audioUrl ? 'audio' : imageUrl ? 'image' : undefined),
+                    mediaId: mediaId || (audioUrl && audioUrl.length > 20 ? audioUrl : undefined), // Fallback if audioUrl is actually the ID
                     direction: 'INBOUND',
                     userId: user?.id,
                     contactId: contact?.id,

packages/database/prisma/schema.prisma

@@ -43,8 +43,9 @@ model Organization {
   userBadges         UserBadge[]
   progress           UserProgress[]
   phoneNumbers       WhatsAppPhoneNumber[]
-  contacts           Contact[]
+  analytics          AnalyticsLog[]
   campaigns          CampaignHistory[]
+  contacts           Contact[]
   broadcastLists     BroadcastList[]
 }
 
@@ -99,12 +100,15 @@ model CampaignHistory {
 
 model AnalyticsLog {
   id                String          @id @default(uuid())
+  organizationId    String
   campaignHistoryId String
   eventType         String          // CLICK, READ, RESPONSE
   metadata          Json?
   occurredAt        DateTime        @default(now())
+  organization      Organization    @relation(fields: [organizationId], references: [id])
   campaign          CampaignHistory @relation(fields: [campaignHistoryId], references: [id], onDelete: Cascade)
 
+  @@index([organizationId])
   @@index([campaignHistoryId])
   @@index([eventType])
 }
@@ -147,7 +151,7 @@ model User {
   currentStreak   Int              @default(0)
   longestStreak   Int              @default(0)
   lastActivityAt  DateTime?
-  organizationId  String           @default("default-org-id")
+  organizationId  String           
   businessProfile BusinessProfile?
   enrollments     Enrollment[]
   messages        Message[]
@@ -196,8 +200,7 @@ model BusinessProfile {
   lastUpdatedFromDay   Int          @default(0)
   createdAt            DateTime     @default(now())
   updatedAt            DateTime     @updatedAt
-  teamMembers          Json?        @map("teamMembers")
-  organizationId       String       @default("default-org-id")
+  organizationId       String       
   organization         Organization @relation(fields: [organizationId], references: [id])
   user                 User         @relation(fields: [userId], references: [id])
   teamMembersList      TeamMember[]
@@ -211,7 +214,7 @@ model TeamMember {
   name              String?
   role              String?
   bio               String?
-  organizationId    String          @default("default-org-id")
+  organizationId    String          
   businessProfile   BusinessProfile @relation(fields: [businessProfileId], references: [id], onDelete: Cascade)
   organization      Organization    @relation(fields: [organizationId], references: [id])
 
@@ -229,7 +232,7 @@ model Track {
   stripePriceId  String?
   createdAt      DateTime       @default(now())
   updatedAt      DateTime       @updatedAt
-  organizationId String         @default("default-org-id")
+  organizationId String         
   enrollments    Enrollment[]
   payments       Payment[]
   organization   Organization   @relation(fields: [organizationId], references: [id])
@@ -258,7 +261,7 @@ model TrackDay {
   unlockCondition   String?
   createdAt         DateTime     @default(now())
   updatedAt         DateTime     @updatedAt
-  organizationId    String       @default("default-org-id")
+  organizationId    String       
   organization      Organization @relation(fields: [organizationId], references: [id])
   track             Track        @relation(fields: [trackId], references: [id])
 
@@ -283,7 +286,7 @@ model UserProgress {
   updatedAt          DateTime       @updatedAt
   iterationCount     Int            @default(0)
   aiSource           String?
-  organizationId     String         @default("default-org-id")
+  organizationId     String         
   userBadges         UserBadge[]
   organization       Organization   @relation(fields: [organizationId], references: [id])
   track              Track          @relation(fields: [trackId], references: [id])
@@ -303,7 +306,7 @@ model Enrollment {
   startedAt      DateTime         @default(now())
   completedAt    DateTime?
   lastActivityAt DateTime         @default(now())
-  organizationId String           @default("default-org-id")
+  organizationId String           
   organization   Organization     @relation(fields: [organizationId], references: [id])
   track          Track            @relation(fields: [trackId], references: [id])
   user           User             @relation(fields: [userId], references: [id])
@@ -322,7 +325,7 @@ model Response {
   mediaUrl       String?
   createdAt      DateTime     @default(now())
   aiSource       String?
-  organizationId String       @default("default-org-id")
+  organizationId String       
   enrollment     Enrollment   @relation(fields: [enrollmentId], references: [id], onDelete: Cascade)
   organization   Organization @relation(fields: [organizationId], references: [id])
   user           User         @relation(fields: [userId], references: [id])
@@ -338,10 +341,12 @@ model Message {
   channel        String       @default("WHATSAPP")
   content        String?
   mediaUrl       String?
+  mediaType      String?
+  mediaId        String?
   payload        Json?
   createdAt      DateTime     @default(now())
   status         MessageStatus @default(SENT)
-  organizationId String       @default("default-org-id")
+  organizationId String       
   organization   Organization @relation(fields: [organizationId], references: [id])
   user           User?        @relation(fields: [userId], references: [id])
   contact        Contact?     @relation(fields: [contactId], references: [id])
@@ -362,7 +367,7 @@ model Payment {
   stripeSessionId String?       @unique
   createdAt       DateTime      @default(now())
   updatedAt       DateTime      @updatedAt
-  organizationId  String        @default("default-org-id")
+  organizationId  String        
   organization    Organization  @relation(fields: [organizationId], references: [id])
   track           Track         @relation(fields: [trackId], references: [id])
   user            User          @relation(fields: [userId], references: [id])
@@ -398,7 +403,7 @@ model UserBadge {
   userProgressId String
   name           String
   earnedAt       DateTime     @default(now())
-  organizationId String       @default("default-org-id")
+  organizationId String       
   organization   Organization @relation(fields: [organizationId], references: [id])
   userProgress   UserProgress @relation(fields: [userProgressId], references: [id], onDelete: Cascade)
 

packages/database/seed.ts

@@ -10,10 +10,10 @@ const prisma = new PrismaClient();
 async function main() {
     console.log('🌱 Seeding database...');
 
-    // Upsert Track
+    const DEFAULT_ORG_ID = 'default-org-id';
     const track = await prisma.track.upsert({
         where: { id: 'seed-module-1-ecomoto' },
-        update: {},
+        update: { organizationId: DEFAULT_ORG_ID },
         create: {
             id: 'seed-module-1-ecomoto',
             title: 'Lancer son Business – Module 1',
@@ -21,6 +21,7 @@ async function main() {
             duration: 3,
             language: 'FR',
             isPremium: false,
+            organizationId: DEFAULT_ORG_ID
         }
     });
 
@@ -96,10 +97,10 @@ EXEMPLE :
             where: { trackId: track.id, dayNumber: day.dayNumber }
         });
         if (existing) {
-            await prisma.trackDay.update({ where: { id: existing.id }, data: day });
+            await prisma.trackDay.update({ where: { id: existing.id }, data: { ...day, organizationId: DEFAULT_ORG_ID } });
             console.log(`✅ Updated Day ${day.dayNumber}: ${day.title}`);
         } else {
-            await prisma.trackDay.create({ data: { ...day, trackId: track.id } });
+            await prisma.trackDay.create({ data: { ...day, trackId: track.id, organizationId: DEFAULT_ORG_ID } });
             console.log(`✅ Created Day ${day.dayNumber}: ${day.title}`);
         }
     }

pnpm-lock.yaml

@@ -60,6 +60,9 @@ importers:
       recharts:
         specifier: ^3.8.1
         version: 3.8.1(@types/react@18.3.28)(react-dom@18.3.1(react@18.3.1))(react-is@18.3.1)(react@18.3.1)(redux@5.0.1)
+      xlsx:
+        specifier: ^0.18.5
+        version: 0.18.5
     devDependencies:
       '@repo/tsconfig':
         specifier: workspace:*