blob: 422d39793ccbf91ad19aea4c095b94a96d62f840 (
plain) (
blame)
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
69
|
import { Socket } from 'socket.io-client'
import { LiveVideoEventPayload, VideoDetails, VideoState } from '../../../../../shared/models'
import { PlayerHTML } from './player-html'
import { Translations } from './translations'
export class LiveManager {
private liveSocket: Socket
constructor (
private readonly playerHTML: PlayerHTML
) {
}
async displayInfoAndListenForChanges (options: {
video: VideoDetails
translations: Translations
onPublishedVideo: () => any
}) {
const { video, onPublishedVideo } = options
this.displayAppropriateInfo(options)
if (!this.liveSocket) {
const io = (await import('socket.io-client')).io
this.liveSocket = io(window.location.origin + '/live-videos')
}
this.liveSocket.on('state-change', (payload: LiveVideoEventPayload) => {
if (payload.state === VideoState.PUBLISHED) {
this.playerHTML.removeInformation()
onPublishedVideo()
return
}
})
this.liveSocket.emit('subscribe', { videoId: video.id })
}
stopListeningForChanges (video: VideoDetails) {
this.liveSocket.emit('unsubscribe', { videoId: video.id })
}
private displayAppropriateInfo (options: {
video: VideoDetails
translations: Translations
}) {
const { video, translations } = options
if (video.state.id === VideoState.WAITING_FOR_LIVE) {
this.displayWaitingForLiveInfo(translations)
return
}
if (video.state.id === VideoState.LIVE_ENDED) {
this.displayEndedLiveInfo(translations)
return
}
}
private displayWaitingForLiveInfo (translations: Translations) {
this.playerHTML.displayInformation('This live has not started yet.', translations)
}
private displayEndedLiveInfo (translations: Translations) {
this.playerHTML.displayInformation('This live has ended.', translations)
}
}
|
