@digitaloptgroup/cli/lib/stream-logs.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const cli_config_1 = require("./cli-config");
const EventSource = require("eventsource");
const auth_1 = require("./auth");
const get_project_id_1 = require("./get-project-id");
exports.streamLogs = (logType, prettyjson, filterBy, filterValue) => {
    //console.log('Connecting to realtime log stream...')
    const token = auth_1.auth.get('token');
    const projectId = get_project_id_1.getProjectId();
    const filters = filterBy && filterValue
        ? `&filterBy=${filterBy}&filterValue=${filterValue}`
        : '';
    // if (filterBy && filterValue) {
    //   console.log()
    //   console.log(`Filtering ${filterBy} by ${filterValue}:`)
    //   console.log()
    // }
    const url = `${cli_config_1.REALTIME_LOGS_URL}?token=${token}&projectId=${projectId}&logType=${logType}${filters}`;
    var source = new EventSource(url);
    source.addEventListener('put', (message) => {
        const logLines = JSON.parse(message.data);
        if (logLines.path === '/' && message.data !== null && logLines.data) {
            Object.values(logLines.data).forEach(line => {
                if (prettyjson) {
                    console.log(JSON.stringify(line, null, 4));
                    console.log();
                }
                else
                    console.log(JSON.stringify(line));
            });
        }
        else if (message.data !== null && logLines && logLines.data) {
            if (prettyjson)
                console.log(JSON.stringify(logLines.data, null, 4));
            else
                console.log(JSON.stringify(logLines.data));
        }
    });
    source.onmessage = (e) => {
        //console.log(e.data)
    };
    source.onerror = e => {
        console.log(e);
        process.exit();
    };
};