+++ /dev/null
-"use strict";
-/**
- * Copyright (c) 2012-2015, Christopher Jeffrey, Peter Sunde (MIT License)
- * Copyright (c) 2016, Daniel Imms (MIT License).
- * Copyright (c) 2018, Microsoft Corporation (MIT License).
- */
-Object.defineProperty(exports, "__esModule", { value: true });
-var os = require("os");
-var path = require("path");
-var net_1 = require("net");
-var child_process_1 = require("child_process");
-var conptyNative;
-var winptyNative;
-/**
- * The amount of time to wait for additional data after the conpty shell process has exited before
- * shutting down the socket. The timer will be reset if a new data event comes in after the timer
- * has started.
- */
-var FLUSH_DATA_INTERVAL = 20;
-/**
- * This agent sits between the WindowsTerminal class and provides a common interface for both conpty
- * and winpty.
- */
-var WindowsPtyAgent = /** @class */ (function () {
- function WindowsPtyAgent(file, args, env, cwd, cols, rows, debug, _useConpty, conptyInheritCursor) {
- var _this = this;
- if (conptyInheritCursor === void 0) { conptyInheritCursor = false; }
- this._useConpty = _useConpty;
- if (this._useConpty === undefined || this._useConpty === true) {
- this._useConpty = this._getWindowsBuildNumber() >= 18309;
- }
- if (this._useConpty) {
- if (!conptyNative) {
- try {
- conptyNative = require('../build/Release/conpty.node');
- }
- catch (outerError) {
- try {
- conptyNative = require('../build/Debug/conpty.node');
- }
- catch (innerError) {
- console.error('innerError', innerError);
- // Re-throw the exception from the Release require if the Debug require fails as well
- throw outerError;
- }
- }
- }
- }
- else {
- if (!winptyNative) {
- try {
- winptyNative = require('../build/Release/pty.node');
- }
- catch (outerError) {
- try {
- winptyNative = require('../build/Debug/pty.node');
- }
- catch (innerError) {
- console.error('innerError', innerError);
- // Re-throw the exception from the Release require if the Debug require fails as well
- throw outerError;
- }
- }
- }
- }
- this._ptyNative = this._useConpty ? conptyNative : winptyNative;
- // Sanitize input variable.
- cwd = path.resolve(cwd);
- // Compose command line
- var commandLine = argsToCommandLine(file, args);
- // Open pty session.
- var term;
- if (this._useConpty) {
- term = this._ptyNative.startProcess(file, cols, rows, debug, this._generatePipeName(), conptyInheritCursor);
- }
- else {
- term = this._ptyNative.startProcess(file, commandLine, env, cwd, cols, rows, debug);
- this._pid = term.pid;
- this._innerPid = term.innerPid;
- this._innerPidHandle = term.innerPidHandle;
- }
- // Not available on windows.
- this._fd = term.fd;
- // Generated incremental number that has no real purpose besides using it
- // as a terminal id.
- this._pty = term.pty;
- // Create terminal pipe IPC channel and forward to a local unix socket.
- this._outSocket = new net_1.Socket();
- this._outSocket.setEncoding('utf8');
- this._outSocket.connect(term.conout, function () {
- // TODO: Emit event on agent instead of socket?
- // Emit ready event.
- _this._outSocket.emit('ready_datapipe');
- });
- this._inSocket = new net_1.Socket();
- this._inSocket.setEncoding('utf8');
- this._inSocket.connect(term.conin);
- // TODO: Wait for ready event?
- if (this._useConpty) {
- var connect = this._ptyNative.connect(this._pty, commandLine, cwd, env, function (c) { return _this._$onProcessExit(c); });
- this._innerPid = connect.pid;
- }
- }
- Object.defineProperty(WindowsPtyAgent.prototype, "inSocket", {
- get: function () { return this._inSocket; },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(WindowsPtyAgent.prototype, "outSocket", {
- get: function () { return this._outSocket; },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(WindowsPtyAgent.prototype, "fd", {
- get: function () { return this._fd; },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(WindowsPtyAgent.prototype, "innerPid", {
- get: function () { return this._innerPid; },
- enumerable: true,
- configurable: true
- });
- Object.defineProperty(WindowsPtyAgent.prototype, "pty", {
- get: function () { return this._pty; },
- enumerable: true,
- configurable: true
- });
- WindowsPtyAgent.prototype.resize = function (cols, rows) {
- if (this._useConpty) {
- if (this._exitCode !== undefined) {
- throw new Error('Cannot resize a pty that has already exited');
- }
- this._ptyNative.resize(this._pty, cols, rows);
- return;
- }
- this._ptyNative.resize(this._pid, cols, rows);
- };
- WindowsPtyAgent.prototype.kill = function () {
- var _this = this;
- this._inSocket.readable = false;
- this._inSocket.writable = false;
- this._outSocket.readable = false;
- this._outSocket.writable = false;
- // Tell the agent to kill the pty, this releases handles to the process
- if (this._useConpty) {
- this._getConsoleProcessList().then(function (consoleProcessList) {
- consoleProcessList.forEach(function (pid) {
- try {
- process.kill(pid);
- }
- catch (e) {
- // Ignore if process cannot be found (kill ESRCH error)
- }
- });
- _this._ptyNative.kill(_this._pty);
- });
- }
- else {
- this._ptyNative.kill(this._pid, this._innerPidHandle);
- // Since pty.kill closes the handle it will kill most processes by itself
- // and process IDs can be reused as soon as all handles to them are
- // dropped, we want to immediately kill the entire console process list.
- // If we do not force kill all processes here, node servers in particular
- // seem to become detached and remain running (see
- // Microsoft/vscode#26807).
- var processList = this._ptyNative.getProcessList(this._pid);
- processList.forEach(function (pid) {
- try {
- process.kill(pid);
- }
- catch (e) {
- // Ignore if process cannot be found (kill ESRCH error)
- }
- });
- }
- };
- WindowsPtyAgent.prototype._getConsoleProcessList = function () {
- var _this = this;
- return new Promise(function (resolve) {
- var agent = child_process_1.fork(path.join(__dirname, 'conpty_console_list_agent'), [_this._innerPid.toString()]);
- agent.on('message', function (message) {
- clearTimeout(timeout);
- resolve(message.consoleProcessList);
- });
- var timeout = setTimeout(function () {
- // Something went wrong, just send back the shell PID
- agent.kill();
- resolve([_this._innerPid]);
- }, 5000);
- });
- };
- Object.defineProperty(WindowsPtyAgent.prototype, "exitCode", {
- get: function () {
- if (this._useConpty) {
- return this._exitCode;
- }
- return this._ptyNative.getExitCode(this._innerPidHandle);
- },
- enumerable: true,
- configurable: true
- });
- WindowsPtyAgent.prototype._getWindowsBuildNumber = function () {
- var osVersion = (/(\d+)\.(\d+)\.(\d+)/g).exec(os.release());
- var buildNumber = 0;
- if (osVersion && osVersion.length === 4) {
- buildNumber = parseInt(osVersion[3]);
- }
- return buildNumber;
- };
- WindowsPtyAgent.prototype._generatePipeName = function () {
- return "conpty-" + Math.random() * 10000000;
- };
- /**
- * Triggered from the native side when a contpy process exits.
- */
- WindowsPtyAgent.prototype._$onProcessExit = function (exitCode) {
- var _this = this;
- this._exitCode = exitCode;
- this._flushDataAndCleanUp();
- this._outSocket.on('data', function () { return _this._flushDataAndCleanUp(); });
- };
- WindowsPtyAgent.prototype._flushDataAndCleanUp = function () {
- var _this = this;
- if (this._closeTimeout) {
- clearTimeout(this._closeTimeout);
- }
- this._closeTimeout = setTimeout(function () { return _this._cleanUpProcess(); }, FLUSH_DATA_INTERVAL);
- };
- WindowsPtyAgent.prototype._cleanUpProcess = function () {
- this._inSocket.readable = false;
- this._inSocket.writable = false;
- this._outSocket.readable = false;
- this._outSocket.writable = false;
- this._outSocket.destroy();
- };
- return WindowsPtyAgent;
-}());
-exports.WindowsPtyAgent = WindowsPtyAgent;
-// Convert argc/argv into a Win32 command-line following the escaping convention
-// documented on MSDN (e.g. see CommandLineToArgvW documentation). Copied from
-// winpty project.
-function argsToCommandLine(file, args) {
- if (isCommandLine(args)) {
- if (args.length === 0) {
- return file;
- }
- return argsToCommandLine(file, []) + " " + args;
- }
- var argv = [file];
- Array.prototype.push.apply(argv, args);
- var result = '';
- for (var argIndex = 0; argIndex < argv.length; argIndex++) {
- if (argIndex > 0) {
- result += ' ';
- }
- var arg = argv[argIndex];
- // if it is empty or it contains whitespace and is not already quoted
- var hasLopsidedEnclosingQuote = xOr((arg[0] !== '"'), (arg[arg.length - 1] !== '"'));
- var hasNoEnclosingQuotes = ((arg[0] !== '"') && (arg[arg.length - 1] !== '"'));
- var quote = arg === '' ||
- (arg.indexOf(' ') !== -1 ||
- arg.indexOf('\t') !== -1) &&
- ((arg.length > 1) &&
- (hasLopsidedEnclosingQuote || hasNoEnclosingQuotes));
- if (quote) {
- result += '\"';
- }
- var bsCount = 0;
- for (var i = 0; i < arg.length; i++) {
- var p = arg[i];
- if (p === '\\') {
- bsCount++;
- }
- else if (p === '"') {
- result += repeatText('\\', bsCount * 2 + 1);
- result += '"';
- bsCount = 0;
- }
- else {
- result += repeatText('\\', bsCount);
- bsCount = 0;
- result += p;
- }
- }
- if (quote) {
- result += repeatText('\\', bsCount * 2);
- result += '\"';
- }
- else {
- result += repeatText('\\', bsCount);
- }
- }
- return result;
-}
-exports.argsToCommandLine = argsToCommandLine;
-function isCommandLine(args) {
- return typeof args === 'string';
-}
-function repeatText(text, count) {
- var result = '';
- for (var i = 0; i < count; i++) {
- result += text;
- }
- return result;
-}
-function xOr(arg1, arg2) {
- return ((arg1 && !arg2) || (!arg1 && arg2));
-}
-//# sourceMappingURL=windowsPtyAgent.js.map
\ No newline at end of file
projects / VSoRC / .git / blobdiff