feat: email notifications via Resend on new incident

lib/notifications/email.ts

@@ -0,0 +1,52 @@
+import { Resend } from 'resend'
+import { createClient } from '@/lib/supabase/server'
+import { newIncidentTemplate } from '@/lib/notifications/templates/new-incident'
+
+export async function sendNewIncidentEmail(
+  incidentId: string,
+  siteId: string,
+  reference_no: string,
+  incidentType: string,
+): Promise<void> {
+  const supabase = await createClient()
+
+  const { data: recipients } = await supabase
+    .from('users')
+    .select('email, name, role')
+    .in('role', ['supervisor', 'hse'])
+    .eq('site_id', siteId)
+
+  if (!recipients || recipients.length === 0) return
+
+  const to = recipients.map((r: { email: string }) => r.email).filter(Boolean)
+  if (to.length === 0) return
+
+  const { data: incident } = await supabase
+    .from('incidents')
+    .select('reported_at, sites (name), reporter:users!reported_by (name)')
+    .eq('id', incidentId)
+    .single()
+
+  const siteName = (incident?.sites as any)?.name ?? 'Unknown Site'
+  const reporterName = (incident?.reporter as any)?.name ?? 'Unknown'
+  const reportedAt = incident?.reported_at
+    ? new Date(incident.reported_at).toLocaleString('en-MY', { timeZone: 'Asia/Kuala_Lumpur' })
+    : '-'
+  const siteUrl = process.env.NEXT_PUBLIC_SITE_URL ?? 'http://localhost:3000'
+
+  const { subject, html, text } = newIncidentTemplate({
+    reference_no,
+    incident_type: incidentType,
+    site_name: siteName,
+    reporter_name: reporterName,
+    reported_at: reportedAt,
+    site_url: siteUrl,
+    incident_id: incidentId,
+  })
+
+  const resend = new Resend(process.env.RESEND_API_KEY)
+  const from = process.env.RESEND_FROM_EMAIL ?? 'onboarding@resend.dev'
+
+  const { error } = await resend.emails.send({ from, to, subject, html, text })
+  if (error) console.error('Resend error:', error)
+}