import { BushTask, Reminder } from '#lib'; const { Op } = (await import('sequelize')).default; export default class HandlerRemindersTask extends BushTask { public constructor() { super('handlerReminders', { delay: 30_000, // 30 seconds runOnStart: true }); } public override async exec() { const expiredEntries = await Reminder.findAll({ where: { expires: { [Op.lt]: new Date(Date.now() + 30_000) // Find all rows with an expiry date before 30 seconds from now }, notified: false } }); void client.logger.verbose(`handlerReminders`, `Queried reminders, found <<${expiredEntries.length}>> expired reminders.`); for (const entry of expiredEntries) { setTimeout(() => { void client.users .send( entry.user, `The reminder you set ${util.dateDelta(entry.created)} ago has expired: ${util.format.bold(entry.content)}\n${ entry.messageUrl }` ) .catch(() => false); void entry.update({ notified: true }); }, entry.expires.getTime() - new Date().getTime()); } } }