terminalInstance.ts 23.6 KB
Newer Older
1 2 3 4 5
/*---------------------------------------------------------------------------------------------
 *  Copyright (c) Microsoft Corporation. All rights reserved.
 *  Licensed under the MIT License. See License.txt in the project root for license information.
 *--------------------------------------------------------------------------------------------*/

6 7
import * as path from 'path';
import * as pfs from 'vs/base/node/pfs';
8
import DOM = require('vs/base/browser/dom');
J
Johannes Rieken 已提交
9
import Event, { Emitter } from 'vs/base/common/event';
10 11
import URI from 'vs/base/common/uri';
import cp = require('child_process');
12
import lifecycle = require('vs/base/common/lifecycle');
C
Christof Marti 已提交
13
import nls = require('vs/nls');
C
Christof Marti 已提交
14
import os = require('os');
15
import platform = require('vs/base/common/platform');
16
import xterm = require('xterm');
17
import { TPromise } from 'vs/base/common/winjs.base';
18
import { Dimension } from 'vs/base/browser/builder';
19
import { IContextKeyService, IContextKey } from 'vs/platform/contextkey/common/contextkey';
20 21
import { IKeybindingService } from 'vs/platform/keybinding/common/keybinding';
import { IMessageService, Severity } from 'vs/platform/message/common/message';
22
import { IPanelService } from 'vs/workbench/services/panel/common/panelService';
23
import { IStringDictionary } from 'vs/base/common/collections';
24
import { ITerminalInstance, KEYBINDING_CONTEXT_TERMINAL_TEXT_SELECTED, TERMINAL_PANEL_ID, IShellLaunchConfig } from 'vs/workbench/parts/terminal/common/terminal';
25
import { ITerminalProcessFactory } from 'vs/workbench/parts/terminal/electron-browser/terminal';
26
import { IWorkspace, IWorkspaceContextService } from 'vs/platform/workspace/common/workspace';
27
import { IWorkbenchEditorService } from 'vs/workbench/services/editor/common/editorService';
28 29
import { StandardKeyboardEvent } from 'vs/base/browser/keyboardEvent';
import { TabFocus } from 'vs/editor/common/config/commonEditorConfig';
30
import { TerminalConfigHelper } from 'vs/workbench/parts/terminal/electron-browser/terminalConfigHelper';
31

D
Daniel Imms 已提交
32 33 34
/** The amount of time to consider terminal errors to be related to the launch */
const LAUNCHING_DURATION = 500;

35 36 37 38 39 40 41
/** A regex that matches paths in the form /path, ~/path, ./path, ../path */
const pathPrefix = '(\\.\\.?|\\~)';
const pathStartClause = '\\/';
const excludedPathCharactersClause = '[^\\0\\s!$`&*()+\'":;]'; // '":; are allowed in paths but they are often separators so ignore them
const escapedExcludedPathCharactersClause = '(\\\\s|\\\\!|\\\\$|\\\\`|\\\\&|\\\\*|(|)|\\+)';
const LOCAL_UNIX_LIKE_LINK_REGEX = new RegExp('(' + pathPrefix + '?(' + pathStartClause + '(' + excludedPathCharactersClause + '|' + escapedExcludedPathCharactersClause + ')+)+)');

42 43 44 45 46 47 48 49 50
class StandardTerminalProcessFactory implements ITerminalProcessFactory {
	public create(env: { [key: string]: string }): cp.ChildProcess {
		return cp.fork('./terminalProcess', [], {
			env,
			cwd: URI.parse(path.dirname(require.toUrl('./terminalProcess'))).fsPath
		});
	}
}

