138 lines
3.7 KiB
JavaScript
138 lines
3.7 KiB
JavaScript
"use strict";
|
|
|
|
const $ = require("jquery");
|
|
const storage = require("./localStorage");
|
|
const socket = require("./socket");
|
|
|
|
let pushNotificationsButton;
|
|
let clientSubscribed = null;
|
|
let applicationServerKey;
|
|
|
|
module.exports.hasServiceWorker = false;
|
|
|
|
module.exports.configurePushNotifications = (subscribedOnServer, key) => {
|
|
applicationServerKey = key;
|
|
|
|
// If client has push registration but the server knows nothing about it,
|
|
// this subscription is broken and client has to register again
|
|
if (clientSubscribed === true && subscribedOnServer === false) {
|
|
pushNotificationsButton.attr("disabled", true);
|
|
|
|
navigator.serviceWorker.ready
|
|
.then((registration) => registration.pushManager.getSubscription())
|
|
.then((subscription) => subscription && subscription.unsubscribe())
|
|
.then((successful) => {
|
|
if (successful) {
|
|
alternatePushButton().removeAttr("disabled");
|
|
}
|
|
});
|
|
}
|
|
};
|
|
|
|
module.exports.initialize = () => {
|
|
pushNotificationsButton = $("#pushNotifications");
|
|
|
|
if (!isAllowedServiceWorkersHost()) {
|
|
return;
|
|
}
|
|
|
|
$("#pushNotificationsHttps").hide();
|
|
|
|
if ("serviceWorker" in navigator) {
|
|
navigator.serviceWorker.register("service-worker.js").then((registration) => {
|
|
module.exports.hasServiceWorker = true;
|
|
|
|
if (!registration.pushManager) {
|
|
return;
|
|
}
|
|
|
|
return registration.pushManager.getSubscription().then((subscription) => {
|
|
$("#pushNotificationsUnsupported").hide();
|
|
|
|
pushNotificationsButton
|
|
.removeAttr("disabled")
|
|
.on("click", onPushButton);
|
|
|
|
clientSubscribed = !!subscription;
|
|
|
|
if (clientSubscribed) {
|
|
alternatePushButton();
|
|
}
|
|
});
|
|
}).catch((err) => {
|
|
$("#pushNotificationsUnsupported span").text(err);
|
|
});
|
|
}
|
|
};
|
|
|
|
function onPushButton() {
|
|
pushNotificationsButton.attr("disabled", true);
|
|
|
|
navigator.serviceWorker.ready.then((registration) => {
|
|
registration.pushManager.getSubscription().then((existingSubscription) => {
|
|
if (existingSubscription) {
|
|
socket.emit("push:unregister");
|
|
|
|
return existingSubscription.unsubscribe();
|
|
}
|
|
|
|
return registration.pushManager.subscribe({
|
|
applicationServerKey: urlBase64ToUint8Array(applicationServerKey),
|
|
userVisibleOnly: true,
|
|
}).then((subscription) => {
|
|
const rawKey = subscription.getKey ? subscription.getKey("p256dh") : "";
|
|
const key = rawKey ? window.btoa(String.fromCharCode.apply(null, new Uint8Array(rawKey))) : "";
|
|
const rawAuthSecret = subscription.getKey ? subscription.getKey("auth") : "";
|
|
const authSecret = rawAuthSecret ? window.btoa(String.fromCharCode.apply(null, new Uint8Array(rawAuthSecret))) : "";
|
|
|
|
socket.emit("push:register", {
|
|
token: storage.get("token"),
|
|
endpoint: subscription.endpoint,
|
|
keys: {
|
|
p256dh: key,
|
|
auth: authSecret,
|
|
},
|
|
});
|
|
|
|
return true;
|
|
});
|
|
}).then((successful) => {
|
|
if (successful) {
|
|
alternatePushButton().removeAttr("disabled");
|
|
}
|
|
});
|
|
}).catch((err) => {
|
|
$("#pushNotificationsUnsupported span").text(err).show();
|
|
});
|
|
|
|
return false;
|
|
}
|
|
|
|
function alternatePushButton() {
|
|
const text = pushNotificationsButton.text();
|
|
|
|
return pushNotificationsButton
|
|
.text(pushNotificationsButton.data("text-alternate"))
|
|
.data("text-alternate", text);
|
|
}
|
|
|
|
function urlBase64ToUint8Array(base64String) {
|
|
const padding = "=".repeat((4 - base64String.length % 4) % 4);
|
|
const base64 = (base64String + padding)
|
|
.replace(/-/g, "+")
|
|
.replace(/_/g, "/");
|
|
|
|
const rawData = window.atob(base64);
|
|
const outputArray = new Uint8Array(rawData.length);
|
|
|
|
for (let i = 0; i < rawData.length; ++i) {
|
|
outputArray[i] = rawData.charCodeAt(i);
|
|
}
|
|
|
|
return outputArray;
|
|
}
|
|
|
|
function isAllowedServiceWorkersHost() {
|
|
return location.protocol === "https:" || location.hostname === "localhost" || location.hostname === "127.0.0.1";
|
|
}
|