Notifications

flowchart TD
    A[Nouveau signalement] --> B[Notification Service]
    B --> C{Canal activé ?}
    C -->|In-app| D[DB insert + WebSocket]
    C -->|Email| E[Queue → Resend API]
    C -->|WhatsApp| F{Fenêtre d'agrégation ?}
    F -->|Premier message| G[Queue → WhatsApp API]
    F -->|Déjà envoyé récemment| H[Agrégé — pas d'envoi]

import { Resend } from "resend";

const resend = new Resend(env.RESEND_API_KEY);

await resend.emails.send({
  from: "alerts@wcare.fr",
  to: establishment.email,
  subject: `🚽 Signalement — ${toilet.name}`,
  html: renderReportEmail({ establishment, toilet, report }),
});

🚽 *{{establishment_name}}* — Signalement WC

📍 *{{toilet_name}}* {{#if toilet_location}}({{toilet_location}}){{/if}}
⚠️ {{issue_category}}: {{issue_detail}}
🕐 {{timestamp}}

👉 Dashboard : {{dashboard_url}}

async function shouldSendWhatsApp(
  toiletId: string,
  windowMinutes: number,
): Promise<boolean> {
  const recentWhatsapp = await db
    .select()
    .from(notification)
    .where(
      and(
        eq(notification.channel, "whatsapp"),
        eq(notification.status, "sent"),
        gt(notification.sentAt, subMinutes(new Date(), windowMinutes)),
        // Joindre avec report pour filtrer par toiletId
      ),
    )
    .limit(1);

  return recentWhatsapp.length === 0;
}