-/* tslint:disable:no-unused-expression */
+/* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
-import * as chai from 'chai'
import 'mocha'
-import { JobState, Video } from '../../../../shared/models'
-import { VideoPrivacy } from '../../../../shared/models/videos'
-import { VideoCommentThreadTree } from '../../../../shared/models/videos/video-comment.model'
-
+import * as chai from 'chai'
+import { HttpStatusCode } from '@shared/core-utils'
import {
+ addVideoCommentReply,
+ addVideoCommentThread,
cleanupTests,
+ closeAllSequelize,
completeVideoCheck,
flushAndRunMultipleServers,
getVideo,
+ getVideoCommentThreads,
getVideosList,
+ getVideoThreadComments,
immutableAssign,
killallServers,
reRunServer,
ServerInfo,
setAccessTokensToServers,
- unfollow,
+ setActorFollowScores,
updateVideo,
- uploadVideo, uploadVideoAndGetId,
+ uploadVideo,
+ uploadVideoAndGetId,
wait,
- setActorFollowScores, closeAllSequelize
-} from '../../../../shared/extra-utils'
-import { follow, getFollowersListPaginationAndSort } from '../../../../shared/extra-utils/server/follows'
-import { getJobsListPaginationAndSort, waitJobs } from '../../../../shared/extra-utils/server/jobs'
-import {
- addVideoCommentReply,
- addVideoCommentThread,
- getVideoCommentThreads,
- getVideoThreadComments
-} from '../../../../shared/extra-utils/videos/video-comments'
+ waitJobs
+} from '@shared/extra-utils'
+import { JobState, Video, VideoCommentThreadTree, VideoPrivacy } from '@shared/models'
const expect = chai.expect
let missedVideo2: Video
let unlistedVideo: Video
- let videoIdsServer1: number[] = []
+ const videoIdsServer1: string[] = []
const videoAttributes = {
name: 'my super name for server 1',
this.timeout(240000)
// Server 2 and 3 follow server 1
- await follow(servers[1].url, [ servers[0].url ], servers[1].accessToken)
- await follow(servers[2].url, [ servers[0].url ], servers[2].accessToken)
+ await servers[1].followsCommand.follow({ targets: [ servers[0].url ] })
+ await servers[2].followsCommand.follow({ targets: [ servers[0].url ] })
await waitJobs(servers)
// Remove server 2 follower
for (let i = 0; i < 10; i++) {
- await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, videoAttributes)
+ await uploadVideo(servers[0].url, servers[0].accessToken, videoAttributes)
}
- await waitJobs(servers[0])
+ await waitJobs([ servers[0], servers[2] ])
// Kill server 3
killallServers([ servers[2] ])
- const resLastVideo1 = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, videoAttributes)
+ const resLastVideo1 = await uploadVideo(servers[0].url, servers[0].accessToken, videoAttributes)
missedVideo1 = resLastVideo1.body.video
- const resLastVideo2 = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, videoAttributes)
+ const resLastVideo2 = await uploadVideo(servers[0].url, servers[0].accessToken, videoAttributes)
missedVideo2 = resLastVideo2.body.video
// Unlisted video
- let resVideo = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, unlistedVideoAttributes)
+ const resVideo = await uploadVideo(servers[0].url, servers[0].accessToken, unlistedVideoAttributes)
unlistedVideo = resVideo.body.video
// Add comments to video 2
await wait(11000)
// Only server 3 is still a follower of server 1
- const res = await getFollowersListPaginationAndSort({ url: servers[ 0 ].url, start: 0, count: 2, sort: 'createdAt' })
- expect(res.body.data).to.be.an('array')
- expect(res.body.data).to.have.lengthOf(1)
- expect(res.body.data[0].follower.host).to.equal('localhost:' + servers[2].port)
+ const body = await servers[0].followsCommand.getFollowers({ start: 0, count: 2, sort: 'createdAt' })
+ expect(body.data).to.be.an('array')
+ expect(body.data).to.have.lengthOf(1)
+ expect(body.data[0].follower.host).to.equal('localhost:' + servers[2].port)
})
it('Should not have pending/processing jobs anymore', async function () {
const states: JobState[] = [ 'waiting', 'active' ]
for (const state of states) {
- const res = await getJobsListPaginationAndSort({
- url: servers[ 0 ].url,
- accessToken: servers[ 0 ].accessToken,
+ const body = await servers[0].jobsCommand.getJobsList({
state: state,
start: 0,
count: 50,
sort: '-createdAt'
})
- expect(res.body.data).to.have.length(0)
+ expect(body.data).to.have.length(0)
}
})
await reRunServer(servers[1])
await reRunServer(servers[2])
- await unfollow(servers[1].url, servers[1].accessToken, servers[0])
+ await servers[1].followsCommand.unfollow({ target: servers[0] })
await waitJobs(servers)
- await follow(servers[1].url, [ servers[0].url ], servers[1].accessToken)
+ await servers[1].followsCommand.follow({ targets: [ servers[0].url ] })
await waitJobs(servers)
- const res = await getFollowersListPaginationAndSort({ url: servers[ 0 ].url, start: 0, count: 2, sort: 'createdAt' })
- expect(res.body.data).to.be.an('array')
- expect(res.body.data).to.have.lengthOf(2)
+ const body = await servers[0].followsCommand.getFollowers({ start: 0, count: 2, sort: 'createdAt' })
+ expect(body.data).to.be.an('array')
+ expect(body.data).to.have.lengthOf(2)
})
it('Should send an update to server 3, and automatically fetch the video', async function () {
expect(res1.body.data).to.be.an('array')
expect(res1.body.data).to.have.lengthOf(11)
- await updateVideo(servers[0].url, servers[0].accessToken, missedVideo1.uuid, { })
- await updateVideo(servers[0].url, servers[0].accessToken, unlistedVideo.uuid, { })
+ await updateVideo(servers[0].url, servers[0].accessToken, missedVideo1.uuid, {})
+ await updateVideo(servers[0].url, servers[0].accessToken, unlistedVideo.uuid, {})
await waitJobs(servers)
this.timeout(120000)
for (let i = 0; i < 10; i++) {
- const uuid = (await uploadVideoAndGetId({ server: servers[ 0 ], videoName: 'video ' + i })).uuid
+ const uuid = (await uploadVideoAndGetId({ server: servers[0], videoName: 'video ' + i })).uuid
videoIdsServer1.push(uuid)
}
await waitJobs(servers)
for (const id of videoIdsServer1) {
- await getVideo(servers[ 1 ].url, id)
+ await getVideo(servers[1].url, id)
}
await waitJobs(servers)
// Wait video expiration
await wait(11000)
- for (let i = 0; i < 3; i++) {
- await getVideo(servers[1].url, videoIdsServer1[i])
- await wait(1000)
- await waitJobs([ servers[1] ])
+ for (let i = 0; i < 5; i++) {
+ try {
+ await getVideo(servers[1].url, videoIdsServer1[i])
+ await waitJobs([ servers[1] ])
+ await wait(1500)
+ } catch {}
}
for (const id of videoIdsServer1) {
- await getVideo(servers[1].url, id, 403)
+ await getVideo(servers[1].url, id, HttpStatusCode.FORBIDDEN_403)
}
})