import './setup.ts'; import { isGrantedForUser } from '../src/helpers.ts'; import dbConnection from './db.ts'; import mailer from './mailer.ts'; const shouldNotify = (frequency) => { if (frequency === 0) { return false; } if (frequency === 7) { return new Date().getDay() === 6; // Saturdays } return true; }; async function notify() { const db = await dbConnection(); const awaitingModeration = [ ...await db.all('SELECT \'nouns\' as type, locale, count(*) as c FROM nouns WHERE approved = 0 AND deleted=0 GROUP BY locale'), ...await db.all('SELECT \'inclusive\' as type, locale, count(*) as c FROM inclusive WHERE approved = 0 AND deleted=0 GROUP BY locale'), ...await db.all('SELECT \'terms\' as type, locale, count(*) as c FROM terms WHERE approved = 0 AND deleted=0 GROUP BY locale'), ...await db.all('SELECT \'sources\' as type, locale, count(*) as c FROM sources WHERE approved = 0 AND deleted=0 GROUP BY locale'), ...await db.all('SELECT \'names\' as type, locale, count(*) as c FROM names WHERE approved = 0 AND deleted=0 GROUP BY locale'), ...await db.all('SELECT \'translations\' as type, locale, count(*) as c FROM translations WHERE status = 0 OR status = 1 GROUP BY locale'), ...await db.all('SELECT \'reports\' as type, null as locale, count(*) as c FROM reports WHERE isHandled = 0'), ...await db.all('SELECT \'ban-proposals\' as type, null as locale, (SELECT count(*) FROM ban_proposals p LEFT JOIN users u ON p.userId = u.id WHERE u.bannedBy IS NULL) as c'), ].filter((r) => r.c > 0); if (!awaitingModeration.length) { console.log('No entries awaiting moderation'); return; } const admins = await db.all('SELECT email, roles, adminNotifications FROM users WHERE roles != \'\''); const awaitingModerationGrouped = {}; let count = 0; for (const m of awaitingModeration) { for (const admin of admins) { if (isGrantedForUser(admin, m.locale, m.type) && shouldNotify(admin.adminNotifications)) { if (awaitingModerationGrouped[admin.email] === undefined) { awaitingModerationGrouped[admin.email] = {}; } awaitingModerationGrouped[admin.email][`${m.locale || '*'}-${m.type}`] = m.c; } } count += m.c; } console.log('Entries awaiting moderation: ', count); for (const email in awaitingModerationGrouped) { if (!awaitingModerationGrouped.hasOwnProperty(email)) { continue; } const stats = awaitingModerationGrouped[email]; console.log('Sending email:', email, stats); mailer(email, 'notify', { stats }); } await db.close(); } notify();