task.contribution.ts 54.2 KB
Newer Older
E
Erich Gamma 已提交
1 2 3 4 5 6 7 8 9
/*---------------------------------------------------------------------------------------------
 *  Copyright (c) Microsoft Corporation. All rights reserved.
 *  Licensed under the MIT License. See License.txt in the project root for license information.
 *--------------------------------------------------------------------------------------------*/

'use strict';

import 'vs/css!./media/task.contribution';
import 'vs/workbench/parts/tasks/browser/taskQuickOpen';
10
import 'vs/workbench/parts/tasks/browser/terminateQuickOpen';
11
import 'vs/workbench/parts/tasks/browser/restartQuickOpen';
E
Erich Gamma 已提交
12 13 14

import * as nls from 'vs/nls';

15
import { TPromise } from 'vs/base/common/winjs.base';
E
Erich Gamma 已提交
16 17 18 19 20
import Severity from 'vs/base/common/severity';
import * as Objects from 'vs/base/common/objects';
import { IStringDictionary } from 'vs/base/common/collections';
import { Action } from 'vs/base/common/actions';
import * as Dom from 'vs/base/browser/dom';
J
Joao Moreno 已提交
21
import { IDisposable, dispose } from 'vs/base/common/lifecycle';
A
Alex Dima 已提交
22
import { EventEmitter } from 'vs/base/common/eventEmitter';
E
Erich Gamma 已提交
23 24 25
import * as Builder from 'vs/base/browser/builder';
import * as Types from 'vs/base/common/types';
import { KeyMod, KeyCode } from 'vs/base/common/keyCodes';
D
Dirk Baeumer 已提交
26
import { TerminateResponse, TerminateResponseCode } from 'vs/base/common/processes';
27
import * as strings from 'vs/base/common/strings';
28
import { ValidationStatus, ValidationState } from 'vs/base/common/parsers';
29
import * as UUID from 'vs/base/common/uuid';
E
Erich Gamma 已提交
30 31 32

import { Registry } from 'vs/platform/platform';
import { ILifecycleService } from 'vs/platform/lifecycle/common/lifecycle';
33
import { SyncActionDescriptor, MenuRegistry } from 'vs/platform/actions/common/actions';
E
Erich Gamma 已提交
34
import { registerSingleton } from 'vs/platform/instantiation/common/extensions';
35
import { IEditor } from 'vs/platform/editor/common/editor';
E
Erich Gamma 已提交
36 37 38
import { IMessageService } from 'vs/platform/message/common/message';
import { IMarkerService, MarkerStatistics } from 'vs/platform/markers/common/markers';
import { ITelemetryService } from 'vs/platform/telemetry/common/telemetry';
39
import { IConfigurationService } from 'vs/platform/configuration/common/configuration';
40
import { IFileService } from 'vs/platform/files/common/files';
A
Alex Dima 已提交
41
import { IExtensionService } from 'vs/platform/extensions/common/extensions';
42
import { CommandsRegistry } from 'vs/platform/commands/common/commands';
43 44
import { KeybindingsRegistry } from 'vs/platform/keybinding/common/keybindingsRegistry';
import { ServicesAccessor } from 'vs/platform/instantiation/common/instantiation';
45
import { ProblemMatcherRegistry } from 'vs/platform/markers/common/problemMatcher';
46

E
Erich Gamma 已提交
47 48 49 50

import { IModeService } from 'vs/editor/common/services/modeService';
import { IModelService } from 'vs/editor/common/services/modelService';

M
Martin Aeschlimann 已提交
51
import jsonContributionRegistry = require('vs/platform/jsonschemas/common/jsonContributionRegistry');
E
Erich Gamma 已提交
52 53
import { IJSONSchema } from 'vs/base/common/jsonSchema';

54
import { IWorkbenchActionRegistry, Extensions as WorkbenchActionExtensions } from 'vs/workbench/common/actionRegistry';
J
Johannes Rieken 已提交
55
import { IStatusbarItem, IStatusbarRegistry, Extensions as StatusbarExtensions, StatusbarItemDescriptor, StatusbarAlignment } from 'vs/workbench/browser/parts/statusbar/statusbar';
56
import { IQuickOpenRegistry, Extensions as QuickOpenExtensions, QuickOpenHandlerDescriptor } from 'vs/workbench/browser/quickopen';
E
Erich Gamma 已提交
57

J
Johannes Rieken 已提交
58
import { IQuickOpenService } from 'vs/platform/quickOpen/common/quickOpen';
59
import { IPanelService } from 'vs/workbench/services/panel/common/panelService';
60 61
import Constants from 'vs/workbench/parts/markers/common/constants';
import { IPartService } from 'vs/workbench/services/part/common/partService';
E
Erich Gamma 已提交
62
import { IWorkbenchEditorService } from 'vs/workbench/services/editor/common/editorService';
63
import { IConfigurationResolverService } from 'vs/workbench/services/configurationResolver/common/configurationResolver';
D
Dirk Baeumer 已提交
64
import { IConfigurationEditingService, ConfigurationTarget } from 'vs/workbench/services/configuration/common/configurationEditing';
65
import { IWorkspaceContextService } from 'vs/platform/workspace/common/workspace';
E
Erich Gamma 已提交
66

67
import { ITextFileService } from 'vs/workbench/services/textfile/common/textfiles';
68
import { IOutputService, IOutputChannelRegistry, Extensions as OutputExt, IOutputChannel } from 'vs/workbench/parts/output/common/output';
69
import { Scope, IActionBarRegistry, Extensions as ActionBarExtensions } from 'vs/workbench/browser/actions';
E
Erich Gamma 已提交
70

71 72
import { ITerminalService } from 'vs/workbench/parts/terminal/common/terminal';

73
import { ITaskSystem, ITaskResolver, ITaskSummary, ITaskExecuteResult, TaskExecuteKind, TaskError, TaskErrors, TaskSystemEvents } from 'vs/workbench/parts/tasks/common/taskSystem';
74
import { Task, TaskSet, TaskGroup, ExecutionEngine, TaskSourceKind } from 'vs/workbench/parts/tasks/common/tasks';
75
import { ITaskService, TaskServiceEvents, ITaskProvider } from 'vs/workbench/parts/tasks/common/taskService';
D
Dirk Baeumer 已提交
76
import { templates as taskTemplates } from 'vs/workbench/parts/tasks/common/taskTemplates';
E
Erich Gamma 已提交
77

78
import * as TaskConfig from 'vs/workbench/parts/tasks/common/taskConfiguration';
79
import { ProcessTaskSystem } from 'vs/workbench/parts/tasks/node/processTaskSystem';
80
import { TerminalTaskSystem } from './terminalTaskSystem';
J
Johannes Rieken 已提交
81
import { ProcessRunnerDetector } from 'vs/workbench/parts/tasks/node/processRunnerDetector';
D
Dirk Baeumer 已提交
82
import { QuickOpenActionContributor } from '../browser/quickOpen';
83

J
Johannes Rieken 已提交
84
import { IEnvironmentService } from 'vs/platform/environment/common/environment';
E
Erich Gamma 已提交
85

86
import { Themable, STATUS_BAR_FOREGROUND, STATUS_BAR_NO_FOLDER_FOREGROUND } from 'vs/workbench/common/theme';
87 88
import { IThemeService } from 'vs/platform/theme/common/themeService';

E
Erich Gamma 已提交
89
let $ = Builder.$;
90
let tasksCategory = nls.localize('tasksCategory', "Tasks");
E
Erich Gamma 已提交
91

