From d3f4689bded2a6f5b589fe79c3f8b6082d553d9e Mon Sep 17 00:00:00 2001
From: Chocobozzz <me@florianbigard.com>
Date: Tue, 31 May 2022 14:18:41 +0200
Subject: Add live autostart/messages in embed

---
 .../src/standalone/videos/shared/live-manager.ts   | 69 ++++++++++++++++++++++
 1 file changed, 69 insertions(+)
 create mode 100644 client/src/standalone/videos/shared/live-manager.ts

(limited to 'client/src/standalone/videos/shared/live-manager.ts')

diff --git a/client/src/standalone/videos/shared/live-manager.ts b/client/src/standalone/videos/shared/live-manager.ts
new file mode 100644
index 000000000..422d39793
--- /dev/null
+++ b/client/src/standalone/videos/shared/live-manager.ts
@@ -0,0 +1,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)
+
+  }
+}
-- 
cgit v1.2.3