51
export class TerminalInstance implements ITerminalInstance {
52
	private static readonly EOL_REGEX = /\r?\n/g;
C
Christof Marti 已提交
53

54
	private static _terminalProcessFactory: ITerminalProcessFactory = new StandardTerminalProcessFactory();
D
Daniel Imms 已提交
55 56
	private static _idCounter = 1;

57
	private _id: number;
D
Daniel Imms 已提交
58
	private _isExiting: boolean;
K
Kai Wood 已提交
59
	private _hadFocusOnExit: boolean;
60
	private _isLaunching: boolean;
D
Daniel Imms 已提交
61
	private _isVisible: boolean;
62
	private _onDisposed: Emitter<ITerminalInstance>;
63
	private _onProcessIdReady: Emitter<TerminalInstance>;
D
Daniel Imms 已提交
64
	private _onTitleChanged: Emitter<string>;
D
Daniel Imms 已提交
65
	private _process: cp.ChildProcess;
66
	private _processId: number;
D
Daniel Imms 已提交
67
	private _skipTerminalCommands: string[];
D
Daniel Imms 已提交
68
	private _title: string;
69 70
	private _instanceDisposables: lifecycle.IDisposable[];
	private _processDisposables: lifecycle.IDisposable[];
D
Daniel Imms 已提交
71 72 73
	private _wrapperElement: HTMLDivElement;
	private _xterm: any;
	private _xtermElement: HTMLDivElement;
74
	private _terminalHasTextContextKey: IContextKey<boolean>;
D
Daniel Imms 已提交
75

76
	public get id(): number { return this._id; }
77
	public get processId(): number { return this._processId; }
78
	public get onDisposed(): Event<ITerminalInstance> { return this._onDisposed.event; }
79
	public get onProcessIdReady(): Event<TerminalInstance> { return this._onProcessIdReady.event; }
D
Daniel Imms 已提交
80
	public get onTitleChanged(): Event<string> { return this._onTitleChanged.event; }
D
Daniel Imms 已提交
81
	public get title(): string { return this._title; }
K
Kai Wood 已提交
82
	public get hadFocusOnExit(): boolean { return this._hadFocusOnExit; }
83 84

	public constructor(
D
Daniel Imms 已提交
85 86 87
		private _terminalFocusContextKey: IContextKey<boolean>,
		private _configHelper: TerminalConfigHelper,
		private _container: HTMLElement,
88
		private _shellLaunchConfig: IShellLaunchConfig,
89
		@IContextKeyService private _contextKeyService: IContextKeyService,
D
Daniel Imms 已提交
90
		@IKeybindingService private _keybindingService: IKeybindingService,
91
		@IMessageService private _messageService: IMessageService,
92
		@IPanelService private _panelService: IPanelService,
93 94
		@IWorkspaceContextService private _contextService: IWorkspaceContextService,
		@IWorkbenchEditorService private _editorService: IWorkbenchEditorService
95
	) {
96 97
		this._instanceDisposables = [];
		this._processDisposables = [];
D
Daniel Imms 已提交
98
		this._skipTerminalCommands = [];
D
Daniel Imms 已提交
99
		this._isExiting = false;
K
Kai Wood 已提交
100
		this._hadFocusOnExit = false;
101
		this._isLaunching = true;
D
Daniel Imms 已提交
102 103
		this._isVisible = false;
		this._id = TerminalInstance._idCounter++;
104
		this._terminalHasTextContextKey = KEYBINDING_CONTEXT_TERMINAL_TEXT_SELECTED.bindTo(this._contextKeyService);
D
Daniel Imms 已提交
105

106
		this._onDisposed = new Emitter<TerminalInstance>();
107 108
		this._onProcessIdReady = new Emitter<TerminalInstance>();
		this._onTitleChanged = new Emitter<string>();
109

D
Daniel Imms 已提交
110
		this._createProcess(this._contextService.getWorkspace(), this._shellLaunchConfig);
111
		this._createXterm();
D
Daniel Imms 已提交
112

113
		// Only attach xterm.js to the DOM if the terminal panel has been opened before.
D
Daniel Imms 已提交
114 115
		if (_container) {
			this.attachToElement(_container);
116 117 118
		}
	}

D
Daniel Imms 已提交
119
	public addDisposable(disposable: lifecycle.IDisposable): void {
120
		this._instanceDisposables.push(disposable);
D
Daniel Imms 已提交
121 122
	}

123 124 125 126
	/**
	 * Create xterm.js instance and attach data listeners.
	 */
	protected _createXterm(): void {
127 128 129
		this._xterm = xterm({
			scrollback: this._configHelper.getScrollback()
		});
130
		this._process.on('message', (message) => this._sendPtyDataToXterm(message));
D
Daniel Imms 已提交
131
		this._xterm.on('data', (data) => {
132 133 134 135 136 137
			if (this._process) {
				this._process.send({
					event: 'input',
					data: this._sanitizeInput(data)
				});
			}
D
Daniel Imms 已提交
138 139
			return false;
		});
140 141 142 143 144 145 146 147 148 149 150 151 152
	}

