server/tests/api/videos/videos-views-cleaner.ts

   1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
   2
   3 import 'mocha'
   4 import * as chai from 'chai'
   5 import {
   6   cleanupTests,
   7   doubleFollow,
   8   flushAndRunMultipleServers,
   9   killallServers,
  10   reRunServer,
  11   ServerInfo,
  12   setAccessTokensToServers,
  13   wait,
  14   waitJobs
  15 } from '../../../../shared/extra-utils'
  16
  17 const expect = chai.expect
  18
  19 describe('Test video views cleaner', function () {
  20   let servers: ServerInfo[]
  21
  22   let videoIdServer1: string
  23   let videoIdServer2: string
  24
  25   before(async function () {
  26     this.timeout(120000)
  27
  28     servers = await flushAndRunMultipleServers(2)
  29     await setAccessTokensToServers(servers)
  30
  31     await doubleFollow(servers[0], servers[1])
  32
  33     videoIdServer1 = (await servers[0].videosCommand.quickUpload({ name: 'video server 1' })).uuid
  34     videoIdServer2 = (await servers[1].videosCommand.quickUpload({ name: 'video server 2' })).uuid
  35
  36     await waitJobs(servers)
  37
  38     await servers[0].videosCommand.view({ id: videoIdServer1 })
  39     await servers[1].videosCommand.view({ id: videoIdServer1 })
  40     await servers[0].videosCommand.view({ id: videoIdServer2 })
  41     await servers[1].videosCommand.view({ id: videoIdServer2 })
  42
  43     await waitJobs(servers)
  44   })
  45
  46   it('Should not clean old video views', async function () {
  47     this.timeout(50000)
  48
  49     await killallServers([ servers[0] ])
  50
  51     await reRunServer(servers[0], { views: { videos: { remote: { max_age: '10 days' } } } })
  52
  53     await wait(6000)
  54
  55     // Should still have views
  56
  57     {
  58       for (const server of servers) {
  59         const total = await server.sqlCommand.countVideoViewsOf(videoIdServer1)
  60         expect(total).to.equal(2, 'Server ' + server.serverNumber + ' does not have the correct amount of views')
  61       }
  62     }
  63
  64     {
  65       for (const server of servers) {
  66         const total = await server.sqlCommand.countVideoViewsOf(videoIdServer2)
  67         expect(total).to.equal(2, 'Server ' + server.serverNumber + ' does not have the correct amount of views')
  68       }
  69     }
  70   })
  71
  72   it('Should clean old video views', async function () {
  73     this.timeout(50000)
  74
  75     await killallServers([ servers[0] ])
  76
  77     await reRunServer(servers[0], { views: { videos: { remote: { max_age: '5 seconds' } } } })
  78
  79     await wait(6000)
  80
  81     // Should still have views
  82
  83     {
  84       for (const server of servers) {
  85         const total = await server.sqlCommand.countVideoViewsOf(videoIdServer1)
  86         expect(total).to.equal(2)
  87       }
  88     }
  89
  90     {
  91       const totalServer1 = await servers[0].sqlCommand.countVideoViewsOf(videoIdServer2)
  92       expect(totalServer1).to.equal(0)
  93
  94       const totalServer2 = await servers[1].sqlCommand.countVideoViewsOf(videoIdServer2)
  95       expect(totalServer2).to.equal(2)
  96     }
  97   })
  98
  99   after(async function () {
 100     await cleanupTests(servers)
 101   })
 102 })