server/tests/api/server/logs.ts

   1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
   2
   3 import * as chai from 'chai'
   4 import 'mocha'
   5 import { cleanupTests, flushAndRunServer, ServerInfo, setAccessTokensToServers } from '../../../../shared/extra-utils/index'
   6 import { waitJobs } from '../../../../shared/extra-utils/server/jobs'
   7 import { uploadVideo } from '../../../../shared/extra-utils/videos/videos'
   8 import { getAuditLogs, getLogs } from '../../../../shared/extra-utils/logs/logs'
   9
  10 const expect = chai.expect
  11
  12 describe('Test logs', function () {
  13   let server: ServerInfo
  14
  15   before(async function () {
  16     this.timeout(30000)
  17
  18     server = await flushAndRunServer(1)
  19     await setAccessTokensToServers([ server ])
  20   })
  21
  22   describe('With the standard log file', function () {
  23     it('Should get logs with a start date', async function () {
  24       this.timeout(10000)
  25
  26       await uploadVideo(server.url, server.accessToken, { name: 'video 1' })
  27       await waitJobs([ server ])
  28
  29       const now = new Date()
  30
  31       await uploadVideo(server.url, server.accessToken, { name: 'video 2' })
  32       await waitJobs([ server ])
  33
  34       const res = await getLogs(server.url, server.accessToken, now)
  35       const logsString = JSON.stringify(res.body)
  36
  37       expect(logsString.includes('video 1')).to.be.false
  38       expect(logsString.includes('video 2')).to.be.true
  39     })
  40
  41     it('Should get logs with an end date', async function () {
  42       this.timeout(20000)
  43
  44       await uploadVideo(server.url, server.accessToken, { name: 'video 3' })
  45       await waitJobs([ server ])
  46
  47       const now1 = new Date()
  48
  49       await uploadVideo(server.url, server.accessToken, { name: 'video 4' })
  50       await waitJobs([ server ])
  51
  52       const now2 = new Date()
  53
  54       await uploadVideo(server.url, server.accessToken, { name: 'video 5' })
  55       await waitJobs([ server ])
  56
  57       const res = await getLogs(server.url, server.accessToken, now1, now2)
  58       const logsString = JSON.stringify(res.body)
  59
  60       expect(logsString.includes('video 3')).to.be.false
  61       expect(logsString.includes('video 4')).to.be.true
  62       expect(logsString.includes('video 5')).to.be.false
  63     })
  64
  65     it('Should get filter by level', async function () {
  66       this.timeout(10000)
  67
  68       const now = new Date()
  69
  70       await uploadVideo(server.url, server.accessToken, { name: 'video 6' })
  71       await waitJobs([ server ])
  72
  73       {
  74         const res = await getLogs(server.url, server.accessToken, now, undefined, 'info')
  75         const logsString = JSON.stringify(res.body)
  76
  77         expect(logsString.includes('video 6')).to.be.true
  78       }
  79
  80       {
  81         const res = await getLogs(server.url, server.accessToken, now, undefined, 'warn')
  82         const logsString = JSON.stringify(res.body)
  83
  84         expect(logsString.includes('video 6')).to.be.false
  85       }
  86     })
  87   })
  88
  89   describe('With the audit log', function () {
  90     it('Should get logs with a start date', async function () {
  91       this.timeout(10000)
  92
  93       await uploadVideo(server.url, server.accessToken, { name: 'video 7' })
  94       await waitJobs([ server ])
  95
  96       const now = new Date()
  97
  98       await uploadVideo(server.url, server.accessToken, { name: 'video 8' })
  99       await waitJobs([ server ])
 100
 101       const res = await getAuditLogs(server.url, server.accessToken, now)
 102       const logsString = JSON.stringify(res.body)
 103
 104       expect(logsString.includes('video 7')).to.be.false
 105       expect(logsString.includes('video 8')).to.be.true
 106
 107       expect(res.body).to.have.lengthOf(1)
 108
 109       const item = res.body[0]
 110
 111       const message = JSON.parse(item.message)
 112       expect(message.domain).to.equal('videos')
 113       expect(message.action).to.equal('create')
 114     })
 115
 116     it('Should get logs with an end date', async function () {
 117       this.timeout(20000)
 118
 119       await uploadVideo(server.url, server.accessToken, { name: 'video 9' })
 120       await waitJobs([ server ])
 121
 122       const now1 = new Date()
 123
 124       await uploadVideo(server.url, server.accessToken, { name: 'video 10' })
 125       await waitJobs([ server ])
 126
 127       const now2 = new Date()
 128
 129       await uploadVideo(server.url, server.accessToken, { name: 'video 11' })
 130       await waitJobs([ server ])
 131
 132       const res = await getAuditLogs(server.url, server.accessToken, now1, now2)
 133       const logsString = JSON.stringify(res.body)
 134
 135       expect(logsString.includes('video 9')).to.be.false
 136       expect(logsString.includes('video 10')).to.be.true
 137       expect(logsString.includes('video 11')).to.be.false
 138     })
 139   })
 140
 141   after(async function () {
 142     await cleanupTests([ server ])
 143   })
 144 })