-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
refactor: move web push related stuff into WebPushService
Also added check for OculusBrowser and removed subscription from server after logout. Refs: #85
- Loading branch information
Showing
5 changed files
with
167 additions
and
101 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,131 @@ | ||
| import { computed, DestroyRef, EventEmitter, inject, Injectable, signal } from '@angular/core'; | ||
| import { toObservable, takeUntilDestroyed, toSignal } from '@angular/core/rxjs-interop'; | ||
| import { SwPush } from '@angular/service-worker'; | ||
| import { combineLatest, filter, first, startWith, pairwise, firstValueFrom, map } from 'rxjs'; | ||
|
|
||
| import { AuthService } from './auth.service'; | ||
| import { getHasRejectedPush, setHasRejectedPush } from './storage'; | ||
| import { TranslateService } from './translate.service'; | ||
| import { WellKnownService } from './well-known.service'; | ||
| import { NotificationsService } from '../api/services'; | ||
| import { arrayBufferToBase64 } from '../utils/buffer.utils'; | ||
| import { chainSignals } from '../utils/signal.utils'; | ||
|
|
||
| const Notification = 'Notification' in window ? window.Notification : null; | ||
|
|
||
| @Injectable({ providedIn: 'root' }) | ||
| export class WebPushService { | ||
| private readonly _authService = inject(AuthService); | ||
| private readonly _translateService = inject(TranslateService); | ||
| private readonly _swPush = inject(SwPush); | ||
| private readonly _notificationsService = inject(NotificationsService); | ||
| private readonly _wellKnownService = inject(WellKnownService); | ||
| private readonly _destroyRef = inject(DestroyRef); | ||
|
|
||
| private readonly _subscription = toSignal(this._swPush.subscription); | ||
|
|
||
| public readonly onPromptNotification = new EventEmitter<void>(); | ||
| public readonly notificationsPermission = signal(Notification?.permission ?? 'denied'); | ||
| public readonly notificationsSupported = | ||
| !!Notification && this._swPush.isEnabled && !/OculusBrowser/.test(navigator.userAgent); | ||
| public readonly notificationsEnabled = this.notificationsSupported | ||
| ? chainSignals(toSignal(this._swPush.subscription.pipe(map(x => !!x))), hasPushSub => | ||
| computed(() => hasPushSub() && this.notificationsPermission() === 'granted') | ||
| ) | ||
| : signal(false); | ||
|
|
||
| public init(): void { | ||
| if (!this.notificationsSupported) return; | ||
|
|
||
| if (!getHasRejectedPush()) { | ||
| combineLatest([ | ||
| toObservable(this._authService.isAuthorized), | ||
| this._swPush.subscription, | ||
| toObservable(this.notificationsPermission), | ||
| ]) | ||
| .pipe( | ||
| filter( | ||
| ([isLoggedIn, subscription, permission]) => | ||
| isLoggedIn && !subscription && permission !== 'denied' | ||
| ), | ||
| first(), | ||
| takeUntilDestroyed(this._destroyRef) | ||
| ) | ||
| .subscribe(() => this.onPromptNotification.emit()); | ||
| } | ||
|
|
||
| combineLatest([ | ||
| toObservable(this._authService.user), | ||
| toObservable(this._translateService.language), | ||
| this._swPush.subscription, | ||
| ]) | ||
| .pipe( | ||
| startWith([undefined, undefined, undefined]), | ||
| pairwise(), | ||
| takeUntilDestroyed(this._destroyRef) | ||
| ) | ||
| .subscribe(([[_oldUser, _oldLang, oldSub], [newUser, newLang, newSub]]) => { | ||
| if (newSub && newLang && newUser && newUser.id !== 'admin') { | ||
| this.registerSubscription(newLang, newSub); | ||
| } else if (oldSub && !newSub) { | ||
| this.unregisterSubscription(oldSub); | ||
| } | ||
| }); | ||
| } | ||
|
|
||
| public async enable(): Promise<boolean> { | ||
| if (!this.notificationsSupported || !Notification || Notification.permission === 'denied') { | ||
| return false; | ||
| } | ||
|
|
||
| let permission: NotificationPermission = Notification.permission; | ||
| if (permission === 'default') { | ||
| permission = await Notification.requestPermission(); | ||
| this.notificationsPermission.set(permission); | ||
| } | ||
|
|
||
| if (permission === 'granted') { | ||
| const subscription = this._subscription(); | ||
| if (subscription) { | ||
| await this.registerSubscription(this._translateService.language(), subscription); | ||
| return true; | ||
| } | ||
| const { vapidPublicKey } = await firstValueFrom(this._wellKnownService.wellKnown$); | ||
| await this._swPush.requestSubscription({ serverPublicKey: vapidPublicKey }); | ||
| return true; | ||
| } else { | ||
| setHasRejectedPush(true); | ||
| return false; | ||
| } | ||
| } | ||
|
|
||
| public async disable(keepSubscription: boolean = false): Promise<void> { | ||
| if (!this.notificationsSupported) return; | ||
|
|
||
| const subscription = this._subscription(); | ||
| if (!subscription) return; | ||
|
|
||
| if (keepSubscription) { | ||
| await this.unregisterSubscription(subscription); | ||
| } else { | ||
| await this._swPush.unsubscribe(); | ||
| } | ||
| } | ||
|
|
||
| private async registerSubscription(newLang: string, newSub: PushSubscription) { | ||
| await this._notificationsService.subscribeToNotifications({ | ||
| body: { | ||
| lang: newLang, | ||
| endpoint: newSub.endpoint, | ||
| p256DH: arrayBufferToBase64(newSub.getKey('p256dh')), | ||
| auth: arrayBufferToBase64(newSub.getKey('auth')), | ||
| }, | ||
| }); | ||
| } | ||
|
|
||
| private async unregisterSubscription(oldSub: PushSubscription) { | ||
| await this._notificationsService.unsubscribeFromNotifications({ | ||
| body: { endpoint: oldSub.endpoint }, | ||
| }); | ||
| } | ||
| } |