110 lines
3.6 KiB
JavaScript
110 lines
3.6 KiB
JavaScript
function urlBase64ToUint8Array (base64String) {
|
|
const padding = '='.repeat((4 - base64String.length % 4) % 4)
|
|
const base64 = (base64String + padding)
|
|
.replace(/-/g, '+')
|
|
.replace(/_/g, '/')
|
|
|
|
const rawData = window.atob(base64)
|
|
return Uint8Array.from([...rawData].map((char) => char.charCodeAt(0)))
|
|
}
|
|
|
|
function isPushSupported () {
|
|
return 'serviceWorker' in navigator && 'PushManager' in window
|
|
}
|
|
|
|
function getOrCreateServiceWorker () {
|
|
return navigator.serviceWorker.register('/sw-pleroma.js')
|
|
.catch((err) => console.error('Unable to get or create a service worker.', err))
|
|
}
|
|
|
|
function subscribePush (registration, isEnabled, vapidPublicKey) {
|
|
if (!isEnabled) return Promise.reject(new Error('Web Push is disabled in config'))
|
|
if (!vapidPublicKey) return Promise.reject(new Error('VAPID public key is not found'))
|
|
|
|
const subscribeOptions = {
|
|
userVisibleOnly: true,
|
|
applicationServerKey: urlBase64ToUint8Array(vapidPublicKey)
|
|
}
|
|
return registration.pushManager.subscribe(subscribeOptions)
|
|
}
|
|
|
|
function unsubscribePush (registration) {
|
|
return registration.pushManager.getSubscription()
|
|
.then((subscribtion) => {
|
|
if (subscribtion === null) { return }
|
|
return subscribtion.unsubscribe()
|
|
})
|
|
}
|
|
|
|
function deleteSubscriptionFromBackEnd (token) {
|
|
return window.fetch('/api/v1/push/subscription/', {
|
|
method: 'DELETE',
|
|
headers: {
|
|
'Content-Type': 'application/json',
|
|
'Authorization': `Bearer ${token}`
|
|
}
|
|
}).then((response) => {
|
|
if (!response.ok) throw new Error('Bad status code from server.')
|
|
return response
|
|
})
|
|
}
|
|
|
|
function sendSubscriptionToBackEnd (subscription, token, notificationVisibility) {
|
|
return window.fetch('/api/v1/push/subscription/', {
|
|
method: 'POST',
|
|
headers: {
|
|
'Content-Type': 'application/json',
|
|
'Authorization': `Bearer ${token}`
|
|
},
|
|
body: JSON.stringify({
|
|
subscription,
|
|
data: {
|
|
alerts: {
|
|
follow: notificationVisibility.follows,
|
|
favourite: notificationVisibility.likes,
|
|
mention: notificationVisibility.mentions,
|
|
reblog: notificationVisibility.repeats,
|
|
move: notificationVisibility.moves
|
|
}
|
|
}
|
|
})
|
|
}).then((response) => {
|
|
if (!response.ok) throw new Error('Bad status code from server.')
|
|
return response.json()
|
|
}).then((responseData) => {
|
|
if (!responseData.id) throw new Error('Bad response from server.')
|
|
return responseData
|
|
})
|
|
}
|
|
|
|
export function registerPushNotifications (isEnabled, vapidPublicKey, token, notificationVisibility) {
|
|
if (isPushSupported()) {
|
|
getOrCreateServiceWorker()
|
|
.then((registration) => subscribePush(registration, isEnabled, vapidPublicKey))
|
|
.then((subscription) => sendSubscriptionToBackEnd(subscription, token, notificationVisibility))
|
|
.catch((e) => console.warn(`Failed to setup Web Push Notifications: ${e.message}`))
|
|
}
|
|
}
|
|
|
|
export function unregisterPushNotifications (token) {
|
|
if (isPushSupported()) {
|
|
Promise.all([
|
|
deleteSubscriptionFromBackEnd(token),
|
|
getOrCreateServiceWorker()
|
|
.then((registration) => {
|
|
return unsubscribePush(registration).then((result) => [registration, result])
|
|
})
|
|
.then(([registration, unsubResult]) => {
|
|
if (!unsubResult) {
|
|
console.warn('Push subscription cancellation wasn\'t successful, killing SW anyway...')
|
|
}
|
|
return registration.unregister().then((result) => {
|
|
if (!result) {
|
|
console.warn('Failed to kill SW')
|
|
}
|
|
})
|
|
})
|
|
]).catch((e) => console.warn(`Failed to disable Web Push Notifications: ${e.message}`))
|
|
}
|
|
}
|