92
abstract class OpenTaskConfigurationAction extends Action {
E
Erich Gamma 已提交
93

94 95 96 97 98 99 100 101 102
	constructor(id: string, label: string,
		private taskService: ITaskService,
		private configurationService: IConfigurationService,
		private editorService: IWorkbenchEditorService, private fileService: IFileService,
		private contextService: IWorkspaceContextService, private outputService: IOutputService,
		private messageService: IMessageService, private quickOpenService: IQuickOpenService,
		private environmentService: IEnvironmentService,
		private configurationResolverService: IConfigurationResolverService,
		private extensionService: IExtensionService) {
E
Erich Gamma 已提交
103 104 105 106

		super(id, label);
	}

J
Johannes Rieken 已提交
107
	public run(event?: any): TPromise<IEditor> {
B
Benjamin Pasero 已提交
108
		if (!this.contextService.hasWorkspace()) {
109 110 111
			this.messageService.show(Severity.Info, nls.localize('ConfigureTaskRunnerAction.noWorkspace', 'Tasks are only available on a workspace folder.'));
			return TPromise.as(undefined);
		}
E
Erich Gamma 已提交
112
		let sideBySide = !!(event && (event.ctrlKey || event.metaKey));
113
		let configFileCreated = false;
E
Erich Gamma 已提交
114 115
		return this.fileService.resolveFile(this.contextService.toResource('.vscode/tasks.json')).then((success) => {
			return success;
J
Johannes Rieken 已提交
116
		}, (err: any) => {
117
			;
J
Johannes Rieken 已提交
118
			return this.quickOpenService.pick(taskTemplates, { placeHolder: nls.localize('ConfigureTaskRunnerAction.quickPick.template', 'Select a Task Runner') }).then(selection => {
D
Dirk Baeumer 已提交
119 120
				if (!selection) {
					return undefined;
E
Erich Gamma 已提交
121
				}
122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167
				let contentPromise: TPromise<string>;
				if (selection.autoDetect) {
					const outputChannel = this.outputService.getChannel(TaskService.OutputChannelId);
					outputChannel.show(true);
					outputChannel.append(nls.localize('ConfigureTaskRunnerAction.autoDetecting', 'Auto detecting tasks for {0}', selection.id) + '\n');
					let detector = new ProcessRunnerDetector(this.fileService, this.contextService, this.configurationResolverService);
					contentPromise = detector.detect(false, selection.id).then((value) => {
						let config = value.config;
						if (value.stderr && value.stderr.length > 0) {
							value.stderr.forEach((line) => {
								outputChannel.append(line + '\n');
							});
							if (config && (!config.tasks || config.tasks.length === 0)) {
								this.messageService.show(Severity.Warning, nls.localize('ConfigureTaskRunnerAction.autoDetect', 'Auto detecting the task system failed. Using default template. Consult the task output for details.'));
								return selection.content;
							} else {
								this.messageService.show(Severity.Warning, nls.localize('ConfigureTaskRunnerAction.autoDetectError', 'Auto detecting the task system produced errors. Consult the task output for details.'));
							}
						}
						if (config) {
							if (value.stdout && value.stdout.length > 0) {
								value.stdout.forEach(line => outputChannel.append(line + '\n'));
							}
							let content = JSON.stringify(config, null, '\t');
							content = [
								'{',
								'\t// See https://go.microsoft.com/fwlink/?LinkId=733558',
								'\t// for the documentation about the tasks.json format',
							].join('\n') + content.substr(1);
							return content;
						} else {
							return selection.content;
						}
					});
				} else {
					contentPromise = TPromise.as(selection.content);
				}
				return contentPromise.then(content => {
					let editorConfig = this.configurationService.getConfiguration<any>();
					if (editorConfig.editor.insertSpaces) {
						content = content.replace(/(\n)(\t+)/g, (_, s1, s2) => s1 + strings.repeat(' ', s2.length * editorConfig.editor.tabSize));
					}
					configFileCreated = true;
					return this.fileService.createFile(this.contextService.toResource('.vscode/tasks.json'), content);
				});
				/* 2.0 version
D
Dirk Baeumer 已提交
168 169 170 171
				let content = selection.content;
				let editorConfig = this.configurationService.getConfiguration<any>();
				if (editorConfig.editor.insertSpaces) {
					content = content.replace(/(\n)(\t+)/g, (_, s1, s2) => s1 + strings.repeat(' ', s2.length * editorConfig.editor.tabSize));
E
Erich Gamma 已提交
172
				}
D
Dirk Baeumer 已提交
173 174
				configFileCreated = true;
				return this.fileService.createFile(this.contextService.toResource('.vscode/tasks.json'), content);
175
				*/
E
Erich Gamma 已提交
176 177
			});
		}).then((stat) => {
D
Dirk Baeumer 已提交
178 179 180 181
			if (!stat) {
				return undefined;
			}
			// // (2) Open editor with configuration file
E
Erich Gamma 已提交
182 183 184
			return this.editorService.openEditor({
				resource: stat.resource,
				options: {
185 186
					forceOpen: true,
					pinned: configFileCreated // pin only if config file is created #8727
E
Erich Gamma 已提交
187
				}
D
Dirk Baeumer 已提交
188
			}, sideBySide);
E
Erich Gamma 已提交
189 190 191 192 193 194
		}, (error) => {
			throw new Error(nls.localize('ConfigureTaskRunnerAction.failed', "Unable to create the 'tasks.json' file inside the '.vscode' folder. Consult the task output for details."));
		});
	}
}

195 196 197 198
class ConfigureTaskRunnerAction extends OpenTaskConfigurationAction {
	public static ID = 'workbench.action.tasks.configureTaskRunner';
	public static TEXT = nls.localize('ConfigureTaskRunnerAction.label', "Configure Task Runner");

199 200
	constructor(id: string, label: string,
		@ITaskService taskService, @IConfigurationService configurationService: IConfigurationService,
201 202 203
		@IWorkbenchEditorService editorService: IWorkbenchEditorService, @IFileService fileService: IFileService,
		@IWorkspaceContextService contextService: IWorkspaceContextService, @IOutputService outputService: IOutputService,
		@IMessageService messageService: IMessageService, @IQuickOpenService quickOpenService: IQuickOpenService,
204
		@IEnvironmentService environmentService: IEnvironmentService,
205 206 207 208 209
		@IConfigurationResolverService configurationResolverService: IConfigurationResolverService,
		@IExtensionService extensionService) {
		super(id, label, taskService, configurationService, editorService, fileService, contextService,
			outputService, messageService, quickOpenService, environmentService, configurationResolverService,
			extensionService);
J
Johannes Rieken 已提交
210
	}
211 212 213 214 215 216
}

class ConfigureBuildTaskAction extends OpenTaskConfigurationAction {
	public static ID = 'workbench.action.tasks.configureBuildTask';
	public static TEXT = nls.localize('ConfigureBuildTaskAction.label', "Configure Build Task");

217 218
	constructor(id: string, label: string,
		@ITaskService taskService, @IConfigurationService configurationService: IConfigurationService,
219 220 221
		@IWorkbenchEditorService editorService: IWorkbenchEditorService, @IFileService fileService: IFileService,
		@IWorkspaceContextService contextService: IWorkspaceContextService, @IOutputService outputService: IOutputService,
		@IMessageService messageService: IMessageService, @IQuickOpenService quickOpenService: IQuickOpenService,
222
		@IEnvironmentService environmentService: IEnvironmentService,
223 224 225 226 227
		@IConfigurationResolverService configurationResolverService: IConfigurationResolverService,
		@IExtensionService extensionService) {
		super(id, label, taskService, configurationService, editorService, fileService, contextService,
			outputService, messageService, quickOpenService, environmentService, configurationResolverService,
			extensionService);
J
Johannes Rieken 已提交
228
	}
229 230
}

E
Erich Gamma 已提交
231 232 233 234 235 236 237 238 239 240
class CloseMessageAction extends Action {

	public static ID = 'workbench.action.build.closeMessage';
	public static TEXT = nls.localize('CloseMessageAction.label', 'Close');

	public closeFunction: () => void;

	constructor() {
		super(CloseMessageAction.ID, CloseMessageAction.TEXT);
	}
241
	public run(): TPromise<void> {
E
Erich Gamma 已提交
242 243 244
		if (this.closeFunction) {
			this.closeFunction();
		}
245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260
		return TPromise.as(undefined);
	}
}

class ViewTerminalAction extends Action {

	public static ID = 'workbench.action.build.viewTerminal';
	public static TEXT = nls.localize('ShowTerminalAction.label', 'View Terminal');

	constructor( @ITerminalService private terminalService: ITerminalService) {
		super(ViewTerminalAction.ID, ViewTerminalAction.TEXT);
	}

	public run(): TPromise<void> {
		this.terminalService.showPanel();
		return TPromise.as(undefined);
E
Erich Gamma 已提交
261 262 263
	}
}

264
class StatusBarItem extends Themable implements IStatusbarItem {
E
Erich Gamma 已提交
265 266
	private intervalToken: any;
	private activeCount: number;
J
Johannes Rieken 已提交
267
	private static progressChars: string = '|/-\\';
268 269 270 271 272 273 274 275
	private icons: HTMLElement[];

