Anjing Webshells

Website : rimsha.abasa.com
: / var / www / cal.com / cal.com / node_modules / process-wrapper / dist /
Filename : index.js
back
"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const node_child_process_1 = require("node:child_process");
const os_1 = require("os");
const signals_1 = __importDefault(require("./signals"));
const spawnWrapped = (command, options = {}) => {
    const wrapped = (0, node_child_process_1.spawn)(command, process.argv.slice(2));
    mapStreamLines(wrapped.stdout, process.stdout, options.mapStdout);
    mapStreamLines(wrapped.stderr, process.stderr, options.mapStderr);
    signals_1.default.forEach((signal) => {
        process.on(signal, () => {
            wrapped.kill(signal);
        });
    });
    wrapped.on('exit', (code, signal) => {
        if (signal) {
            process.kill(process.pid, signal);
        }
        else {
            process.exit(code ?? undefined);
        }
    });
};
const mapStreamLines = (readable, writable, lineMapper) => {
    if (!lineMapper) {
        readable.pipe(writable);
        return;
    }
    let lineBuffer = '';
    readable.on('data', (data) => {
        lineBuffer += data.toString();
        const lines = lineBuffer.split(os_1.EOL);
        for (let i = 0; i < lines.length - 1; i += 1) {
            const line = lines[i] + os_1.EOL;
            writable.write(lineMapper(line));
        }
        lineBuffer = lines[lines.length - 1] ?? '';
    });
};
exports.default = spawnWrapped;