	public attachToElement(container: HTMLElement): void {
		if (this._wrapperElement) {
			throw new Error('The terminal instance has already been attached to a container');
		}

		this._container = container;
		this._wrapperElement = document.createElement('div');
		DOM.addClass(this._wrapperElement, 'terminal-wrapper');
		this._xtermElement = document.createElement('div');

		this._xterm.open(this._xtermElement);
153
		this._xterm.registerLinkMatcher(LOCAL_UNIX_LIKE_LINK_REGEX, (url) => this._openRelativeUnixLikeLink(url), 1);
D
Daniel Imms 已提交
154
		this._xterm.attachCustomKeydownHandler((event: KeyboardEvent) => {
155 156 157 158 159
			// Disable all input if the terminal is exiting
			if (this._isExiting) {
				return false;
			}

160 161
			// Skip processing by xterm.js of keyboard events that resolve to commands described
			// within commandsToSkipShell
D
Daniel Imms 已提交
162
			const standardKeyboardEvent = new StandardKeyboardEvent(event);
163
			const keybinding = standardKeyboardEvent.toKeybinding();
D
Daniel Imms 已提交
164 165
			const resolveResult = this._keybindingService.resolve(keybinding, standardKeyboardEvent.target);
			if (resolveResult && this._skipTerminalCommands.some(k => k === resolveResult.commandId)) {
D
Daniel Imms 已提交
166 167 168 169 170 171 172 173
				event.preventDefault();
				return false;
			}

			// If tab focus mode is on, tab is not passed to the terminal
			if (TabFocus.getTabFocusMode() && event.keyCode === 9) {
				return false;
			}
174
			return undefined;
D
Daniel Imms 已提交
175
		});
176
		this._instanceDisposables.push(DOM.addDisposableListener(this._xterm.element, 'mouseup', (event: KeyboardEvent) => {
177 178 179
			// Wait until mouseup has propogated through the DOM before evaluating the new selection
			// state.
			setTimeout(() => {
180 181
				this._refreshSelectionContextKey();
			}, 0);
182
		}));
183 184

		// xterm.js currently drops selection on keyup as we need to handle this case.
185
		this._instanceDisposables.push(DOM.addDisposableListener(this._xterm.element, 'keyup', (event: KeyboardEvent) => {
186 187 188 189
			// Wait until keyup has propogated through the DOM before evaluating the new selection
			// state.
			setTimeout(() => {
				this._refreshSelectionContextKey();
190
			}, 0);
191
		}));
D
Daniel Imms 已提交
192

D
Daniel Imms 已提交
193 194
		const xtermHelper: HTMLElement = this._xterm.element.querySelector('.xterm-helpers');
		const focusTrap: HTMLElement = document.createElement('div');
195 196
		focusTrap.setAttribute('tabindex', '0');
		DOM.addClass(focusTrap, 'focus-trap');
197
		this._instanceDisposables.push(DOM.addDisposableListener(focusTrap, 'focus', (event: FocusEvent) => {
198 199 200 201
			let currentElement = focusTrap;
			while (!DOM.hasClass(currentElement, 'part')) {
				currentElement = currentElement.parentElement;
			}
D
Daniel Imms 已提交
202
			const hidePanelElement = <HTMLElement>currentElement.querySelector('.hide-panel-action');
203
			hidePanelElement.focus();
204
		}));
D
Daniel Imms 已提交
205
		xtermHelper.insertBefore(focusTrap, this._xterm.textarea);
206

207
		this._instanceDisposables.push(DOM.addDisposableListener(this._xterm.textarea, 'focus', (event: KeyboardEvent) => {
D
Daniel Imms 已提交
208
			this._terminalFocusContextKey.set(true);
209
		}));
210
		this._instanceDisposables.push(DOM.addDisposableListener(this._xterm.textarea, 'blur', (event: KeyboardEvent) => {
D
Daniel Imms 已提交
211
			this._terminalFocusContextKey.reset();
212
			this._refreshSelectionContextKey();
213
		}));
214
		this._instanceDisposables.push(DOM.addDisposableListener(this._xterm.element, 'focus', (event: KeyboardEvent) => {
D
Daniel Imms 已提交
215
			this._terminalFocusContextKey.set(true);
216
		}));
217
		this._instanceDisposables.push(DOM.addDisposableListener(this._xterm.element, 'blur', (event: KeyboardEvent) => {
D
Daniel Imms 已提交
218
			this._terminalFocusContextKey.reset();
219
			this._refreshSelectionContextKey();
220 221
		}));

D
Daniel Imms 已提交
222 223
		this._wrapperElement.appendChild(this._xtermElement);
		this._container.appendChild(this._wrapperElement);
224

225 226 227 228
		const computedStyle = window.getComputedStyle(this._container);
		const width = parseInt(computedStyle.getPropertyValue('width').replace('px', ''), 10);
		const height = parseInt(computedStyle.getPropertyValue('height').replace('px', ''), 10);
		this.layout(new Dimension(width, height));
D
Daniel Imms 已提交
229
		this.setVisible(this._isVisible);
230
		this.updateConfig();
231 232
	}

233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259
	private _openRelativeUnixLikeLink(link: string): TPromise<void> {
		// Resolve ~ -> $HOME
		if (link.charAt(0) === '~') {
			link = process.env.HOME + link.substring(1);
		}

		// Resolve workspace path . / .. -> <path>/. / <path/..
		if (link.charAt(0) === '.') {
			if (!this._contextService.hasWorkspace) {
				// Abort if no workspace is open
				return TPromise.as(void 0);
			}
			link = path.join(this._contextService.getWorkspace().resource.fsPath, link);
		}

		// Clean up the path
		const resource = URI.file(path.normalize(path.resolve(link)));

		// Open an editor if the path exists
		return pfs.fileExists(link).then(isFile => {
			if (!isFile) {
				return void 0;
			}
			return this._editorService.openEditor({ resource }).then(() => void 0);
		});
	}

260 261 262 263
	public hasSelection(): boolean {
		return !document.getSelection().isCollapsed;
	}

D
Daniel Imms 已提交
264
	public copySelection(): void {
D
Daniel Imms 已提交
265 266 267
		if (document.activeElement.classList.contains('xterm')) {
			document.execCommand('copy');
		} else {
D
Daniel Imms 已提交
268
			this._messageService.show(Severity.Warning, nls.localize('terminal.integrated.copySelection.noSelection', 'Cannot copy terminal selection when terminal does not have focus'));
D
Daniel Imms 已提交
269
		}
D
Daniel Imms 已提交
270 271
	}

272 273 274 275
	public clearSelection(): void {
		document.getSelection().empty();
	}

D
Daniel Imms 已提交
276
	public dispose(): void {
K
Kai Wood 已提交
277 278 279
		if (this._xterm && this._xterm.element) {
			this._hadFocusOnExit = DOM.hasClass(this._xterm.element, 'focus');
		}
D
Daniel Imms 已提交
280 281 282
		if (this._wrapperElement) {
			this._container.removeChild(this._wrapperElement);
			this._wrapperElement = null;
D
Daniel Imms 已提交
283
		}
D
Daniel Imms 已提交
284 285 286
		if (this._xterm) {
			this._xterm.destroy();
			this._xterm = null;
D
Daniel Imms 已提交
287
		}
D
Daniel Imms 已提交
288 289 290
		if (this._process) {
			if (this._process.connected) {
				this._process.kill();
D
Daniel Imms 已提交
291
			}
D
Daniel Imms 已提交
292
			this._process = null;
D
Daniel Imms 已提交
293
		}
294
		this._onDisposed.fire(this);
295 296
		this._processDisposables = lifecycle.dispose(this._processDisposables);
		this._instanceDisposables = lifecycle.dispose(this._instanceDisposables);
D
Daniel Imms 已提交
297 298
	}

D
Daniel Imms 已提交
299
	public focus(force?: boolean): void {
D
Daniel Imms 已提交
300
		if (!this._xterm) {
D
Daniel Imms 已提交
301 302
			return;
		}
D
Daniel Imms 已提交
303
		const text = window.getSelection().toString();
D
Daniel Imms 已提交
304
		if (!text || force) {
D
Daniel Imms 已提交
305
			this._xterm.focus();
D
Daniel Imms 已提交
306
		}
D
Daniel Imms 已提交
307 308 309
	}

