nmemmert
112 lines
4.2 KiB
JavaScript
112 lines
4.2 KiB
JavaScript
import { Resend } from 'resend'
|
|
import { state } from './state.js'
|
|
import { queuePodcastChecklistWrite, queueCalendarEventsWrite } from './data.js'
|
|
import { DEFAULT_RESEND_FROM, DEFAULT_RESEND_TO } from './config.js'
|
|
|
|
function toDateKey(date) {
|
|
return date.toISOString().slice(0, 10)
|
|
}
|
|
|
|
export function startReminderScheduler() {
|
|
checkReminders()
|
|
setInterval(checkReminders, 60 * 60 * 1000)
|
|
}
|
|
|
|
async function checkReminders() {
|
|
const todayKey = toDateKey(new Date())
|
|
|
|
// Episodes
|
|
const episodes = state.podcastChecklist?.episodes
|
|
if (Array.isArray(episodes)) {
|
|
let changed = false
|
|
for (const ep of episodes) {
|
|
if (!ep.datePublished || !(ep.reminderDays > 0) || ep.reminderSentAt) continue
|
|
const publish = new Date(ep.datePublished + 'T12:00:00Z')
|
|
if (isNaN(publish.getTime())) continue
|
|
const reminderDate = new Date(publish)
|
|
reminderDate.setUTCDate(reminderDate.getUTCDate() - ep.reminderDays)
|
|
if (todayKey === toDateKey(reminderDate)) {
|
|
const sent = await sendReminderEmail({
|
|
label: ep.episodeNumber ? `Episode ${ep.episodeNumber}` : 'Episode',
|
|
title: ep.title || 'Untitled',
|
|
series: ep.series,
|
|
date: ep.datePublished,
|
|
reminderDays: ep.reminderDays,
|
|
type: 'episode',
|
|
})
|
|
if (sent) { ep.reminderSentAt = new Date().toISOString(); changed = true }
|
|
}
|
|
}
|
|
if (changed) queuePodcastChecklistWrite()
|
|
}
|
|
|
|
// Calendar events
|
|
const events = state.calendarEvents
|
|
if (Array.isArray(events)) {
|
|
let changed = false
|
|
for (const ev of events) {
|
|
if (!ev.date || !(ev.reminderDays > 0) || ev.reminderSentAt) continue
|
|
const publish = new Date(ev.date + 'T12:00:00Z')
|
|
if (isNaN(publish.getTime())) continue
|
|
const reminderDate = new Date(publish)
|
|
reminderDate.setUTCDate(reminderDate.getUTCDate() - ev.reminderDays)
|
|
if (todayKey === toDateKey(reminderDate)) {
|
|
const sent = await sendReminderEmail({
|
|
label: ev.type.charAt(0).toUpperCase() + ev.type.slice(1),
|
|
title: ev.title,
|
|
series: null,
|
|
date: ev.date,
|
|
reminderDays: ev.reminderDays,
|
|
type: ev.type,
|
|
})
|
|
if (sent) { ev.reminderSentAt = new Date().toISOString(); changed = true }
|
|
}
|
|
}
|
|
if (changed) queueCalendarEventsWrite()
|
|
}
|
|
}
|
|
|
|
const TYPE_ICONS = { episode: '📅', general: '📌', recording: '🎙️', social: '📱', task: '✅' }
|
|
|
|
async function sendReminderEmail({ label, title, series, date, reminderDays, type }) {
|
|
if (!process.env.RESEND_API_KEY) return false
|
|
|
|
try {
|
|
const resend = new Resend(process.env.RESEND_API_KEY)
|
|
const from = process.env.RESEND_FROM ?? DEFAULT_RESEND_FROM
|
|
const to = process.env.RESEND_TO ?? DEFAULT_RESEND_TO
|
|
|
|
const eventDate = new Date(date + 'T12:00:00Z')
|
|
const msLeft = eventDate.getTime() - Date.now()
|
|
const daysLeft = Math.max(0, Math.ceil(msLeft / (1000 * 60 * 60 * 24)))
|
|
|
|
const seriesStr = series ? ` (${series})` : ''
|
|
const daysText = daysLeft === 0 ? 'today' : daysLeft === 1 ? 'in 1 day' : `in ${daysLeft} days`
|
|
const icon = TYPE_ICONS[type] ?? '📅'
|
|
const subject = `Reminder: ${label}: ${title} — ${daysText}`
|
|
|
|
const html = `
|
|
<div style="font-family:system-ui,sans-serif;max-width:540px;margin:0 auto;color:#222">
|
|
<h2 style="color:#c8860a;margin-bottom:4px">${icon} Calendar Reminder</h2>
|
|
<p style="font-size:1.1rem;margin-bottom:16px">
|
|
<strong>${label}: ${title}</strong>${seriesStr}<br>
|
|
<span style="color:#555">Scheduled for <strong>${date}</strong> — ${daysText}</span>
|
|
</p>
|
|
<hr style="border:none;border-top:1px solid #eee;margin:16px 0">
|
|
<p style="color:#777;font-size:0.85rem">
|
|
This reminder was set ${reminderDays} day${reminderDays === 1 ? '' : 's'} before the date.
|
|
To change or remove it, open the Calendar in your admin panel.
|
|
</p>
|
|
</div>
|
|
`
|
|
|
|
const { error } = await resend.emails.send({ from, to, subject, html })
|
|
if (error) { console.error('[reminder] send error:', error); return false }
|
|
console.log(`[reminder] sent for "${title}" (${date})`)
|
|
return true
|
|
} catch (err) {
|
|
console.error('[reminder] send exception:', err)
|
|
return false
|
|
}
|
|
}
|