1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
import { Component, ElementRef, ViewChild } from '@angular/core'
import { Video } from '@app/shared/shared-main'
import { NgbModal } from '@ng-bootstrap/ng-bootstrap'
import { LiveVideo, LiveVideoError, LiveVideoErrorType, LiveVideoSession } from '@peertube/peertube-models'
import { LiveVideoService } from './live-video.service'
@Component({
selector: 'my-live-stream-information',
templateUrl: './live-stream-information.component.html',
styleUrls: [ './live-stream-information.component.scss' ]
})
export class LiveStreamInformationComponent {
@ViewChild('modal', { static: true }) modal: ElementRef
video: Video
live: LiveVideo
latestLiveSessions: LiveVideoSession[] = []
constructor (
private modalService: NgbModal,
private liveVideoService: LiveVideoService
) { }
show (video: Video) {
this.video = video
this.live = undefined
this.loadLiveInfo(video)
this.modalService
.open(this.modal, { centered: true })
}
getVideoUrl (video: { shortUUID: string }) {
return Video.buildWatchUrl(video)
}
getErrorLabel (session: LiveVideoSession) {
if (!session.error) return undefined
const errors: { [ id in LiveVideoErrorType ]: string } = {
[LiveVideoError.BAD_SOCKET_HEALTH]: $localize`Server too slow`,
[LiveVideoError.BLACKLISTED]: $localize`Live blacklisted`,
[LiveVideoError.DURATION_EXCEEDED]: $localize`Max duration exceeded`,
[LiveVideoError.FFMPEG_ERROR]: $localize`Server error`,
[LiveVideoError.QUOTA_EXCEEDED]: $localize`Quota exceeded`,
[LiveVideoError.RUNNER_JOB_CANCEL]: $localize`Runner job cancelled`,
[LiveVideoError.RUNNER_JOB_ERROR]: $localize`Error in runner job`
}
return errors[session.error]
}
isReplayBeingProcessed (session: LiveVideoSession) {
// Running live
if (!session.endDate) return false
return session.saveReplay && !session.endingProcessed
}
private loadLiveInfo (video: Video) {
this.liveVideoService.getVideoLive(video.id)
.subscribe(live => this.live = live)
this.liveVideoService.listSessions(video.id)
.subscribe(({ data }) => this.latestLiveSessions = data.reverse().slice(0, 5))
}
}
|
