1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
3 import { expect } from 'chai'
4 import { wait } from '@shared/core-utils'
11 setAccessTokensToServers,
13 } from '@shared/server-commands'
15 describe('Test video views cleaner', function () {
16 let servers: PeerTubeServer[]
18 let videoIdServer1: string
19 let videoIdServer2: string
21 before(async function () {
24 servers = await createMultipleServers(2)
25 await setAccessTokensToServers(servers)
27 await doubleFollow(servers[0], servers[1])
29 videoIdServer1 = (await servers[0].videos.quickUpload({ name: 'video server 1' })).uuid
30 videoIdServer2 = (await servers[1].videos.quickUpload({ name: 'video server 2' })).uuid
32 await waitJobs(servers)
34 await servers[0].views.simulateView({ id: videoIdServer1 })
35 await servers[1].views.simulateView({ id: videoIdServer1 })
36 await servers[0].views.simulateView({ id: videoIdServer2 })
37 await servers[1].views.simulateView({ id: videoIdServer2 })
39 await waitJobs(servers)
42 it('Should not clean old video views', async function () {
45 await killallServers([ servers[0] ])
47 await servers[0].run({ views: { videos: { remote: { max_age: '10 days' } } } })
51 // Should still have views
54 for (const server of servers) {
55 const total = await server.sql.countVideoViewsOf(videoIdServer1)
56 expect(total).to.equal(2, 'Server ' + server.serverNumber + ' does not have the correct amount of views')
61 for (const server of servers) {
62 const total = await server.sql.countVideoViewsOf(videoIdServer2)
63 expect(total).to.equal(2, 'Server ' + server.serverNumber + ' does not have the correct amount of views')
68 it('Should clean old video views', async function () {
71 await killallServers([ servers[0] ])
73 await servers[0].run({ views: { videos: { remote: { max_age: '5 seconds' } } } })
77 // Should still have views
80 for (const server of servers) {
81 const total = await server.sql.countVideoViewsOf(videoIdServer1)
82 expect(total).to.equal(2)
87 const totalServer1 = await servers[0].sql.countVideoViewsOf(videoIdServer2)
88 expect(totalServer1).to.equal(0)
90 const totalServer2 = await servers[1].sql.countVideoViewsOf(videoIdServer2)
91 expect(totalServer2).to.equal(2)
95 after(async function () {
96 await cleanupTests(servers)