X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=client%2Fsrc%2Fapp%2F%2Bvideos%2F%2Bvideo-edit%2Fvideo-add-components%2Fvideo-go-live.component.ts;h=ee7011b4c1a5d5bb3bb7f24692de41ba746424a3;hb=3eb7ee658db32d270553046eeb77afc679a71466;hp=870a70d3d6e8c8f9f897b55394530197e5afe306;hpb=a056ca4813c82f490dcd31ac97a64d6bf76d3dcc;p=github%2FChocobozzz%2FPeerTube.git diff --git a/client/src/app/+videos/+video-edit/video-add-components/video-go-live.component.ts b/client/src/app/+videos/+video-edit/video-add-components/video-go-live.component.ts index 870a70d3d..ee7011b4c 100644 --- a/client/src/app/+videos/+video-edit/video-add-components/video-go-live.component.ts +++ b/client/src/app/+videos/+video-edit/video-add-components/video-go-live.component.ts @@ -1,13 +1,14 @@ import { forkJoin } from 'rxjs' -import { Component, EventEmitter, OnInit, Output } from '@angular/core' +import { AfterViewInit, Component, EventEmitter, OnInit, Output } from '@angular/core' import { Router } from '@angular/router' -import { AuthService, CanComponentDeactivate, Notifier, ServerService } from '@app/core' +import { AuthService, CanComponentDeactivate, HooksService, Notifier, ServerService } from '@app/core' import { scrollToTop } from '@app/helpers' import { FormValidatorService } from '@app/shared/shared-forms' -import { LiveVideoService, VideoCaptionService, VideoEdit, VideoService } from '@app/shared/shared-main' +import { Video, VideoCaptionService, VideoEdit, VideoService } from '@app/shared/shared-main' +import { LiveVideoService } from '@app/shared/shared-video-live' import { LoadingBarService } from '@ngx-loading-bar/core' -import { LiveVideo, LiveVideoCreate, LiveVideoUpdate, ServerErrorCode, VideoPrivacy } from '@shared/models' +import { LiveVideo, LiveVideoCreate, LiveVideoUpdate, PeerTubeProblemDocument, ServerErrorCode } from '@shared/models' import { VideoSend } from './video-send' @Component({ @@ -18,18 +19,19 @@ import { VideoSend } from './video-send' './video-send.scss' ] }) -export class VideoGoLiveComponent extends VideoSend implements OnInit, CanComponentDeactivate { +export class VideoGoLiveComponent extends VideoSend implements OnInit, AfterViewInit, CanComponentDeactivate { @Output() firstStepDone = new EventEmitter() @Output() firstStepError = new EventEmitter() isInUpdateForm = false liveVideo: LiveVideo + videoId: number videoUUID: string - error: string + videoShortUUID: string - protected readonly DEFAULT_VIDEO_PRIVACY = VideoPrivacy.PUBLIC + error: string constructor ( protected formValidatorService: FormValidatorService, @@ -40,8 +42,9 @@ export class VideoGoLiveComponent extends VideoSend implements OnInit, CanCompon protected videoService: VideoService, protected videoCaptionService: VideoCaptionService, private liveVideoService: LiveVideoService, - private router: Router - ) { + private router: Router, + private hooks: HooksService + ) { super() } @@ -49,50 +52,62 @@ export class VideoGoLiveComponent extends VideoSend implements OnInit, CanCompon super.ngOnInit() } + ngAfterViewInit () { + this.hooks.runAction('action:go-live.init', 'video-edit') + } + canDeactivate () { return { canDeactivate: true } } goLive () { + const name = 'Live' + const video: LiveVideoCreate = { - name: 'Live', - privacy: VideoPrivacy.PRIVATE, + name, + privacy: this.highestPrivacy, nsfw: this.serverConfig.instance.isNSFW, waitTranscoding: true, commentsEnabled: true, downloadEnabled: true, + permanentLive: false, + saveReplay: false, channelId: this.firstStepChannelId } - this.firstStepDone.emit(name) - // Go live in private mode, but correctly fill the update form with the first user choice const toPatch = Object.assign({}, video, { privacy: this.firstStepPrivacyId }) this.form.patchValue(toPatch) - this.liveVideoService.goLive(video).subscribe( - res => { - this.videoId = res.video.id - this.videoUUID = res.video.uuid - this.isInUpdateForm = true + this.liveVideoService.goLive(video) + .subscribe({ + next: res => { + this.videoId = res.video.id + this.videoUUID = res.video.uuid + this.videoShortUUID = res.video.shortUUID + this.isInUpdateForm = true - this.fetchVideoLive() - }, + this.firstStepDone.emit(name) - err => { - this.firstStepError.emit() + this.fetchVideoLive() + }, - let message = err.message + error: err => { + this.firstStepError.emit() - if (err.body?.code === ServerErrorCode.MAX_INSTANCE_LIVES_LIMIT_REACHED) { - message = $localize`Cannot create live because this instance have too many created lives` - } else if (err.body?.code) { - message = $localize`Cannot create live because you created too many lives` - } + let message = err.message - this.notifier.error(message) - } - ) + const error = err.body as PeerTubeProblemDocument + + if (error?.code === ServerErrorCode.MAX_INSTANCE_LIVES_LIMIT_REACHED) { + message = $localize`Cannot create live because this instance have too many created lives` + } else if (error?.code === ServerErrorCode.MAX_USER_LIVES_LIMIT_REACHED) { + message = $localize`Cannot create live because you created too many lives` + } + + this.notifier.error(message) + } + }) } updateSecondStep () { @@ -104,9 +119,11 @@ export class VideoGoLiveComponent extends VideoSend implements OnInit, CanCompon video.patch(this.form.value) video.id = this.videoId video.uuid = this.videoUUID + video.shortUUID = this.videoShortUUID const liveVideoUpdate: LiveVideoUpdate = { - saveReplay: this.form.value.saveReplay + saveReplay: this.form.value.saveReplay, + permanentLive: this.form.value.permanentLive } // Update the video @@ -114,36 +131,40 @@ export class VideoGoLiveComponent extends VideoSend implements OnInit, CanCompon this.updateVideoAndCaptions(video), this.liveVideoService.updateLive(this.videoId, liveVideoUpdate) - ]).subscribe( - () => { + ]).subscribe({ + next: () => { this.notifier.success($localize`Live published.`) - this.router.navigate(['/videos/watch', video.uuid]) + this.router.navigateByUrl(Video.buildWatchUrl(video)) }, - err => { + error: err => { this.error = err.message scrollToTop() console.error(err) } - ) + }) } getMaxLiveDuration () { return this.serverConfig.live.maxDuration / 1000 } + isWaitTranscodingEnabled () { + return this.form.value['saveReplay'] === true + } + private fetchVideoLive () { this.liveVideoService.getVideoLive(this.videoId) - .subscribe( - liveVideo => { + .subscribe({ + next: liveVideo => { this.liveVideo = liveVideo }, - err => { + error: err => { this.firstStepError.emit() this.notifier.error(err.message) } - ) + }) } }