1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
4 import * as chai from 'chai'
5 import { Job } from '@shared/models'
11 setAccessTokensToServers,
13 } from '@shared/server-commands'
15 const expect = chai.expect
17 describe('Test slow follows', function () {
18 let servers: PeerTubeServer[] = []
20 let afterFollows: Date
22 before(async function () {
25 servers = await createMultipleServers(3)
27 // Get the access tokens
28 await setAccessTokensToServers(servers)
30 await doubleFollow(servers[0], servers[1])
31 await doubleFollow(servers[0], servers[2])
33 afterFollows = new Date()
35 for (let i = 0; i < 5; i++) {
36 await servers[0].videos.quickUpload({ name: 'video ' + i })
39 await waitJobs(servers)
42 it('Should only have broadcast jobs', async function () {
43 const { data } = await servers[0].jobs.list({ jobType: 'activitypub-http-unicast', sort: '-createdAt' })
45 for (const job of data) {
46 expect(new Date(job.createdAt)).below(afterFollows)
50 it('Should process bad follower', async function () {
53 await servers[1].kill()
55 // Set server 2 as bad follower
56 await servers[0].videos.quickUpload({ name: 'video 6' })
57 await waitJobs(servers[0])
59 afterFollows = new Date()
60 const filter = (job: Job) => new Date(job.createdAt) > afterFollows
62 // Resend another broadcast job
63 await servers[0].videos.quickUpload({ name: 'video 7' })
64 await waitJobs(servers[0])
66 const resBroadcast = await servers[0].jobs.list({ jobType: 'activitypub-http-broadcast', sort: '-createdAt' })
67 const resUnicast = await servers[0].jobs.list({ jobType: 'activitypub-http-unicast', sort: '-createdAt' })
69 const broadcast = resBroadcast.data.filter(filter)
70 const unicast = resUnicast.data.filter(filter)
72 expect(unicast).to.have.lengthOf(2)
73 expect(broadcast).to.have.lengthOf(2)
75 for (const u of unicast) {
76 expect(u.data.uri).to.equal(servers[1].url + '/inbox')
79 for (const b of broadcast) {
80 expect(b.data.uris).to.have.lengthOf(1)
81 expect(b.data.uris[0]).to.equal(servers[2].url + '/inbox')
85 after(async function () {
86 await cleanupTests(servers)