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