	constructor(
		@IPanelService private panelService: IPanelService,
		@IMarkerService private markerService: IMarkerService,
		@IOutputService private outputService: IOutputService,
		@ITaskService private taskService: ITaskService,
		@IPartService private partService: IPartService,
276 277
		@IThemeService themeService: IThemeService,
		@IWorkspaceContextService private contextService: IWorkspaceContextService
278 279
	) {
		super(themeService);
E
Erich Gamma 已提交
280 281

		this.activeCount = 0;
282
		this.icons = [];
E
Erich Gamma 已提交
283 284
	}

285 286
	protected updateStyles(): void {
		super.updateStyles();
E
Erich Gamma 已提交
287

288
		this.icons.forEach(icon => {
289
			icon.style.backgroundColor = this.getColor(this.contextService.hasWorkspace() ? STATUS_BAR_FOREGROUND : STATUS_BAR_NO_FOLDER_FOREGROUND);
290 291
		});
	}
E
Erich Gamma 已提交
292

293 294 295 296 297 298 299 300 301 302 303 304
	public render(container: HTMLElement): IDisposable {
		let callOnDispose: IDisposable[] = [];

		const element = document.createElement('div');
		const progress = document.createElement('div');
		const label = document.createElement('a');
		const errorIcon = document.createElement('div');
		const warningIcon = document.createElement('div');
		const infoIcon = document.createElement('div');
		const error = document.createElement('div');
		const warning = document.createElement('div');
		const info = document.createElement('div');
E
Erich Gamma 已提交
305

306
		Dom.addClass(element, 'task-statusbar-item');
E
Erich Gamma 已提交
307 308 309 310 311 312 313 314

		Dom.addClass(progress, 'task-statusbar-item-progress');
		element.appendChild(progress);
		progress.innerHTML = StatusBarItem.progressChars[0];
		$(progress).hide();

		Dom.addClass(label, 'task-statusbar-item-label');
		element.appendChild(label);
S
Sandeep Somavarapu 已提交
315
		element.title = nls.localize('problems', "Problems");
E
Erich Gamma 已提交
316

317
		Dom.addClass(errorIcon, 'task-statusbar-item-label-error');
318
		Dom.addClass(errorIcon, 'mask-icon');
319 320 321 322
		label.appendChild(errorIcon);
		this.icons.push(errorIcon);

		Dom.addClass(error, 'task-statusbar-item-label-counter');
E
Erich Gamma 已提交
323 324 325
		error.innerHTML = '0';
		label.appendChild(error);

326
		Dom.addClass(warningIcon, 'task-statusbar-item-label-warning');
327
		Dom.addClass(warningIcon, 'mask-icon');
328 329 330 331
		label.appendChild(warningIcon);
		this.icons.push(warningIcon);

		Dom.addClass(warning, 'task-statusbar-item-label-counter');
E
Erich Gamma 已提交
332 333 334
		warning.innerHTML = '0';
		label.appendChild(warning);

335
		Dom.addClass(infoIcon, 'task-statusbar-item-label-info');
336
		Dom.addClass(infoIcon, 'mask-icon');
337 338 339 340 341
		label.appendChild(infoIcon);
		this.icons.push(infoIcon);
		$(infoIcon).hide();

		Dom.addClass(info, 'task-statusbar-item-label-counter');
E
Erich Gamma 已提交
342 343 344
		label.appendChild(info);
		$(info).hide();

J
Johannes Rieken 已提交
345 346
		callOnDispose.push(Dom.addDisposableListener(label, 'click', (e: MouseEvent) => {
			const panel = this.panelService.getActivePanel();
347 348 349 350 351
			if (panel && panel.getId() === Constants.MARKERS_PANEL_ID) {
				this.partService.setPanelHidden(true);
			} else {
				this.panelService.openPanel(Constants.MARKERS_PANEL_ID, true);
			}
J
Johannes Rieken 已提交
352
		}));
E
Erich Gamma 已提交
353

354
		let updateStatus = (element: HTMLDivElement, icon: HTMLDivElement, stats: number): boolean => {
E
Erich Gamma 已提交
355 356 357
			if (stats > 0) {
				element.innerHTML = stats.toString();
				$(element).show();
358
				$(icon).show();
E
Erich Gamma 已提交
359 360 361
				return true;
			} else {
				$(element).hide();
362
				$(icon).hide();
E
Erich Gamma 已提交
363 364 365 366 367 368 369 370
				return false;
			}
		};

		let manyMarkers = nls.localize('manyMarkers', "99+");
		let updateLabel = (stats: MarkerStatistics) => {
			error.innerHTML = stats.errors < 100 ? stats.errors.toString() : manyMarkers;
			warning.innerHTML = stats.warnings < 100 ? stats.warnings.toString() : manyMarkers;
371
			updateStatus(info, infoIcon, stats.infos);
E
Erich Gamma 已提交
372 373 374 375 376 377
		};

		this.markerService.onMarkerChanged((changedResources) => {
			updateLabel(this.markerService.getStatistics());
		});

A
Alex Dima 已提交
378
		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Active, () => {
E
Erich Gamma 已提交
379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394
			this.activeCount++;
			if (this.activeCount === 1) {
				let index = 1;
				let chars = StatusBarItem.progressChars;
				progress.innerHTML = chars[0];
				this.intervalToken = setInterval(() => {
					progress.innerHTML = chars[index];
					index++;
					if (index >= chars.length) {
						index = 0;
					}
				}, 50);
				$(progress).show();
			}
		}));

A
Alex Dima 已提交
395
		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Inactive, (data: TaskServiceEventData) => {
396 397 398 399 400 401 402 403 404 405 406
			// Since the exiting of the sub process is communicated async we can't order inactive and terminate events.
			// So try to treat them accordingly.
			if (this.activeCount > 0) {
				this.activeCount--;
				if (this.activeCount === 0) {
					$(progress).hide();
					if (this.intervalToken) {
						clearInterval(this.intervalToken);
						this.intervalToken = null;
					}
				}
E
Erich Gamma 已提交
407 408 409
			}
		}));

A
Alex Dima 已提交
410
		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Terminated, () => {
E
Erich Gamma 已提交
411 412 413 414 415 416 417 418 419 420 421 422
			if (this.activeCount !== 0) {
				$(progress).hide();
				if (this.intervalToken) {
					clearInterval(this.intervalToken);
					this.intervalToken = null;
				}
				this.activeCount = 0;
			}
		}));

		container.appendChild(element);

423 424
		this.updateStyles();

E
Erich Gamma 已提交
425
		return {
426
			dispose: () => {
J
Joao Moreno 已提交
427
				callOnDispose = dispose(callOnDispose);
428
			}
E
Erich Gamma 已提交
429 430 431 432 433 434 435 436
		};
	}
}

interface TaskServiceEventData {
	error?: any;
}

437
class NullTaskSystem extends EventEmitter implements ITaskSystem {
438
	public run(task: Task): ITaskExecuteResult {
439
		return {
440
			kind: TaskExecuteKind.Started,
441 442 443 444 445 446 447 448 449
			promise: TPromise.as<ITaskSummary>({})
		};
	}
	public isActive(): TPromise<boolean> {
		return TPromise.as(false);
	}
	public isActiveSync(): boolean {
		return false;
	}
450 451 452
	public getActiveTasks(): Task[] {
		return [];
	}
453 454 455
	public canAutoTerminate(): boolean {
		return true;
	}
456 457 458 459
	public terminate(task: string | Task): TPromise<TerminateResponse> {
		return TPromise.as<TerminateResponse>({ success: true });
	}
	public terminateAll(): TPromise<TerminateResponse> {
460 461 462 463
		return TPromise.as<TerminateResponse>({ success: true });
	}
}

464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500
class ProblemReporter implements TaskConfig.IProblemReporter {

	private _validationStatus: ValidationStatus;

	constructor(private _outputChannel: IOutputChannel) {
		this._validationStatus = new ValidationStatus();
	}

	public info(message: string): void {
		this._validationStatus.state = ValidationState.Info;
		this._outputChannel.append(message + '\n');
	}

	public warn(message: string): void {
		this._validationStatus.state = ValidationState.Warning;
		this._outputChannel.append(message + '\n');
	}

	public error(message: string): void {
		this._validationStatus.state = ValidationState.Error;
		this._outputChannel.append(message + '\n');
	}

	public fatal(message: string): void {
		this._validationStatus.state = ValidationState.Fatal;
		this._outputChannel.append(message + '\n');
	}

	public get status(): ValidationStatus {
		return this._validationStatus;
	}

	public clearOutput(): void {
		this._outputChannel.clear();
	}
}

501
interface WorkspaceTaskResult {
502
	set: TaskSet;
503 504
	annotatingTasks: {
		byIdentifier: IStringDictionary<Task>;
505
		byLabel: IStringDictionary<Task>;
506
	};
507 508 509
	hasErrors: boolean;
}

510 511 512 513 514
interface WorkspaceConfigurationResult {
	config: TaskConfig.ExternalTaskRunnerConfiguration;
	hasErrors: boolean;
}

