X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=client%2Fsrc%2Fapp%2Fmenu%2Favatar-notification.component.ts;h=9a64faa6adf90c8a53c83dd4f59f40142ebdc3af;hb=67ed6552b831df66713bac9e672738796128d33f;hp=38dbb935b5568a09d088e54138e37d637f1d5c86;hpb=f36da21e40104a50acb00132920b835240cebb38;p=github%2FChocobozzz%2FPeerTube.git diff --git a/client/src/app/menu/avatar-notification.component.ts b/client/src/app/menu/avatar-notification.component.ts index 38dbb935b..9a64faa6a 100644 --- a/client/src/app/menu/avatar-notification.component.ts +++ b/client/src/app/menu/avatar-notification.component.ts @@ -1,11 +1,10 @@ +import { Subject, Subscription } from 'rxjs' +import { filter } from 'rxjs/operators' import { Component, Input, OnDestroy, OnInit, ViewChild } from '@angular/core' -import { User } from '../shared/users/user.model' -import { UserNotificationService } from '@app/shared/users/user-notification.service' -import { Subscription } from 'rxjs' -import { Notifier, UserNotificationSocket } from '@app/core' -import { NgbPopover } from '@ng-bootstrap/ng-bootstrap' import { NavigationEnd, Router } from '@angular/router' -import { filter } from 'rxjs/operators' +import { Notifier, User, UserNotificationSocket } from '@app/core' +import { UserNotificationService } from '@app/shared/shared-main' +import { NgbPopover } from '@ng-bootstrap/ng-bootstrap' @Component({ selector: 'my-avatar-notification', @@ -14,11 +13,14 @@ import { filter } from 'rxjs/operators' }) export class AvatarNotificationComponent implements OnInit, OnDestroy { @ViewChild('popover', { static: true }) popover: NgbPopover + @Input() user: User unreadNotifications = 0 loaded = false + markAllAsReadSubject = new Subject() + private notificationSub: Subscription private routeSub: Subscription @@ -63,6 +65,10 @@ export class AvatarNotificationComponent implements OnInit, OnDestroy { this.loaded = true } + markAllAsRead () { + this.markAllAsReadSubject.next(true) + } + private async subscribeToNotifications () { const obs = await this.userNotificationSocket.getMyNotificationsSocket()