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, killallServers, makeGetRequest, makePingRequest, reRunServer, 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
  24     it('Should get logs with a start date', async function () {
  25       this.timeout(10000)
  26
  27       await uploadVideo(server.url, server.accessToken, { name: 'video 1' })
  28       await waitJobs([ server ])
  29
  30       const now = new Date()
  31
  32       await uploadVideo(server.url, server.accessToken, { name: 'video 2' })
  33       await waitJobs([ server ])
  34
  35       const res = await getLogs(server.url, server.accessToken, now)
  36       const logsString = JSON.stringify(res.body)
  37
  38       expect(logsString.includes('video 1')).to.be.false
  39       expect(logsString.includes('video 2')).to.be.true
  40     })
  41
  42     it('Should get logs with an end date', async function () {
  43       this.timeout(20000)
  44
  45       await uploadVideo(server.url, server.accessToken, { name: 'video 3' })
  46       await waitJobs([ server ])
  47
  48       const now1 = new Date()
  49
  50       await uploadVideo(server.url, server.accessToken, { name: 'video 4' })
  51       await waitJobs([ server ])
  52
  53       const now2 = new Date()
  54
  55       await uploadVideo(server.url, server.accessToken, { name: 'video 5' })
  56       await waitJobs([ server ])
  57
  58       const res = await getLogs(server.url, server.accessToken, now1, now2)
  59       const logsString = JSON.stringify(res.body)
  60
  61       expect(logsString.includes('video 3')).to.be.false
  62       expect(logsString.includes('video 4')).to.be.true
  63       expect(logsString.includes('video 5')).to.be.false
  64     })
  65
  66     it('Should get filter by level', async function () {
  67       this.timeout(10000)
  68
  69       const now = new Date()
  70
  71       await uploadVideo(server.url, server.accessToken, { name: 'video 6' })
  72       await waitJobs([ server ])
  73
  74       {
  75         const res = await getLogs(server.url, server.accessToken, now, undefined, 'info')
  76         const logsString = JSON.stringify(res.body)
  77
  78         expect(logsString.includes('video 6')).to.be.true
  79       }
  80
  81       {
  82         const res = await getLogs(server.url, server.accessToken, now, undefined, 'warn')
  83         const logsString = JSON.stringify(res.body)
  84
  85         expect(logsString.includes('video 6')).to.be.false
  86       }
  87     })
  88
  89     it('Should log ping requests', async function () {
  90       const now = new Date()
  91
  92       await makePingRequest(server)
  93
  94       const res = await getLogs(server.url, server.accessToken, now, undefined, 'info')
  95       const logsString = JSON.stringify(res.body)
  96
  97       expect(logsString.includes('/api/v1/ping')).to.be.true
  98     })
  99
 100     it('Should not log ping requests', async function () {
 101       this.timeout(30000)
 102
 103       killallServers([ server ])
 104
 105       await reRunServer(server, { log: { log_ping_requests: false } })
 106
 107       const now = new Date()
 108
 109       await makePingRequest(server)
 110
 111       const res = await getLogs(server.url, server.accessToken, now, undefined, 'info')
 112       const logsString = JSON.stringify(res.body)
 113
 114       expect(logsString.includes('/api/v1/ping')).to.be.false
 115     })
 116   })
 117
 118   describe('With the audit log', function () {
 119     it('Should get logs with a start date', async function () {
 120       this.timeout(10000)
 121
 122       await uploadVideo(server.url, server.accessToken, { name: 'video 7' })
 123       await waitJobs([ server ])
 124
 125       const now = new Date()
 126
 127       await uploadVideo(server.url, server.accessToken, { name: 'video 8' })
 128       await waitJobs([ server ])
 129
 130       const res = await getAuditLogs(server.url, server.accessToken, now)
 131       const logsString = JSON.stringify(res.body)
 132
 133       expect(logsString.includes('video 7')).to.be.false
 134       expect(logsString.includes('video 8')).to.be.true
 135
 136       expect(res.body).to.have.lengthOf(1)
 137
 138       const item = res.body[0]
 139
 140       const message = JSON.parse(item.message)
 141       expect(message.domain).to.equal('videos')
 142       expect(message.action).to.equal('create')
 143     })
 144
 145     it('Should get logs with an end date', async function () {
 146       this.timeout(20000)
 147
 148       await uploadVideo(server.url, server.accessToken, { name: 'video 9' })
 149       await waitJobs([ server ])
 150
 151       const now1 = new Date()
 152
 153       await uploadVideo(server.url, server.accessToken, { name: 'video 10' })
 154       await waitJobs([ server ])
 155
 156       const now2 = new Date()
 157
 158       await uploadVideo(server.url, server.accessToken, { name: 'video 11' })
 159       await waitJobs([ server ])
 160
 161       const res = await getAuditLogs(server.url, server.accessToken, now1, now2)
 162       const logsString = JSON.stringify(res.body)
 163
 164       expect(logsString.includes('video 9')).to.be.false
 165       expect(logsString.includes('video 10')).to.be.true
 166       expect(logsString.includes('video 11')).to.be.false
 167     })
 168   })
 169
 170   after(async function () {
 171     await cleanupTests([ server ])
 172   })
 173 })