E
Erich Gamma 已提交
515
class TaskService extends EventEmitter implements ITaskService {
516

517
	// private static autoDetectTelemetryName: string = 'taskServer.autoDetect';
518

519
	public _serviceBrand: any;
E
Erich Gamma 已提交
520
	public static SERVICE_ID: string = 'taskService';
J
Johannes Rieken 已提交
521 522
	public static OutputChannelId: string = 'tasks';
	public static OutputChannelLabel: string = nls.localize('tasks', "Tasks");
E
Erich Gamma 已提交
523 524 525

	private modeService: IModeService;
	private configurationService: IConfigurationService;
D
Dirk Baeumer 已提交
526
	private configurationEditingService: IConfigurationEditingService;
E
Erich Gamma 已提交
527 528 529 530 531 532 533 534 535
	private markerService: IMarkerService;
	private outputService: IOutputService;
	private messageService: IMessageService;
	private fileService: IFileService;
	private telemetryService: ITelemetryService;
	private editorService: IWorkbenchEditorService;
	private contextService: IWorkspaceContextService;
	private textFileService: ITextFileService;
	private modelService: IModelService;
A
Alex Dima 已提交
536
	private extensionService: IExtensionService;
D
Dirk Baeumer 已提交
537
	private quickOpenService: IQuickOpenService;
E
Erich Gamma 已提交
538

539
	private _configHasErrors: boolean;
540
	private _providers: Map<number, ITaskProvider>;
541 542

	private _workspaceTasksPromise: TPromise<WorkspaceTaskResult>;
543

E
Erich Gamma 已提交
544
	private _taskSystem: ITaskSystem;
545
	private _taskSystemListeners: IDisposable[];
546

547
	private _outputChannel: IOutputChannel;
E
Erich Gamma 已提交
548

J
Johannes Rieken 已提交
549
	constructor( @IModeService modeService: IModeService, @IConfigurationService configurationService: IConfigurationService,
D
Dirk Baeumer 已提交
550
		@IConfigurationEditingService configurationEditingService: IConfigurationEditingService,
E
Erich Gamma 已提交
551
		@IMarkerService markerService: IMarkerService, @IOutputService outputService: IOutputService,
J
Johannes Rieken 已提交
552 553 554
		@IMessageService messageService: IMessageService, @IWorkbenchEditorService editorService: IWorkbenchEditorService,
		@IFileService fileService: IFileService, @IWorkspaceContextService contextService: IWorkspaceContextService,
		@ITelemetryService telemetryService: ITelemetryService, @ITextFileService textFileService: ITextFileService,
555
		@ILifecycleService lifecycleService: ILifecycleService,
A
Alex Dima 已提交
556
		@IModelService modelService: IModelService, @IExtensionService extensionService: IExtensionService,
557
		@IQuickOpenService quickOpenService: IQuickOpenService,
558
		@IEnvironmentService private environmentService: IEnvironmentService,
559
		@IConfigurationResolverService private configurationResolverService: IConfigurationResolverService,
560 561
		@ITerminalService private terminalService: ITerminalService,
		@IWorkbenchEditorService private workbenchEditorService: IWorkbenchEditorService
562
	) {
E
Erich Gamma 已提交
563 564 565 566

		super();
		this.modeService = modeService;
		this.configurationService = configurationService;
D
Dirk Baeumer 已提交
567
		this.configurationEditingService = configurationEditingService;
E
Erich Gamma 已提交
568 569 570 571 572 573 574 575 576
		this.markerService = markerService;
		this.outputService = outputService;
		this.messageService = messageService;
		this.editorService = editorService;
		this.fileService = fileService;
		this.contextService = contextService;
		this.telemetryService = telemetryService;
		this.textFileService = textFileService;
		this.modelService = modelService;
A
Alex Dima 已提交
577
		this.extensionService = extensionService;
D
Dirk Baeumer 已提交
578
		this.quickOpenService = quickOpenService;
E
Erich Gamma 已提交
579

580 581
		this._configHasErrors = false;
		this._workspaceTasksPromise = undefined;
582 583 584
		this._taskSystemListeners = [];
		this._outputChannel = this.outputService.getChannel(TaskService.OutputChannelId);
		this._providers = new Map<number, ITaskProvider>();
J
Johannes Rieken 已提交
585
		this.configurationService.onDidUpdateConfiguration(() => {
586
			if (!this._taskSystem && !this._workspaceTasksPromise) {
587 588
				return;
			}
589
			this.updateWorkspaceTasks();
590 591 592
			if (!this._taskSystem) {
				return;
			}
593 594 595 596
			let currentExecutionEngine = this._taskSystem instanceof TerminalTaskSystem
				? ExecutionEngine.Terminal
				: this._taskSystem instanceof ProcessTaskSystem
					? ExecutionEngine.Process
597
					: undefined;
598
			if (currentExecutionEngine !== this.getExecutionEngine()) {
599
				this.messageService.show(Severity.Info, nls.localize('TaskSystem.noHotSwap', 'Changing the task execution engine requires restarting VS Code. The change is ignored.'));
D
Dirk Baeumer 已提交
600
			}
E
Erich Gamma 已提交
601
		});
602
		lifecycleService.onWillShutdown(event => event.veto(this.beforeShutdown()));
603 604 605 606
		this.registerCommands();
	}

	private registerCommands(): void {
607
		CommandsRegistry.registerCommand('workbench.action.tasks.runTask', (accessor, arg) => {
608 609 610
			this.runTaskCommand(accessor, arg);
		});

611 612 613 614
		CommandsRegistry.registerCommand('workbench.action.tasks.restartTask', (accessor, arg) => {
			this.runRestartTaskCommand(accessor, arg);
		});

615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642
		CommandsRegistry.registerCommand('workbench.action.tasks.terminate', (accessor, arg) => {
			this.runTerminateCommand();
		});

		CommandsRegistry.registerCommand('workbench.action.tasks.showLog', () => {
			if (!this.canRunCommand()) {
				return;
			}
			this.showOutput();
		});

		CommandsRegistry.registerCommand('workbench.action.tasks.build', () => {
			if (!this.canRunCommand()) {
				return;
			}
			this.build();
		});

		KeybindingsRegistry.registerKeybindingRule({
			id: 'workbench.action.tasks.build',
			weight: KeybindingsRegistry.WEIGHT.workbenchContrib(),
			when: undefined,
			primary: KeyMod.CtrlCmd | KeyMod.Shift | KeyCode.KEY_B
		});

		CommandsRegistry.registerCommand('workbench.action.tasks.test', () => {
			if (!this.canRunCommand()) {
				return;
643
			}
644
			this.runTest();
645
		});
E
Erich Gamma 已提交
646 647
	}

648
	private showOutput(): void {
649
		this._outputChannel.show(true);
650 651
	}

E
Erich Gamma 已提交
652
	private disposeTaskSystemListeners(): void {
653
		this._taskSystemListeners = dispose(this._taskSystemListeners);
E
Erich Gamma 已提交
654 655
	}

656 657 658 659
	public registerTaskProvider(handle: number, provider: ITaskProvider): void {
		if (!provider) {
			return;
		}
660
		this._providers.set(handle, provider);
661 662 663
	}

	public unregisterTaskProvider(handle: number): boolean {
664
		return this._providers.delete(handle);
665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683
	}

	public tasks(): TPromise<Task[]> {
		return this.getTaskSets().then((sets) => {
			let result: Task[] = [];
			for (let set of sets) {
				result.push(...set.tasks);
			}
			return result;
		});
	};

	public isActive(): TPromise<boolean> {
		if (!this._taskSystem) {
			return TPromise.as(false);
		}
		return this._taskSystem.isActive();
	}

684 685 686 687 688 689 690 691
	public getActiveTasks(): TPromise<Task[]> {
		if (!this._taskSystem) {
			return TPromise.as([]);
		}
		return TPromise.as(this._taskSystem.getActiveTasks());
	}


692 693
	public build(): TPromise<ITaskSummary> {
		return this.getTaskSets().then((values) => {
694
			let runnable = this.createRunnableTask(values, TaskGroup.Build);
695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714
			if (!runnable || !runnable.task) {
				throw new TaskError(Severity.Info, nls.localize('TaskService.noBuildTask', 'No build task defined. Mark a task with \'isBuildCommand\' in the tasks.json file.'), TaskErrors.NoBuildTask);
			}
			return this.executeTask(runnable.task, runnable.resolver);
		}).then(value => value, (error) => {
			this.handleError(error);
			return TPromise.wrapError(error);
		});
	}

