1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
3 import { expect } from 'chai'
4 import { HttpStatusCode } from '@shared/models'
11 setAccessTokensToServers,
13 } from '@shared/server-commands'
15 describe('Test logs', function () {
16 let server: PeerTubeServer
17 let logsCommand: LogsCommand
19 before(async function () {
22 server = await createSingleServer(1)
23 await setAccessTokensToServers([ server ])
25 logsCommand = server.logs
28 describe('With the standard log file', function () {
30 it('Should get logs with a start date', async function () {
33 await server.videos.upload({ attributes: { name: 'video 1' } })
34 await waitJobs([ server ])
36 const now = new Date()
38 await server.videos.upload({ attributes: { name: 'video 2' } })
39 await waitJobs([ server ])
41 const body = await logsCommand.getLogs({ startDate: now })
42 const logsString = JSON.stringify(body)
44 expect(logsString.includes('video 1')).to.be.false
45 expect(logsString.includes('video 2')).to.be.true
48 it('Should get logs with an end date', async function () {
51 await server.videos.upload({ attributes: { name: 'video 3' } })
52 await waitJobs([ server ])
54 const now1 = new Date()
56 await server.videos.upload({ attributes: { name: 'video 4' } })
57 await waitJobs([ server ])
59 const now2 = new Date()
61 await server.videos.upload({ attributes: { name: 'video 5' } })
62 await waitJobs([ server ])
64 const body = await logsCommand.getLogs({ startDate: now1, endDate: now2 })
65 const logsString = JSON.stringify(body)
67 expect(logsString.includes('video 3')).to.be.false
68 expect(logsString.includes('video 4')).to.be.true
69 expect(logsString.includes('video 5')).to.be.false
72 it('Should filter by level', async function () {
75 const now = new Date()
77 await server.videos.upload({ attributes: { name: 'video 6' } })
78 await waitJobs([ server ])
81 const body = await logsCommand.getLogs({ startDate: now, level: 'info' })
82 const logsString = JSON.stringify(body)
84 expect(logsString.includes('video 6')).to.be.true
88 const body = await logsCommand.getLogs({ startDate: now, level: 'warn' })
89 const logsString = JSON.stringify(body)
91 expect(logsString.includes('video 6')).to.be.false
95 it('Should filter by tag', async function () {
96 const now = new Date()
98 const { uuid } = await server.videos.upload({ attributes: { name: 'video 6' } })
99 await waitJobs([ server ])
102 const body = await logsCommand.getLogs({ startDate: now, level: 'debug', tagsOneOf: [ 'toto' ] })
103 expect(body).to.have.lengthOf(0)
107 const body = await logsCommand.getLogs({ startDate: now, level: 'debug', tagsOneOf: [ uuid ] })
108 expect(body).to.not.have.lengthOf(0)
110 for (const line of body) {
111 expect(line.tags).to.contain(uuid)
116 it('Should log ping requests', async function () {
119 const now = new Date()
121 await server.servers.ping()
123 const body = await logsCommand.getLogs({ startDate: now, level: 'info' })
124 const logsString = JSON.stringify(body)
126 expect(logsString.includes('/api/v1/ping')).to.be.true
129 it('Should not log ping requests', async function () {
132 await killallServers([ server ])
134 await server.run({ log: { log_ping_requests: false } })
136 const now = new Date()
138 await server.servers.ping()
140 const body = await logsCommand.getLogs({ startDate: now, level: 'info' })
141 const logsString = JSON.stringify(body)
143 expect(logsString.includes('/api/v1/ping')).to.be.false
147 describe('With the audit log', function () {
149 it('Should get logs with a start date', async function () {
152 await server.videos.upload({ attributes: { name: 'video 7' } })
153 await waitJobs([ server ])
155 const now = new Date()
157 await server.videos.upload({ attributes: { name: 'video 8' } })
158 await waitJobs([ server ])
160 const body = await logsCommand.getAuditLogs({ startDate: now })
161 const logsString = JSON.stringify(body)
163 expect(logsString.includes('video 7')).to.be.false
164 expect(logsString.includes('video 8')).to.be.true
166 expect(body).to.have.lengthOf(1)
170 const message = JSON.parse(item.message)
171 expect(message.domain).to.equal('videos')
172 expect(message.action).to.equal('create')
175 it('Should get logs with an end date', async function () {
178 await server.videos.upload({ attributes: { name: 'video 9' } })
179 await waitJobs([ server ])
181 const now1 = new Date()
183 await server.videos.upload({ attributes: { name: 'video 10' } })
184 await waitJobs([ server ])
186 const now2 = new Date()
188 await server.videos.upload({ attributes: { name: 'video 11' } })
189 await waitJobs([ server ])
191 const body = await logsCommand.getAuditLogs({ startDate: now1, endDate: now2 })
192 const logsString = JSON.stringify(body)
194 expect(logsString.includes('video 9')).to.be.false
195 expect(logsString.includes('video 10')).to.be.true
196 expect(logsString.includes('video 11')).to.be.false
200 describe('When creating log from the client', function () {
202 it('Should create a warn client log', async function () {
203 const now = new Date()
205 await server.logs.createLogClient({
208 url: 'http://example.com',
209 message: 'my super client message'
214 const body = await logsCommand.getLogs({ startDate: now })
215 const logsString = JSON.stringify(body)
217 expect(logsString.includes('my super client message')).to.be.true
220 it('Should create an error authenticated client log', async function () {
221 const now = new Date()
223 await server.logs.createLogClient({
225 url: 'https://example.com/page1',
227 message: 'my super client message 2',
228 userAgent: 'super user agent',
230 stackTrace: 'super stack trace'
234 const body = await logsCommand.getLogs({ startDate: now })
235 const logsString = JSON.stringify(body)
237 expect(logsString.includes('my super client message 2')).to.be.true
238 expect(logsString.includes('super user agent')).to.be.true
239 expect(logsString.includes('super stack trace')).to.be.true
240 expect(logsString.includes('{hello}')).to.be.true
241 expect(logsString.includes('https://example.com/page1')).to.be.true
244 it('Should refuse to create client logs', async function () {
249 accept_client_log: false
253 await server.logs.createLogClient({
256 url: 'http://example.com',
257 message: 'my super client message'
259 expectedStatus: HttpStatusCode.FORBIDDEN_403
264 after(async function () {
265 await cleanupTests([ server ])