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