	public rebuild(): TPromise<ITaskSummary> {
		return TPromise.wrapError<ITaskSummary>(new Error('Not implemented'));
	}

	public clean(): TPromise<ITaskSummary> {
		return TPromise.wrapError<ITaskSummary>(new Error('Not implemented'));
	}

	public runTest(): TPromise<ITaskSummary> {
		return this.getTaskSets().then((values) => {
715
			let runnable = this.createRunnableTask(values, TaskGroup.Test);
716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733
			if (!runnable || !runnable.task) {
				throw new TaskError(Severity.Info, nls.localize('TaskService.noTestTask', 'No test task defined. Mark a task with \'isTestCommand\' in the tasks.json file.'), TaskErrors.NoTestTask);
			}
			return this.executeTask(runnable.task, runnable.resolver);
		}).then(value => value, (error) => {
			this.handleError(error);
			return TPromise.wrapError(error);
		});
	}

	public run(task: string | Task): TPromise<ITaskSummary> {
		return this.getTaskSets().then((values) => {
			let resolver = this.createResolver(values);
			let requested: string;
			let toExecute: Task;
			if (Types.isString(task)) {
				requested = task;
				toExecute = resolver.resolve(task);
734
			} else {
735
				requested = task.name;
D
Dirk Baeumer 已提交
736
				toExecute = task;
737 738 739 740 741
			}
			if (!toExecute) {
				throw new TaskError(Severity.Info, nls.localize('TaskServer.noTask', 'Requested task {0} to execute not found.', requested), TaskErrors.TaskNotFound);
			} else {
				return this.executeTask(toExecute, resolver);
742
			}
743 744 745 746 747 748
		}).then(value => value, (error) => {
			this.handleError(error);
			return TPromise.wrapError(error);
		});
	}

D
Dirk Baeumer 已提交
749 750 751 752 753 754 755 756 757 758
	public customize(task: Task, openConfig: boolean = false): TPromise<void> {
		if (task._source.kind !== TaskSourceKind.Extension) {
			return TPromise.as<void>(undefined);
		}
		let configuration = this.getConfiguration();
		if (configuration.hasParseErrors) {
			this.messageService.show(Severity.Warning, nls.localize('customizeParseErrors', 'The current task configuration has errors. Please fix the errors first before customizing a task.'));
			return TPromise.as<void>(undefined);
		}
		let fileConfig = configuration.config;
759
		let customize = { taskName: task._label, identifier: task.identifier };
D
Dirk Baeumer 已提交
760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785
		if (!fileConfig) {
			fileConfig = {
				version: '2.0.0',
				tasks: [customize]
			};
		} else {
			if (Array.isArray(fileConfig.tasks)) {
				fileConfig.tasks.push(customize);
			} else {
				fileConfig.tasks = [customize];
			}
		};
		return this.configurationEditingService.writeConfiguration(ConfigurationTarget.WORKSPACE, { key: 'tasks', value: fileConfig }).then(() => {
			if (openConfig) {
				let resource = this.contextService.toResource('.vscode/tasks.json');
				this.editorService.openEditor({
					resource: resource,
					options: {
						forceOpen: true,
						pinned: false
					}
				}, false);
			}
		});
	}

786
	private createRunnableTask(sets: TaskSet[], group: TaskGroup): { task: Task; resolver: ITaskResolver } {
787
		let uuidMap: IStringDictionary<Task> = Object.create(null);
D
Dirk Baeumer 已提交
788
		let labelMap: IStringDictionary<Task> = Object.create(null);
789 790
		let identifierMap: IStringDictionary<Task> = Object.create(null);

791 792
		let workspaceTasks: Task[] = [];
		let extensionTasks: Task[] = [];
793 794 795
		sets.forEach((set) => {
			set.tasks.forEach((task) => {
				uuidMap[task._id] = task;
796
				labelMap[task._label] = task;
797
				identifierMap[task.identifier] = task;
798
				if (group && task.group === group) {
799 800 801 802 803
					if (task._source.kind === TaskSourceKind.Workspace) {
						workspaceTasks.push(task);
					} else {
						extensionTasks.push(task);
					}
804
				}
805 806 807 808
			});
		});
		let resolver: ITaskResolver = {
			resolve: (id: string) => {
D
Dirk Baeumer 已提交
809
				return uuidMap[id] || labelMap[id] || identifierMap[id];
810 811
			}
		};
812 813 814 815 816 817 818 819 820 821 822 823
		if (workspaceTasks.length > 0) {
			if (workspaceTasks.length > 1) {
				this._outputChannel.append(nls.localize('moreThanOneBuildTask', 'There are many build tasks defined in the tasks.json. Executing the first one.\n'));
			}
			return { task: workspaceTasks[0], resolver };
		}
		if (extensionTasks.length === 0) {
			return undefined;
		}

		if (extensionTasks.length === 1) {
			return { task: extensionTasks[0], resolver };
824 825 826 827
		} else {
			let id: string = UUID.generateUuid();
			let task: Task = {
				_id: id,
828
				_source: { kind: TaskSourceKind.Generic, label: 'generic' },
829
				_label: id,
830 831
				name: id,
				identifier: id,
832
				dependsOn: extensionTasks.map(task => task._id),
833 834 835
				command: undefined,
			};
			return { task, resolver };
E
Erich Gamma 已提交
836 837 838
		}
	}

839
	private createResolver(sets: TaskSet[]): ITaskResolver {
D
Dirk Baeumer 已提交
840
		let labelMap: IStringDictionary<Task> = Object.create(null);
841 842 843 844
		let identifierMap: IStringDictionary<Task> = Object.create(null);

		sets.forEach((set) => {
			set.tasks.forEach((task) => {
845
				labelMap[task._label] = task;
846 847 848 849 850
				identifierMap[task.identifier] = task;
			});
		});
		return {
			resolve: (id: string) => {
D
Dirk Baeumer 已提交
851
				return labelMap[id] || identifierMap[id];
852
			}
853 854 855 856
		};
	}

	private executeTask(task: Task, resolver: ITaskResolver): TPromise<ITaskSummary> {
857 858 859 860 861 862 863 864 865 866
		return ProblemMatcherRegistry.onReady().then(() => {
			return this.textFileService.saveAll().then((value) => { // make sure all dirty files are saved
				let executeResult = this.getTaskSystem().run(task, resolver);
				if (executeResult.kind === TaskExecuteKind.Active) {
					let active = executeResult.active;
					if (active.same && active.background) {
						this.messageService.show(Severity.Info, nls.localize('TaskSystem.activeSame', 'The task is already active and in watch mode. To terminate the task use `F1 > terminate task`'));
					} else {
						throw new TaskError(Severity.Warning, nls.localize('TaskSystem.active', 'There is already a task running. Terminate it first before executing another task.'), TaskErrors.RunningTask);
					}
867
				}
868 869
				return executeResult.promise;
			});
870 871 872
		});
	}

873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888
	public restart(task: string | Task): void {
		if (!this._taskSystem) {
			return;
		}
		const id: string = Types.isString(task) ? task : task._id;
		this._taskSystem.terminate(id).then((response) => {
			if (response.success) {
				this.emit(TaskServiceEvents.Terminated, {});
				this.run(task);
			} else {
				this.messageService.show(Severity.Warning, nls.localize('TaskSystem.restartFailed', 'Failed to terminate and restart task {0}', Types.isString(task) ? task : task.name));
			}
			return response;
		});
	}

889
	public terminate(task: string | Task): TPromise<TerminateResponse> {
890 891 892
		if (!this._taskSystem) {
			return TPromise.as({ success: true });
		}
893 894
		const id: string = Types.isString(task) ? task : task._id;
		return this._taskSystem.terminate(id).then((response) => {
895 896 897
			if (response.success) {
				this.emit(TaskServiceEvents.Terminated, {});
			}
898 899 900 901 902 903 904 905 906
			return response;
		});
	}

	public terminateAll(): TPromise<TerminateResponse> {
		if (!this._taskSystem) {
			return TPromise.as({ success: true });
		}
		return this._taskSystem.terminateAll().then((response) => {
907 908 909 910 911 912 913 914 915 916 917 918 919 920
			this.emit(TaskServiceEvents.Terminated, {});
			return response;
		});
	}

