-import { Component, EventEmitter, OnInit, Output } from '@angular/core'
+import { forkJoin } from 'rxjs'
+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, VideoCreate, VideoPrivacy } from '@shared/models'
+import { LiveVideo, LiveVideoCreate, LiveVideoUpdate, PeerTubeProblemDocument, ServerErrorCode, VideoPrivacy } from '@shared/models'
import { VideoSend } from './video-send'
@Component({
'./video-send.scss'
]
})
-export class VideoGoLiveComponent extends VideoSend implements OnInit, CanComponentDeactivate {
+export class VideoGoLiveComponent extends VideoSend implements OnInit, AfterViewInit, CanComponentDeactivate {
@Output() firstStepDone = new EventEmitter<string>()
@Output() firstStepError = new EventEmitter<void>()
videoUUID: string
error: string
- protected readonly DEFAULT_VIDEO_PRIVACY = VideoPrivacy.PUBLIC
-
constructor (
protected formValidatorService: FormValidatorService,
protected loadingBar: LoadingBarService,
protected videoService: VideoService,
protected videoCaptionService: VideoCaptionService,
private liveVideoService: LiveVideoService,
- private router: Router
+ private router: Router,
+ private hooks: HooksService
) {
super()
}
super.ngOnInit()
}
+ ngAfterViewInit () {
+ this.hooks.runAction('action:go-live.init', 'video-edit')
+ }
+
canDeactivate () {
return { canDeactivate: true }
}
goLive () {
- const video: VideoCreate = {
- name: 'Live',
+ const name = 'Live'
+
+ const video: LiveVideoCreate = {
+ name,
privacy: VideoPrivacy.PRIVATE,
nsfw: this.serverConfig.instance.isNSFW,
waitTranscoding: true,
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.videoUUID = res.video.uuid
this.isInUpdateForm = true
+ this.firstStepDone.emit(name)
+
this.fetchVideoLive()
},
err => {
this.firstStepError.emit()
- this.notifier.error(err.message)
+
+ let message = err.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)
}
)
}
video.id = this.videoId
video.uuid = this.videoUUID
+ const liveVideoUpdate: LiveVideoUpdate = {
+ saveReplay: this.form.value.saveReplay,
+ permanentLive: this.form.value.permanentLive
+ }
+
// Update the video
- this.updateVideoAndCaptions(video)
- .subscribe(
- () => {
- this.notifier.success($localize`Live published.`)
+ forkJoin([
+ this.updateVideoAndCaptions(video),
+
+ this.liveVideoService.updateLive(this.videoId, liveVideoUpdate)
+ ]).subscribe(
+ () => {
+ this.notifier.success($localize`Live published.`)
+
+ this.router.navigateByUrl(Video.buildWatchUrl(video))
+ },
- this.router.navigate([ '/videos/watch', video.uuid ])
- },
+ err => {
+ this.error = err.message
+ scrollToTop()
+ console.error(err)
+ }
+ )
+ }
- 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 () {