feat: add Dockerfile and script for Hugging Face Spaces

Dockerfile

@@ -0,0 +1,46 @@
+FROM node:18-alpine
+
+WORKDIR /app
+
+# Install pnpm and global dependencies
+RUN npm install -g pnpm turbo
+
+# Copy root package files
+COPY package.json pnpm-workspace.yaml turbo.json ./
+
+# Copy package configurations
+COPY packages/tsconfig packages/tsconfig
+COPY packages/database packages/database
+COPY packages/shared-types packages/shared-types
+
+# Copy app configurations
+COPY apps/api/package.json apps/api/package.json
+COPY apps/whatsapp-worker/package.json apps/whatsapp-worker/package.json
+COPY apps/api/tsconfig.json apps/api/tsconfig.json
+COPY apps/whatsapp-worker/tsconfig.json apps/whatsapp-worker/tsconfig.json
+
+# Install dependencies
+RUN pnpm install
+
+# Copy source code
+COPY packages/database packages/database
+COPY packages/shared-types packages/shared-types
+COPY apps/api apps/api
+COPY apps/whatsapp-worker apps/whatsapp-worker
+COPY scripts/start-backend.sh scripts/start-backend.sh
+
+# Generate Prisma Client
+RUN pnpm db:generate
+
+# Build packages and apps
+RUN pnpm build --filter=api --filter=whatsapp-worker...
+
+# Make script executable
+RUN chmod +x scripts/start-backend.sh
+
+# Expose port (HF Spaces uses 7860)
+EXPOSE 7860
+ENV PORT=7860
+
+# Start command
+CMD ["./scripts/start-backend.sh"]

apps/api/src/index.ts

@@ -17,8 +17,9 @@ server.get('/health', async (request, reply) => {
 
 const start = async () => {
     try {
-        await server.listen({ port: 3001, host: '0.0.0.0' });
-        console.log('Server listening on http://localhost:3001');
+        const port = parseInt(process.env.PORT || '3001');
+        await server.listen({ port, host: '0.0.0.0' });
+        console.log(`Server listening on http://0.0.0.0:${port}`);
     } catch (err) {
         server.log.error(err);
         process.exit(1);

apps/api/src/services/queue.ts

@@ -0,0 +1,27 @@
+import { Queue } from 'bullmq';
+
+const connection = {
+    host: process.env.REDIS_HOST || 'localhost',
+    port: parseInt(process.env.REDIS_PORT || '6379'),
+};
+
+export const whatsappQueue = new Queue('whatsapp-queue', { connection });
+
+export async function scheduleMessage(userId: string, text: string, delayMs: number = 0) {
+    await whatsappQueue.add('send-message', {
+        userId,
+        text
+    }, {
+        delay: delayMs
+    });
+}
+
+export async function scheduleTrackDay(userId: string, trackId: string, dayNumber: number, delayMs: number = 0) {
+    await whatsappQueue.add('send-content', {
+        userId,
+        trackId,
+        dayNumber
+    }, {
+        delay: delayMs
+    });
+}

apps/api/src/services/whatsapp.ts

@@ -77,9 +77,11 @@ export class WhatsAppService {
 
             console.log(`User ${user.id} enrolled in ${defaultTrack.title}`);
 
-            // TODO: Send Day 1 Content immediately
-            // const day1 = await prisma.trackDay.findFirst(...)
-            // await sendMessage(phone, day1.textContent);
+            // 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);
+
         } else {
             console.log('Unknown command, sending menu...');
             // TODO: Send "Envoyez INSCRIPTION pour commencer"

apps/whatsapp-worker/src/index.ts

@@ -1,18 +1,52 @@
-import { Worker } from 'bullmq';
+import { Worker, Job } from 'bullmq';
 import dotenv from 'dotenv';
+import { PrismaClient } from '@prisma/client';
 
 dotenv.config();
 
+const prisma = new PrismaClient();
+
 const connection = {
     host: process.env.REDIS_HOST || 'localhost',
     port: parseInt(process.env.REDIS_PORT || '6379'),
 };
 
-const worker = new Worker('whatsapp-queue', async job => {
-    console.log('Processing job:', job.id, job.data);
-    // Simulating work
-    await new Promise(resolve => setTimeout(resolve, 1000));
-    console.log('Job completed:', job.id);
+const worker = new Worker('whatsapp-queue', async (job: Job) => {
+    console.log('Processing job:', job.name, job.id);
+
+    try {
+        if (job.name === 'send-message') {
+            const { userId, text } = job.data;
+            // TODO: Call WhatsApp Cloud API to send text
+            console.log(`[MOCK SEND] To User ${userId}: "${text}"`);
+        }
+        else if (job.name === 'send-content') {
+            const { userId, trackId, dayNumber } = job.data;
+
+            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}"`);
+
+                // Update enrollment progress
+                await prisma.enrollment.updateMany({
+                    where: { userId, trackId },
+                    data: {
+                        currentDay: dayNumber,
+                        lastActivityAt: new Date()
+                    }
+                });
+            } else {
+                console.error(`Content not found for Track ${trackId} Day ${dayNumber}`);
+            }
+        }
+    } catch (error) {
+        console.error(`Job ${job.id} failed:`, error);
+        throw error;
+    }
 }, { connection });
 
 console.log('WhatsApp Worker started...');

scripts/start-backend.sh

@@ -0,0 +1,13 @@
+#!/bin/sh
+
+# Migrate database
+echo "Running database migrations..."
+pnpm db:push
+
+# Start Worker in background
+echo "Starting WhatsApp Worker..."
+node apps/whatsapp-worker/dist/index.js &
+
+# Start API in foreground
+echo "Starting API..."
+node apps/api/dist/index.js