	private getTaskSystem(): ITaskSystem {
		if (this._taskSystem) {
			return this._taskSystem;
		}
		let engine = this.getExecutionEngine();
		if (engine === ExecutionEngine.Terminal) {
			this._taskSystem = new TerminalTaskSystem(
				this.terminalService, this.outputService, this.markerService,
				this.modelService, this.configurationResolverService, this.telemetryService,
921
				this.workbenchEditorService,
922 923 924 925 926 927 928 929 930 931
				TaskService.OutputChannelId
			);
		} else {
			let system = new ProcessTaskSystem(
				this.markerService, this.modelService, this.telemetryService, this.outputService,
				this.configurationResolverService, TaskService.OutputChannelId,
			);
			system.hasErrors(this._configHasErrors);
			this._taskSystem = system;
		}
A
Alex Dima 已提交
932 933
		this._taskSystemListeners.push(this._taskSystem.addListener(TaskSystemEvents.Active, (event) => this.emit(TaskServiceEvents.Active, event)));
		this._taskSystemListeners.push(this._taskSystem.addListener(TaskSystemEvents.Inactive, (event) => this.emit(TaskServiceEvents.Inactive, event)));
934 935 936 937
		return this._taskSystem;
	}

	private getTaskSets(): TPromise<TaskSet[]> {
D
Dirk Baeumer 已提交
938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960
		return this.extensionService.activateByEvent('onCommand:workbench.action.tasks.runTask').then(() => {
			return new TPromise<TaskSet[]>((resolve, reject) => {
				let result: TaskSet[] = [];
				let counter: number = 0;
				let done = (value: TaskSet) => {
					if (value) {
						result.push(value);
					}
					if (--counter === 0) {
						resolve(result);
					}
				};
				let error = () => {
					if (--counter === 0) {
						resolve(result);
					}
				};
				if (this.getExecutionEngine() === ExecutionEngine.Terminal && this._providers.size > 0) {
					this._providers.forEach((provider) => {
						counter++;
						provider.provideTasks().done(done, error);
					});
				} else {
961 962
					resolve(result);
				}
D
Dirk Baeumer 已提交
963
			});
964 965 966 967 968 969 970 971 972
		}).then((result) => {
			return this.getWorkspaceTasks().then((workspaceTaskResult) => {
				let workspaceTasksToDelete: Task[] = [];
				let annotatingTasks = workspaceTaskResult.annotatingTasks;
				let legacyAnnotatingTasks = workspaceTaskResult.set ? this.getLegacyAnnotatingTasks(workspaceTaskResult.set) : undefined;
				if (annotatingTasks || legacyAnnotatingTasks) {
					for (let set of result) {
						for (let task of set.tasks) {
							if (annotatingTasks) {
973
								let annotatingTask = annotatingTasks.byIdentifier[task.identifier] || annotatingTasks.byLabel[task._label];
974 975
								if (annotatingTask) {
									TaskConfig.mergeTasks(task, annotatingTask);
976
									task.name = annotatingTask.name;
977
									task._label = annotatingTask._label;
978 979 980 981 982 983 984 985 986
									task._source.kind = TaskSourceKind.Workspace;
									continue;
								}
							}
							if (legacyAnnotatingTasks) {
								let legacyAnnotatingTask = legacyAnnotatingTasks[task.identifier];
								if (legacyAnnotatingTask) {
									TaskConfig.mergeTasks(task, legacyAnnotatingTask);
									task._source.kind = TaskSourceKind.Workspace;
987
									task.name = legacyAnnotatingTask.name;
988
									task._label = legacyAnnotatingTask._label;
989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017
									workspaceTasksToDelete.push(legacyAnnotatingTask);
									continue;
								}
							}
						}
					}
				}
				if (workspaceTaskResult.set) {
					if (workspaceTasksToDelete.length > 0) {
						let tasks = workspaceTaskResult.set.tasks;
						let newSet: TaskSet = {
							extension: workspaceTaskResult.set.extension,
							tasks: []
						};
						let toDelete = workspaceTasksToDelete.reduce<IStringDictionary<boolean>>((map, task) => {
							map[task._id] = true;
							return map;
						}, Object.create(null));
						newSet.tasks = tasks.filter(task => !toDelete[task._id]);
						result.push(newSet);
					} else {
						result.push(workspaceTaskResult.set);
					}
				}
				return result;
			}, () => {
				// If we can't read the tasks.json file provide at least the contributed tasks
				return result;
			});
1018 1019 1020
		});
	}

1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041
	private getLegacyAnnotatingTasks(workspaceTasks: TaskSet): IStringDictionary<Task> {
		let result: IStringDictionary<Task>;
		function getResult() {
			if (result) {
				return result;
			}
			result = Object.create(null);
			return result;
		}
		for (let task of workspaceTasks.tasks) {
			let commandName = task.command && task.command.name;
			// This is for backwards compatibility with the 0.1.0 task annotation code
			// if we had a gulp, jake or grunt command a task specification was a annotation
			if (commandName === 'gulp' || commandName === 'grunt' || commandName === 'jake') {
				getResult()[`${commandName}.${task.name}`] = task;
			}
		}
		return result;
	}

	private getWorkspaceTasks(): TPromise<WorkspaceTaskResult> {
1042 1043 1044
		if (this._workspaceTasksPromise) {
			return this._workspaceTasksPromise;
		}
1045
		this.updateWorkspaceTasks();
1046 1047 1048 1049 1050 1051
		return this._workspaceTasksPromise;
	}

	private updateWorkspaceTasks(): void {
		this._workspaceTasksPromise = this.computeWorkspaceTasks().then(value => {
			this._configHasErrors = value.hasErrors;
1052 1053 1054 1055
			if (this._taskSystem instanceof ProcessTaskSystem) {
				this._taskSystem.hasErrors(this._configHasErrors);
			}
			return value;
1056 1057 1058 1059
		});
	}

	private computeWorkspaceTasks(): TPromise<WorkspaceTaskResult> {
1060
		let configPromise: TPromise<WorkspaceConfigurationResult>;
1061 1062 1063
		{
			let { config, hasParseErrors } = this.getConfiguration();
			if (hasParseErrors) {
1064
				return TPromise.as({ set: undefined, hasErrors: true });
1065
			}
1066
			let engine = TaskConfig.ExecutionEngine._default;
1067
			if (config) {
1068
				engine = TaskConfig.ExecutionEngine.from(config);
1069 1070 1071 1072 1073 1074 1075
				if (engine === ExecutionEngine.Process) {
					if (this.hasDetectorSupport(config)) {
						configPromise = new ProcessRunnerDetector(this.fileService, this.contextService, this.configurationResolverService, config).detect(true).then((value): WorkspaceConfigurationResult => {
							let hasErrors = this.printStderr(value.stderr);
							let detectedConfig = value.config;
							if (!detectedConfig) {
								return { config, hasErrors };
1076
							}
1077 1078 1079 1080 1081
							let result: TaskConfig.ExternalTaskRunnerConfiguration = Objects.clone(config);
							let configuredTasks: IStringDictionary<TaskConfig.TaskDescription> = Object.create(null);
							if (!result.tasks) {
								if (detectedConfig.tasks) {
									result.tasks = detectedConfig.tasks;
1082
								}
1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098
							} else {
								result.tasks.forEach(task => configuredTasks[task.taskName] = task);
								detectedConfig.tasks.forEach((task) => {
									if (!configuredTasks[task.taskName]) {
										result.tasks.push(task);
									}
								});
							}
							return { config: result, hasErrors };
						});
					} else {
						configPromise = new ProcessRunnerDetector(this.fileService, this.contextService, this.configurationResolverService).detect(true).then((value) => {
							let hasErrors = this.printStderr(value.stderr);
							return { config: value.config, hasErrors };
						});
					}
1099 1100 1101
				} else {
					configPromise = TPromise.as({ config, hasErrors: false });
				}
1102
			} else {
1103 1104 1105 1106 1107 1108 1109 1110
				if (engine === ExecutionEngine.Terminal) {
					configPromise = TPromise.as({ config, hasErrors: false });
				} else {
					configPromise = new ProcessRunnerDetector(this.fileService, this.contextService, this.configurationResolverService).detect(true).then((value) => {
						let hasErrors = this.printStderr(value.stderr);
						return { config: value.config, hasErrors };
					});
				}
1111 1112
			}
		}
1113
		return configPromise.then((resolved) => {
1114
			return ProblemMatcherRegistry.onReady().then((): WorkspaceTaskResult => {
1115
				if (!resolved || !resolved.config) {
1116
					return { set: undefined, annotatingTasks: undefined, hasErrors: resolved !== void 0 ? resolved.hasErrors : false };
1117
				}
1118
				let problemReporter = new ProblemReporter(this._outputChannel);
1119
				let parseResult = TaskConfig.parse(resolved.config, problemReporter);
1120 1121 1122 1123 1124 1125 1126
				let hasErrors = false;
				if (!parseResult.validationStatus.isOK()) {
					hasErrors = true;
					this.showOutput();
				}
				if (problemReporter.status.isFatal()) {
					problemReporter.fatal(nls.localize('TaskSystem.configurationErrors', 'Error: the provided task configuration has validation errors and can\'t not be used. Please correct the errors first.'));
1127 1128
					return { set: undefined, annotatingTasks: undefined, hasErrors };
				}
1129
				let annotatingTasks: { byIdentifier: IStringDictionary<Task>; byLabel: IStringDictionary<Task>; };
1130 1131 1132
				if (parseResult.annotatingTasks && parseResult.annotatingTasks.length > 0) {
					annotatingTasks = {
						byIdentifier: Object.create(null),
1133
						byLabel: Object.create(null)
1134 1135 1136
					};
					for (let task of parseResult.annotatingTasks) {
						annotatingTasks.byIdentifier[task.identifier] = task;
1137 1138
						if (task._label) {
							annotatingTasks.byLabel[task._label] = task;
1139 1140
						}
					}
1141
				}
1142
				return { set: { tasks: parseResult.tasks }, annotatingTasks: annotatingTasks, hasErrors };
1143 1144 1145 1146 1147 1148 1149
			});
		});
	}

