Your SMTP configuration is working correctly.
Sent at ${new Date().toISOString()}
`; try { await sendEmail(to, 'Bill Tracker — Test Email', html); markNotificationTestSuccess(); } catch (err) { markNotificationError(err); throw err; } } // ── Notification tracking ───────────────────────────────────────────────────── function hasNotification(db, billId, userId, year, month, type, date) { return !!db.prepare(` SELECT 1 FROM notifications WHERE bill_id=? AND user_id=? AND year=? AND month=? AND type=? AND sent_date=? `).get(billId, userId, year, month, type, date); } function recordNotification(db, billId, userId, year, month, type, date) { try { db.prepare(` INSERT INTO notifications (bill_id, user_id, year, month, type, sent_date) VALUES (?, ?, ?, ?, ?, ?) `).run(billId, userId, year, month, type, date); } catch { // Unique constraint: already recorded, ignore } } // ── Main notification runner (called by daily worker) ───────────────────────── async function runNotifications() { const db = getDb(); if (getSetting('notify_smtp_enabled') !== 'true') return; if (!getSetting('notify_smtp_host')) return; if (!getSetting('notify_sender_address')) return; const now = new Date(); const year = now.getFullYear(); const month = now.getMonth() + 1; const today = now.toISOString().slice(0, 10); const { getCycleRange, resolveDueDate } = require('./statusService'); const { start, end } = getCycleRange(year, month); const bills = db.prepare('SELECT * FROM bills WHERE active = 1').all(); const allowUserConfig = getSetting('notify_allow_user_config') === 'true'; const globalRecipient = getSetting('notify_global_recipient'); // Gather recipient list const recipients = []; if (allowUserConfig) { const users = db.prepare( "SELECT * FROM users WHERE role='user' AND notifications_enabled=1 AND notification_email IS NOT NULL AND notification_email != ''" ).all(); recipients.push(...users); } else if (globalRecipient) { // Treat global recipient as a synthetic user-like object recipients.push({ id: 0, notification_email: globalRecipient, notify_3d: 1, notify_1d: 1, notify_due: 1, notify_overdue: 1, }); } if (!recipients.length) return; const errors = []; for (const bill of bills) { const payments = db.prepare( 'SELECT * FROM payments WHERE bill_id = ? AND paid_date BETWEEN ? AND ? AND deleted_at IS NULL' ).all(bill.id, start, end); const totalPaid = payments.reduce((s, p) => s + p.amount, 0); const isPaid = totalPaid >= bill.expected_amount; if (isPaid) continue; const dueDate = resolveDueDate(bill, year, month); const due = new Date(dueDate + 'T00:00:00'); const diffDays = Math.floor((due - now) / 86400000); // Determine which type applies today let type = null; if (diffDays === 3) type = 'due_3d'; else if (diffDays === 1) type = 'due_1d'; else if (diffDays === 0) type = 'due_today'; else if (diffDays < 0) type = 'overdue'; if (!type) continue; for (const recipient of recipients) { // Check recipient's preferences if (type === 'due_3d' && !recipient.notify_3d) continue; if (type === 'due_1d' && !recipient.notify_1d) continue; if (type === 'due_today' && !recipient.notify_due) continue; if (type === 'overdue' && !recipient.notify_overdue) continue; if (hasNotification(db, bill.id, recipient.id, year, month, type, today)) continue; const meta = TYPE_META[type]; const subject = meta.subject(bill); const html = buildEmailHtml(bill, type, dueDate); try { await sendEmail(recipient.notification_email, subject, html); recordNotification(db, bill.id, recipient.id, year, month, type, today); } catch (err) { errors.push(`${recipient.notification_email}/${bill.name}: ${err.message}`); } } } if (errors.length) { markNotificationError(new Error(errors.join('; '))); console.error('[notifications] Send errors:', errors); } else { markNotificationSuccess(); console.log(`[notifications] Run complete for ${today}`); } } module.exports = { runNotifications, sendTestEmail, createTransport };