From 6b67897e2eab96978daee40aeaf716835856d65d Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Tue, 24 Nov 2020 16:29:39 +0100 Subject: Add transcoding module comments --- shared/extra-utils/videos/live.ts | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) (limited to 'shared/extra-utils/videos') diff --git a/shared/extra-utils/videos/live.ts b/shared/extra-utils/videos/live.ts index 85c83c5bb..c8acb90da 100644 --- a/shared/extra-utils/videos/live.ts +++ b/shared/extra-utils/videos/live.ts @@ -128,7 +128,15 @@ async function stopFfmpeg (command: ffmpeg.FfmpegCommand) { await wait(500) } -async function waitUntilLiveStarts (url: string, token: string, videoId: number | string) { +function waitUntilLiveStarts (url: string, token: string, videoId: number | string) { + return waitWhileLiveState(url, token, videoId, VideoState.WAITING_FOR_LIVE) +} + +function waitUntilLivePublished (url: string, token: string, videoId: number | string) { + return waitWhileLiveState(url, token, videoId, VideoState.PUBLISHED) +} + +async function waitWhileLiveState (url: string, token: string, videoId: number | string, state: VideoState) { let video: VideoDetails do { @@ -136,7 +144,7 @@ async function waitUntilLiveStarts (url: string, token: string, videoId: number video = res.body await wait(500) - } while (video.state.id === VideoState.WAITING_FOR_LIVE) + } while (video.state.id === state) } async function checkLiveCleanup (server: ServerInfo, videoUUID: string, resolutions: number[] = []) { @@ -168,6 +176,7 @@ async function checkLiveCleanup (server: ServerInfo, videoUUID: string, resoluti export { getLive, + waitUntilLivePublished, updateLive, waitUntilLiveStarts, createLive, -- cgit v1.2.3