X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=scripts%2Fparse-log.ts;h=065fe7e82ff5e7b7c678f3c1400bec09f88c2609;hb=1e743faafeed89af13ee9dd3d62c1ceb696779cd;hp=26049b54d993e9f24753ed26bfc9e7dbe1ec8d95;hpb=1b05d82d861f42c27766e9f24d8d55e68b0cf098;p=github%2FChocobozzz%2FPeerTube.git diff --git a/scripts/parse-log.ts b/scripts/parse-log.ts index 26049b54d..065fe7e82 100755 --- a/scripts/parse-log.ts +++ b/scripts/parse-log.ts @@ -9,9 +9,11 @@ import * as winston from 'winston' import { labelFormatter } from '../server/helpers/logger' import { CONFIG } from '../server/initializers/config' import { mtimeSortFilesDesc } from '../shared/core-utils/logs/logs' +import { inspect } from 'util' program .option('-l, --level [level]', 'Level log (debug/info/warn/error)') + .option('-f, --files [file...]', 'Files to parse. If not provided, the script will parse the latest log file from config)') .parse(process.argv) const excludedKeys = { @@ -62,27 +64,32 @@ run() function run () { return new Promise(async res => { - const logFiles = await readdir(CONFIG.STORAGE.LOG_DIR) - const lastLogFile = await getNewestFile(logFiles, CONFIG.STORAGE.LOG_DIR) + const files = await getFiles() - const path = join(CONFIG.STORAGE.LOG_DIR, lastLogFile) - console.log('Opening %s.', path) + for (const file of files) { + console.log('Opening %s.', file) - const stream = createReadStream(path) + const stream = createReadStream(file) - const rl = createInterface({ - input: stream - }) + const rl = createInterface({ + input: stream + }) - rl.on('line', line => { - const log = JSON.parse(line) - // Don't know why but loggerFormat does not remove splat key - Object.assign(log, { splat: undefined }) + rl.on('line', line => { + try { + const log = JSON.parse(line) + // Don't know why but loggerFormat does not remove splat key + Object.assign(log, { splat: undefined }) - logLevels[ log.level ](log) - }) + logLevels[log.level](log) + } catch (err) { + console.error('Cannot parse line.', inspect(line)) + throw err + } + }) - stream.once('close', () => res()) + stream.once('close', () => res()) + } }) } @@ -90,7 +97,16 @@ function run () { async function getNewestFile (files: string[], basePath: string) { const sorted = await mtimeSortFilesDesc(files, basePath) - return (sorted.length > 0) ? sorted[ 0 ].file : '' + return (sorted.length > 0) ? sorted[0].file : '' +} + +async function getFiles () { + if (program['files']) return program['files'] + + const logFiles = await readdir(CONFIG.STORAGE.LOG_DIR) + + const filename = await getNewestFile(logFiles, CONFIG.STORAGE.LOG_DIR) + return [ join(CONFIG.STORAGE.LOG_DIR, filename) ] } function toTimeFormat (time: string) {