diff --git a/lib/notifier/queries.js b/lib/notifier/queries.js index e6fa0844..eb3cc500 100644 --- a/lib/notifier/queries.js +++ b/lib/notifier/queries.js @@ -72,7 +72,11 @@ const markAllAsRead = () => { } const hasUnreadNotifications = () => { - const sql = `SELECT EXISTS (SELECT 1 FROM notifications WHERE read = 'f' LIMIT 1)` + const sql = ` + SELECT EXISTS + (SELECT * FROM notifications + WHERE valid AND NOT read AND created > (CURRENT_TIMESTAMP - INTERVAL '7' DAY)) + ` return db.oneOrNone(sql).then(res => res.exists).catch(logger.error) }