1 import * as express from 'express'
2 import { UserRight } from '../../../../shared/models/users'
3 import { asyncMiddleware, authenticate, ensureUserHasRight } from '../../../middlewares'
4 import { mtimeSortFilesDesc } from '../../../../shared/core-utils/logs/logs'
5 import { readdir, readFile } from 'fs-extra'
6 import { MAX_LOGS_OUTPUT_CHARACTERS } from '../../../initializers/constants'
7 import { join } from 'path'
8 import { getLogsValidator } from '../../../middlewares/validators/logs'
9 import { LogLevel } from '../../../../shared/models/server/log-level.type'
10 import { CONFIG } from '../../../initializers/config'
12 const logsRouter = express.Router()
14 logsRouter.get('/logs',
16 ensureUserHasRight(UserRight.MANAGE_LOGS),
18 asyncMiddleware(getLogs)
21 // ---------------------------------------------------------------------------
27 // ---------------------------------------------------------------------------
29 async function getLogs (req: express.Request, res: express.Response) {
30 const logFiles = await readdir(CONFIG.STORAGE.LOG_DIR)
31 const sortedLogFiles = await mtimeSortFilesDesc(logFiles, CONFIG.STORAGE.LOG_DIR)
34 const startDate = new Date(req.query.startDate)
35 const endDate = req.query.endDate ? new Date(req.query.endDate) : new Date()
36 const level: LogLevel = req.query.level || 'info'
38 let output: string[] = []
40 for (const meta of sortedLogFiles) {
41 const path = join(CONFIG.STORAGE.LOG_DIR, meta.file)
43 const result = await getOutputFromFile(path, startDate, endDate, level, currentSize)
44 if (!result.output) break
46 output = result.output.concat(output)
47 currentSize = result.currentSize
49 if (currentSize > MAX_LOGS_OUTPUT_CHARACTERS || (result.logTime && result.logTime < startDate.getTime())) break
52 return res.json(output).end()
55 async function getOutputFromFile (path: string, startDate: Date, endDate: Date, level: LogLevel, currentSize: number) {
56 const startTime = startDate.getTime()
57 const endTime = endDate.getTime()
60 const logsLevel: { [ id in LogLevel ]: number } = {
67 const content = await readFile(path)
68 const lines = content.toString().split('\n')
69 const output: any[] = []
71 for (let i = lines.length - 1; i >= 0; i--) {
72 const line = lines[ i ]
76 log = JSON.parse(line)
78 // Maybe there a multiple \n at the end of the file
82 logTime = new Date(log.timestamp).getTime()
83 if (logTime >= startTime && logTime <= endTime && logsLevel[ log.level ] >= logsLevel[ level ]) {
86 currentSize += line.length
88 if (currentSize > MAX_LOGS_OUTPUT_CHARACTERS) break
89 } else if (logTime < startTime) {
94 return { currentSize, output: output.reverse(), logTime }