	public paste(): void {
D
Daniel Imms 已提交
310 311
		this.focus();
		document.execCommand('paste');
D
Daniel Imms 已提交
312 313 314
	}

	public sendText(text: string, addNewLine: boolean): void {
D
Daniel Imms 已提交
315 316 317
		if (addNewLine && text.substr(text.length - os.EOL.length) !== os.EOL) {
			text += os.EOL;
		}
D
Daniel Imms 已提交
318
		this._process.send({
D
Daniel Imms 已提交
319 320 321
			event: 'input',
			data: text
		});
D
Daniel Imms 已提交
322
	}
323 324

	public setVisible(visible: boolean): void {
D
Daniel Imms 已提交
325 326 327
		this._isVisible = visible;
		if (this._wrapperElement) {
			DOM.toggleClass(this._wrapperElement, 'active', visible);
328
		}
D
Daniel Imms 已提交
329
		if (visible && this._xterm) {
330 331 332 333 334 335
			// Trigger a manual scroll event which will sync the viewport and scroll bar. This is
			// necessary if the number of rows in the terminal has decreased while it was in the
			// background since scrollTop changes take no effect but the terminal's position does
			// change since the number of visible rows decreases.
			this._xterm.emit('scroll', this._xterm.ydisp);
		}
336 337
	}

338
	public scrollDownLine(): void {
D
Daniel Imms 已提交
339
		this._xterm.scrollDisp(1);
D
Daniel Imms 已提交
340 341
	}

342
	public scrollDownPage(): void {
343
		this._xterm.scrollPages(1);
344 345
	}

346 347 348 349
	public scrollToBottom(): void {
		this._xterm.scrollToBottom();
	}

350
	public scrollUpLine(): void {
D
Daniel Imms 已提交
351
		this._xterm.scrollDisp(-1);
D
Daniel Imms 已提交
352
	}
353

354
	public scrollUpPage(): void {
355
		this._xterm.scrollPages(-1);
356 357
	}

358 359 360 361
	public scrollToTop(): void {
		this._xterm.scrollToTop();
	}

D
Daniel Imms 已提交
362 363 364 365
	public clear(): void {
		this._xterm.clear();
	}

366
	private _refreshSelectionContextKey() {
367 368 369
		const activePanel = this._panelService.getActivePanel();
		const isFocused = activePanel && activePanel.getId() === TERMINAL_PANEL_ID;
		this._terminalHasTextContextKey.set(isFocused && !window.getSelection().isCollapsed);
370 371
	}

D
Daniel Imms 已提交
372
	private _sanitizeInput(data: any) {
373
		return typeof data === 'string' ? data.replace(TerminalInstance.EOL_REGEX, os.EOL) : data;
C
Christof Marti 已提交
374 375
	}

376 377 378 379 380
	protected _getCwd(shell: IShellLaunchConfig, workspace: IWorkspace): string {
		if (shell.cwd) {
			return shell.cwd;
		}

B
Benjamin Pasero 已提交
381
		let cwd: string;
D
Daniel Imms 已提交
382 383

		// TODO: Handle non-existent customCwd
384
		if (!shell.ignoreConfigurationCwd) {
385
			// Evaluate custom cwd first
D
Daniel Imms 已提交
386
			const customCwd = this._configHelper.getCwd();
387 388 389 390 391 392
			if (customCwd) {
				if (path.isAbsolute(customCwd)) {
					cwd = customCwd;
				} else if (workspace) {
					cwd = path.normalize(path.join(workspace.resource.fsPath, customCwd));
				}
D
Daniel Imms 已提交
393 394 395 396 397
			}
		}

		// If there was no custom cwd or it was relative with no workspace
		if (!cwd) {
398
			cwd = workspace ? workspace.resource.fsPath : os.homedir();
D
Daniel Imms 已提交
399 400 401 402 403
		}

		return TerminalInstance._sanitizeCwd(cwd);
	}

404
	protected _createProcess(workspace: IWorkspace, shell: IShellLaunchConfig): void {
D
Daniel Imms 已提交
405
		const locale = this._configHelper.isSetLocaleVariables() ? platform.locale : undefined;
D
Daniel Imms 已提交
406
		if (!shell.executable) {
407
			this._configHelper.mergeDefaultShellPathAndArgs(shell);
P
Pine Wu 已提交
408
		}
409
		const env = TerminalInstance.createTerminalEnv(process.env, shell, this._getCwd(shell, workspace), locale);
D
Daniel Imms 已提交
410
		this._title = shell.name || '';
D
Daniel Imms 已提交
411
		this._process = cp.fork('./terminalProcess', [], {
412 413 414
			env: env,
			cwd: URI.parse(path.dirname(require.toUrl('./terminalProcess'))).fsPath
		});
D
Daniel Imms 已提交
415
		if (!shell.name) {
416
			// Only listen for process title changes when a name is not provided
D
Daniel Imms 已提交
417
			this._process.on('message', (message) => {
418
				if (message.type === 'title') {
D
Daniel Imms 已提交
419
					this._title = message.content ? message.content : '';
420
					this._onTitleChanged.fire(this._title);
421
				}
422 423
			});
		}
424 425 426 427 428 429
		this._process.on('message', (message) => {
			if (message.type === 'pid') {
				this._processId = message.content;
				this._onProcessIdReady.fire(this);
			}
		});
430 431 432 433 434 435
		this._process.on('exit', exitCode => this._onPtyProcessExit(exitCode));
		setTimeout(() => {
			this._isLaunching = false;
		}, LAUNCHING_DURATION);
	}

436 437 438 439 440 441
	private _sendPtyDataToXterm(message: { type: string, content: string }): void {
		if (message.type === 'data') {
			this._xterm.write(message.content);
		}
	}

442 443 444 445 446 447 448 449
	private _onPtyProcessExit(exitCode: number): void {
		// Prevent dispose functions being triggered multiple times
		if (this._isExiting) {
			return;
		}

		this._isExiting = true;
		let exitCodeMessage: string;
450
		if (exitCode) {
451 452 453
			exitCodeMessage = nls.localize('terminal.integrated.exitedWithCode', 'The terminal process terminated with exit code: {0}', exitCode);
		}

454 455 456 457 458
		// Only trigger wait on exit when the exit was triggered by the process, not through the
		// `workbench.action.terminal.kill` command
		const triggeredByProcess = exitCode !== null;

		if (triggeredByProcess && this._shellLaunchConfig.waitOnExit) {
459
			if (exitCode) {
460 461 462 463 464
				this._xterm.writeln(exitCodeMessage);
			}
			this._xterm.writeln(nls.localize('terminal.integrated.waitOnExit', 'Press any key to close the terminal'));
			// Disable all input if the terminal is exiting and listen for next keypress
			this._xterm.setOption('disableStdin', true);
465
			this._processDisposables.push(DOM.addDisposableListener(this._xterm.textarea, 'keypress', (event: KeyboardEvent) => {
466
				this.dispose();
467
				event.preventDefault();
468
			}));
469 470
		} else {
			this.dispose();
471
			if (exitCode) {
472 473 474 475 476 477 478 479 480
				if (this._isLaunching) {
					let args = '';
					if (this._shellLaunchConfig.args && this._shellLaunchConfig.args.length) {
						args = ' ' + this._shellLaunchConfig.args.map(a => {
							if (a.indexOf(' ') !== -1) {
								return `'${a}'`;
							}
							return a;
						}).join(' ');
481
					}
482 483 484
					this._messageService.show(Severity.Error, nls.localize('terminal.integrated.launchFailed', 'The terminal process command `{0}{1}` failed to launch (exit code: {2})', this._shellLaunchConfig.executable, args, exitCode));
				} else {
					this._messageService.show(Severity.Error, exitCodeMessage);
485 486
				}
			}
487
		}
488 489
	}

490 491
	public reuseTerminal(shell?: IShellLaunchConfig): void {
		// Kill and clean up old process
492 493 494 495 496 497 498
		if (this._process) {
			this._process.removeAllListeners('exit');
			if (this._process.connected) {
				this._process.kill();
			}
			this._process = null;
		}
499 500 501
		lifecycle.dispose(this._processDisposables);
		this._processDisposables = [];

502 503
		// Ensure new processes' output starts at start of new line
		this._xterm.write('\n\x1b[G');
504 505

		// Initialize new process
D
Daniel Imms 已提交
506
		this._createProcess(this._contextService.getWorkspace(), shell);
507
		this._process.on('message', (message) => this._sendPtyDataToXterm(message));
508 509

		// Clean up waitOnExit state
510 511
		if (this._isExiting && this._shellLaunchConfig.waitOnExit) {
			this._xterm.setOption('disableStdin', false);
512
			this._isExiting = false;
513
		}
514

515 516 517 518
		// Set the new shell launch config
		this._shellLaunchConfig = shell;
	}

519 520
	// TODO: This should be private/protected
	// TODO: locale should not be optional
521
	public static createTerminalEnv(parentEnv: IStringDictionary<string>, shell: IShellLaunchConfig, cwd: string, locale?: string): IStringDictionary<string> {
522
		const env = shell.env ? shell.env : TerminalInstance._cloneEnv(parentEnv);
523 524
		env['PTYPID'] = process.pid.toString();
		env['PTYSHELL'] = shell.executable;
D
Daniel Imms 已提交
525 526 527 528 529
		if (shell.args) {
			shell.args.forEach((arg, i) => {
				env[`PTYSHELLARG${i}`] = arg;
			});
		}
D
Daniel Imms 已提交
530
		env['PTYCWD'] = cwd;
531
		if (locale) {
D
Daniel Imms 已提交
532
			env['LANG'] = TerminalInstance._getLangEnvVariable(locale);
533 534
		}
		return env;
535 536
	}

D
Dirk Baeumer 已提交
537 538
	public onData(listener: (data: string) => void): lifecycle.IDisposable {
		let callback = (message) => {
539 540 541
			if (message.type === 'data') {
				listener(message.content);
			}
D
Dirk Baeumer 已提交
542 543 544 545
		};
		this._process.on('message', callback);
		return {
			dispose: () => {
546 547 548
				if (this._process) {
					this._process.removeListener('message', callback);
				}
D
Dirk Baeumer 已提交
549 550
			}
		};
551 552
	}

D
Dirk Baeumer 已提交
553
	public onExit(listener: (exitCode: number) => void): lifecycle.IDisposable {
554
		this._process.on('exit', listener);
D
Dirk Baeumer 已提交
555 556
		return {
			dispose: () => {
557 558 559
				if (this._process) {
					this._process.removeListener('exit', listener);
				}
D
Dirk Baeumer 已提交
560 561
			}
		};
562 563
	}

D
Daniel Imms 已提交
564
	private static _sanitizeCwd(cwd: string) {
565 566 567
		// Make the drive letter uppercase on Windows (see #9448)
		if (platform.platform === platform.Platform.Windows && cwd && cwd[1] === ':') {
			return cwd[0].toUpperCase() + cwd.substr(1);
D
Daniel Imms 已提交
568
		}
569
		return cwd;
D
Daniel Imms 已提交
570 571
	}

D
Daniel Imms 已提交
572
	private static _cloneEnv(env: IStringDictionary<string>): IStringDictionary<string> {
D
Daniel Imms 已提交
573
		const newEnv: IStringDictionary<string> = Object.create(null);
574 575
		Object.keys(env).forEach((key) => {
			newEnv[key] = env[key];
576
		});
577
		return newEnv;
578 579
	}

D
Daniel Imms 已提交
580
	private static _getLangEnvVariable(locale: string) {
581 582
		const parts = locale.split('-');
		const n = parts.length;
583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598
		const language = parts[0];
		if (n === 0) {
			return '';
		}
		if (n === 1) {
			// app.getLocale can return just a language without a variant, fill in the variant for
			// supported languages as many shells expect a 2-part locale.
			const languageVariants = {
				de: 'DE',
				en: 'US',
				es: 'ES',
				fr: 'FR',
				it: 'IT',
				ja: 'JP',
				ko: 'KR',
				ru: 'RU',
599
				zh: 'CN'
600 601 602 603 604 605 606
			};
			if (language in languageVariants) {
				parts.push(languageVariants[language]);
			}
		} else {
			// Ensure the variant is uppercase
			parts[1] = parts[1].toUpperCase();
D
Daniel Imms 已提交
607
		}
608
		return parts.join('_') + '.UTF-8';
D
Daniel Imms 已提交
609
	}
D
Daniel Imms 已提交
610

611
	public updateConfig(): void {
612
		this._setFlowControl(this._configHelper.getFlowControl());
613
		this._setCursorBlink(this._configHelper.getCursorBlink());
614
		this._setCursorStyle(this._configHelper.getCursorStyle());
615 616 617 618
		this._setCommandsToSkipShell(this._configHelper.getCommandsToSkipShell());
		this._setScrollback(this._configHelper.getScrollback());
	}

619 620 621 622 623 624
	private _setFlowControl(flowControl: boolean): void {
		if (this._xterm && this._xterm.getOption('useFlowControl') !== flowControl) {
			this._xterm.setOption('useFlowControl', flowControl);
		}
	}

625
	private _setCursorBlink(blink: boolean): void {
D
Daniel Imms 已提交
626
		if (this._xterm && this._xterm.getOption('cursorBlink') !== blink) {
D
Daniel Imms 已提交
627
			this._xterm.setOption('cursorBlink', blink);
D
Daniel Imms 已提交
628
			this._xterm.refresh(0, this._xterm.rows - 1);
D
Daniel Imms 已提交
629 630 631
		}
	}

632 633 634 635 636 637 638 639
	private _setCursorStyle(style: string): void {
		if (this._xterm && this._xterm.getOption('cursorStyle') !== style) {
			// 'line' is used instead of bar in VS Code to be consistent with editor.cursorStyle
			const xtermOption = style === 'line' ? 'bar' : style;
			this._xterm.setOption('cursorStyle', xtermOption);
		}
	}

640
	private _setCommandsToSkipShell(commands: string[]): void {
D
Daniel Imms 已提交
641
		this._skipTerminalCommands = commands;
D
Daniel Imms 已提交
642 643
	}

644
	private _setScrollback(lineCount: number): void {
D
Daniel Imms 已提交
645
		if (this._xterm && this._xterm.getOption('scrollback') !== lineCount) {
646
			console.log('set scrollback to: ' + lineCount);
D
Daniel Imms 已提交
647 648 649 650
			this._xterm.setOption('scrollback', lineCount);
		}
	}

651
	public layout(dimension: { width: number, height: number }): void {
D
Daniel Imms 已提交
652
		const font = this._configHelper.getFont();
653
		if (!font || !font.charWidth || !font.charHeight) {
D
Daniel Imms 已提交
654 655 656 657
			return;
		}
		if (!dimension.height) { // Minimized
			return;
658 659 660 661 662 663
		} else {
			// Trigger scroll event manually so that the viewport's scroll area is synced. This
			// needs to happen otherwise its scrollTop value is invalid when the panel is toggled as
			// it gets removed and then added back to the DOM (resetting scrollTop to 0).
			// Upstream issue: https://github.com/sourcelair/xterm.js/issues/291
			this._xterm.emit('scroll', this._xterm.ydisp);
D
Daniel Imms 已提交
664
		}
665
		const padding = parseInt(getComputedStyle(document.querySelector('.terminal-outer-container')).paddingLeft.split('px')[0], 10);
D
Daniel Imms 已提交
666 667 668
		// Use left padding as right padding, right padding is not defined in CSS just in case
		// xterm.js causes an unexpected overflow.
		const innerWidth = dimension.width - padding * 2;
D
Daniel Imms 已提交
669 670
		const cols = Math.floor(innerWidth / font.charWidth);
		const rows = Math.floor(dimension.height / font.charHeight);
D
Daniel Imms 已提交
671 672 673
		if (this._xterm) {
			this._xterm.resize(cols, rows);
			this._xterm.element.style.width = innerWidth + 'px';
D
Daniel Imms 已提交
674
		}
D
Daniel Imms 已提交
675 676
		if (this._process.connected) {
			this._process.send({
D
Daniel Imms 已提交
677 678 679 680 681 682
				event: 'resize',
				cols: cols,
				rows: rows
			});
		}
	}
683 684 685 686

	public static setTerminalProcessFactory(factory: ITerminalProcessFactory): void {
		this._terminalProcessFactory = factory;
	}
687
}