feat: implement automated certificate generation and email sending

Author: macayu17

backend/package-lock.json

@@ -43,6 +43,7 @@
     "jsonwebtoken": "^9.0.2",
     "multer": "^1.4.5-lts.1",
     "nodemailer": "^6.9.7",
+    "pdf-lib": "^1.17.1",
     "pdfkit": "^0.17.2",
     "qrcode": "^1.5.3",
     "razorpay": "^2.9.2",
@@ -54,4 +55,4 @@
     "nodemon": "^3.0.2",
     "prisma": "^6.19.0"
   }
-}
+}

backend/package.json

@@ -66,6 +66,11 @@ model Event {
   
   // Ticket styling options (JSON: template, primaryColor, accentColor, logoUrl)
   ticketStyle Json?         @map("ticket_style")
+
+  // Certificate styling
+  certificateEnabled      Boolean   @default(false) @map("certificate_enabled")
+  certificateTemplateUrl  String?   @map("certificate_template_url")
+  certificateMapping      Json?     @map("certificate_mapping")
   
   createdAt   DateTime      @default(now()) @map("created_at")
   updatedAt   DateTime      @updatedAt @map("updated_at")

backend/prisma/schema.prisma

@@ -12,6 +12,31 @@ const router = express.Router();
 router.use(authenticate);
 router.use(requireOrganizer);
 
+// Upload generic file (e.g. certificate template)
+router.post('/upload', upload.single('file'), async (req, res) => {
+  try {
+    if (!req.file) {
+      return res.status(400).json({ error: 'No file uploaded' });
+    }
+
+    let fileUrl;
+    
+    // Try Cloudinary first
+    if (isCloudinaryConfigured()) {
+      const result = await uploadToCloudinary(req.file.path, 'events/certificates');
+      fileUrl = result.secure_url;
+    } else {
+      // Fallback to local
+      fileUrl = `/uploads/${req.file.filename}`;
+    }
+
+    res.json({ url: fileUrl });
+  } catch (error) {
+    console.error('Upload error:', error);
+    res.status(500).json({ error: 'Failed to upload file' });
+  }
+});
+
 // Create event
 router.post('/events',
   [
@@ -1242,5 +1267,95 @@ router.delete('/events/:id/team/:memberId', async (req, res) => {
   }
 });
 
+import { generateCertificate } from '../services/certificate.service.js';
+import { sendCertificateEmail } from '../services/email.service.js';
+
+// Send Certificates to checked-in users
+router.post('/events/:id/certificates', async (req, res) => {
+  try {
+    const { id } = req.params;
+    const { dryRun } = req.body; // if true, just return count
+
+    const event = await prisma.event.findUnique({
+      where: { id }
+    });
+
+    if (!event) return res.status(404).json({ error: 'Event not found' });
+    if (!event.certificateEnabled || !event.certificateTemplateUrl) {
+      return res.status(400).json({ error: 'Certificates not configured for this event' });
+    }
+
+    // Find checked-in tickets
+    const tickets = await prisma.ticket.findMany({
+      where: {
+        checkedInAt: { not: null },
+        order: {
+          registration: {
+            eventId: id
+          }
+        }
+      },
+      include: {
+        order: {
+          include: {
+            registration: true
+          }
+        }
+      }
+    });
+
+    if (tickets.length === 0) {
+      return res.json({ message: 'No checked-in attendees found', count: 0 });
+    }
+
+    if (dryRun) {
+      return res.json({ message: 'Dry run complete', count: tickets.length });
+    }
+
+    let sentCount = 0;
+    
+    // Process certificates
+    for (const ticket of tickets) {
+      const registration = ticket.order.registration;
+      // Use registration name if available, else fallback (schema says userEmail on registration, name might be in User model if we linked it, but registration has userEmail. Let's assume we need name.)
+      // Registration model doesn't have name field in the snippet I saw earlier? 
+      // Wait, let me check schema again. Registration has `userEmail`. User model has `name`.
+      // But Registration doesn't link to User directly? 
+      // "userEmail" map "user_email". "User" model has "email" @unique.
+      
+      const user = await prisma.user.findUnique({
+        where: { email: registration.userEmail }
+      });
+      
+      const userName = user ? user.name : registration.userEmail.split('@')[0];
+      const eventDate = event.startTime.toDateString();
+
+      try {
+        const pdfBytes = await generateCertificate(
+            event.certificateTemplateUrl,
+            event.certificateMapping,
+            {
+                userName,
+                eventName: event.title,
+                date: eventDate,
+                qrCode: ticket.id 
+            }
+        );
+
+        await sendCertificateEmail(registration.userEmail, userName, event.title, Buffer.from(pdfBytes));
+        sentCount++;
+      } catch (err) {
+        console.error(`Failed to send cert to ${registration.userEmail}`, err);
+      }
+    }
+
+    res.json({ message: `Certificates sent to ${sentCount} attendees`, count: sentCount });
+
+  } catch (error) {
+    console.error('Certificate generation error:', error);
+    res.status(500).json({ error: 'Failed to generate certificates' });
+  }
+});
+
 export default router;
 

backend/src/routes/admin.routes.js

@@ -0,0 +1,46 @@
+import { PDFDocument, StandardFonts, rgb } from 'pdf-lib';
+import fetch from 'node-fetch';
+
+export const generateCertificate = async (templateUrl, mapping, data) => {
+  try {
+    // 1. Fetch the template
+    const existingPdfBytes = await fetch(templateUrl).then(res => res.arrayBuffer());
+
+    // 2. Load PDF
+    const pdfDoc = await PDFDocument.load(existingPdfBytes);
+    const font = await pdfDoc.embedFont(StandardFonts.Helvetica);
+    const pages = pdfDoc.getPages();
+    const firstPage = pages[0];
+    const { width, height } = firstPage.getSize();
+
+    // 3. Draw fields
+    for (const field of mapping) {
+      const { fieldId, x, y, fontSize = 12, color = '#000000' } = field;
+      
+      let text = '';
+      if (fieldId === 'userName') text = data.userName || '';
+      if (fieldId === 'eventName') text = data.eventName || '';
+      if (fieldId === 'date') text = data.date || '';
+      
+      // Convert hex color to rgb
+      const r = parseInt(color.slice(1, 3), 16) / 255;
+      const g = parseInt(color.slice(3, 5), 16) / 255;
+      const b = parseInt(color.slice(5, 7), 16) / 255;
+
+      firstPage.drawText(text, {
+        x: x * width,
+        y: (1 - y) * height, // PDF y-axis starts from bottom, but DOM usually top
+        size: fontSize,
+        font: font,
+        color: rgb(r, g, b),
+      });
+    }
+
+    // 4. Save
+    const pdfBytes = await pdfDoc.save();
+    return pdfBytes;
+  } catch (error) {
+    console.error('Certificate generation error:', error);
+    throw error;
+  }
+};

backend/src/services/certificate.service.js

@@ -235,3 +235,32 @@ export async function sendCustomEmail(to, subject, html) {
 
   return transporter.sendMail(mailOptions);
 }
+
+export async function sendCertificateEmail(toEmail, userName, eventName, pdfBuffer) {
+  try {
+    await transporter.sendMail({
+      from: `"Occasio Events" <${process.env.SMTP_FROM_EMAIL || 'noreply@occasio.io'}>`,
+      to: toEmail,
+      subject: `Certificate of Participation - ${eventName}`,
+      html: `
+        <div style="font-family: sans-serif; max-width: 600px; margin: 0 auto;">
+          <h1>Hi ${userName},</h1>
+          <p>Thank you for attending <strong>${eventName}</strong>.</p>
+          <p>Please find your certificate of participation attached to this email.</p>
+          <br>
+          <p>Best regards,<br>The Occasio Team</p>
+        </div>
+      `,
+      attachments: [
+        {
+          filename: `Certificate - ${eventName}.pdf`,
+          content: pdfBuffer,
+          contentType: 'application/pdf'
+        }
+      ]
+    });
+    console.log(`Certificate sent to ${toEmail}`);
+  } catch (error) {
+    console.error('Email send error:', error);
+  }
+}