Added notification clear, improved notification styling.

src/alerts.js

@@ -49,7 +49,92 @@ async function removeAlert(alertId) {
 	await knex('alerts').where('id', alertId).delete();
 }
 
+async function notify(scenes, sessionUser) {
+	const releases = await knex.raw(`
+		SELECT alerts.id as alert_id, alerts.notify, alerts.email, releases.id as scene_id, users.id as user_id
+		FROM releases
+		CROSS JOIN alerts
+		LEFT JOIN users ON users.id = alerts.user_id
+		LEFT JOIN releases_tags ON releases_tags.release_id = releases.id
+		/* match updated IDs from input */
+		WHERE users.id = :userId
+		WHERE (releases.id = ANY(:sceneIds))
+		/* match tags */
+		AND (NOT EXISTS (SELECT alerts_tags.alert_id
+			FROM alerts_tags
+			WHERE alerts_tags.alert_id = alerts.id)
+		OR (SELECT array_agg(releases_tags.tag_id)
+			FROM releases_tags
+			WHERE releases_tags.release_id = releases.id
+			GROUP BY releases_tags.release_id)
+		@> (SELECT array_agg(alerts_tags.tag_id)
+			FROM alerts_tags
+			WHERE alerts_tags.alert_id = alerts.id
+			GROUP BY alerts_tags.alert_id))
+		/* match actors */
+		AND (NOT EXISTS (SELECT alerts_actors.alert_id
+			FROM alerts_actors
+			WHERE alerts_actors.alert_id = alerts.id)
+		OR (SELECT array_agg(releases_actors.actor_id)
+			FROM releases_actors
+			WHERE releases_actors.release_id = releases.id
+			GROUP BY releases_actors.release_id)
+		@> (SELECT array_agg(alerts_actors.actor_id)
+			FROM alerts_actors
+			WHERE alerts_actors.alert_id = alerts.id
+			GROUP BY alerts_actors.alert_id))
+		/* match entity */
+		AND ((NOT EXISTS (SELECT alerts_entities.entity_id
+			FROM alerts_entities
+			WHERE alerts_entities.alert_id = alerts.id))
+		OR (releases.entity_id
+		= ANY(array(SELECT alerts_entities.entity_id
+			FROM alerts_entities
+			WHERE alerts_entities.alert_id = alerts.id))))
+		GROUP BY releases.id, users.id, alerts.id;
+	`, {
+		sceneIds: scenes.map(scene => scene.id),
+		userId: sessionUser.id,
+	});
+
+	const notifications = releases.rows.filter(alert => alert.notify);
+
+	await knex('notifications')
+		.insert(notifications.map(notification => ({
+			user_id: notification.user_id,
+			alert_id: notification.alert_id,
+			scene_id: notification.scene_id,
+		})));
+
+	return releases.rows;
+}
+
+async function updateNotification(notificationId, notification, sessionUser) {
+	console.log(notification, sessionUser.id);
+
+	await knex('notifications')
+		.where('user_id', sessionUser.id)
+		.where('id', notificationId)
+		.update({
+			seen: notification.seen,
+		});
+}
+
+
+async function updateNotifications(notification, sessionUser) {
+	console.log(notification, sessionUser.id);
+
+	await knex('notifications')
+		.where('user_id', sessionUser.id)
+		.update({
+			seen: notification.seen,
+		});
+}
+
 module.exports = {
 	addAlert,
 	removeAlert,
+	notify,
+	updateNotification,
+	updateNotifications,
 };