Class ProcessService

src/platform/common/process/proc.node.ts:39–283

 * Environment variables to launch with can be passed into the constructor.
 */
export class ProcessService implements IProcessService {
    private processesToKill = new Set<IDisposable>();
    private readonly decoder: IBufferDecoder;
    constructor(private readonly env?: EnvironmentVariables) {
        this.decoder = new BufferDecoder();
    }
    public static isAlive(pid?: number): boolean {
        try {
            if (!pid) {
                return false;
            }
            process.kill(pid, 0);
            return true;
        } catch {
            return false;
        }
    }
    public static kill(pid?: number): void {
        try {
            if (!pid) {
                return;
            }
            if (process.platform === 'win32') {
                // Windows doesn't support SIGTERM, so execute taskkill to kill the process
                execSync(`taskkill /pid ${pid} /T /F`);
            } else {
                process.kill(pid);
            }
        } catch {
            // Ignore.
        }
    }
    public dispose() {
        this.processesToKill.forEach((p) => {
            try {
                p.dispose();
            } catch {
                // ignore.
            }
        });
    }

    public execObservable(file: string, args: string[], options: SpawnOptions = {}): ObservableExecutionResult<string> {
        const spawnOptions = this.getDefaultOptions(options);
        const proc = spawn(file, args, spawnOptions);
        let procExited = false;
        logger.ci(`Exec observable ${file}, ${args.join(' ')}`);
        const disposables: IDisposable[] = [];
        const disposable: IDisposable = {
            // eslint-disable-next-line
            dispose: function () {
                if (proc && !proc.killed && !procExited) {
                    ProcessService.kill(proc.pid);
                }
                if (proc) {
                    proc.unref();
                }
                dispose(disposables);