aboutsummaryrefslogtreecommitdiffhomepage
path: root/client/src/app/menu/avatar-notification.component.ts
diff options
context:
space:
mode:
Diffstat (limited to 'client/src/app/menu/avatar-notification.component.ts')
-rw-r--r--client/src/app/menu/avatar-notification.component.ts6
1 files changed, 3 insertions, 3 deletions
diff --git a/client/src/app/menu/avatar-notification.component.ts b/client/src/app/menu/avatar-notification.component.ts
index 8b9955069..ed3ffc2d8 100644
--- a/client/src/app/menu/avatar-notification.component.ts
+++ b/client/src/app/menu/avatar-notification.component.ts
@@ -2,7 +2,7 @@ import { Subject, Subscription } from 'rxjs'
2import { filter } from 'rxjs/operators' 2import { filter } from 'rxjs/operators'
3import { Component, EventEmitter, Input, Output, OnDestroy, OnInit, ViewChild } from '@angular/core' 3import { Component, EventEmitter, Input, Output, OnDestroy, OnInit, ViewChild } from '@angular/core'
4import { NavigationEnd, Router } from '@angular/router' 4import { NavigationEnd, Router } from '@angular/router'
5import { Notifier, User, UserNotificationSocket } from '@app/core' 5import { Notifier, User, PeerTubeSocket } from '@app/core'
6import { UserNotificationService } from '@app/shared/shared-main' 6import { UserNotificationService } from '@app/shared/shared-main'
7import { NgbPopover } from '@ng-bootstrap/ng-bootstrap' 7import { NgbPopover } from '@ng-bootstrap/ng-bootstrap'
8 8
@@ -27,7 +27,7 @@ export class AvatarNotificationComponent implements OnInit, OnDestroy {
27 27
28 constructor ( 28 constructor (
29 private userNotificationService: UserNotificationService, 29 private userNotificationService: UserNotificationService,
30 private userNotificationSocket: UserNotificationSocket, 30 private peertubeSocket: PeerTubeSocket,
31 private notifier: Notifier, 31 private notifier: Notifier,
32 private router: Router 32 private router: Router
33 ) { 33 ) {
@@ -75,7 +75,7 @@ export class AvatarNotificationComponent implements OnInit, OnDestroy {
75 } 75 }
76 76
77 private async subscribeToNotifications () { 77 private async subscribeToNotifications () {
78 const obs = await this.userNotificationSocket.getMyNotificationsSocket() 78 const obs = await this.peertubeSocket.getMyNotificationsSocket()
79 79
80 this.notificationSub = obs.subscribe(data => { 80 this.notificationSub = obs.subscribe(data => {
81 if (data.type === 'new') return this.unreadNotifications++ 81 if (data.type === 'new') return this.unreadNotifications++