X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=client%2Fsrc%2Fapp%2Fshared%2Fvideo-playlist%2Fvideo-playlist.service.ts;h=1ec9315efddb41de0e4bb4fd1a8cfb5870d81080;hb=119b16e5acffff1901f23c7a0188c78272453e7d;hp=d78fdc09f062e8aea90ef292cff3441adeabbe32;hpb=b7819090de8ced71e5f9c5773c575ab627a148e4;p=github%2FChocobozzz%2FPeerTube.git diff --git a/client/src/app/shared/video-playlist/video-playlist.service.ts b/client/src/app/shared/video-playlist/video-playlist.service.ts index d78fdc09f..1ec9315ef 100644 --- a/client/src/app/shared/video-playlist/video-playlist.service.ts +++ b/client/src/app/shared/video-playlist/video-playlist.service.ts @@ -1,6 +1,6 @@ -import { bufferTime, catchError, distinctUntilChanged, filter, first, map, share, switchMap } from 'rxjs/operators' +import { bufferTime, catchError, filter, map, share, switchMap, tap } from 'rxjs/operators' import { Injectable } from '@angular/core' -import { Observable, ReplaySubject, Subject } from 'rxjs' +import { merge, Observable, of, ReplaySubject, Subject } from 'rxjs' import { RestExtractor } from '../rest/rest-extractor.service' import { HttpClient, HttpParams } from '@angular/common/http' import { ResultList, VideoPlaylistElementCreate, VideoPlaylistElementUpdate } from '../../../../../shared' @@ -11,16 +11,22 @@ import { VideoChannel } from '@app/shared/video-channel/video-channel.model' import { VideoPlaylistCreate } from '@shared/models/videos/playlist/video-playlist-create.model' import { VideoPlaylistUpdate } from '@shared/models/videos/playlist/video-playlist-update.model' import { objectToFormData } from '@app/shared/misc/utils' -import { ServerService } from '@app/core' +import { AuthUser, ServerService } from '@app/core' import { VideoPlaylist } from '@app/shared/video-playlist/video-playlist.model' import { AccountService } from '@app/shared/account/account.service' import { Account } from '@app/shared/account/account.model' import { RestService } from '@app/shared/rest' -import { VideoExistInPlaylist } from '@shared/models/videos/playlist/video-exist-in-playlist.model' +import { VideoExistInPlaylist, VideosExistInPlaylists } from '@shared/models/videos/playlist/video-exist-in-playlist.model' import { VideoPlaylistReorder } from '@shared/models/videos/playlist/video-playlist-reorder.model' -import { ComponentPagination } from '@app/shared/rest/component-pagination.model' +import { ComponentPaginationLight } from '@app/shared/rest/component-pagination.model' import { VideoPlaylistElement as ServerVideoPlaylistElement } from '@shared/models/videos/playlist/video-playlist-element.model' import { VideoPlaylistElement } from '@app/shared/video-playlist/video-playlist-element.model' +import { uniq } from 'lodash-es' +import * as debug from 'debug' + +const logger = debug('peertube:playlists:VideoPlaylistService') + +export type CachedPlaylist = VideoPlaylist | { id: number, displayName: string } @Injectable() export class VideoPlaylistService { @@ -28,8 +34,15 @@ export class VideoPlaylistService { static MY_VIDEO_PLAYLIST_URL = environment.apiUrl + '/api/v1/users/me/video-playlists/' // Use a replay subject because we "next" a value before subscribing - private videoExistsInPlaylistSubject: Subject = new ReplaySubject(1) - private readonly videoExistsInPlaylistObservable: Observable + private videoExistsInPlaylistNotifier = new ReplaySubject(1) + private videoExistsInPlaylistCacheSubject = new Subject() + private readonly videoExistsInPlaylistObservable: Observable + + private videoExistsObservableCache: { [ id: number ]: Observable } = {} + private videoExistsCache: { [ id: number ]: VideoExistInPlaylist[] } = {} + + private myAccountPlaylistCache: ResultList = undefined + private myAccountPlaylistCacheSubject = new Subject>() constructor ( private authHttp: HttpClient, @@ -37,16 +50,20 @@ export class VideoPlaylistService { private restExtractor: RestExtractor, private restService: RestService ) { - this.videoExistsInPlaylistObservable = this.videoExistsInPlaylistSubject.pipe( - distinctUntilChanged(), - bufferTime(500), - filter(videoIds => videoIds.length !== 0), - switchMap(videoIds => this.doVideosExistInPlaylist(videoIds)), - share() + this.videoExistsInPlaylistObservable = merge( + this.videoExistsInPlaylistNotifier.pipe( + bufferTime(500), + filter(videoIds => videoIds.length !== 0), + map(videoIds => uniq(videoIds)), + switchMap(videoIds => this.doVideosExistInPlaylist(videoIds)), + share() + ), + + this.videoExistsInPlaylistCacheSubject ) } - listChannelPlaylists (videoChannel: VideoChannel, componentPagination: ComponentPagination): Observable> { + listChannelPlaylists (videoChannel: VideoChannel, componentPagination: ComponentPaginationLight): Observable> { const url = VideoChannelService.BASE_VIDEO_CHANNEL_URL + videoChannel.nameWithHost + '/video-playlists' const pagination = this.restService.componentPaginationToRestPagination(componentPagination) @@ -60,9 +77,20 @@ export class VideoPlaylistService { ) } + listMyPlaylistWithCache (user: AuthUser, search?: string) { + if (!search && this.myAccountPlaylistCache) return of(this.myAccountPlaylistCache) + + return this.listAccountPlaylists(user.account, undefined, '-updatedAt', search) + .pipe( + tap(result => { + if (!search) this.myAccountPlaylistCache = result + }) + ) + } + listAccountPlaylists ( account: Account, - componentPagination: ComponentPagination, + componentPagination: ComponentPaginationLight, sort: string, search?: string ): Observable> { @@ -97,6 +125,16 @@ export class VideoPlaylistService { return this.authHttp.post<{ videoPlaylist: { id: number } }>(VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL, data) .pipe( + tap(res => { + this.myAccountPlaylistCache.total++ + + this.myAccountPlaylistCache.data.push({ + id: res.videoPlaylist.id, + displayName: body.displayName + }) + + this.myAccountPlaylistCacheSubject.next(this.myAccountPlaylistCache) + }), catchError(err => this.restExtractor.handleError(err)) ) } @@ -107,6 +145,12 @@ export class VideoPlaylistService { return this.authHttp.put(VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL + videoPlaylist.id, data) .pipe( map(this.restExtractor.extractDataBool), + tap(() => { + const playlist = this.myAccountPlaylistCache.data.find(p => p.id === videoPlaylist.id) + playlist.displayName = body.displayName + + this.myAccountPlaylistCacheSubject.next(this.myAccountPlaylistCache) + }), catchError(err => this.restExtractor.handleError(err)) ) } @@ -115,6 +159,13 @@ export class VideoPlaylistService { return this.authHttp.delete(VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL + videoPlaylist.id) .pipe( map(this.restExtractor.extractDataBool), + tap(() => { + this.myAccountPlaylistCache.total-- + this.myAccountPlaylistCache.data = this.myAccountPlaylistCache.data + .filter(p => p.id !== videoPlaylist.id) + + this.myAccountPlaylistCacheSubject.next(this.myAccountPlaylistCache) + }), catchError(err => this.restExtractor.handleError(err)) ) } @@ -123,21 +174,49 @@ export class VideoPlaylistService { const url = VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL + playlistId + '/videos' return this.authHttp.post<{ videoPlaylistElement: { id: number } }>(url, body) - .pipe(catchError(err => this.restExtractor.handleError(err))) + .pipe( + tap(res => { + const existsResult = this.videoExistsCache[body.videoId] + existsResult.push({ + playlistId, + playlistElementId: res.videoPlaylistElement.id, + startTimestamp: body.startTimestamp, + stopTimestamp: body.stopTimestamp + }) + + this.runPlaylistCheck(body.videoId) + }), + catchError(err => this.restExtractor.handleError(err)) + ) } - updateVideoOfPlaylist (playlistId: number, playlistElementId: number, body: VideoPlaylistElementUpdate) { + updateVideoOfPlaylist (playlistId: number, playlistElementId: number, body: VideoPlaylistElementUpdate, videoId: number) { return this.authHttp.put(VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL + playlistId + '/videos/' + playlistElementId, body) .pipe( map(this.restExtractor.extractDataBool), + tap(() => { + const existsResult = this.videoExistsCache[videoId] + const elem = existsResult.find(e => e.playlistElementId === playlistElementId) + + elem.startTimestamp = body.startTimestamp + elem.stopTimestamp = body.stopTimestamp + + this.runPlaylistCheck(videoId) + }), catchError(err => this.restExtractor.handleError(err)) ) } - removeVideoFromPlaylist (playlistId: number, playlistElementId: number) { + removeVideoFromPlaylist (playlistId: number, playlistElementId: number, videoId?: number) { return this.authHttp.delete(VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL + playlistId + '/videos/' + playlistElementId) .pipe( map(this.restExtractor.extractDataBool), + tap(() => { + if (!videoId) return + + this.videoExistsCache[videoId] = this.videoExistsCache[videoId].filter(e => e.playlistElementId !== playlistElementId) + this.runPlaylistCheck(videoId) + }), catchError(err => this.restExtractor.handleError(err)) ) } @@ -157,7 +236,7 @@ export class VideoPlaylistService { getPlaylistVideos ( videoPlaylistId: number | string, - componentPagination: ComponentPagination + componentPagination: ComponentPaginationLight ): Observable> { const path = VideoPlaylistService.BASE_VIDEO_PLAYLIST_URL + videoPlaylistId + '/videos' const pagination = this.restService.componentPaginationToRestPagination(componentPagination) @@ -173,10 +252,37 @@ export class VideoPlaylistService { ) } - doesVideoExistInPlaylist (videoId: number) { - this.videoExistsInPlaylistSubject.next(videoId) + listenToMyAccountPlaylistsChange () { + return this.myAccountPlaylistCacheSubject.asObservable() + } + + listenToVideoPlaylistChange (videoId: number) { + if (this.videoExistsObservableCache[ videoId ]) { + return this.videoExistsObservableCache[ videoId ] + } + + const obs = this.videoExistsInPlaylistObservable + .pipe( + map(existsResult => existsResult[ videoId ]), + filter(r => !!r), + tap(result => this.videoExistsCache[ videoId ] = result) + ) + + this.videoExistsObservableCache[ videoId ] = obs + return obs + } + + runPlaylistCheck (videoId: number) { + logger('Running playlist check.') + + if (this.videoExistsCache[videoId]) { + logger('Found cache for %d.', videoId) + + return this.videoExistsInPlaylistCacheSubject.next({ [videoId]: this.videoExistsCache[videoId] }) + } - return this.videoExistsInPlaylistObservable.pipe(first()) + logger('Fetching from network for %d.', videoId) + return this.videoExistsInPlaylistNotifier.next(videoId) } extractPlaylists (result: ResultList) { @@ -218,7 +324,7 @@ export class VideoPlaylistService { ) } - private doVideosExistInPlaylist (videoIds: number[]): Observable { + private doVideosExistInPlaylist (videoIds: number[]): Observable { const url = VideoPlaylistService.MY_VIDEO_PLAYLIST_URL + 'videos-exist' let params = new HttpParams()