Untitled

"use strict";
var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
    return c > 3 && r && Object.defineProperty(target, key, r), r;
};
var __metadata = (this && this.__metadata) || function (k, v) {
    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.trimLogs = exports.LogTask = void 0;
const common_1 = require("@nestjs/common");
const schedule_1 = require("@nestjs/schedule");
const App_1 = require("../service/configuration/App");
const fs = require("fs");
const readline = require("readline");
const logspath = App_1.App.LOGS_PATH;
const trim_limit = 10000;
const directory_level_limit = 3;
let LogTask = class LogTask {
    constructor() { }
    _trimLogs() {
        trimLogs();
    }
};
exports.LogTask = LogTask;
__decorate([
    (0, schedule_1.Cron)(schedule_1.CronExpression.EVERY_5_MINUTES),
    __metadata("design:type", Function),
    __metadata("design:paramtypes", []),
    __metadata("design:returntype", void 0)
], LogTask.prototype, "_trimLogs", null);
exports.LogTask = LogTask = __decorate([
    (0, common_1.Injectable)(),
    __metadata("design:paramtypes", [])
], LogTask);
function trimLogs(directory = logspath, level = 0) {
    if (level > directory_level_limit) {
        console.warn("There are some directories in logs/ that will not be trimmed due to directory_level_limit being set too low. This should't happen naturally.");
        console.warn(directory);
        return;
    }
    const lines = fs.readdirSync(directory);
    for (const line of lines) {
        let absolute_path = directory + '/' + line;
        let file_or_directory = fs.statSync(absolute_path);
        if (file_or_directory.isFile() && absolute_path.endsWith('.log')) {
            trimFile(absolute_path, trim_limit);
        }
        else if (file_or_directory.isDirectory()) {
            trimLogs(absolute_path, level + 1);
        }
        else if (file_or_directory.isFile() && !absolute_path.endsWith('.log')) {
        }
        else if (file_or_directory.isSymbolicLink()) {
        }
        else {
            console.error("Unable to determine path: " + absolute_path);
        }
    }
}
exports.trimLogs = trimLogs;
function trimFile(filepath, limit) {
    const tempFilePath = filepath + '.tmp';
    const writeStream = fs.createWriteStream(tempFilePath);
    const readlineMachine = readline.createInterface({
        input: fs.createReadStream(filepath),
        crlfDelay: Infinity,
    });
    let linesCount = 0;
    let linesBuffer = [];
    readlineMachine.on('line', (line) => {
        linesBuffer.push(line);
        linesCount++;
        if (linesCount >= limit) {
            linesBuffer.shift();
        }
    });
    readlineMachine.on('close', () => {
        for (const line of linesBuffer) {
            writeStream.write(line + '\n');
        }
        writeStream.end(() => {
            fs.rename(tempFilePath, filepath, (err) => {
                if (err) {
                    console.error('Error renaming file: ' + tempFilePath
                        + ' to ' + filepath, err);
                }
                else {
                    console.log('Renamed file: ' + tempFilePath
                        + ' to ' + filepath);
                }
            });
        });
        console.log('Trimmed file: ' + filepath);
    });
    readlineMachine.on('error', (err) => {
        console.error('Error reading file:' + filepath, err);
        readlineMachine.close();
        writeStream.end();
    });
    writeStream.on('error', (err) => {
        console.error('Error writing file:' + filepath, err);
        readlineMachine.close();
        writeStream.end();
    });
}
//# sourceMappingURL=log.task.js.map