1 /* tslint:disable:no-unused-expression */
4 import * as chai from 'chai'
8 flushAndRunMultipleServers,
16 setAccessTokensToServers,
27 import { createUser } from '../utils/users'
29 const expect = chai.expect
31 describe('Test multiple servers', function () {
32 let servers: ServerInfo[] = []
35 let videoChannelId: number
37 before(async function () {
40 servers = await flushAndRunMultipleServers(3)
42 // Get the access tokens
43 await setAccessTokensToServers(servers)
45 const videoChannel = {
47 description: 'super channel'
49 await addVideoChannel(servers[0].url, servers[0].accessToken, videoChannel)
50 const channelRes = await getVideoChannelsList(servers[0].url, 0, 1)
51 videoChannelId = channelRes.body.data[0].id
53 // Server 1 and server 2 follow each other
54 await doubleFollow(servers[0], servers[1])
55 // Server 1 and server 3 follow each other
56 await doubleFollow(servers[0], servers[2])
57 // Server 2 and server 3 follow each other
58 await doubleFollow(servers[1], servers[2])
61 it('Should not have videos for all servers', async function () {
62 for (const server of servers) {
63 const res = await getVideosList(server.url)
64 const videos = res.body.data
65 expect(videos).to.be.an('array')
66 expect(videos.length).to.equal(0)
70 describe('Should upload the video and propagate on each server', function () {
71 it('Should upload the video on server 1 and propagate on each server', async function () {
72 // Server 1 has video transcoding activated
75 const videoAttributes = {
76 name: 'my super name for server 1',
81 description: 'my super description for server 1',
82 tags: [ 'tag1p1', 'tag2p1' ],
83 channelId: videoChannelId,
84 fixture: 'video_short1.webm'
86 await uploadVideo(servers[0].url, servers[0].accessToken, videoAttributes)
90 // All servers should have this video
91 for (const server of servers) {
94 const res = await getVideosList(server.url)
96 const videos = res.body.data
97 expect(videos).to.be.an('array')
98 expect(videos.length).to.equal(1)
99 const video = videos[0]
100 expect(video.name).to.equal('my super name for server 1')
101 expect(video.category).to.equal(5)
102 expect(video.categoryLabel).to.equal('Sports')
103 expect(video.licence).to.equal(4)
104 expect(video.licenceLabel).to.equal('Attribution - Non Commercial')
105 expect(video.language).to.equal(9)
106 expect(video.languageLabel).to.equal('Japanese')
107 expect(video.nsfw).to.be.ok
108 expect(video.description).to.equal('my super description for server 1')
109 expect(video.serverHost).to.equal('localhost:9001')
110 expect(video.duration).to.equal(10)
111 expect(video.tags).to.deep.equal([ 'tag1p1', 'tag2p1' ])
112 expect(dateIsValid(video.createdAt)).to.be.true
113 expect(dateIsValid(video.updatedAt)).to.be.true
114 expect(video.account).to.equal('root')
116 const res2 = await getVideo(server.url, video.uuid)
117 const videoDetails = res2.body
119 expect(videoDetails.channel.name).to.equal('my channel')
120 expect(videoDetails.channel.description).to.equal('super channel')
121 expect(dateIsValid(videoDetails.channel.createdAt)).to.be.true
122 expect(dateIsValid(videoDetails.channel.updatedAt)).to.be.true
123 expect(videoDetails.files).to.have.lengthOf(1)
125 const file = videoDetails.files[0]
126 const magnetUri = file.magnetUri
127 expect(file.magnetUri).to.have.lengthOf.above(2)
128 expect(file.torrentUrl).to
129 .equal(`http://${videoDetails.serverHost}/static/torrents/${videoDetails.uuid}-${file.resolution}.torrent`)
130 expect(file.fileUrl).to.equal(`http://${videoDetails.serverHost}/static/webseed/${videoDetails.uuid}-${file.resolution}.webm`)
131 expect(file.resolution).to.equal(720)
132 expect(file.resolutionLabel).to.equal('720p')
133 expect(file.size).to.equal(572456)
135 if (server.url !== 'http://localhost:9001') {
136 expect(video.isLocal).to.be.false
137 expect(videoDetails.channel.isLocal).to.be.false
139 expect(video.isLocal).to.be.true
140 expect(videoDetails.channel.isLocal).to.be.true
143 // All servers should have the same magnet Uri
144 if (baseMagnet === null) {
145 baseMagnet = magnetUri
147 expect(baseMagnet).to.equal(magnetUri)
150 const test = await testVideoImage(server.url, 'video_short1.webm', video.thumbnailPath)
151 expect(test).to.equal(true)
155 it('Should upload the video on server 2 and propagate on each server', async function () {
160 password: 'super_password'
162 await createUser(servers[1].url, servers[1].accessToken, user.username, user.password)
163 const userAccessToken = await getUserAccessToken(servers[1], user)
165 const videoAttributes = {
166 name: 'my super name for server 2',
171 description: 'my super description for server 2',
172 tags: [ 'tag1p2', 'tag2p2', 'tag3p2' ],
173 fixture: 'video_short2.webm'
175 await uploadVideo(servers[1].url, userAccessToken, videoAttributes)
180 // All servers should have this video
181 for (const server of servers) {
184 const res = await getVideosList(server.url)
186 const videos = res.body.data
187 expect(videos).to.be.an('array')
188 expect(videos.length).to.equal(2)
189 const video = videos[1]
190 expect(video.name).to.equal('my super name for server 2')
191 expect(video.category).to.equal(4)
192 expect(video.categoryLabel).to.equal('Art')
193 expect(video.licence).to.equal(3)
194 expect(video.licenceLabel).to.equal('Attribution - No Derivatives')
195 expect(video.language).to.equal(11)
196 expect(video.languageLabel).to.equal('German')
197 expect(video.nsfw).to.be.true
198 expect(video.description).to.equal('my super description for server 2')
199 expect(video.serverHost).to.equal('localhost:9002')
200 expect(video.duration).to.equal(5)
201 expect(video.tags).to.deep.equal([ 'tag1p2', 'tag2p2', 'tag3p2' ])
202 expect(dateIsValid(video.createdAt)).to.be.true
203 expect(dateIsValid(video.updatedAt)).to.be.true
204 expect(video.account).to.equal('user1')
206 if (server.url !== 'http://localhost:9002') {
207 expect(video.isLocal).to.be.false
209 expect(video.isLocal).to.be.true
212 const res2 = await getVideo(server.url, video.uuid)
213 const videoDetails = res2.body
215 expect(videoDetails.channel.name).to.equal('Default user1 channel')
216 expect(dateIsValid(videoDetails.channel.createdAt)).to.be.true
217 expect(dateIsValid(videoDetails.channel.updatedAt)).to.be.true
219 expect(videoDetails.files).to.have.lengthOf(4)
221 // Check common attributes
222 for (const file of videoDetails.files) {
223 expect(file.magnetUri).to.have.lengthOf.above(2)
225 // All servers should have the same magnet Uri
226 if (baseMagnet[file.resolution] === undefined) {
227 baseMagnet[file.resolution] = file.magnet
229 expect(baseMagnet[file.resolution]).to.equal(file.magnet)
233 const file240p = videoDetails.files.find(f => f.resolution === 240)
234 expect(file240p).not.to.be.undefined
235 expect(file240p.resolutionLabel).to.equal('240p')
236 expect(file240p.size).to.be.above(180000).and.below(200000)
238 const file360p = videoDetails.files.find(f => f.resolution === 360)
239 expect(file360p).not.to.be.undefined
240 expect(file360p.resolutionLabel).to.equal('360p')
241 expect(file360p.size).to.be.above(270000).and.below(290000)
243 const file480p = videoDetails.files.find(f => f.resolution === 480)
244 expect(file480p).not.to.be.undefined
245 expect(file480p.resolutionLabel).to.equal('480p')
246 expect(file480p.size).to.be.above(380000).and.below(400000)
248 const file720p = videoDetails.files.find(f => f.resolution === 720)
249 expect(file720p).not.to.be.undefined
250 expect(file720p.resolutionLabel).to.equal('720p')
251 expect(file720p.size).to.be.above(700000).and.below(7200000)
253 const test = await testVideoImage(server.url, 'video_short2.webm', videoDetails.thumbnailPath)
254 expect(test).to.equal(true)
258 it('Should upload two videos on server 3 and propagate on each server', async function () {
261 const videoAttributes1 = {
262 name: 'my super name for server 3',
267 description: 'my super description for server 3',
269 fixture: 'video_short3.webm'
271 await uploadVideo(servers[2].url, servers[2].accessToken, videoAttributes1)
273 const videoAttributes2 = {
274 name: 'my super name for server 3-2',
279 description: 'my super description for server 3-2',
280 tags: [ 'tag2p3', 'tag3p3', 'tag4p3' ],
281 fixture: 'video_short.webm'
283 await uploadVideo(servers[2].url, servers[2].accessToken, videoAttributes2)
287 let baseMagnet = null
288 // All servers should have this video
289 for (const server of servers) {
290 const res = await getVideosList(server.url)
292 const videos = res.body.data
293 expect(videos).to.be.an('array')
294 expect(videos.length).to.equal(4)
296 // We not sure about the order of the two last uploads
299 if (videos[2].name === 'my super name for server 3') {
307 expect(video1.name).to.equal('my super name for server 3')
308 expect(video1.category).to.equal(6)
309 expect(video1.categoryLabel).to.equal('Travels')
310 expect(video1.licence).to.equal(5)
311 expect(video1.licenceLabel).to.equal('Attribution - Non Commercial - Share Alike')
312 expect(video1.language).to.equal(11)
313 expect(video1.languageLabel).to.equal('German')
314 expect(video1.nsfw).to.be.ok
315 expect(video1.description).to.equal('my super description for server 3')
316 expect(video1.serverHost).to.equal('localhost:9003')
317 expect(video1.duration).to.equal(5)
318 expect(video1.tags).to.deep.equal([ 'tag1p3' ])
319 expect(video1.account).to.equal('root')
320 expect(dateIsValid(video1.createdAt)).to.be.true
321 expect(dateIsValid(video1.updatedAt)).to.be.true
323 const res2 = await getVideo(server.url, video1.id)
324 const video1Details = res2.body
325 expect(video1Details.files).to.have.lengthOf(1)
327 const file1 = video1Details.files[0]
328 expect(file1.magnetUri).to.have.lengthOf.above(2)
329 expect(file1.resolution).to.equal(720)
330 expect(file1.resolutionLabel).to.equal('720p')
331 expect(file1.size).to.equal(292677)
333 expect(video2.name).to.equal('my super name for server 3-2')
334 expect(video2.category).to.equal(7)
335 expect(video2.categoryLabel).to.equal('Gaming')
336 expect(video2.licence).to.equal(6)
337 expect(video2.licenceLabel).to.equal('Attribution - Non Commercial - No Derivatives')
338 expect(video2.language).to.equal(12)
339 expect(video2.languageLabel).to.equal('Korean')
340 expect(video2.nsfw).to.be.false
341 expect(video2.description).to.equal('my super description for server 3-2')
342 expect(video2.serverHost).to.equal('localhost:9003')
343 expect(video2.duration).to.equal(5)
344 expect(video2.tags).to.deep.equal([ 'tag2p3', 'tag3p3', 'tag4p3' ])
345 expect(video2.account).to.equal('root')
346 expect(dateIsValid(video2.createdAt)).to.be.true
347 expect(dateIsValid(video2.updatedAt)).to.be.true
349 const res3 = await getVideo(server.url, video2.id)
350 const video2Details = res3.body
352 expect(video2Details.files).to.have.lengthOf(1)
354 const file2 = video2Details.files[0]
355 const magnetUri2 = file2.magnetUri
356 expect(file2.magnetUri).to.have.lengthOf.above(2)
357 expect(file2.resolution).to.equal(720)
358 expect(file2.resolutionLabel).to.equal('720p')
359 expect(file2.size).to.equal(218910)
361 if (server.url !== 'http://localhost:9003') {
362 expect(video1.isLocal).to.be.false
363 expect(video2.isLocal).to.be.false
365 expect(video1.isLocal).to.be.true
366 expect(video2.isLocal).to.be.true
369 // All servers should have the same magnet Uri
370 if (baseMagnet === null) {
371 baseMagnet = magnetUri2
373 expect(baseMagnet).to.equal(magnetUri2)
376 const test1 = await testVideoImage(server.url, 'video_short3.webm', video1.thumbnailPath)
377 expect(test1).to.equal(true)
379 const test2 = await testVideoImage(server.url, 'video_short.webm', video2.thumbnailPath)
380 expect(test2).to.equal(true)
385 describe('Should seed the uploaded video', function () {
386 it('Should add the file 1 by asking server 3', async function () {
389 const res = await getVideosList(servers[2].url)
391 const video = res.body.data[0]
392 toRemove.push(res.body.data[2])
393 toRemove.push(res.body.data[3])
395 const res2 = await getVideo(servers[2].url, video.id)
396 const videoDetails = res2.body
398 const torrent = await webtorrentAdd(videoDetails.files[0].magnetUri)
399 expect(torrent.files).to.be.an('array')
400 expect(torrent.files.length).to.equal(1)
401 expect(torrent.files[0].path).to.exist.and.to.not.equal('')
404 it('Should add the file 2 by asking server 1', async function () {
407 const res = await getVideosList(servers[0].url)
409 const video = res.body.data[1]
410 const res2 = await getVideo(servers[0].url, video.id)
411 const videoDetails = res2.body
413 const torrent = await webtorrentAdd(videoDetails.files[0].magnetUri)
414 expect(torrent.files).to.be.an('array')
415 expect(torrent.files.length).to.equal(1)
416 expect(torrent.files[0].path).to.exist.and.to.not.equal('')
419 it('Should add the file 3 by asking server 2', async function () {
422 const res = await getVideosList(servers[1].url)
424 const video = res.body.data[2]
425 const res2 = await getVideo(servers[1].url, video.id)
426 const videoDetails = res2.body
428 const torrent = await webtorrentAdd(videoDetails.files[0].magnetUri)
429 expect(torrent.files).to.be.an('array')
430 expect(torrent.files.length).to.equal(1)
431 expect(torrent.files[0].path).to.exist.and.to.not.equal('')
434 it('Should add the file 3-2 by asking server 1', async function () {
437 const res = await getVideosList(servers[0].url)
439 const video = res.body.data[3]
440 const res2 = await getVideo(servers[0].url, video.id)
441 const videoDetails = res2.body
443 const torrent = await webtorrentAdd(videoDetails.files[0].magnetUri)
444 expect(torrent.files).to.be.an('array')
445 expect(torrent.files.length).to.equal(1)
446 expect(torrent.files[0].path).to.exist.and.to.not.equal('')
449 it('Should add the file 2 in 360p by asking server 1', async function () {
452 const res = await getVideosList(servers[0].url)
454 const video = res.body.data.find(v => v.name === 'my super name for server 2')
455 const res2 = await getVideo(servers[0].url, video.id)
456 const videoDetails = res2.body
458 const file = videoDetails.files.find(f => f.resolution === 360)
459 expect(file).not.to.be.undefined
461 const torrent = await webtorrentAdd(file.magnetUri)
462 expect(torrent.files).to.be.an('array')
463 expect(torrent.files.length).to.equal(1)
464 expect(torrent.files[0].path).to.exist.and.to.not.equal('')
468 describe('Should update video views, likes and dislikes', function () {
469 let localVideosServer3 = []
470 let remoteVideosServer1 = []
471 let remoteVideosServer2 = []
472 let remoteVideosServer3 = []
474 before(async function () {
475 const res1 = await getVideosList(servers[0].url)
476 remoteVideosServer1 = res1.body.data.filter(video => video.isLocal === false).map(video => video.uuid)
478 const res2 = await getVideosList(servers[1].url)
479 remoteVideosServer2 = res2.body.data.filter(video => video.isLocal === false).map(video => video.uuid)
481 const res3 = await getVideosList(servers[2].url)
482 localVideosServer3 = res3.body.data.filter(video => video.isLocal === true).map(video => video.uuid)
483 remoteVideosServer3 = res3.body.data.filter(video => video.isLocal === false).map(video => video.uuid)
486 it('Should view multiple videos on owned servers', async function () {
489 const tasks: Promise<any>[] = []
490 tasks.push(getVideo(servers[2].url, localVideosServer3[0]))
491 tasks.push(getVideo(servers[2].url, localVideosServer3[0]))
492 tasks.push(getVideo(servers[2].url, localVideosServer3[0]))
493 tasks.push(getVideo(servers[2].url, localVideosServer3[1]))
495 await Promise.all(tasks)
499 for (const server of servers) {
500 const res = await getVideosList(server.url)
502 const videos = res.body.data
503 const video0 = videos.find(v => v.uuid === localVideosServer3[0])
504 const video1 = videos.find(v => v.uuid === localVideosServer3[1])
506 expect(video0.views).to.equal(7)
507 expect(video1.views).to.equal(5)
511 it('Should view multiple videos on each servers', async function () {
514 const tasks: Promise<any>[] = []
515 tasks.push(getVideo(servers[0].url, remoteVideosServer1[0]))
516 tasks.push(getVideo(servers[1].url, remoteVideosServer2[0]))
517 tasks.push(getVideo(servers[1].url, remoteVideosServer2[0]))
518 tasks.push(getVideo(servers[2].url, remoteVideosServer3[0]))
519 tasks.push(getVideo(servers[2].url, remoteVideosServer3[1]))
520 tasks.push(getVideo(servers[2].url, remoteVideosServer3[1]))
521 tasks.push(getVideo(servers[2].url, remoteVideosServer3[1]))
522 tasks.push(getVideo(servers[2].url, localVideosServer3[1]))
523 tasks.push(getVideo(servers[2].url, localVideosServer3[1]))
524 tasks.push(getVideo(servers[2].url, localVideosServer3[1]))
526 await Promise.all(tasks)
530 let baseVideos = null
532 for (const server of servers) {
533 const res = await getVideosList(server.url)
535 const videos = res.body.data
537 // Initialize base videos for future comparisons
538 if (baseVideos === null) {
543 for (const baseVideo of baseVideos) {
544 const sameVideo = videos.find(video => video.name === baseVideo.name)
545 expect(baseVideo.views).to.equal(sameVideo.views)
550 it('Should like and dislikes videos on different services', async function () {
553 const tasks: Promise<any>[] = []
554 tasks.push(rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'like'))
555 tasks.push(rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'dislike'))
556 tasks.push(rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'like'))
557 tasks.push(rateVideo(servers[2].url, servers[2].accessToken, localVideosServer3[1], 'like'))
558 tasks.push(rateVideo(servers[2].url, servers[2].accessToken, localVideosServer3[1], 'dislike'))
559 tasks.push(rateVideo(servers[2].url, servers[2].accessToken, remoteVideosServer3[1], 'dislike'))
560 tasks.push(rateVideo(servers[2].url, servers[2].accessToken, remoteVideosServer3[0], 'like'))
562 await Promise.all(tasks)
566 let baseVideos = null
567 for (const server of servers) {
568 const res = await getVideosList(server.url)
570 const videos = res.body.data
572 // Initialize base videos for future comparisons
573 if (baseVideos === null) {
578 baseVideos.forEach(baseVideo => {
579 const sameVideo = videos.find(video => video.name === baseVideo.name)
580 expect(baseVideo.likes).to.equal(sameVideo.likes)
581 expect(baseVideo.dislikes).to.equal(sameVideo.dislikes)
587 describe('Should manipulate these videos', function () {
588 it('Should update the video 3 by asking server 3', async function () {
592 name: 'my super video updated',
597 description: 'my super description updated',
598 tags: [ 'tag_up_1', 'tag_up_2' ]
601 await updateVideo(servers[2].url, servers[2].accessToken, toRemove[0].id, attributes)
606 it('Should have the video 3 updated on each server', async function () {
609 for (const server of servers) {
610 const res = await getVideosList(server.url)
612 const videos = res.body.data
613 const videoUpdated = videos.find(video => video.name === 'my super video updated')
615 expect(!!videoUpdated).to.be.true
616 expect(videoUpdated.category).to.equal(10)
617 expect(videoUpdated.categoryLabel).to.equal('Entertainment')
618 expect(videoUpdated.licence).to.equal(7)
619 expect(videoUpdated.licenceLabel).to.equal('Public Domain Dedication')
620 expect(videoUpdated.language).to.equal(13)
621 expect(videoUpdated.languageLabel).to.equal('French')
622 expect(videoUpdated.nsfw).to.be.ok
623 expect(videoUpdated.description).to.equal('my super description updated')
624 expect(videoUpdated.tags).to.deep.equal([ 'tag_up_1', 'tag_up_2' ])
625 expect(dateIsValid(videoUpdated.updatedAt, 20000)).to.be.true
627 const res2 = await getVideo(server.url, videoUpdated.uuid)
628 const videoUpdatedDetails = res2.body
630 const file = videoUpdatedDetails .files[0]
631 expect(file.magnetUri).to.have.lengthOf.above(2)
632 expect(file.resolution).to.equal(720)
633 expect(file.resolutionLabel).to.equal('720p')
634 expect(file.size).to.equal(292677)
636 const test = await testVideoImage(server.url, 'video_short3.webm', videoUpdated.thumbnailPath)
637 expect(test).to.equal(true)
639 // Avoid "duplicate torrent" errors
640 const refreshWebTorrent = true
641 const torrent = await webtorrentAdd(videoUpdatedDetails .files[0].magnetUri, refreshWebTorrent)
642 expect(torrent.files).to.be.an('array')
643 expect(torrent.files.length).to.equal(1)
644 expect(torrent.files[0].path).to.exist.and.to.not.equal('')
648 it('Should remove the videos 3 and 3-2 by asking server 3', async function () {
651 await removeVideo(servers[2].url, servers[2].accessToken, toRemove[0].id)
652 await removeVideo(servers[2].url, servers[2].accessToken, toRemove[1].id)
657 it('Should have videos 1 and 3 on each server', async function () {
658 for (const server of servers) {
659 const res = await getVideosList(server.url)
661 const videos = res.body.data
662 expect(videos).to.be.an('array')
663 expect(videos.length).to.equal(2)
664 expect(videos[0].name).not.to.equal(videos[1].name)
665 expect(videos[0].name).not.to.equal(toRemove[0].name)
666 expect(videos[1].name).not.to.equal(toRemove[0].name)
667 expect(videos[0].name).not.to.equal(toRemove[1].name)
668 expect(videos[1].name).not.to.equal(toRemove[1].name)
670 videoUUID = videos.find(video => video.name === 'my super name for server 1').uuid
674 it('Should get the same video by UUID on each server', async function () {
676 for (const server of servers) {
677 const res = await getVideo(server.url, videoUUID)
679 const video = res.body
681 if (baseVideo === null) {
686 expect(baseVideo.name).to.equal(video.name)
687 expect(baseVideo.uuid).to.equal(video.uuid)
688 expect(baseVideo.category).to.equal(video.category)
689 expect(baseVideo.language).to.equal(video.language)
690 expect(baseVideo.licence).to.equal(video.licence)
691 expect(baseVideo.category).to.equal(video.category)
692 expect(baseVideo.nsfw).to.equal(video.nsfw)
693 expect(baseVideo.account).to.equal(video.account)
694 expect(baseVideo.tags).to.deep.equal(video.tags)
698 it('Should get the preview from each server', async function () {
699 for (const server of servers) {
700 const res = await getVideo(server.url, videoUUID)
701 const video = res.body
703 const test = await testVideoImage(server.url, 'video_short1-preview.webm', video.previewPath)
704 expect(test).to.equal(true)
709 after(async function () {
710 killallServers(servers)
712 // Keep the logs if the test failed