Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
@skava/graphql / dist / graphql-modules / pm2 / transform.js
Size: Mime:
"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const log_1 = require("../../log");
const fixture_1 = require("./fixture");
exports.fromProcessDescriptionListToResponse = (list) => {
    if (list.length === 0) {
        log_1.logger.warn('[@skava/graphql]{pm2} had empty list of processes');
        return fixture_1.fixture;
    }
    const [description] = list;
    const pm2env = {
        cwd: description.pm2_env.pm_cwd,
        errorLogPath: description.pm2_env.pm_err_log_path,
        logPath: description.pm2_env.pm_out_log_path,
        restartTime: description.pm2_env.restart_time,
        status: description.pm2_env.status,
        executionPath: description.pm2_env.pm_exec_path,
    };
    return {
        processId: description.pid,
        processManagerProcessId: description.pm_id,
        env: pm2env,
        monitor: description.monit,
    };
};
/** @todo typings */
const parse_1 = __importDefault(require("date-fns/parse"));
const is_before_1 = __importDefault(require("date-fns/is_before"));
const is_after_1 = __importDefault(require("date-fns/is_after"));
const distance_in_words_to_now_1 = __importDefault(require("date-fns/distance_in_words_to_now"));
const exotic_1 = require("exotic");
exports.fromLogListToFormatted = (list) => {
    return list.map(exports.fromLogToFormatted);
};
exports.fromLogToFormatted = (item) => {
    const timestamp = item.timestamp
        ? distance_in_words_to_now_1.default(item.timestamp)
        : 'missing timestamp!';
    return {
        timestampFull: item.timestamp,
        timestamp,
        correlationId: item.correlationId,
        message: item.message,
    };
};
exports.fromLogArgsToCoerced = (args) => {
    const before = exotic_1.isNonEmptyString(args.before) ? parse_1.default(args.before) : '';
    const after = exotic_1.isNonEmptyString(args.after) ? parse_1.default(args.after) : '';
    const matches = exotic_1.isString(args.matches) && args.matches.includes('/')
        ? new RegExp(args.matches, 'gmi')
        : args.matches || '';
    return { before, after, matches };
};
exports.isRawArgs = (args) => !!args.password;
exports.filterLogListForArgs = (list, rawArgs) => {
    const args = exports.isRawArgs(rawArgs) ? exports.fromLogArgsToCoerced(rawArgs) : rawArgs;
    return list.filter(item => {
        const date = parse_1.default(item.timestamp);
        // 1st before 2nd
        if (args.before && !is_before_1.default(date, args.before)) {
            // logger.debug('[@skava/graphql]{logs.transform} removing `before`')
            return false;
        }
        // 1st after 2nd
        if (args.after && !is_after_1.default(date, args.after)) {
            // logger.debug('[@skava/graphql]{logs.transform} removing `after`')
            return false;
        }
        // @todo truthy fix
        if (args.matches) {
            // logger.debug('[@skava/graphql]{logs.transform} removing `matches`')
            if (exotic_1.isString(args.matches)) {
                return item.message && item.message.includes(args.matches);
            }
            else {
                return args.matches.test(item.message);
            }
        }
        return true;
    });
};
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidHJhbnNmb3JtLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vc3JjL2dyYXBocWwtbW9kdWxlcy9wbTIvdHJhbnNmb3JtLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQ0EsbUNBQWtDO0FBQ2xDLHVDQUFtQztBQUV0QixRQUFBLG9DQUFvQyxHQUFHLENBQ2xELElBQTBCLEVBQzFCLEVBQUU7SUFDRixJQUFJLElBQUksQ0FBQyxNQUFNLEtBQUssQ0FBQyxFQUFFO1FBQ3JCLFlBQU0sQ0FBQyxJQUFJLENBQUMsbURBQW1ELENBQUMsQ0FBQTtRQUNoRSxPQUFPLGlCQUFPLENBQUE7S0FDZjtJQUVELE1BQU0sQ0FBQyxXQUFXLENBQUMsR0FBRyxJQUFJLENBQUE7SUFFMUIsTUFBTSxNQUFNLEdBQUc7UUFDYixHQUFHLEVBQUUsV0FBVyxDQUFDLE9BQU8sQ0FBQyxNQUFNO1FBQy9CLFlBQVksRUFBRSxXQUFXLENBQUMsT0FBTyxDQUFDLGVBQWU7UUFDakQsT0FBTyxFQUFFLFdBQVcsQ0FBQyxPQUFPLENBQUMsZUFBZTtRQUM1QyxXQUFXLEVBQUUsV0FBVyxDQUFDLE9BQU8sQ0FBQyxZQUFZO1FBQzdDLE1BQU0sRUFBRSxXQUFXLENBQUMsT0FBTyxDQUFDLE1BQU07UUFDbEMsYUFBYSxFQUFFLFdBQVcsQ0FBQyxPQUFPLENBQUMsWUFBWTtLQUNoRCxDQUFBO0lBRUQsT0FBTztRQUNMLFNBQVMsRUFBRSxXQUFXLENBQUMsR0FBRztRQUMxQix1QkFBdUIsRUFBRSxXQUFXLENBQUMsS0FBSztRQUMxQyxHQUFHLEVBQUUsTUFBTTtRQUNYLE9BQU8sRUFBRSxXQUFXLENBQUMsS0FBSztLQUMzQixDQUFBO0FBQ0gsQ0FBQyxDQUFBO0FBRUQsb0JBQW9CO0FBRXBCLDJEQUFrQztBQUNsQyxtRUFBeUM7QUFDekMsaUVBQXVDO0FBQ3ZDLGlHQUErRDtBQUMvRCxtQ0FBbUQ7QUFHdEMsUUFBQSxzQkFBc0IsR0FBRyxDQUFDLElBQWdCLEVBQUUsRUFBRTtJQUN6RCxPQUFPLElBQUksQ0FBQyxHQUFHLENBQUMsMEJBQWtCLENBQUMsQ0FBQTtBQUNyQyxDQUFDLENBQUE7QUFFWSxRQUFBLGtCQUFrQixHQUFHLENBQUMsSUFBYyxFQUFFLEVBQUU7SUFDbkQsTUFBTSxTQUFTLEdBQUcsSUFBSSxDQUFDLFNBQVM7UUFDOUIsQ0FBQyxDQUFDLGtDQUFlLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQztRQUNqQyxDQUFDLENBQUMsb0JBQW9CLENBQUE7SUFDeEIsT0FBTztRQUNMLGFBQWEsRUFBRSxJQUFJLENBQUMsU0FBUztRQUM3QixTQUFTO1FBQ1QsYUFBYSxFQUFFLElBQUksQ0FBQyxhQUFhO1FBQ2pDLE9BQU8sRUFBRSxJQUFJLENBQUMsT0FBTztLQUN0QixDQUFBO0FBQ0gsQ0FBQyxDQUFBO0FBRVksUUFBQSxvQkFBb0IsR0FBRyxDQUFDLElBQWEsRUFBa0IsRUFBRTtJQUNwRSxNQUFNLE1BQU0sR0FBRyx5QkFBZ0IsQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUMsQ0FBQyxDQUFDLGVBQUssQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUMsQ0FBQyxDQUFDLEVBQUUsQ0FBQTtJQUN0RSxNQUFNLEtBQUssR0FBRyx5QkFBZ0IsQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLENBQUMsQ0FBQyxDQUFDLGVBQUssQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLENBQUMsQ0FBQyxDQUFDLEVBQUUsQ0FBQTtJQUNuRSxNQUFNLE9BQU8sR0FDWCxpQkFBUSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxJQUFJLENBQUMsT0FBTyxDQUFDLFFBQVEsQ0FBQyxHQUFHLENBQUM7UUFDbEQsQ0FBQyxDQUFDLElBQUksTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLEVBQUUsS0FBSyxDQUFDO1FBQ2pDLENBQUMsQ0FBQyxJQUFJLENBQUMsT0FBTyxJQUFJLEVBQUUsQ0FBQTtJQUV4QixPQUFPLEVBQUUsTUFBTSxFQUFFLEtBQUssRUFBRSxPQUFPLEVBQUUsQ0FBQTtBQUNuQyxDQUFDLENBQUE7QUFFWSxRQUFBLFNBQVMsR0FBRyxDQUFDLElBQThCLEVBQW1CLEVBQUUsQ0FDM0UsQ0FBQyxDQUFFLElBQVksQ0FBQyxRQUFRLENBQUE7QUFDYixRQUFBLG9CQUFvQixHQUFHLENBQ2xDLElBQWdCLEVBQ2hCLE9BQWlDLEVBQ2pDLEVBQUU7SUFDRixNQUFNLElBQUksR0FBRyxpQkFBUyxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUMsQ0FBQyw0QkFBb0IsQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUMsT0FBTyxDQUFBO0lBRXpFLE9BQU8sSUFBSSxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsRUFBRTtRQUN4QixNQUFNLElBQUksR0FBRyxlQUFLLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxDQUFBO1FBRWxDLGlCQUFpQjtRQUNqQixJQUFJLElBQUksQ0FBQyxNQUFNLElBQUksQ0FBQyxtQkFBUSxDQUFDLElBQUksRUFBRSxJQUFJLENBQUMsTUFBTSxDQUFDLEVBQUU7WUFDL0MscUVBQXFFO1lBQ3JFLE9BQU8sS0FBSyxDQUFBO1NBQ2I7UUFDRCxnQkFBZ0I7UUFDaEIsSUFBSSxJQUFJLENBQUMsS0FBSyxJQUFJLENBQUMsa0JBQU8sQ0FBQyxJQUFJLEVBQUUsSUFBSSxDQUFDLEtBQUssQ0FBQyxFQUFFO1lBQzVDLG9FQUFvRTtZQUNwRSxPQUFPLEtBQUssQ0FBQTtTQUNiO1FBQ0QsbUJBQW1CO1FBQ25CLElBQUksSUFBSSxDQUFDLE9BQU8sRUFBRTtZQUNoQixzRUFBc0U7WUFFdEUsSUFBSSxpQkFBUSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsRUFBRTtnQkFDMUIsT0FBTyxJQUFJLENBQUMsT0FBTyxJQUFJLElBQUksQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQTthQUMzRDtpQkFBTTtnQkFDTCxPQUFPLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQTthQUN2QztTQUNGO1FBRUQsT0FBTyxJQUFJLENBQUE7SUFDYixDQUFDLENBQUMsQ0FBQTtBQUNKLENBQUMsQ0FBQSJ9