	private getExecutionEngine(): ExecutionEngine {
		let { config } = this.getConfiguration();
		if (!config) {
1150
			return ExecutionEngine.Process;
1151 1152 1153 1154
		}
		return TaskConfig.ExecutionEngine.from(config);
	}

1155 1156 1157 1158 1159 1160 1161 1162 1163 1164
	/*
	private getJsonSchemaVersion(): JsonSchemaVersion {
		let { config } = this.getConfiguration();
		if (!config) {
			return JsonSchemaVersion.V2_0_0;
		}
		return TaskConfig.JsonSchemaVersion.from(config);
	}
	*/

1165 1166 1167
	private getConfiguration(): { config: TaskConfig.ExternalTaskRunnerConfiguration; hasParseErrors: boolean } {
		let result = this.configurationService.getConfiguration<TaskConfig.ExternalTaskRunnerConfiguration>('tasks');
		if (!result) {
1168
			return { config: undefined, hasParseErrors: false };
1169 1170 1171 1172 1173 1174 1175 1176 1177
		}
		let parseErrors: string[] = (result as any).$parseErrors;
		if (parseErrors) {
			let isAffected = false;
			for (let i = 0; i < parseErrors.length; i++) {
				if (/tasks\.json$/.test(parseErrors[i])) {
					isAffected = true;
					break;
				}
1178
			}
1179
			if (isAffected) {
1180
				this._outputChannel.append(nls.localize('TaskSystem.invalidTaskJson', 'Error: The content of the tasks.json file has syntax errors. Please correct them before executing a task.\n'));
1181
				this.showOutput();
1182
				return { config: undefined, hasParseErrors: true };
1183
			}
1184 1185
		}
		return { config: result, hasParseErrors: false };
1186 1187
	}

E
Erich Gamma 已提交
1188
	private printStderr(stderr: string[]): boolean {
1189
		let result = false;
E
Erich Gamma 已提交
1190 1191
		if (stderr && stderr.length > 0) {
			stderr.forEach((line) => {
1192
				result = true;
1193
				this._outputChannel.append(line + '\n');
E
Erich Gamma 已提交
1194
			});
1195
			this._outputChannel.show(true);
E
Erich Gamma 已提交
1196 1197 1198 1199
		}
		return result;
	}

1200
	public inTerminal(): boolean {
1201
		return this._taskSystem instanceof TerminalTaskSystem;
1202 1203
	}

1204
	private hasDetectorSupport(config: TaskConfig.ExternalTaskRunnerConfiguration): boolean {
E
Erich Gamma 已提交
1205 1206 1207 1208 1209 1210
		if (!config.command) {
			return false;
		}
		return ProcessRunnerDetector.supports(config.command);
	}

1211
	public configureAction(): Action {
1212
		return new ConfigureTaskRunnerAction(ConfigureTaskRunnerAction.ID, ConfigureTaskRunnerAction.TEXT, this,
1213
			this.configurationService, this.editorService, this.fileService, this.contextService,
1214 1215
			this.outputService, this.messageService, this.quickOpenService, this.environmentService, this.configurationResolverService,
			this.extensionService);
1216 1217
	}

1218
	private configureBuildTask(): Action {
1219
		return new ConfigureBuildTaskAction(ConfigureBuildTaskAction.ID, ConfigureBuildTaskAction.TEXT, this,
1220
			this.configurationService, this.editorService, this.fileService, this.contextService,
1221 1222
			this.outputService, this.messageService, this.quickOpenService, this.environmentService, this.configurationResolverService,
			this.extensionService);
1223 1224
	}

E
Erich Gamma 已提交
1225 1226
	public beforeShutdown(): boolean | TPromise<boolean> {
		if (this._taskSystem && this._taskSystem.isActiveSync()) {
D
Dirk Baeumer 已提交
1227
			if (this._taskSystem.canAutoTerminate() || this.messageService.confirm({
E
Erich Gamma 已提交
1228
				message: nls.localize('TaskSystem.runningTask', 'There is a task running. Do you want to terminate it?'),
B
Benjamin Pasero 已提交
1229
				primaryButton: nls.localize({ key: 'TaskSystem.terminateTask', comment: ['&& denotes a mnemonic'] }, "&&Terminate Task")
E
Erich Gamma 已提交
1230
			})) {
1231
				return this._taskSystem.terminateAll().then((response) => {
E
Erich Gamma 已提交
1232 1233 1234 1235 1236
					if (response.success) {
						this.emit(TaskServiceEvents.Terminated, {});
						this._taskSystem = null;
						this.disposeTaskSystemListeners();
						return false; // no veto
D
Dirk Baeumer 已提交
1237 1238 1239 1240 1241
					} else if (response.code && response.code === TerminateResponseCode.ProcessNotFound) {
						return !this.messageService.confirm({
							message: nls.localize('TaskSystem.noProcess', 'The launched task doesn\'t exist anymore. If the task spawned background processes exiting VS Code might result in orphaned processes. To avoid this start the last background process with a wait flag.'),
							primaryButton: nls.localize({ key: 'TaskSystem.exitAnyways', comment: ['&& denotes a mnemonic'] }, "&&Exit Anyways")
						});
E
Erich Gamma 已提交
1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253
					}
					return true; // veto
				}, (err) => {
					return true; // veto
				});
			} else {
				return true; // veto
			}
		}
		return false; // Nothing to do here
	}

1254
	private getConfigureAction(code: TaskErrors): Action {
J
Johannes Rieken 已提交
1255
		switch (code) {
1256 1257 1258 1259 1260 1261
			case TaskErrors.NoBuildTask:
				return this.configureBuildTask();
			default:
				return this.configureAction();
		}
	}
1262

J
Johannes Rieken 已提交
1263
	private handleError(err: any): void {
E
Erich Gamma 已提交
1264 1265 1266
		let showOutput = true;
		if (err instanceof TaskError) {
			let buildError = <TaskError>err;
1267 1268 1269
			let needsConfig = buildError.code === TaskErrors.NotConfigured || buildError.code === TaskErrors.NoBuildTask || buildError.code === TaskErrors.NoTestTask;
			let needsTerminate = buildError.code === TaskErrors.RunningTask;
			if (needsConfig || needsTerminate) {
E
Erich Gamma 已提交
1270
				let closeAction = new CloseMessageAction();
1271
				let action: Action = needsConfig
1272
					? this.getConfigureAction(buildError.code)
1273 1274 1275 1276
					: new Action(
						'workbench.action.tasks.terminate',
						nls.localize('TerminateAction.label', "Terminate Running Task"),
						undefined, true, () => { this.runTerminateCommand(); return TPromise.as<void>(undefined); });
J
Johannes Rieken 已提交
1277
				closeAction.closeFunction = this.messageService.show(buildError.severity, { message: buildError.message, actions: [action, closeAction] });
E
Erich Gamma 已提交
1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289
			} else {
				this.messageService.show(buildError.severity, buildError.message);
			}
		} else if (err instanceof Error) {
			let error = <Error>err;
			this.messageService.show(Severity.Error, error.message);
		} else if (Types.isString(err)) {
			this.messageService.show(Severity.Error, <string>err);
		} else {
			this.messageService.show(Severity.Error, nls.localize('TaskSystem.unknownError', 'An error has occurred while running a task. See task log for details.'));
		}
		if (showOutput) {
1290
			this._outputChannel.show(true);
E
Erich Gamma 已提交
1291 1292
		}
	}
1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308

