projects / github / Chocobozzz / PeerTube.git / blame
| Commit | Line | Data |
|---|---|---|
| d3f4689b C |
1 | import { Socket } from 'socket.io-client' |
| 2 | import { LiveVideoEventPayload, VideoDetails, VideoState } from '../../../../../shared/models' | |
| 3 | import { PlayerHTML } from './player-html' | |
| 4 | import { Translations } from './translations' | |
| 5 | ||
| 6 | export class LiveManager { | |
| 7 | private liveSocket: Socket | |
| 8 | ||
| 9 | constructor ( | |
| 10 | private readonly playerHTML: PlayerHTML | |
| 11 | ) { | |
| 12 | ||
| 13 | } | |
| 14 | ||
| 15 | async displayInfoAndListenForChanges (options: { | |
| 16 | video: VideoDetails | |
| 17 | translations: Translations | |
| 18 | onPublishedVideo: () => any | |
| 19 | }) { | |
| 20 | const { video, onPublishedVideo } = options | |
| 21 | ||
| 22 | this.displayAppropriateInfo(options) | |
| 23 | ||
| 24 | if (!this.liveSocket) { | |
| 25 | const io = (await import('socket.io-client')).io | |
| 26 | this.liveSocket = io(window.location.origin + '/live-videos') | |
| 27 | } | |
| 28 | ||
| 29 | this.liveSocket.on('state-change', (payload: LiveVideoEventPayload) => { | |
| 30 | if (payload.state === VideoState.PUBLISHED) { | |
| 31 | this.playerHTML.removeInformation() | |
| 32 | onPublishedVideo() | |
| 33 | return | |
| 34 | } | |
| 35 | }) | |
| 36 | ||
| 37 | this.liveSocket.emit('subscribe', { videoId: video.id }) | |
| 38 | } | |
| 39 | ||
| 40 | stopListeningForChanges (video: VideoDetails) { | |
| 41 | this.liveSocket.emit('unsubscribe', { videoId: video.id }) | |
| 42 | } | |
| 43 | ||
| 44 | private displayAppropriateInfo (options: { | |
| 45 | video: VideoDetails | |
| 46 | translations: Translations | |
| 47 | }) { | |
| 48 | const { video, translations } = options | |
| 49 | ||
| 50 | if (video.state.id === VideoState.WAITING_FOR_LIVE) { | |
| 51 | this.displayWaitingForLiveInfo(translations) | |
| 52 | return | |
| 53 | } | |
| 54 | ||
| 55 | if (video.state.id === VideoState.LIVE_ENDED) { | |
| 56 | this.displayEndedLiveInfo(translations) | |
| 57 | return | |
| 58 | } | |
| 59 | } | |
| 60 | ||
| 61 | private displayWaitingForLiveInfo (translations: Translations) { | |
| 62 | this.playerHTML.displayInformation('This live has not started yet.', translations) | |
| 63 | } | |
| 64 | ||
| 65 | private displayEndedLiveInfo (translations: Translations) { | |
| 66 | this.playerHTML.displayInformation('This live has ended.', translations) | |
| 67 | ||
| 68 | } | |
| 69 | } |