X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=client%2Fsrc%2Fapp%2F%2Bvideos%2F%2Bvideo-watch%2Fvideo-watch.component.ts;h=19ad97d42a2a4e6dbd32b7e8fcfd6dd78ef3b3fe;hb=6de076222aca7005371e01768171efdc62ed8018;hp=77405d1499909d605bb47e8ec012b664e312eb03;hpb=2539932e16129992a2c0889b4ff527c265a8e2c7;p=github%2FChocobozzz%2FPeerTube.git diff --git a/client/src/app/+videos/+video-watch/video-watch.component.ts b/client/src/app/+videos/+video-watch/video-watch.component.ts index 77405d149..19ad97d42 100644 --- a/client/src/app/+videos/+video-watch/video-watch.component.ts +++ b/client/src/app/+videos/+video-watch/video-watch.component.ts @@ -1,40 +1,42 @@ import { Hotkey, HotkeysService } from 'angular2-hotkeys' -import { forkJoin, Observable, Subscription } from 'rxjs' -import { catchError } from 'rxjs/operators' +import { forkJoin, map, Observable, of, Subscription, switchMap } from 'rxjs' +import { VideoJsPlayer } from 'video.js' import { PlatformLocation } from '@angular/common' -import { ChangeDetectorRef, Component, ElementRef, Inject, LOCALE_ID, NgZone, OnDestroy, OnInit, ViewChild } from '@angular/core' +import { Component, ElementRef, Inject, LOCALE_ID, NgZone, OnDestroy, OnInit, ViewChild } from '@angular/core' import { ActivatedRoute, Router } from '@angular/router' import { AuthService, AuthUser, ConfirmService, - MarkdownService, + MetaService, Notifier, PeerTubeSocket, + PluginService, RestExtractor, ScreenService, ServerService, + User, UserService } from '@app/core' import { HooksService } from '@app/core/plugins/hooks.service' -import { RedirectService } from '@app/core/routing/redirect.service' import { isXPercentInViewport, scrollToTop } from '@app/helpers' -import { Video, VideoCaptionService, VideoDetails, VideoService } from '@app/shared/shared-main' -import { VideoShareComponent } from '@app/shared/shared-share-modal' -import { SupportModalComponent } from '@app/shared/shared-support-modal' +import { Video, VideoCaptionService, VideoDetails, VideoFileTokenService, VideoService } from '@app/shared/shared-main' import { SubscribeButtonComponent } from '@app/shared/shared-user-subscription' -import { VideoActionsDisplayType, VideoDownloadComponent } from '@app/shared/shared-video-miniature' +import { LiveVideoService } from '@app/shared/shared-video-live' import { VideoPlaylist, VideoPlaylistService } from '@app/shared/shared-video-playlist' -import { MetaService } from '@ngx-meta/core' -import { peertubeLocalStorage } from '@root-helpers/peertube-web-storage' -import { HttpStatusCode } from '@shared/core-utils/miscs/http-error-codes' -import { ServerConfig, ServerErrorCode, UserVideoRateType, VideoCaption, VideoPrivacy, VideoState } from '@shared/models' +import { logger } from '@root-helpers/logger' +import { isP2PEnabled, videoRequiresAuth } from '@root-helpers/video' +import { timeToInt } from '@shared/core-utils' import { - cleanupVideoWatch, - getStoredP2PEnabled, - getStoredTheater, - getStoredVideoWatchHistory -} from '../../../assets/player/peertube-player-local-storage' + HTMLServerConfig, + HttpStatusCode, + LiveVideo, + PeerTubeProblemDocument, + ServerErrorCode, + VideoCaption, + VideoPrivacy, + VideoState +} from '@shared/models' import { CustomizationOptions, P2PMediaLoaderOptions, @@ -42,10 +44,10 @@ import { PeertubePlayerManagerOptions, PlayerMode, videojs -} from '../../../assets/player/peertube-player-manager' -import { isWebRTCDisabled, timeToInt } from '../../../assets/player/utils' +} from '../../../assets/player' +import { cleanupVideoWatch, getStoredTheater, getStoredVideoWatchHistory } from '../../../assets/player/peertube-player-local-storage' import { environment } from '../../../environments/environment' -import { VideoWatchPlaylistComponent } from './video-watch-playlist.component' +import { VideoWatchPlaylistComponent } from './shared' type URLOptions = CustomizationOptions & { playerMode: PlayerMode } @@ -55,76 +57,49 @@ type URLOptions = CustomizationOptions & { playerMode: PlayerMode } styleUrls: [ './video-watch.component.scss' ] }) export class VideoWatchComponent implements OnInit, OnDestroy { - private static LOCAL_STORAGE_PRIVACY_CONCERN_KEY = 'video-watch-privacy-concern' - @ViewChild('videoWatchPlaylist', { static: true }) videoWatchPlaylist: VideoWatchPlaylistComponent - @ViewChild('videoShareModal') videoShareModal: VideoShareComponent - @ViewChild('supportModal') supportModal: SupportModalComponent @ViewChild('subscribeButton') subscribeButton: SubscribeButtonComponent - @ViewChild('videoDownloadModal') videoDownloadModal: VideoDownloadComponent - player: any + player: VideoJsPlayer playerElement: HTMLVideoElement - - theaterEnabled = false - - userRating: UserVideoRateType = null - playerPlaceholderImgSrc: string + theaterEnabled = false video: VideoDetails = null videoCaptions: VideoCaption[] = [] + liveVideo: LiveVideo playlistPosition: number playlist: VideoPlaylist = null - descriptionLoading = false - completeDescriptionShown = false - completeVideoDescription: string - shortVideoDescription: string - videoHTMLDescription = '' - - likesBarTooltipText = '' - - hasAlreadyAcceptedPrivacyConcern = false remoteServerDown = false + noPlaylistVideoFound = false - hotkeys: Hotkey[] = [] - - tooltipLike = '' - tooltipDislike = '' - tooltipSupport = '' - tooltipSaveToPlaylist = '' + private nextVideoUUID = '' + private nextVideoTitle = '' - videoActionsOptions: VideoActionsDisplayType = { - playlist: false, - download: true, - update: true, - blacklist: true, - delete: true, - report: true, - duplicate: true, - mute: true, - liveInfo: true - } + private videoFileToken: string - private nextVideoUuid = '' - private nextVideoTitle = '' private currentTime: number + private paramsSub: Subscription private queryParamsSub: Subscription private configSub: Subscription private liveVideosSub: Subscription - private serverConfig: ServerConfig + private serverConfig: HTMLServerConfig + + private hotkeys: Hotkey[] = [] + + private static VIEW_VIDEO_INTERVAL_MS = 5000 constructor ( private elementRef: ElementRef, - private changeDetector: ChangeDetectorRef, private route: ActivatedRoute, private router: Router, private videoService: VideoService, private playlistService: VideoPlaylistService, + private liveVideoService: LiveVideoService, private confirmService: ConfirmService, private metaService: MetaService, private authService: AuthService, @@ -132,14 +107,14 @@ export class VideoWatchComponent implements OnInit, OnDestroy { private serverService: ServerService, private restExtractor: RestExtractor, private notifier: Notifier, - private markdownService: MarkdownService, private zone: NgZone, - private redirectService: RedirectService, private videoCaptionService: VideoCaptionService, private hotkeysService: HotkeysService, private hooks: HooksService, + private pluginService: PluginService, private peertubeSocket: PeerTubeSocket, private screenService: ScreenService, + private videoFileTokenService: VideoFileTokenService, private location: PlatformLocation, @Inject(LOCALE_ID) private localeId: string ) { } @@ -152,61 +127,13 @@ export class VideoWatchComponent implements OnInit, OnDestroy { return this.userService.getAnonymousUser() } - async ngOnInit () { - // Hide the tooltips for unlogged users in mobile view, this adds confusion with the popover - if (this.user || !this.screenService.isInMobileView()) { - this.tooltipLike = $localize`Like this video` - this.tooltipDislike = $localize`Dislike this video` - this.tooltipSupport = $localize`Support options for this video` - this.tooltipSaveToPlaylist = $localize`Save to playlist` - } + ngOnInit () { + this.serverConfig = this.serverService.getHTMLConfig() PeertubePlayerManager.initState() - this.serverConfig = this.serverService.getTmpConfig() - - this.configSub = this.serverService.getConfig() - .subscribe(config => { - this.serverConfig = config - - if ( - isWebRTCDisabled() || - this.serverConfig.tracker.enabled === false || - getStoredP2PEnabled() === false || - peertubeLocalStorage.getItem(VideoWatchComponent.LOCAL_STORAGE_PRIVACY_CONCERN_KEY) === 'true' - ) { - this.hasAlreadyAcceptedPrivacyConcern = true - } - }) - - this.paramsSub = this.route.params.subscribe(routeParams => { - const videoId = routeParams[ 'videoId' ] - if (videoId) this.loadVideo(videoId) - - const playlistId = routeParams[ 'playlistId' ] - if (playlistId) this.loadPlaylist(playlistId) - }) - - this.queryParamsSub = this.route.queryParams.subscribe(queryParams => { - // Handle the ?playlistPosition - const positionParam = queryParams[ 'playlistPosition' ] ?? 1 - - this.playlistPosition = positionParam === 'last' - ? -1 // Handle the "last" index - : parseInt(positionParam + '', 10) - - if (isNaN(this.playlistPosition)) { - console.error(`playlistPosition query param '${positionParam}' was parsed as NaN, defaulting to 1.`) - this.playlistPosition = 1 - } - - this.videoWatchPlaylist.updatePlaylistIndex(this.playlistPosition) - - const start = queryParams[ 'start' ] - if (this.player && start) this.player.currentTime(parseInt(start, 10)) - }) - - this.initHotkeys() + this.loadRouteParams() + this.loadRouteQuery() this.theaterEnabled = getStoredTheater() @@ -228,169 +155,46 @@ export class VideoWatchComponent implements OnInit, OnDestroy { this.hotkeysService.remove(this.hotkeys) } - setLike () { - if (this.isUserLoggedIn() === false) return - - // Already liked this video - if (this.userRating === 'like') this.setRating('none') - else this.setRating('like') - } - - setDislike () { - if (this.isUserLoggedIn() === false) return - - // Already disliked this video - if (this.userRating === 'dislike') this.setRating('none') - else this.setRating('dislike') - } - - getRatePopoverText () { - if (this.isUserLoggedIn()) return undefined - - return $localize`You need to be logged in to rate this video.` + getCurrentTime () { + return this.currentTime } - showMoreDescription () { - if (this.completeVideoDescription === undefined) { - return this.loadCompleteDescription() - } - - this.updateVideoDescription(this.completeVideoDescription) - this.completeDescriptionShown = true + getCurrentPlaylistPosition () { + return this.videoWatchPlaylist.currentPlaylistPosition } - showLessDescription () { - this.updateVideoDescription(this.shortVideoDescription) - this.completeDescriptionShown = false - } - - showDownloadModal () { - this.videoDownloadModal.show(this.video, this.videoCaptions) - } + onRecommendations (videos: Video[]) { + if (videos.length === 0) return - isVideoDownloadable () { - return this.video && this.video instanceof VideoDetails && this.video.downloadEnabled && !this.video.isLive + // The recommended videos's first element should be the next video + const video = videos[0] + this.nextVideoUUID = video.uuid + this.nextVideoTitle = video.name } - loadCompleteDescription () { - this.descriptionLoading = true - - this.videoService.loadCompleteDescription(this.video.descriptionPath) - .subscribe( - description => { - this.completeDescriptionShown = true - this.descriptionLoading = false - - this.shortVideoDescription = this.video.description - this.completeVideoDescription = description - - this.updateVideoDescription(this.completeVideoDescription) - }, + handleTimestampClicked (timestamp: number) { + if (!this.player || this.video.isLive) return - error => { - this.descriptionLoading = false - this.notifier.error(error.message) - } - ) + this.player.currentTime(timestamp) + scrollToTop() } - showSupportModal () { - this.supportModal.show() + onPlaylistVideoFound (videoId: string) { + this.loadVideo({ videoId, forceAutoplay: false }) } - showShareModal () { - this.videoShareModal.show(this.currentTime, this.videoWatchPlaylist.currentPlaylistPosition) + onPlaylistNoVideoFound () { + this.noPlaylistVideoFound = true } isUserLoggedIn () { return this.authService.isLoggedIn() } - getVideoUrl () { - if (!this.video.url) { - return this.video.originInstanceUrl + VideoDetails.buildClientUrl(this.video.uuid) - } - return this.video.url - } - - getVideoTags () { - if (!this.video || Array.isArray(this.video.tags) === false) return [] - - return this.video.tags - } - - onRecommendations (videos: Video[]) { - if (videos.length > 0) { - // The recommended videos's first element should be the next video - const video = videos[0] - this.nextVideoUuid = video.uuid - this.nextVideoTitle = video.name - } - } - - onVideoRemoved () { - this.redirectService.redirectToHomepage() - } - - declinedPrivacyConcern () { - peertubeLocalStorage.setItem(VideoWatchComponent.LOCAL_STORAGE_PRIVACY_CONCERN_KEY, 'false') - this.hasAlreadyAcceptedPrivacyConcern = false - } - - acceptedPrivacyConcern () { - peertubeLocalStorage.setItem(VideoWatchComponent.LOCAL_STORAGE_PRIVACY_CONCERN_KEY, 'true') - this.hasAlreadyAcceptedPrivacyConcern = true - } - - isVideoToTranscode () { - return this.video && this.video.state.id === VideoState.TO_TRANSCODE - } - - isVideoToImport () { - return this.video && this.video.state.id === VideoState.TO_IMPORT - } - - hasVideoScheduledPublication () { - return this.video && this.video.scheduledUpdate !== undefined - } - - isLive () { - return !!(this.video?.isLive) - } - - isWaitingForLive () { - return this.video?.state.id === VideoState.WAITING_FOR_LIVE - } - - isLiveEnded () { - return this.video?.state.id === VideoState.LIVE_ENDED - } - isVideoBlur (video: Video) { return video.isVideoNSFWForUser(this.user, this.serverConfig) } - isAutoPlayEnabled () { - return ( - (this.user && this.user.autoPlayNextVideo) || - this.anonymousUser.autoPlayNextVideo - ) - } - - handleTimestampClicked (timestamp: number) { - if (!this.player || this.video.isLive) return - - this.player.currentTime(timestamp) - scrollToTop() - } - - isPlaylistAutoPlayEnabled () { - return ( - (this.user && this.user.autoPlayNextVideoPlaylist) || - this.anonymousUser.autoPlayNextVideoPlaylist - ) - } - isChannelDisplayNameGeneric () { const genericChannelDisplayName = [ `Main ${this.video.channel.ownerAccount.name} channel`, @@ -400,21 +204,54 @@ export class VideoWatchComponent implements OnInit, OnDestroy { return genericChannelDisplayName.includes(this.video.channel.displayName) } - onPlaylistVideoFound (videoId: string) { - this.loadVideo(videoId) - } - displayOtherVideosAsRow () { // Use the same value as in the SASS file return this.screenService.getWindowInnerWidth() <= 1100 } - private loadVideo (videoId: string) { - // Video did not change - if (this.video && this.video.uuid === videoId) return + private loadRouteParams () { + this.paramsSub = this.route.params.subscribe(routeParams => { + const videoId = routeParams['videoId'] + if (videoId) return this.loadVideo({ videoId, forceAutoplay: false }) + + const playlistId = routeParams['playlistId'] + if (playlistId) return this.loadPlaylist(playlistId) + }) + } + + private loadRouteQuery () { + this.queryParamsSub = this.route.queryParams.subscribe(queryParams => { + // Handle the ?playlistPosition + const positionParam = queryParams['playlistPosition'] ?? 1 + + this.playlistPosition = positionParam === 'last' + ? -1 // Handle the "last" index + : parseInt(positionParam + '', 10) + + if (isNaN(this.playlistPosition)) { + logger.error(`playlistPosition query param '${positionParam}' was parsed as NaN, defaulting to 1.`) + this.playlistPosition = 1 + } + + this.videoWatchPlaylist.updatePlaylistIndex(this.playlistPosition) + + const start = queryParams['start'] + if (this.player && start) this.player.currentTime(parseInt(start, 10)) + }) + } + + private loadVideo (options: { + videoId: string + forceAutoplay: boolean + }) { + const { videoId, forceAutoplay } = options + + if (this.isSameElement(this.video, videoId)) return if (this.player) this.player.pause() + this.video = undefined + const videoObs = this.hooks.wrapObsFun( this.videoService.getVideo.bind(this.videoService), { videoId }, @@ -423,43 +260,28 @@ export class VideoWatchComponent implements OnInit, OnDestroy { 'filter:api.video-watch.video.get.result' ) - // Video did change - forkJoin([ - videoObs, - this.videoCaptionService.listCaptions(videoId) - ]) - .pipe( - // If 400, 403 or 404, the video is private or blocked so redirect to 404 - catchError(err => { - if (err.body.errorCode === ServerErrorCode.DOES_NOT_RESPECT_FOLLOW_CONSTRAINTS && err.body.originUrl) { - const search = window.location.search - let originUrl = err.body.originUrl - if (search) originUrl += search - - this.confirmService.confirm( - $localize`This video is not available on this instance. Do you want to be redirected on the origin instance: ${originUrl}?`, - $localize`Redirection` - ).then(res => { - if (res === false) { - return this.restExtractor.redirectTo404IfNotFound(err, 'video', [ - HttpStatusCode.BAD_REQUEST_400, - HttpStatusCode.FORBIDDEN_403, - HttpStatusCode.NOT_FOUND_404 - ]) - } - - return window.location.href = originUrl - }) - } + const videoAndLiveObs: Observable<{ video: VideoDetails, live?: LiveVideo, videoFileToken?: string }> = videoObs.pipe( + switchMap(video => { + if (!video.isLive) return of({ video, live: undefined }) - return this.restExtractor.redirectTo404IfNotFound(err, 'video', [ - HttpStatusCode.BAD_REQUEST_400, - HttpStatusCode.FORBIDDEN_403, - HttpStatusCode.NOT_FOUND_404 - ]) - }) - ) - .subscribe(([ video, captionsResult ]) => { + return this.liveVideoService.getVideoLive(video.uuid) + .pipe(map(live => ({ live, video }))) + }), + + switchMap(({ video, live }) => { + if (!videoRequiresAuth(video)) return of({ video, live, videoFileToken: undefined }) + + return this.videoFileTokenService.getVideoFileToken(video.uuid) + .pipe(map(({ token }) => ({ video, live, videoFileToken: token }))) + }) + ) + + forkJoin([ + videoAndLiveObs, + this.videoCaptionService.listCaptions(videoId), + this.userService.getAnonymousOrLoggedUser() + ]).subscribe({ + next: ([ { video, live, videoFileToken }, captionsResult, loggedInOrAnonymousUser ]) => { const queryParams = this.route.snapshot.queryParams const urlOptions = { @@ -473,58 +295,79 @@ export class VideoWatchComponent implements OnInit, OnDestroy { subtitle: queryParams.subtitle, playerMode: queryParams.mode, + playbackRate: queryParams.playbackRate, peertubeLink: false } - this.onVideoFetched(video, captionsResult.data, urlOptions) - .catch(err => this.handleError(err)) - }) + this.onVideoFetched({ + video, + live, + videoCaptions: captionsResult.data, + videoFileToken, + loggedInOrAnonymousUser, + urlOptions, + forceAutoplay + }).catch(err => this.handleGlobalError(err)) + }, + + error: err => this.handleRequestError(err) + }) } private loadPlaylist (playlistId: string) { - // Playlist did not change - if (this.playlist && this.playlist.uuid === playlistId) return + if (this.isSameElement(this.playlist, playlistId)) return + + this.noPlaylistVideoFound = false this.playlistService.getVideoPlaylist(playlistId) - .pipe( - // If 400 or 403, the video is private or blocked so redirect to 404 - catchError(err => this.restExtractor.redirectTo404IfNotFound(err, 'video', [ - HttpStatusCode.BAD_REQUEST_400, - HttpStatusCode.FORBIDDEN_403, - HttpStatusCode.NOT_FOUND_404 - ])) - ) - .subscribe(playlist => { - this.playlist = playlist + .subscribe({ + next: playlist => { + this.playlist = playlist - this.videoWatchPlaylist.loadPlaylistElements(playlist, !this.playlistPosition, this.playlistPosition) + this.videoWatchPlaylist.loadPlaylistElements(playlist, !this.playlistPosition, this.playlistPosition) + }, + + error: err => this.handleRequestError(err) }) } - private updateVideoDescription (description: string) { - this.video.description = description - this.setVideoDescriptionHTML() - .catch(err => console.error(err)) - } + private isSameElement (element: VideoDetails | VideoPlaylist, newId: string) { + if (!element) return false - private async setVideoDescriptionHTML () { - const html = await this.markdownService.textMarkdownToHTML(this.video.description) - this.videoHTMLDescription = this.markdownService.processVideoTimestamps(html) + return (element.id + '') === newId || element.uuid === newId || element.shortUUID === newId } - private setVideoLikesBarTooltipText () { - this.likesBarTooltipText = `${this.video.likes} likes / ${this.video.dislikes} dislikes` + private async handleRequestError (err: any) { + const errorBody = err.body as PeerTubeProblemDocument + + if (errorBody?.code === ServerErrorCode.DOES_NOT_RESPECT_FOLLOW_CONSTRAINTS && errorBody.originUrl) { + const originUrl = errorBody.originUrl + (window.location.search ?? '') + + const res = await this.confirmService.confirm( + // eslint-disable-next-line max-len + $localize`This video is not available on this instance. Do you want to be redirected on the origin instance: ${originUrl}?`, + $localize`Redirection` + ) + + if (res === true) return window.location.href = originUrl + } + + // If 400, 403 or 404, the video is private or blocked so redirect to 404 + return this.restExtractor.redirectTo404IfNotFound(err, 'video', [ + HttpStatusCode.BAD_REQUEST_400, + HttpStatusCode.FORBIDDEN_403, + HttpStatusCode.NOT_FOUND_404 + ]) } - private handleError (err: any) { + private handleGlobalError (err: any) { const errorMessage: string = typeof err === 'string' ? err : err.message if (!errorMessage) return // Display a message in the video player instead of a notification - if (errorMessage.indexOf('from xs param') !== -1) { + if (errorMessage.includes('from xs param')) { this.flushPlayer() this.remoteServerDown = true - this.changeDetector.detectChanges() return } @@ -532,37 +375,27 @@ export class VideoWatchComponent implements OnInit, OnDestroy { this.notifier.error(errorMessage) } - private checkUserRating () { - // Unlogged users do not have ratings - if (this.isUserLoggedIn() === false) return - - this.videoService.getUserVideoRating(this.video.id) - .subscribe( - ratingObject => { - if (ratingObject) { - this.userRating = ratingObject.rating - } - }, - - err => this.notifier.error(err.message) - ) - } + private async onVideoFetched (options: { + video: VideoDetails + live: LiveVideo + videoCaptions: VideoCaption[] + videoFileToken: string - private async onVideoFetched ( - video: VideoDetails, - videoCaptions: VideoCaption[], urlOptions: URLOptions - ) { + loggedInOrAnonymousUser: User + forceAutoplay: boolean + }) { + const { video, live, videoCaptions, urlOptions, videoFileToken, loggedInOrAnonymousUser, forceAutoplay } = options + this.subscribeToLiveEventsIfNeeded(this.video, video) this.video = video this.videoCaptions = videoCaptions + this.liveVideo = live + this.videoFileToken = videoFileToken // Re init attributes this.playerPlaceholderImgSrc = undefined - this.descriptionLoading = false - this.completeDescriptionShown = false - this.completeVideoDescription = undefined this.remoteServerDown = false this.currentTime = undefined @@ -574,14 +407,12 @@ export class VideoWatchComponent implements OnInit, OnDestroy { if (res === false) return this.location.back() } - this.buildPlayer(urlOptions) - .catch(err => console.error('Cannot build the player', err)) + this.buildHotkeysHelp(video) - this.setVideoDescriptionHTML() - this.setVideoLikesBarTooltipText() + this.buildPlayer({ urlOptions, loggedInOrAnonymousUser, forceAutoplay }) + .catch(err => logger.error('Cannot build the player', err)) this.setOpenGraphTags() - this.checkUserRating() const hookOptions = { videojs, @@ -591,7 +422,13 @@ export class VideoWatchComponent implements OnInit, OnDestroy { this.hooks.runAction('action:video-watch.video.loaded', 'video-watch', hookOptions) } - private async buildPlayer (urlOptions: URLOptions) { + private async buildPlayer (options: { + urlOptions: URLOptions + loggedInOrAnonymousUser: User + forceAutoplay: boolean + }) { + const { urlOptions, loggedInOrAnonymousUser, forceAutoplay } = options + // Flush old player if needed this.flushPlayer() @@ -611,7 +448,11 @@ export class VideoWatchComponent implements OnInit, OnDestroy { const params = { video: this.video, videoCaptions: this.videoCaptions, + liveVideo: this.liveVideo, + videoFileToken: this.videoFileToken, urlOptions, + loggedInOrAnonymousUser, + forceAutoplay, user: this.user } const { playerMode, playerOptions } = await this.hooks.wrapFun( @@ -625,50 +466,55 @@ export class VideoWatchComponent implements OnInit, OnDestroy { this.zone.runOutsideAngular(async () => { this.player = await PeertubePlayerManager.initialize(playerMode, playerOptions, player => this.player = player) - this.player.on('customError', ({ err }: { err: any }) => this.handleError(err)) + this.player.on('customError', (_e, data: any) => { + this.zone.run(() => this.handleGlobalError(data.err)) + }) this.player.on('timeupdate', () => { + // Don't need to trigger angular change for this variable, that is sent to children components on click this.currentTime = Math.floor(this.player.currentTime()) }) /** - * replaces this.player.one('ended') - * 'condition()': true to make the upnext functionality trigger, - * false to disable the upnext functionality - * go to the next video in 'condition()' if you don't want of the timer. - * 'next': function triggered at the end of the timer. - * 'suspended': function used at each clic of the timer checking if we need - * to reset progress and wait until 'suspended' becomes truthy again. + * condition: true to make the upnext functionality trigger, false to disable the upnext functionality + * go to the next video in 'condition()' if you don't want of the timer. + * next: function triggered at the end of the timer. + * suspended: function used at each click of the timer checking if we need to reset progress + * and wait until suspended becomes truthy again. */ this.player.upnext({ - timeout: 10000, // 10s + timeout: 5000, // 5s + headText: $localize`Up Next`, cancelText: $localize`Cancel`, suspendedText: $localize`Autoplay is suspended`, + getTitle: () => this.nextVideoTitle, - next: () => this.zone.run(() => this.autoplayNext()), + + next: () => this.zone.run(() => this.playNextVideoInAngularZone()), condition: () => { - if (this.playlist) { - if (this.isPlaylistAutoPlayEnabled()) { - // upnext will not trigger, and instead the next video will play immediately - this.zone.run(() => this.videoWatchPlaylist.navigateToNextPlaylistVideo()) - } - } else if (this.isAutoPlayEnabled()) { - return true // upnext will trigger + if (!this.playlist) return this.isAutoPlayNext() + + // Don't wait timeout to play the next playlist video + if (this.isPlaylistAutoPlayNext()) { + this.playNextVideoInAngularZone() + return undefined } - return false // upnext will not trigger, and instead leave the video stopping + + return false }, + suspended: () => { return ( - !isXPercentInViewport(this.player.el(), 80) || + !isXPercentInViewport(this.player.el() as HTMLElement, 80) || !document.getElementById('content').contains(document.activeElement) ) } }) this.player.one('stopped', () => { - if (this.playlist) { - if (this.isPlaylistAutoPlayEnabled()) this.zone.run(() => this.videoWatchPlaylist.navigateToNextPlaylistVideo()) + if (this.playlist && this.isPlaylistAutoPlayNext()) { + this.playNextVideoInAngularZone() } }) @@ -682,75 +528,33 @@ export class VideoWatchComponent implements OnInit, OnDestroy { this.zone.run(() => this.theaterEnabled = enabled) }) - this.hooks.runAction('action:video-watch.player.loaded', 'video-watch', { player: this.player, videojs, video: this.video }) + this.hooks.runAction('action:video-watch.player.loaded', 'video-watch', { + player: this.player, + playlist: this.playlist, + playlistPosition: this.playlistPosition, + videojs, + video: this.video + }) }) } - private autoplayNext () { + private hasNextVideo () { if (this.playlist) { - this.zone.run(() => this.videoWatchPlaylist.navigateToNextPlaylistVideo()) - } else if (this.nextVideoUuid) { - this.router.navigate([ '/videos/watch', this.nextVideoUuid ]) - } - } - - private setRating (nextRating: UserVideoRateType) { - const ratingMethods: { [id in UserVideoRateType]: (id: number) => Observable } = { - like: this.videoService.setVideoLike, - dislike: this.videoService.setVideoDislike, - none: this.videoService.unsetVideoLike + return this.videoWatchPlaylist.hasNextVideo() } - ratingMethods[nextRating].call(this.videoService, this.video.id) - .subscribe( - () => { - // Update the video like attribute - this.updateVideoRating(this.userRating, nextRating) - this.userRating = nextRating - }, - - (err: { message: string }) => this.notifier.error(err.message) - ) + return true } - private updateVideoRating (oldRating: UserVideoRateType, newRating: UserVideoRateType) { - let likesToIncrement = 0 - let dislikesToIncrement = 0 - - if (oldRating) { - if (oldRating === 'like') likesToIncrement-- - if (oldRating === 'dislike') dislikesToIncrement-- + private playNextVideoInAngularZone () { + if (this.playlist) { + this.zone.run(() => this.videoWatchPlaylist.navigateToNextPlaylistVideo()) + return } - if (newRating === 'like') likesToIncrement++ - if (newRating === 'dislike') dislikesToIncrement++ - - this.video.likes += likesToIncrement - this.video.dislikes += dislikesToIncrement - - this.video.buildLikeAndDislikePercents() - this.setVideoLikesBarTooltipText() - } - - private setOpenGraphTags () { - this.metaService.setTitle(this.video.name) - - this.metaService.setTag('og:type', 'video') - - this.metaService.setTag('og:title', this.video.name) - this.metaService.setTag('name', this.video.name) - - this.metaService.setTag('og:description', this.video.description) - this.metaService.setTag('description', this.video.description) - - this.metaService.setTag('og:image', this.video.previewPath) - - this.metaService.setTag('og:duration', this.video.duration.toString()) - - this.metaService.setTag('og:site_name', 'PeerTube') - - this.metaService.setTag('og:url', window.location.href) - this.metaService.setTag('url', window.location.href) + if (this.nextVideoUUID) { + this.router.navigate([ '/w', this.nextVideoUUID ]) + } } private isAutoplay () { @@ -764,41 +568,65 @@ export class VideoWatchComponent implements OnInit, OnDestroy { return this.user.autoPlayVideo !== false } + private isAutoPlayNext () { + return ( + (this.user?.autoPlayNextVideo) || + this.anonymousUser.autoPlayNextVideo + ) + } + + private isPlaylistAutoPlayNext () { + return ( + (this.user?.autoPlayNextVideoPlaylist) || + this.anonymousUser.autoPlayNextVideoPlaylist + ) + } + private flushPlayer () { // Remove player if it exists - if (this.player) { - try { - this.player.dispose() - this.player = undefined - } catch (err) { - console.error('Cannot dispose player.', err) - } + if (!this.player) return + + try { + this.player.dispose() + this.player = undefined + } catch (err) { + logger.error('Cannot dispose player.', err) } } private buildPlayerManagerOptions (params: { - video: VideoDetails, - videoCaptions: VideoCaption[], - urlOptions: CustomizationOptions & { playerMode: PlayerMode }, - user?: AuthUser + video: VideoDetails + liveVideo: LiveVideo + videoCaptions: VideoCaption[] + + videoFileToken: string + + urlOptions: CustomizationOptions & { playerMode: PlayerMode } + + loggedInOrAnonymousUser: User + forceAutoplay: boolean + user?: AuthUser // Keep for plugins }) { - const { video, videoCaptions, urlOptions, user } = params + const { video, liveVideo, videoCaptions, videoFileToken, urlOptions, loggedInOrAnonymousUser, forceAutoplay } = params + const getStartTime = () => { const byUrl = urlOptions.startTime !== undefined const byHistory = video.userHistory && (!this.playlist || urlOptions.resume !== undefined) const byLocalStorage = getStoredVideoWatchHistory(video.uuid) if (byUrl) return timeToInt(urlOptions.startTime) - if (byHistory) return video.userHistory.currentTime - if (byLocalStorage) return byLocalStorage.duration - return 0 - } + let startTime = 0 + if (byHistory) startTime = video.userHistory.currentTime + if (byLocalStorage) startTime = byLocalStorage.duration + + // If we are at the end of the video, reset the timer + if (video.duration - startTime <= 1) startTime = 0 - let startTime = getStartTime() + return startTime + } - // If we are at the end of the video, reset the timer - if (video.duration - startTime <= 1) startTime = 0 + const startTime = getStartTime() const playerCaptions = videoCaptions.map(c => ({ label: c.language.label, @@ -806,10 +634,18 @@ export class VideoWatchComponent implements OnInit, OnDestroy { src: environment.apiUrl + c.captionPath })) + const liveOptions = video.isLive + ? { latencyMode: liveVideo.latencyMode } + : undefined + const options: PeertubePlayerManagerOptions = { common: { autoplay: this.isAutoplay(), - nextVideo: () => this.zone.run(() => this.autoplayNext()), + forceAutoplay, + p2pEnabled: isP2PEnabled(video, this.serverConfig, loggedInOrAnonymousUser.p2pEnabled), + + hasNextVideo: () => this.hasNextVideo(), + nextVideo: () => this.playNextVideoInAngularZone(), playerElement: this.playerElement, onPlayerElementChange: (element: HTMLVideoElement) => this.playerElement = element, @@ -821,45 +657,59 @@ export class VideoWatchComponent implements OnInit, OnDestroy { startTime, stopTime: urlOptions.stopTime, + controlBar: urlOptions.controlBar, controls: urlOptions.controls, muted: urlOptions.muted, loop: urlOptions.loop, subtitle: urlOptions.subtitle, + playbackRate: urlOptions.playbackRate, peertubeLink: urlOptions.peertubeLink, theaterButton: true, captions: videoCaptions.length !== 0, - videoViewUrl: video.privacy.id !== VideoPrivacy.PRIVATE - ? this.videoService.getVideoViewUrl(video.uuid) - : null, embedUrl: video.embedUrl, embedTitle: video.name, + instanceName: this.serverConfig.instance.name, isLive: video.isLive, + liveOptions, language: this.localeId, - userWatching: user && user.videosHistoryEnabled === true ? { - url: this.videoService.getUserWatchingVideoUrl(video.uuid), - authorizationHeader: this.authService.getRequestHeaderValue() - } : undefined, + metricsUrl: environment.apiUrl + '/api/v1/metrics/playback', + + videoViewUrl: video.privacy.id !== VideoPrivacy.PRIVATE + ? this.videoService.getVideoViewUrl(video.uuid) + : null, + videoViewIntervalMs: VideoWatchComponent.VIEW_VIDEO_INTERVAL_MS, + authorizationHeader: () => this.authService.getRequestHeaderValue(), + + serverUrl: environment.originServerUrl || window.location.origin, - serverUrl: environment.apiUrl, + videoFileToken: () => videoFileToken, + requiresAuth: videoRequiresAuth(video), videoCaptions: playerCaptions, - videoUUID: video.uuid + videoShortUUID: video.shortUUID, + videoUUID: video.uuid, + + errorNotifier: (message: string) => this.notifier.error(message) }, webtorrent: { videoFiles: video.files - } + }, + + pluginsManager: this.pluginService.getPluginsManager() } // Only set this if we're in a playlist if (this.playlist) { + options.common.hasPreviousVideo = () => this.videoWatchPlaylist.hasPreviousVideo() + options.common.previousVideo = () => { this.zone.run(() => this.videoWatchPlaylist.navigateToPreviousPlaylistVideo()) } @@ -875,7 +725,7 @@ export class VideoWatchComponent implements OnInit, OnDestroy { else mode = 'webtorrent' } - // p2p-media-loader needs TextEncoder, try to fallback on WebTorrent + // p2p-media-loader needs TextEncoder, fallback on WebTorrent if not available if (typeof TextEncoder === 'undefined') { mode = 'webtorrent' } @@ -903,7 +753,7 @@ export class VideoWatchComponent implements OnInit, OnDestroy { } if (oldVideo && oldVideo.id !== newVideo.id) { - await this.peertubeSocket.unsubscribeLiveVideos(oldVideo.id) + this.peertubeSocket.unsubscribeLiveVideos(oldVideo.id) } if (!newVideo.isLive) return @@ -915,71 +765,76 @@ export class VideoWatchComponent implements OnInit, OnDestroy { return this.peertubeSocket.getLiveVideosObservable() .subscribe(({ type, payload }) => { if (type === 'state-change') return this.handleLiveStateChange(payload.state) - if (type === 'views-change') return this.handleLiveViewsChange(payload.views) + if (type === 'views-change') return this.handleLiveViewsChange(payload.viewers) }) } private handleLiveStateChange (newState: VideoState) { if (newState !== VideoState.PUBLISHED) return - const videoState = this.video.state.id - if (videoState !== VideoState.WAITING_FOR_LIVE && videoState !== VideoState.LIVE_ENDED) return - - console.log('Loading video after live update.') + logger.info('Loading video after live update.') const videoUUID = this.video.uuid - // Reset to refetch the video + // Reset to force refresh the video this.video = undefined - this.loadVideo(videoUUID) + this.loadVideo({ videoId: videoUUID, forceAutoplay: true }) } - private handleLiveViewsChange (newViews: number) { + private handleLiveViewsChange (newViewers: number) { if (!this.video) { - console.error('Cannot update video live views because video is no defined.') + logger.error('Cannot update video live views because video is no defined.') return } - console.log('Updating live views.') + logger.info('Updating live views.') - this.video.views = newViews + this.video.viewers = newViewers } - private initHotkeys () { + private buildHotkeysHelp (video: Video) { + if (this.hotkeys.length !== 0) { + this.hotkeysService.remove(this.hotkeys) + } + this.hotkeys = [ // These hotkeys are managed by the player - new Hotkey('f', e => e, undefined, $localize`Enter/exit fullscreen (requires player focus)`), - new Hotkey('space', e => e, undefined, $localize`Play/Pause the video (requires player focus)`), - new Hotkey('m', e => e, undefined, $localize`Mute/unmute the video (requires player focus)`), + new Hotkey('f', e => e, undefined, $localize`Enter/exit fullscreen`), + new Hotkey('space', e => e, undefined, $localize`Play/Pause the video`), + new Hotkey('m', e => e, undefined, $localize`Mute/unmute the video`), - new Hotkey('0-9', e => e, undefined, $localize`Skip to a percentage of the video: 0 is 0% and 9 is 90% (requires player focus)`), + new Hotkey('up', e => e, undefined, $localize`Increase the volume`), + new Hotkey('down', e => e, undefined, $localize`Decrease the volume`), - new Hotkey('up', e => e, undefined, $localize`Increase the volume (requires player focus)`), - new Hotkey('down', e => e, undefined, $localize`Decrease the volume (requires player focus)`), + new Hotkey('t', e => { + this.theaterEnabled = !this.theaterEnabled + return false + }, undefined, $localize`Toggle theater mode`) + ] - new Hotkey('right', e => e, undefined, $localize`Seek the video forward (requires player focus)`), - new Hotkey('left', e => e, undefined, $localize`Seek the video backward (requires player focus)`), + if (!video.isLive) { + this.hotkeys = this.hotkeys.concat([ + // These hotkeys are also managed by the player but only for VOD - new Hotkey('>', e => e, undefined, $localize`Increase playback rate (requires player focus)`), - new Hotkey('<', e => e, undefined, $localize`Decrease playback rate (requires player focus)`), + new Hotkey('0-9', e => e, undefined, $localize`Skip to a percentage of the video: 0 is 0% and 9 is 90%`), - new Hotkey('.', e => e, undefined, $localize`Navigate in the video frame by frame (requires player focus)`) - ] + new Hotkey('right', e => e, undefined, $localize`Seek the video forward`), + new Hotkey('left', e => e, undefined, $localize`Seek the video backward`), - if (this.isUserLoggedIn()) { - this.hotkeys = this.hotkeys.concat([ - new Hotkey('shift+l', () => { - this.setLike() - return false - }, undefined, $localize`Like the video`), + new Hotkey('>', e => e, undefined, $localize`Increase playback rate`), + new Hotkey('<', e => e, undefined, $localize`Decrease playback rate`), - new Hotkey('shift+d', () => { - this.setDislike() - return false - }, undefined, $localize`Dislike the video`), + new Hotkey(',', e => e, undefined, $localize`Navigate in the video to the previous frame`), + new Hotkey('.', e => e, undefined, $localize`Navigate in the video to the next frame`) + ]) + } + if (this.isUserLoggedIn()) { + this.hotkeys = this.hotkeys.concat([ new Hotkey('shift+s', () => { - this.subscribeButton.subscribed ? this.subscribeButton.unsubscribe() : this.subscribeButton.subscribe() + if (this.subscribeButton.isSubscribedToAll()) this.subscribeButton.unsubscribe() + else this.subscribeButton.subscribe() + return false }, undefined, $localize`Subscribe to the account`) ]) @@ -987,4 +842,25 @@ export class VideoWatchComponent implements OnInit, OnDestroy { this.hotkeysService.add(this.hotkeys) } + + private setOpenGraphTags () { + this.metaService.setTitle(this.video.name) + + this.metaService.setTag('og:type', 'video') + + this.metaService.setTag('og:title', this.video.name) + this.metaService.setTag('name', this.video.name) + + this.metaService.setTag('og:description', this.video.description) + this.metaService.setTag('description', this.video.description) + + this.metaService.setTag('og:image', this.video.previewPath) + + this.metaService.setTag('og:duration', this.video.duration.toString()) + + this.metaService.setTag('og:site_name', 'PeerTube') + + this.metaService.setTag('og:url', window.location.href) + this.metaService.setTag('url', window.location.href) + } }