Added notifications

2020-09-27 21:54:43 +02:00
parent a92dc45bb7
commit 876776eb5b
3 changed files with 202 additions and 26 deletions
--- a/service-worker.js.php
+++ b/service-worker.js.php
@@ -104,4 +104,143 @@ workbox.routing.registerRoute(


 //Learn more about Service Workers and Configurations
-//https://developers.google.com/web/tools/workbox/
+//https://developers.google.com/web/tools/workbox/
+
+
+// DB
+
+var db = null;
+if (indexedDB) {
+	var request = indexedDB.open('regatten_app_db_<?php echo BOATCLASS; ?>');
+	request.onerror = function (e) {
+		console.log('[sW] Cannot open DB:', e.target.errorCode);
+	};
+	request.onupgradeneeded = function (e) {
+		console.log('[sW] DB does not exist');
+		e.target.transaction.abort();
+	};
+	request.onsuccess = function (e) {
+		console.log('[sW] DB loaded');
+		db = e.target.result;
+		db.onerror = function (e) {
+			console.log('[sW] DB Error:', e)
+		}
+	};
+}
+
+function dbSettingsGet(key) {
+	return new Promise(function(resolve) {
+		if (db != null) {
+			var request = db.transaction('settings').objectStore('settings').get(key);
+			request.onsuccess = function (event) {
+				resolve(typeof request.result != 'undefined' ? request.result.value : null);
+			}
+		} else {
+			resolve(null);
+		}
+	});
+}
+
+function dbSettingsSet(key, value) {
+	if (db != null) {
+		var os = db.transaction('settings', 'readwrite').objectStore('settings');
+		os.put({ key: key, value: value});
+	}
+}
+
+
+
+
+// PUSHES
+
+function getEntry(data, index, defaultValue) {
+	return ((typeof data[index] !== "undefined") ? data[index] : defaultValue);
+}
+
+function isMyRegatta(id) {
+	return new Promise(async function (resolve) {
+		var regattas = await dbSettingsGet('myregattas_<?php echo BOATCLASS; ?>');
+		if (regattas == null) resolve(false);
+		else resolve(regattas.includes(id.toString()));
+	});
+}
+
+self.addEventListener('push', async function(event) {
+	console.log('[sW] Push received:', event.data.text());
+	
+	var data;
+	try {
+		data = JSON.parse(event.data.text());
+	} catch(e) {
+		console.log(e);
+		data = undefined;
+	}
+	
+	if (typeof data.type !== "undefined") {
+		switch (data.type) {
+			case 'notification':
+				if (typeof data.title === "undefined") break;
+				if (typeof data.body === "undefined") break;
+				if (typeof data.channel === "undefined") break;
+				
+				// check channel
+				var okay = false;
+				switch (data.channel) {
+					case 'news':
+						if (await dbSettingsGet('notify_channel_<?php echo BOATCLASS; ?>_news')) okay = true;
+						break;
+					case 'regatta_changed':
+						if (await dbSettingsGet('notify_channel_<?php echo BOATCLASS; ?>_regatta_changed_all')) okay = true;
+						else if (await dbSettingsGet('notify_channel_<?php echo BOATCLASS; ?>_regatta_changed_my')) {
+							if (await isMyRegatta(getEntry(data, 'id', ''))) okay = true;
+						}
+						break;
+					case 'result_ready':
+						if (await dbSettingsGet('notify_channel_<?php echo BOATCLASS; ?>_result_ready_all')) okay = true;
+						else if (await dbSettingsGet('notify_channel_<?php echo BOATCLASS; ?>_result_ready_my')) {
+							if (await isMyRegatta(getEntry(data, 'id', ''))) okay = true;
+						}
+						break;
+					case 'meldeschluss':
+						if (await dbSettingsGet('notify_channel_<?php echo BOATCLASS; ?>_meldeschluss')) {
+							if (await isMyRegatta(getEntry(data, 'id', ''))) okay = true;
+						}
+						break;
+					default:
+						console.log('Unknown channel:', data.channel);
+						break;
+				}
+				if (!okay) {
+					console.log('Notification channel not subscribed');
+					return;
+				}
+				
+				const options = {
+					data: data,
+					body: data.body,
+					icon: getEntry(data, 'icon', '<?php echo SERVER_ADDR; ?>/client/app/icons/icon-512x512.png'),
+					badge: '<?php echo SERVER_ADDR; ?>/client/app/icons/icon-96x96.png',
+					vibrate: [500,100,500]
+				};
+				if ((image = getEntry(data, 'image', null)) !== null) {
+					options.image = image;
+				}
+				
+				console.log('Showing notification');
+				self.registration.showNotification(data.title, options);
+				break;
+		}
+	}
+});
+
+self.addEventListener('notificationclick', function(event) {
+	var data = event.notification.data;
+	
+	event.notification.close();
+	
+	var url = '<?php echo SERVER_ADDR; ?>' + getEntry(data, 'url', '');
+	
+	event.waitUntil(
+		clients.openWindow(url)
+	);
+});