1 /* tslint:disable:no-unused-expression */
3 import * as chai from 'chai'
5 import { VideoPrivacy } from '../../../../shared/models/videos'
6 import { VideoCommentThreadTree } from '../../../../shared/models/videos/video-comment.model'
7 import { completeVideoCheck, getVideo, immutableAssign, reRunServer, viewVideo } from '../../utils'
10 flushAndRunMultipleServers, flushTests, getVideosList, killallServers, ServerInfo, setAccessTokensToServers, uploadVideo,
12 } from '../../utils/index'
13 import { follow, getFollowersListPaginationAndSort } from '../../utils/server/follows'
14 import { getJobsListPaginationAndSort } from '../../utils/server/jobs'
16 addVideoCommentReply, addVideoCommentThread, getVideoCommentThreads,
17 getVideoThreadComments
18 } from '../../utils/videos/video-comments'
20 const expect = chai.expect
22 describe('Test handle downs', function () {
23 let servers: ServerInfo[] = []
25 let threadIdServer1: number
26 let threadIdServer2: number
27 let commentIdServer1: number
28 let commentIdServer2: number
30 const videoAttributes = {
31 name: 'my super name for server 1',
36 privacy: VideoPrivacy.PUBLIC,
37 description: 'my super description for server 1',
38 tags: [ 'tag1p1', 'tag2p1' ],
39 fixture: 'video_short1.webm'
42 const unlistedVideoAttributes = immutableAssign(videoAttributes, {
43 privacy: VideoPrivacy.UNLISTED
46 const checkAttributes = {
47 name: 'my super name for server 1',
52 description: 'my super description for server 1',
53 host: 'localhost:9001',
57 tags: [ 'tag1p1', 'tag2p1' ],
58 privacy: VideoPrivacy.PUBLIC,
59 commentsEnabled: true,
61 name: 'Default root channel',
65 fixture: 'video_short1.webm',
74 const unlistedCheckAttributes = immutableAssign(checkAttributes, {
75 privacy: VideoPrivacy.UNLISTED
78 before(async function () {
81 servers = await flushAndRunMultipleServers(2)
83 // Get the access tokens
84 await setAccessTokensToServers(servers)
87 it('Should remove followers that are often down', async function () {
90 await follow(servers[1].url, [ servers[0].url ], servers[1].accessToken)
94 await uploadVideo(servers[0].url, servers[0].accessToken, videoAttributes)
98 for (const server of servers) {
99 const res = await getVideosList(server.url)
100 expect(res.body.data).to.be.an('array')
101 expect(res.body.data).to.have.lengthOf(1)
105 killallServers([ servers[1] ])
107 let resVideo = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, unlistedVideoAttributes)
108 videos.push(resVideo.body.video)
110 // Remove server 2 follower
111 for (let i = 0; i < 10; i++) {
112 resVideo = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, videoAttributes)
113 videos.push(resVideo.body.video)
116 // Add comments to video 2
118 const text = 'thread 1'
119 let resComment = await addVideoCommentThread(servers[0].url, servers[0].accessToken, videos[1].uuid, text)
120 let comment = resComment.body.comment
121 threadIdServer1 = comment.id
123 resComment = await addVideoCommentReply(servers[0].url, servers[0].accessToken, videos[1].uuid, comment.id, 'comment 1-1')
124 comment = resComment.body.comment
126 resComment = await addVideoCommentReply(servers[0].url, servers[0].accessToken, videos[1].uuid, comment.id, 'comment 1-2')
127 commentIdServer1 = resComment.body.comment.id
132 const res = await getFollowersListPaginationAndSort(servers[0].url, 0, 1, 'createdAt')
133 expect(res.body.data).to.be.an('array')
134 expect(res.body.data).to.have.lengthOf(0)
137 it('Should not have pending/processing jobs anymore', async function () {
138 const res = await getJobsListPaginationAndSort(servers[0].url, servers[0].accessToken, 0, 50, '-createdAt')
139 const jobs = res.body.data
141 for (const job of jobs) {
142 expect(job.state).not.to.equal('pending')
143 expect(job.state).not.to.equal('processing')
147 it('Should follow server 1', async function () {
150 await reRunServer(servers[1])
152 await follow(servers[1].url, [ servers[0].url ], servers[1].accessToken)
156 const res = await getFollowersListPaginationAndSort(servers[0].url, 0, 1, 'createdAt')
157 expect(res.body.data).to.be.an('array')
158 expect(res.body.data).to.have.lengthOf(1)
161 it('Should send a view to server 2, and automatically fetch the video', async function () {
164 await viewVideo(servers[0].url, videos[0].uuid)
168 const res = await getVideosList(servers[1].url)
169 expect(res.body.data).to.be.an('array')
171 expect(res.body.data).to.have.lengthOf(1)
173 const resVideo = await getVideo(servers[1].url, videos[0].uuid)
174 expect(resVideo.body).not.to.be.undefined
176 await completeVideoCheck(servers[1].url, resVideo.body, unlistedCheckAttributes)
179 it('Should send comments on a video to server 2, and automatically fetch the video', async function () {
182 await addVideoCommentReply(servers[0].url, servers[0].accessToken, videos[1].uuid, commentIdServer1, 'comment 1-3')
186 const res = await getVideosList(servers[1].url)
187 expect(res.body.data).to.be.an('array')
188 expect(res.body.data).to.have.lengthOf(2)
190 const resVideo = await getVideo(servers[1].url, videos[0].uuid)
191 expect(resVideo.body).not.to.be.undefined
193 await completeVideoCheck(servers[1].url, resVideo.body, unlistedCheckAttributes)
196 let resComment = await getVideoCommentThreads(servers[1].url, videos[1].uuid, 0, 5)
197 expect(resComment.body.data).to.be.an('array')
198 expect(resComment.body.data).to.have.lengthOf(1)
200 threadIdServer2 = resComment.body.data[0].id
202 resComment = await getVideoThreadComments(servers[1].url, videos[1].uuid, threadIdServer2)
204 const tree: VideoCommentThreadTree = resComment.body
205 expect(tree.comment.text).equal('thread 1')
206 expect(tree.children).to.have.lengthOf(1)
208 const firstChild = tree.children[0]
209 expect(firstChild.comment.text).to.equal('comment 1-1')
210 expect(firstChild.children).to.have.lengthOf(1)
212 const childOfFirstChild = firstChild.children[0]
213 expect(childOfFirstChild.comment.text).to.equal('comment 1-2')
214 expect(childOfFirstChild.children).to.have.lengthOf(1)
216 const childOfChildFirstChild = childOfFirstChild.children[0]
217 expect(childOfChildFirstChild.comment.text).to.equal('comment 1-3')
218 expect(childOfChildFirstChild.children).to.have.lengthOf(0)
220 commentIdServer2 = childOfChildFirstChild.comment.id
224 it('Should correctly reply to the comment', async function () {
227 await addVideoCommentReply(servers[1].url, servers[1].accessToken, videos[1].uuid, commentIdServer2, 'comment 1-4')
232 const resComment = await getVideoThreadComments(servers[0].url, videos[1].uuid, threadIdServer1)
234 const tree: VideoCommentThreadTree = resComment.body
235 expect(tree.comment.text).equal('thread 1')
236 expect(tree.children).to.have.lengthOf(1)
238 const firstChild = tree.children[0]
239 expect(firstChild.comment.text).to.equal('comment 1-1')
240 expect(firstChild.children).to.have.lengthOf(1)
242 const childOfFirstChild = firstChild.children[0]
243 expect(childOfFirstChild.comment.text).to.equal('comment 1-2')
244 expect(childOfFirstChild.children).to.have.lengthOf(1)
246 const childOfChildFirstChild = childOfFirstChild.children[0]
247 expect(childOfChildFirstChild.comment.text).to.equal('comment 1-3')
248 expect(childOfChildFirstChild.children).to.have.lengthOf(1)
250 const childOfChildOfChildOfFirstChild = childOfChildFirstChild.children[0]
251 expect(childOfChildOfChildOfFirstChild.comment.text).to.equal('comment 1-4')
252 expect(childOfChildOfChildOfFirstChild.children).to.have.lengthOf(0)
256 after(async function () {
257 killallServers(servers)
259 // Keep the logs if the test failed