From 45af419633b54e9d5309339afca19e33d4dcb45b Mon Sep 17 00:00:00 2001 From: Todd Martin Date: Thu, 4 Sep 2025 13:08:48 -0400 Subject: [PATCH] Revert changes --- .../default-server-notifications.service.ts | 19 +++---------------- 1 file changed, 3 insertions(+), 16 deletions(-) diff --git a/libs/common/src/platform/server-notifications/internal/default-server-notifications.service.ts b/libs/common/src/platform/server-notifications/internal/default-server-notifications.service.ts index 6d0728ab65d..e8ac93dc61f 100644 --- a/libs/common/src/platform/server-notifications/internal/default-server-notifications.service.ts +++ b/libs/common/src/platform/server-notifications/internal/default-server-notifications.service.ts @@ -172,7 +172,6 @@ export class DefaultServerNotificationsService implements ServerNotificationsSer private hasAccessToken$(userId: UserId) { return this.configService.getFeatureFlag$(FeatureFlag.PushNotificationsWhenLocked).pipe( - distinctUntilChanged(), switchMap((featureFlagEnabled) => { if (featureFlagEnabled) { return this.authService.authStatusFor$(userId).pipe( @@ -306,23 +305,11 @@ export class DefaultServerNotificationsService implements ServerNotificationsSer startListening() { return this.notifications$ .pipe( - mergeMap(async ([notification, userId]) => { - try { - await this.processNotification(notification, userId); - } catch (err: unknown) { - this.logService.error( - `Problem processing notification of type ${notification.type}`, - err, - ); - } - }), + mergeMap(async ([notification, userId]) => this.processNotification(notification, userId)), ) .subscribe({ - error: (err: unknown) => - this.logService.error( - "Fatal error in server notifications$ observable, notifications won't be recieved anymore.", - err, - ), + error: (e: unknown) => + this.logService.warning("Error in server notifications$ observable", e), }); }