	private canRunCommand(): boolean {
		if (!this.contextService.hasWorkspace()) {
			this.messageService.show(Severity.Info, nls.localize('TaskService.noWorkspace', 'Tasks are only available on a workspace folder.'));
			return false;
		}
		return true;
	}

	private runTaskCommand(accessor: ServicesAccessor, arg: any): void {
		if (!this.canRunCommand()) {
			return;
		}
		if (Types.isString(arg)) {
			this.tasks().then(tasks => {
				for (let task of tasks) {
D
Dirk Baeumer 已提交
1309
					if (task.identifier === arg) {
1310
						this.run(task);
1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323
					}
				}
			});
		} else {
			this.quickOpenService.show('task ');
		}
	}

	private runTerminateCommand(): void {
		if (!this.canRunCommand()) {
			return;
		}
		if (this.inTerminal()) {
1324 1325 1326 1327 1328 1329 1330 1331 1332 1333
			this.getActiveTasks().then((activeTasks) => {
				if (activeTasks.length === 0) {
					return;
				}
				if (activeTasks.length === 1) {
					this.terminate(activeTasks[0]);
				} else {
					this.quickOpenService.show('terminate task ');
				}
			});
1334 1335 1336
		} else {
			this.isActive().then((active) => {
				if (active) {
1337
					this.terminateAll().then((response) => {
1338
						if (response.success) {
1339 1340 1341
							return;
						}
						if (response.code && response.code === TerminateResponseCode.ProcessNotFound) {
1342 1343
							this.messageService.show(Severity.Error, nls.localize('TerminateAction.noProcess', 'The launched process doesn\'t exist anymore. If the task spawned background tasks exiting VS Code might result in orphaned processes.'));
						} else {
1344
							this.messageService.show(Severity.Error, nls.localize('TerminateAction.failed', 'Failed to terminate running task'));
1345 1346 1347 1348 1349 1350
						}
					});
				}
			});
		}
	}
1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376

	private runRestartTaskCommand(accessor: ServicesAccessor, arg: any): void {
		if (!this.canRunCommand()) {
			return;
		}
		if (this.inTerminal()) {
			this.getActiveTasks().then((activeTasks) => {
				if (activeTasks.length === 0) {
					return;
				}
				if (activeTasks.length === 1) {
					this.restart(activeTasks[0]);
				} else {
					this.quickOpenService.show('restart task ');
				}
			});
		} else {
			this.getActiveTasks().then((activeTasks) => {
				if (activeTasks.length === 0) {
					return;
				}
				let task = activeTasks[0];
				this.restart(task);
			});
		}
	}
E
Erich Gamma 已提交
1377 1378
}

1379

1380
let workbenchActionsRegistry = <IWorkbenchActionRegistry>Registry.as(WorkbenchActionExtensions.WorkbenchActions);
1381
workbenchActionsRegistry.registerWorkbenchAction(new SyncActionDescriptor(ConfigureTaskRunnerAction, ConfigureTaskRunnerAction.ID, ConfigureTaskRunnerAction.TEXT), 'Configure Task Runner', tasksCategory);
1382

1383 1384
MenuRegistry.addCommand({ id: 'workbench.action.tasks.showLog', title: { value: nls.localize('ShowLogAction.label', "Show Task Log"), original: 'Show Task Log' }, category: { value: tasksCategory, original: 'Tasks' } });
MenuRegistry.addCommand({ id: 'workbench.action.tasks.runTask', title: { value: nls.localize('RunTaskAction.label', "Run Task"), original: 'Run Task' }, category: { value: tasksCategory, original: 'Tasks' } });
1385
MenuRegistry.addCommand({ id: 'workbench.action.tasks.restartTask', title: { value: nls.localize('RestartTaskAction.label', "Restart Task"), original: 'Restart Task' }, category: { value: tasksCategory, original: 'Tasks' } });
1386 1387 1388
MenuRegistry.addCommand({ id: 'workbench.action.tasks.terminate', title: { value: nls.localize('TerminateAction.label', "Terminate Running Task"), original: 'Terminate Running Task' }, category: { value: tasksCategory, original: 'Tasks' } });
MenuRegistry.addCommand({ id: 'workbench.action.tasks.build', title: { value: nls.localize('BuildAction.label', "Run Build Task"), original: 'Run Build Task' }, category: { value: tasksCategory, original: 'Tasks' } });
MenuRegistry.addCommand({ id: 'workbench.action.tasks.test', title: { value: nls.localize('TestAction.label', "Run Test Task"), original: 'Run Test Task' }, category: { value: tasksCategory, original: 'Tasks' } });
1389 1390
// MenuRegistry.addCommand( { id: 'workbench.action.tasks.rebuild', title: nls.localize('RebuildAction.label', 'Run Rebuild Task'), category: tasksCategory });
// MenuRegistry.addCommand( { id: 'workbench.action.tasks.clean', title: nls.localize('CleanAction.label', 'Run Clean Task'), category: tasksCategory });
1391 1392 1393 1394 1395

// Task Service
registerSingleton(ITaskService, TaskService);

// Register Quick Open
1396 1397 1398
const quickOpenRegistry = (<IQuickOpenRegistry>Registry.as(QuickOpenExtensions.Quickopen));

quickOpenRegistry.registerQuickOpenHandler(
1399 1400 1401 1402
	new QuickOpenHandlerDescriptor(
		'vs/workbench/parts/tasks/browser/taskQuickOpen',
		'QuickOpenHandler',
		'task ',
1403 1404 1405 1406 1407 1408 1409 1410 1411 1412
		nls.localize('quickOpen.task', "Run Task")
	)
);

quickOpenRegistry.registerQuickOpenHandler(
	new QuickOpenHandlerDescriptor(
		'vs/workbench/parts/tasks/browser/terminateQuickOpen',
		'QuickOpenHandler',
		'terminate task ',
		nls.localize('quickOpen.terminateTask', "Terminate Task")
1413 1414 1415
	)
);

1416 1417 1418 1419 1420 1421 1422 1423 1424
quickOpenRegistry.registerQuickOpenHandler(
	new QuickOpenHandlerDescriptor(
		'vs/workbench/parts/tasks/browser/restartQuickOpen',
		'QuickOpenHandler',
		'restart task ',
		nls.localize('quickOpen.restartTask', "Restart Task")
	)
);

D
Dirk Baeumer 已提交
1425 1426 1427
const actionBarRegistry = Registry.as<IActionBarRegistry>(ActionBarExtensions.Actionbar);
actionBarRegistry.registerActionBarContributor(Scope.VIEWER, QuickOpenActionContributor);

1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439
// Status bar
let statusbarRegistry = <IStatusbarRegistry>Registry.as(StatusbarExtensions.Statusbar);
statusbarRegistry.registerStatusbarItem(new StatusbarItemDescriptor(StatusBarItem, StatusbarAlignment.LEFT, 50 /* Medium Priority */));

// Output channel
let outputChannelRegistry = <IOutputChannelRegistry>Registry.as(OutputExt.OutputChannels);
outputChannelRegistry.registerChannel(TaskService.OutputChannelId, TaskService.OutputChannelLabel);

// (<IWorkbenchContributionsRegistry>Registry.as(WorkbenchExtensions.Workbench)).registerWorkbenchContribution(TaskServiceParticipant);

// tasks.json validation
let schemaId = 'vscode://schemas/tasks';
D
Dirk Baeumer 已提交
1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450
let schema: IJSONSchema = {
	id: schemaId,
	description: 'Task definition file',
	type: 'object',
	default: {
		version: '0.1.0',
		command: 'myCommand',
		isShellCommand: false,
		args: [],
		showOutput: 'always',
		tasks: [
1451
			{
D
Dirk Baeumer 已提交
1452 1453 1454 1455
				taskName: 'build',
				showOutput: 'silent',
				isBuildCommand: true,
				problemMatcher: ['$tsc', '$lessCompile']
1456 1457
			}
		]
D
Dirk Baeumer 已提交
1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469
	}
};

import schemaVersion1 from './jsonSchema_v1';
import schemaVersion2 from './jsonSchema_v2';
schema.definitions = {
	...schemaVersion1.definitions,
	...schemaVersion2.definitions,
};
schema.oneOf = [...schemaVersion1.oneOf, ...schemaVersion2.oneOf];


1470 1471
let jsonRegistry = <jsonContributionRegistry.IJSONContributionRegistry>Registry.as(jsonContributionRegistry.Extensions.JSONContribution);
jsonRegistry.registerSchema(schemaId, schema);