setAccessTokensToServers, unfollow,
uploadVideo,
viewVideo,
- wait
-} from '../../utils'
-import { waitJobs } from '../../utils/server/jobs'
+ wait,
+ waitUntilLog,
+ checkVideoFilesWereRemoved, removeVideo
+} from '../../../../shared/utils'
+import { waitJobs } from '../../../../shared/utils/server/jobs'
import * as magnetUtil from 'magnet-uri'
-import { updateRedundancy } from '../../utils/server/redundancy'
+import { updateRedundancy } from '../../../../shared/utils/server/redundancy'
import { ActorFollow } from '../../../../shared/models/actors'
import { readdir } from 'fs-extra'
import { join } from 'path'
import { VideoRedundancyStrategy } from '../../../../shared/models/redundancy'
-import { getStats } from '../../utils/server/stats'
+import { getStats } from '../../../../shared/utils/server/stats'
import { ServerStats } from '../../../../shared/models/server/server-stats.model'
const expect = chai.expect
this.timeout(40000)
await waitJobs(servers)
- await wait(15000)
+ await waitUntilLog(servers[0], 'Duplicated ', 4)
await waitJobs(servers)
await check2Webseeds(strategy)
await wait(5000)
await check1WebSeed(strategy)
+
+ await checkVideoFilesWereRemoved(video1Server2UUID, servers[0].serverNumber, [ 'videos' ])
})
after(function () {
this.timeout(40000)
await waitJobs(servers)
- await wait(15000)
+ await waitUntilLog(servers[0], 'Duplicated ', 4)
await waitJobs(servers)
await check2Webseeds(strategy)
await wait(5000)
await check1WebSeed(strategy)
+
+ await checkVideoFilesWereRemoved(video1Server2UUID, servers[0].serverNumber, [ 'videos' ])
})
after(function () {
this.timeout(40000)
await waitJobs(servers)
- await wait(15000)
+ await waitUntilLog(servers[0], 'Duplicated ', 4)
await waitJobs(servers)
await check2Webseeds(strategy)
await checkStatsWith2Webseed(strategy)
})
+ it('Should remove the video and the redundancy files', async function () {
+ this.timeout(20000)
+
+ await removeVideo(servers[1].url, servers[1].accessToken, video1Server2UUID)
+
+ await waitJobs(servers)
+
+ for (const server of servers) {
+ await checkVideoFilesWereRemoved(video1Server2UUID, server.serverNumber)
+ }
+ })
+
after(function () {
return cleanServers()
})
killallServers([ servers[0] ])
- await wait(10000)
+ await wait(15000)
await checkNotContains([ servers[1], servers[2] ], 'http%3A%2F%2Flocalhost%3A9001')
})
await enableRedundancyOnServer1()
await waitJobs(servers)
- await wait(5000)
+ await waitUntilLog(servers[0], 'Duplicated ', 4)
await waitJobs(servers)
await check2Webseeds(strategy)
})
it('Should cache video 2 webseed on the first video', async function () {
- this.timeout(40000)
- this.retries(3)
+ this.timeout(120000)
await waitJobs(servers)
- await wait(7000)
+ let checked = false
+
+ while (checked === false) {
+ await wait(1000)
+
+ try {
+ await check1WebSeed(strategy, video1Server2UUID)
+ await check2Webseeds(strategy, video2Server2UUID)
- await check1WebSeed(strategy, video1Server2UUID)
- await check2Webseeds(strategy, video2Server2UUID)
+ checked = true
+ } catch {
+ checked = false
+ }
+ }
})
after(function () {