+ describe('After a server restart', function () {
+ let liveVideoId: string
+ let liveVideoReplayId: string
+
+ async function createLiveWrapper (saveReplay: boolean) {
+ const liveAttributes = {
+ name: 'live video',
+ channelId: servers[0].videoChannel.id,
+ privacy: VideoPrivacy.PUBLIC,
+ saveReplay
+ }
+
+ const res = await createLive(servers[0].url, servers[0].accessToken, liveAttributes)
+ return res.body.video.uuid
+ }
+
+ before(async function () {
+ this.timeout(120000)
+
+ liveVideoId = await createLiveWrapper(false)
+ liveVideoReplayId = await createLiveWrapper(true)
+
+ await Promise.all([
+ sendRTMPStreamInVideo(servers[0].url, servers[0].accessToken, liveVideoId),
+ sendRTMPStreamInVideo(servers[0].url, servers[0].accessToken, liveVideoReplayId)
+ ])
+
+ await Promise.all([
+ waitUntilLivePublished(servers[0].url, servers[0].accessToken, liveVideoId),
+ waitUntilLivePublished(servers[0].url, servers[0].accessToken, liveVideoReplayId)
+ ])
+
+ await waitUntilLiveSegmentGeneration(servers[0], liveVideoId, 0, 2)
+ await waitUntilLiveSegmentGeneration(servers[0], liveVideoReplayId, 0, 2)
+
+ await killallServers([ servers[0] ])
+ await reRunServer(servers[0])
+
+ await wait(5000)
+ })
+
+ it('Should cleanup lives', async function () {
+ this.timeout(60000)
+
+ await waitUntilLiveEnded(servers[0].url, servers[0].accessToken, liveVideoId)
+ })
+
+ it('Should save a live replay', async function () {
+ this.timeout(120000)
+
+ await waitUntilLivePublished(servers[0].url, servers[0].accessToken, liveVideoReplayId)
+ })
+ })
+