Add Brevo API send as primary email path with SMTP fallback

server.js

@@ -29,6 +29,7 @@ const SMTP_HOST = process.env.SMTP_HOST || 'smtp-relay.brevo.com';
 const SMTP_PORT = parseInt(process.env.SMTP_PORT || '587', 10);
 const SMTP_SECURE = process.env.SMTP_SECURE === 'true' || SMTP_PORT === 465;
 const SMTP_TIMEOUT = parseInt(process.env.SMTP_TIMEOUT_MS || '10000', 10);
+const BREVO_API_TIMEOUT = parseInt(process.env.BREVO_API_TIMEOUT_MS || '10000', 10);
 let emailTransport = null;
 let emailConfigChecked = false;
 
@@ -39,6 +40,46 @@ async function sendMailWithTimeout(transport, mailOptions, timeoutMs = SMTP_TIME
     ]);
 }
 
+async function sendViaBrevoApi(message) {
+    const apiKey = process.env.BREVO_API_KEY;
+    if (!apiKey) {
+        throw new Error('Brak BREVO_API_KEY do wysyłki przez API.');
+    }
+
+    const recipients = (message.to || '')
+        .split(',')
+        .map(s => s.trim())
+        .filter(Boolean)
+        .map(email => ({ email }));
+
+    if (recipients.length === 0) {
+        throw new Error('Brak odbiorców e-mail (EMAIL_TO).');
+    }
+
+    const payload = {
+        sender: { email: message.from },
+        to: recipients,
+        subject: message.subject,
+        textContent: message.text,
+        htmlContent: message.html
+    };
+
+    await axios.post(
+        'https://api.brevo.com/v3/smtp/email',
+        payload,
+        {
+            headers: {
+                'api-key': apiKey,
+                accept: 'application/json',
+                'content-type': 'application/json'
+            },
+            timeout: BREVO_API_TIMEOUT
+        }
+    );
+
+    console.log('Email sent via Brevo API');
+}
+
 function getEmailTransport() {
     if (emailTransport || emailConfigChecked) return emailTransport;
 
@@ -111,15 +152,43 @@ function buildAlertEmail(statusEntry) {
     return { subject, text, html };
 }
 
-async function sendAlertEmail(statusEntry) {
+async function sendEmail(message) {
+    const emailFrom = process.env.EMAIL_FROM;
+    const emailTo = process.env.EMAIL_TO;
+    if (!emailFrom || !emailTo) {
+        throw new Error('Brak EMAIL_FROM/EMAIL_TO do wysyłki e-mail.');
+    }
+
+    // Prefer Brevo API if key is available
+    if (process.env.BREVO_API_KEY) {
+        try {
+            await sendViaBrevoApi(message);
+            return;
+        } catch (err) {
+            console.error('Brevo API send failed, falling back to SMTP if available:', err && err.message ? err.message : err);
+        }
+    }
+
     const transport = getEmailTransport();
-    if (!transport) return;
+    if (!transport) {
+        throw new Error('Brak transportu e-mail (SMTP/API).');
+    }
 
+    await sendMailWithTimeout(transport, {
+        from: message.from,
+        to: message.to,
+        subject: message.subject,
+        text: message.text,
+        html: message.html
+    });
+}
+
+async function sendAlertEmail(statusEntry) {
     const { subject, text, html } = buildAlertEmail(statusEntry);
     const emailFrom = process.env.EMAIL_FROM;
     const emailTo = process.env.EMAIL_TO;
 
-    await sendMailWithTimeout(transport, {
+    await sendEmail({
         from: emailFrom,
         to: emailTo,
         subject,
@@ -226,22 +295,14 @@ function buildStatusReportEmail() {
 async function sendStatusReportEmail() {
     const emailFrom = process.env.EMAIL_FROM;
     const emailTo = process.env.EMAIL_TO;
-    const smtpUser = process.env.SMTP_USER || emailFrom;
-    const smtpPass = process.env.SMTP_PASS || process.env.BREVO_SMTP_PASS || process.env.BREVO_API_KEY;
 
-    if (!emailFrom || !emailTo || !smtpUser || !smtpPass) {
-        throw new Error('Brak konfiguracji e-mail: ustaw EMAIL_FROM, EMAIL_TO, SMTP_USER, SMTP_PASS (lub BREVO_SMTP_PASS / BREVO_API_KEY).');
-    }
-
-    const transport = getEmailTransport();
-    if (!transport) {
-        throw new Error('Transport e-mail nie jest dostępny.');
+    if (!emailFrom || !emailTo) {
+        throw new Error('Brak konfiguracji e-mail: ustaw EMAIL_FROM i EMAIL_TO.');
     }
 
     const { subject, text, html } = buildStatusReportEmail();
-    console.log(`Sending status report email via ${SMTP_HOST}:${SMTP_PORT} secure=${SMTP_SECURE} as ${smtpUser} to ${emailTo}, timeout ${SMTP_TIMEOUT}ms`);
 
-    await sendMailWithTimeout(transport, {
+    await sendEmail({
         from: emailFrom,
         to: emailTo,
         subject,