import {
buildServerDirectory,
cleanupTests,
- createLive,
flushAndRunServer,
getVideo,
PluginsCommand,
- sendRTMPStreamInVideo,
ServerInfo,
setAccessTokensToServers,
setDefaultVideoChannel,
testFfmpegStreamError,
uploadVideoAndGetId,
- waitJobs,
- waitUntilLivePublished
+ waitJobs
} from '@shared/extra-utils'
import { VideoDetails, VideoPrivacy } from '@shared/models'
privacy: VideoPrivacy.PUBLIC
}
- const res = await createLive(server.url, server.accessToken, liveAttributes)
- return res.body.video.uuid
+ const { uuid } = await server.liveCommand.create({ fields: liveAttributes })
+
+ return uuid
}
function updateConf (server: ServerInfo, vodProfile: string, liveProfile: string) {
const liveVideoId = await createLiveWrapper(server)
- await sendRTMPStreamInVideo(server.url, server.accessToken, liveVideoId, 'video_short2.webm')
- await waitUntilLivePublished(server.url, server.accessToken, liveVideoId)
+ await server.liveCommand.sendRTMPStreamInVideo({ videoId: liveVideoId, fixtureName: 'video_short2.webm' })
+ await server.liveCommand.waitUntilPublished({ videoId: liveVideoId })
await waitJobs([ server ])
await checkLiveFPS(liveVideoId, 'above', 20)
const liveVideoId = await createLiveWrapper(server)
- await sendRTMPStreamInVideo(server.url, server.accessToken, liveVideoId, 'video_short2.webm')
- await waitUntilLivePublished(server.url, server.accessToken, liveVideoId)
+ await server.liveCommand.sendRTMPStreamInVideo({ videoId: liveVideoId, fixtureName: 'video_short2.webm' })
+ await server.liveCommand.waitUntilPublished({ videoId: liveVideoId })
await waitJobs([ server ])
await checkLiveFPS(liveVideoId, 'below', 12)
const liveVideoId = await createLiveWrapper(server)
- await sendRTMPStreamInVideo(server.url, server.accessToken, liveVideoId, 'video_short2.webm')
- await waitUntilLivePublished(server.url, server.accessToken, liveVideoId)
+ await server.liveCommand.sendRTMPStreamInVideo({ videoId: liveVideoId, fixtureName: 'video_short2.webm' })
+ await server.liveCommand.waitUntilPublished({ videoId: liveVideoId })
await waitJobs([ server ])
await checkLiveFPS(liveVideoId, 'below', 6)
const liveVideoId = await createLiveWrapper(server)
- const command = await sendRTMPStreamInVideo(server.url, server.accessToken, liveVideoId, 'video_short2.webm')
+ const command = await server.liveCommand.sendRTMPStreamInVideo({ videoId: liveVideoId, fixtureName: 'video_short2.webm' })
await testFfmpegStreamError(command, true)
})
const liveVideoId = await createLiveWrapper(server)
- await sendRTMPStreamInVideo(server.url, server.accessToken, liveVideoId, 'video_short2.webm')
- await waitUntilLivePublished(server.url, server.accessToken, liveVideoId)
+ await server.liveCommand.sendRTMPStreamInVideo({ videoId: liveVideoId, fixtureName: 'video_short2.webm' })
+ await server.liveCommand.waitUntilPublished({ videoId: liveVideoId })
await waitJobs([ server ])
const playlistUrl = `${server.url}/static/streaming-playlists/hls/${liveVideoId}/0.m3u8`