diff options
| author | Chocobozzz <me@florianbigard.com> | 2018-01-25 15:05:18 +0100 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2018-01-25 18:41:17 +0100 |
| commit | 94a5ff8a4a75d75bb9df542a39ce8769e7a7e6a4 (patch) | |
| tree | 32a9148e0e4567f0c4ffae0412cbed20b84e8873 /server/tests/api/videos/multiple-servers.ts | |
| parent | d765fafc3faf0db9818eb1a07161df1cb1bc0efa (diff) | |
| download | PeerTube-94a5ff8a4a75d75bb9df542a39ce8769e7a7e6a4.tar.gz PeerTube-94a5ff8a4a75d75bb9df542a39ce8769e7a7e6a4.tar.zst PeerTube-94a5ff8a4a75d75bb9df542a39ce8769e7a7e6a4.zip | |
Move job queue to redis
We'll use it as cache in the future.
/!\ You'll loose your old jobs (pending jobs too) so upgrade only when
you don't have pending job anymore.
Diffstat (limited to 'server/tests/api/videos/multiple-servers.ts')
| -rw-r--r-- | server/tests/api/videos/multiple-servers.ts | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/server/tests/api/videos/multiple-servers.ts b/server/tests/api/videos/multiple-servers.ts index 4c4b5123d..0215b3011 100644 --- a/server/tests/api/videos/multiple-servers.ts +++ b/server/tests/api/videos/multiple-servers.ts | |||
| @@ -475,16 +475,17 @@ describe('Test multiple servers', function () { | |||
| 475 | it('Should like and dislikes videos on different services', async function () { | 475 | it('Should like and dislikes videos on different services', async function () { |
| 476 | this.timeout(20000) | 476 | this.timeout(20000) |
| 477 | 477 | ||
| 478 | const tasks: Promise<any>[] = [] | 478 | await rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'like') |
| 479 | tasks.push(rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'like')) | 479 | await wait(200) |
| 480 | tasks.push(rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'dislike')) | 480 | await rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'dislike') |
| 481 | tasks.push(rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'like')) | 481 | await wait(200) |
| 482 | tasks.push(rateVideo(servers[2].url, servers[2].accessToken, localVideosServer3[1], 'like')) | 482 | await rateVideo(servers[0].url, servers[0].accessToken, remoteVideosServer1[0], 'like') |
| 483 | tasks.push(rateVideo(servers[2].url, servers[2].accessToken, localVideosServer3[1], 'dislike')) | 483 | await rateVideo(servers[2].url, servers[2].accessToken, localVideosServer3[1], 'like') |
| 484 | tasks.push(rateVideo(servers[2].url, servers[2].accessToken, remoteVideosServer3[1], 'dislike')) | 484 | await wait(200) |
| 485 | tasks.push(rateVideo(servers[2].url, servers[2].accessToken, remoteVideosServer3[0], 'like')) | 485 | await rateVideo(servers[2].url, servers[2].accessToken, localVideosServer3[1], 'dislike') |
| 486 | 486 | await rateVideo(servers[2].url, servers[2].accessToken, remoteVideosServer3[1], 'dislike') | |
| 487 | await Promise.all(tasks) | 487 | await wait(200) |
| 488 | await rateVideo(servers[2].url, servers[2].accessToken, remoteVideosServer3[0], 'like') | ||
| 488 | 489 | ||
| 489 | await wait(10000) | 490 | await wait(10000) |
| 490 | 491 | ||