task.contribution.ts 85.3 KB
Newer Older
E
Erich Gamma 已提交
1 2 3 4 5 6 7 8 9 10
/*---------------------------------------------------------------------------------------------
 *  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 * as nls from 'vs/nls';

11
import { QuickOpenHandler } from 'vs/workbench/parts/tasks/browser/taskQuickOpen';
12
import { TPromise } from 'vs/base/common/winjs.base';
E
Erich Gamma 已提交
13 14
import Severity from 'vs/base/common/severity';
import * as Objects from 'vs/base/common/objects';
15
import URI from 'vs/base/common/uri';
E
Erich Gamma 已提交
16 17 18
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 已提交
19
import { IDisposable, dispose } from 'vs/base/common/lifecycle';
A
Alex Dima 已提交
20
import { EventEmitter } from 'vs/base/common/eventEmitter';
E
Erich Gamma 已提交
21 22 23
import * as Builder from 'vs/base/browser/builder';
import * as Types from 'vs/base/common/types';
import { KeyMod, KeyCode } from 'vs/base/common/keyCodes';
24
import { TerminateResponseCode } from 'vs/base/common/processes';
25
import * as strings from 'vs/base/common/strings';
26
import { ValidationStatus, ValidationState } from 'vs/base/common/parsers';
27
import * as UUID from 'vs/base/common/uuid';
D
Dirk Baeumer 已提交
28
import { LinkedMap, Touch } from 'vs/base/common/map';
29
import { OcticonLabel } from 'vs/base/browser/ui/octiconLabel/octiconLabel';
E
Erich Gamma 已提交
30

31
import { Registry } from 'vs/platform/registry/common/platform';
E
Erich Gamma 已提交
32
import { ILifecycleService } from 'vs/platform/lifecycle/common/lifecycle';
33
import { MenuRegistry } from 'vs/platform/actions/common/actions';
E
Erich Gamma 已提交
34
import { registerSingleton } from 'vs/platform/instantiation/common/extensions';
D
Dirk Baeumer 已提交
35
import { IMessageService, IChoiceService } from 'vs/platform/message/common/message';
E
Erich Gamma 已提交
36 37
import { IMarkerService, MarkerStatistics } from 'vs/platform/markers/common/markers';
import { ITelemetryService } from 'vs/platform/telemetry/common/telemetry';
38
import { IConfigurationService, ConfigurationTarget } from 'vs/platform/configuration/common/configuration';
39
import { IFileService, IFileStat } from 'vs/platform/files/common/files';
A
Alex Dima 已提交
40
import { IExtensionService } from 'vs/platform/extensions/common/extensions';
41
import { CommandsRegistry } from 'vs/platform/commands/common/commands';
42 43
import { KeybindingsRegistry } from 'vs/platform/keybinding/common/keybindingsRegistry';
import { ServicesAccessor } from 'vs/platform/instantiation/common/instantiation';
44
import { ProblemMatcherRegistry, NamedProblemMatcher } from 'vs/platform/markers/common/problemMatcher';
45
import { IStorageService, StorageScope } from 'vs/platform/storage/common/storage';
46
import { IProgressService2, IProgressOptions, ProgressLocation } from 'vs/platform/progress/common/progress';
47
import { IOpenerService } from 'vs/platform/opener/common/opener';
48 49
import { IWindowService } from 'vs/platform/windows/common/windows';

E
Erich Gamma 已提交
50 51
import { IModelService } from 'vs/editor/common/services/modelService';

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

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

58
import { IQuickOpenService, IPickOpenEntry, IPickOpenAction, IPickOpenItem } 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';
S
Sandeep Somavarapu 已提交
64
import { IWorkspaceContextService, WorkbenchState, IWorkspaceFolder } from 'vs/platform/workspace/common/workspace';
E
Erich Gamma 已提交
65

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

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

M
Matt Bierner 已提交
72
import { ITaskSystem, ITaskResolver, ITaskSummary, TaskExecuteKind, TaskError, TaskErrors, TaskSystemEvents, TaskTerminateResponse } from 'vs/workbench/parts/tasks/common/taskSystem';
73
import { Task, CustomTask, ConfiguringTask, ContributedTask, InMemoryTask, TaskSet, TaskGroup, GroupType, ExecutionEngine, JsonSchemaVersion, TaskSourceKind, TaskIdentifier, TaskSorter } from 'vs/workbench/parts/tasks/common/tasks';
74
import { ITaskService, TaskServiceEvents, ITaskProvider, TaskEvent, RunOptions, CustomizationProperties } from 'vs/workbench/parts/tasks/common/taskService';
D
Dirk Baeumer 已提交
75
import { templates as taskTemplates } from 'vs/workbench/parts/tasks/common/taskTemplates';
E
Erich Gamma 已提交
76

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

83
import { Themable, STATUS_BAR_FOREGROUND, STATUS_BAR_NO_FOLDER_FOREGROUND } from 'vs/workbench/common/theme';
84 85
import { IThemeService } from 'vs/platform/theme/common/themeService';

86 87
import { ReloadWindowAction } from 'vs/workbench/electron-browser/actions';

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

91 92 93
namespace ConfigureTaskAction {
	export const ID = 'workbench.action.tasks.configureTaskRunner';
	export const TEXT = nls.localize('ConfigureTaskRunnerAction.label', "Configure Task");
94 95
}

E
Erich Gamma 已提交
96 97 98 99 100 101 102 103 104 105
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);
	}
106
	public run(): TPromise<void> {
E
Erich Gamma 已提交
107 108 109
		if (this.closeFunction) {
			this.closeFunction();
		}
110 111 112 113
		return TPromise.as(undefined);
	}
}

114
class BuildStatusBarItem extends Themable implements IStatusbarItem {
E
Erich Gamma 已提交
115
	private activeCount: number;
116 117 118 119 120 121 122
	private icons: HTMLElement[];

	constructor(
		@IPanelService private panelService: IPanelService,
		@IMarkerService private markerService: IMarkerService,
		@ITaskService private taskService: ITaskService,
		@IPartService private partService: IPartService,
123 124
		@IThemeService themeService: IThemeService,
		@IWorkspaceContextService private contextService: IWorkspaceContextService
125 126
	) {
		super(themeService);
E
Erich Gamma 已提交
127 128

		this.activeCount = 0;
129
		this.icons = [];
B
Benjamin Pasero 已提交
130 131 132 133 134

		this.registerListeners();
	}

	private registerListeners(): void {
135
		this.toUnbind.push(this.contextService.onDidChangeWorkbenchState(() => this.updateStyles()));
E
Erich Gamma 已提交
136 137
	}

138 139
	protected updateStyles(): void {
		super.updateStyles();
E
Erich Gamma 已提交
140

141
		this.icons.forEach(icon => {
142
			icon.style.backgroundColor = this.getColor(this.contextService.getWorkbenchState() !== WorkbenchState.EMPTY ? STATUS_BAR_FOREGROUND : STATUS_BAR_NO_FOLDER_FOREGROUND);
143 144
		});
	}
E
Erich Gamma 已提交
145

146 147 148 149 150 151 152 153 154 155 156
	public render(container: HTMLElement): IDisposable {
		let callOnDispose: IDisposable[] = [];

		const element = 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');
157
		const building = document.createElement('div');
E
Erich Gamma 已提交
158

159
		Dom.addClass(element, 'task-statusbar-item');
E
Erich Gamma 已提交
160 161 162

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

165
		Dom.addClass(errorIcon, 'task-statusbar-item-label-error');
166
		Dom.addClass(errorIcon, 'mask-icon');
167 168 169 170
		label.appendChild(errorIcon);
		this.icons.push(errorIcon);

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

174
		Dom.addClass(warningIcon, 'task-statusbar-item-label-warning');
175
		Dom.addClass(warningIcon, 'mask-icon');
176 177 178 179
		label.appendChild(warningIcon);
		this.icons.push(warningIcon);

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

183
		Dom.addClass(infoIcon, 'task-statusbar-item-label-info');
184
		Dom.addClass(infoIcon, 'mask-icon');
185 186 187 188 189
		label.appendChild(infoIcon);
		this.icons.push(infoIcon);
		$(infoIcon).hide();

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

193 194 195 196 197 198
		Dom.addClass(building, 'task-statusbar-item-building');
		element.appendChild(building);
		building.innerHTML = nls.localize('building', 'Building...');
		$(building).hide();


J
Johannes Rieken 已提交
199 200
		callOnDispose.push(Dom.addDisposableListener(label, 'click', (e: MouseEvent) => {
			const panel = this.panelService.getActivePanel();
201 202 203 204 205
			if (panel && panel.getId() === Constants.MARKERS_PANEL_ID) {
				this.partService.setPanelHidden(true);
			} else {
				this.panelService.openPanel(Constants.MARKERS_PANEL_ID, true);
			}
J
Johannes Rieken 已提交
206
		}));
E
Erich Gamma 已提交
207

208
		let updateStatus = (element: HTMLDivElement, icon: HTMLDivElement, stats: number): boolean => {
E
Erich Gamma 已提交
209 210 211
			if (stats > 0) {
				element.innerHTML = stats.toString();
				$(element).show();
212
				$(icon).show();
E
Erich Gamma 已提交
213 214 215
				return true;
			} else {
				$(element).hide();
216
				$(icon).hide();
E
Erich Gamma 已提交
217 218 219 220 221 222 223 224
				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;
225
			updateStatus(info, infoIcon, stats.infos);
E
Erich Gamma 已提交
226 227 228 229 230 231
		};

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

232
		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Active, (event: TaskEvent) => {
233
			if (this.ignoreEvent(event)) {
234 235
				return;
			}
E
Erich Gamma 已提交
236 237
			this.activeCount++;
			if (this.activeCount === 1) {
238
				$(building).show();
E
Erich Gamma 已提交
239 240 241
			}
		}));

242
		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Inactive, (event: TaskEvent) => {
243
			if (this.ignoreEvent(event)) {
244 245
				return;
			}
246 247 248 249 250
			// 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) {
251
					$(building).hide();
252
				}
E
Erich Gamma 已提交
253 254 255
			}
		}));

256
		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Terminated, (event: TaskEvent) => {
257
			if (this.ignoreEvent(event)) {
258 259
				return;
			}
E
Erich Gamma 已提交
260
			if (this.activeCount !== 0) {
261
				$(building).hide();
E
Erich Gamma 已提交
262 263 264 265 266 267
				this.activeCount = 0;
			}
		}));

		container.appendChild(element);

268 269
		this.updateStyles();

E
Erich Gamma 已提交
270
		return {
271
			dispose: () => {
J
Joao Moreno 已提交
272
				callOnDispose = dispose(callOnDispose);
273
			}
E
Erich Gamma 已提交
274 275
		};
	}
276 277 278 279 280 281 282 283 284 285 286 287 288

	private ignoreEvent(event: TaskEvent): boolean {
		if (!this.taskService.inTerminal()) {
			return false;
		}
		if (event.group !== TaskGroup.Build) {
			return true;
		}
		if (!event.__task) {
			return false;
		}
		return event.__task.problemMatchers === void 0 || event.__task.problemMatchers.length === 0;
	}
E
Erich Gamma 已提交
289 290
}

291 292 293 294 295 296 297 298 299 300 301 302 303 304
class TaskStatusBarItem extends Themable implements IStatusbarItem {

	constructor(
		@ITaskService private taskService: ITaskService,
		@IThemeService themeService: IThemeService,
	) {
		super(themeService);
	}

	protected updateStyles(): void {
		super.updateStyles();
	}

	public render(container: HTMLElement): IDisposable {
305

306
		let callOnDispose: IDisposable[] = [];
307 308
		const element = document.createElement('a');
		Dom.addClass(element, 'task-statusbar-runningItem');
309

310 311 312
		let labelElement = document.createElement('div');
		Dom.addClass(labelElement, 'task-statusbar-runningItem-label');
		element.appendChild(labelElement);
313

314 315
		let label = new OcticonLabel(labelElement);
		label.title = nls.localize('runningTasks', "Show Running Tasks");
316

317
		$(element).hide();
318

319
		callOnDispose.push(Dom.addDisposableListener(labelElement, 'click', (e: MouseEvent) => {
320 321 322 323 324 325
			(this.taskService as TaskService).runShowTasks();
		}));

		let updateStatus = (): void => {
			this.taskService.getActiveTasks().then(tasks => {
				if (tasks.length === 0) {
326
					$(element).hide();
327
				} else {
328 329
					label.text = `$(tools) ${tasks.length}`;
					$(element).show();
330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350
				}
			});
		};

		callOnDispose.push(this.taskService.addListener(TaskServiceEvents.Changed, (event: TaskEvent) => {
			updateStatus();
		}));

		container.appendChild(element);

		this.updateStyles();
		updateStatus();

		return {
			dispose: () => {
				callOnDispose = dispose(callOnDispose);
			}
		};
	}
}

351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387
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();
	}
}

388
interface WorkspaceTaskResult {
389
	set: TaskSet;
390 391
	configurations: {
		byIdentifier: IStringDictionary<ConfiguringTask>;
392
	};
393 394 395
	hasErrors: boolean;
}

396
interface WorkspaceFolderTaskResult extends WorkspaceTaskResult {
S
Sandeep Somavarapu 已提交
397
	workspaceFolder: IWorkspaceFolder;
398 399 400
}

interface WorkspaceFolderConfigurationResult {
S
Sandeep Somavarapu 已提交
401
	workspaceFolder: IWorkspaceFolder;
402 403 404 405
	config: TaskConfig.ExternalTaskRunnerConfiguration;
	hasErrors: boolean;
}

406 407 408 409
interface TaskCustomizationTelementryEvent {
	properties: string[];
}

410 411 412 413 414 415 416 417 418 419
class TaskMap {
	private _store: Map<string, Task[]> = new Map();

	constructor() {
	}

	public forEach(callback: (value: Task[], folder: string) => void): void {
		this._store.forEach(callback);
	}

S
Sandeep Somavarapu 已提交
420
	public get(workspaceFolder: IWorkspaceFolder | string): Task[] {
421 422 423 424 425 426 427 428
		let result: Task[] = Types.isString(workspaceFolder) ? this._store.get(workspaceFolder) : this._store.get(workspaceFolder.uri.toString());
		if (!result) {
			result = [];
			Types.isString(workspaceFolder) ? this._store.set(workspaceFolder, result) : this._store.set(workspaceFolder.uri.toString(), result);
		}
		return result;
	}

S
Sandeep Somavarapu 已提交
429
	public has(workspaceFolder: IWorkspaceFolder): boolean {
430 431 432
		return this._store.has(workspaceFolder.uri.toString());
	}

S
Sandeep Somavarapu 已提交
433
	public add(workspaceFolder: IWorkspaceFolder | string, ...task: Task[]): void {
434 435 436 437 438 439 440 441 442 443 444 445 446 447 448
		let values = Types.isString(workspaceFolder) ? this._store.get(workspaceFolder) : this._store.get(workspaceFolder.uri.toString());
		if (!values) {
			values = [];
			Types.isString(workspaceFolder) ? this._store.set(workspaceFolder, values) : this._store.set(workspaceFolder.uri.toString(), values);
		}
		values.push(...task);
	}

	public all(): Task[] {
		let result: Task[] = [];
		this._store.forEach((values) => result.push(...values));
		return result;
	}
}

449 450 451 452
interface TaskQuickPickEntry extends IPickOpenEntry {
	task: Task;
}

E
Erich Gamma 已提交
453
class TaskService extends EventEmitter implements ITaskService {
454

455
	// private static autoDetectTelemetryName: string = 'taskServer.autoDetect';
456
	private static RecentlyUsedTasks_Key = 'workbench.tasks.recentlyUsedTasks';
T
t-amqi 已提交
457
	private static RanTaskBefore_Key = 'workbench.tasks.ranTaskBefore';
D
Dirk Baeumer 已提交
458
	private static IgnoreTask010DonotShowAgain_key = 'workbench.tasks.ignoreTask010Shown';
459

460
	private static CustomizationTelemetryEventName: string = 'taskService.customize';
461
	public static TemplateTelemetryEventName: string = 'taskService.template';
462

463
	public _serviceBrand: any;
E
Erich Gamma 已提交
464
	public static SERVICE_ID: string = 'taskService';
J
Johannes Rieken 已提交
465 466
	public static OutputChannelId: string = 'tasks';
	public static OutputChannelLabel: string = nls.localize('tasks', "Tasks");
E
Erich Gamma 已提交
467 468 469 470 471

	private configurationService: IConfigurationService;
	private markerService: IMarkerService;
	private outputService: IOutputService;
	private messageService: IMessageService;
D
Dirk Baeumer 已提交
472
	private choiceService: IChoiceService;
E
Erich Gamma 已提交
473 474 475 476 477 478
	private fileService: IFileService;
	private telemetryService: ITelemetryService;
	private editorService: IWorkbenchEditorService;
	private contextService: IWorkspaceContextService;
	private textFileService: ITextFileService;
	private modelService: IModelService;
A
Alex Dima 已提交
479
	private extensionService: IExtensionService;
D
Dirk Baeumer 已提交
480
	private quickOpenService: IQuickOpenService;
E
Erich Gamma 已提交
481

482
	private _configHasErrors: boolean;
D
Dirk Baeumer 已提交
483 484 485
	private __schemaVersion: JsonSchemaVersion;
	private __executionEngine: ExecutionEngine;
	private __workspaceFolders: IWorkspaceFolder[];
D
Dirk Baeumer 已提交
486 487
	private __ignoredWorkspaceFolders: IWorkspaceFolder[];
	private __showIgnoreMessage: boolean;
488
	private _providers: Map<number, ITaskProvider>;
489

D
Dirk Baeumer 已提交
490
	private _workspaceTasksPromise: TPromise<Map<string, WorkspaceFolderTaskResult>>;
491

E
Erich Gamma 已提交
492
	private _taskSystem: ITaskSystem;
493
	private _taskSystemListeners: IDisposable[];
494
	private _recentlyUsedTasks: LinkedMap<string, string>;
495

496
	private _outputChannel: IOutputChannel;
E
Erich Gamma 已提交
497

D
Dirk Baeumer 已提交
498 499
	constructor(
		@IConfigurationService configurationService: IConfigurationService,
E
Erich Gamma 已提交
500
		@IMarkerService markerService: IMarkerService, @IOutputService outputService: IOutputService,
D
Dirk Baeumer 已提交
501 502
		@IMessageService messageService: IMessageService, @IChoiceService choiceService: IChoiceService,
		@IWorkbenchEditorService editorService: IWorkbenchEditorService,
J
Johannes Rieken 已提交
503 504
		@IFileService fileService: IFileService, @IWorkspaceContextService contextService: IWorkspaceContextService,
		@ITelemetryService telemetryService: ITelemetryService, @ITextFileService textFileService: ITextFileService,
505
		@ILifecycleService lifecycleService: ILifecycleService,
A
Alex Dima 已提交
506
		@IModelService modelService: IModelService, @IExtensionService extensionService: IExtensionService,
507
		@IQuickOpenService quickOpenService: IQuickOpenService,
508
		@IConfigurationResolverService private configurationResolverService: IConfigurationResolverService,
509
		@ITerminalService private terminalService: ITerminalService,
510
		@IStorageService private storageService: IStorageService,
511
		@IProgressService2 private progressService: IProgressService2,
512 513
		@IOpenerService private openerService: IOpenerService,
		@IWindowService private _windowServive: IWindowService
514
	) {
E
Erich Gamma 已提交
515 516 517 518 519 520

		super();
		this.configurationService = configurationService;
		this.markerService = markerService;
		this.outputService = outputService;
		this.messageService = messageService;
D
Dirk Baeumer 已提交
521
		this.choiceService = choiceService;
E
Erich Gamma 已提交
522 523 524 525 526 527
		this.editorService = editorService;
		this.fileService = fileService;
		this.contextService = contextService;
		this.telemetryService = telemetryService;
		this.textFileService = textFileService;
		this.modelService = modelService;
A
Alex Dima 已提交
528
		this.extensionService = extensionService;
D
Dirk Baeumer 已提交
529
		this.quickOpenService = quickOpenService;
E
Erich Gamma 已提交
530

531 532
		this._configHasErrors = false;
		this._workspaceTasksPromise = undefined;
533
		this._taskSystem = undefined;
534 535 536
		this._taskSystemListeners = [];
		this._outputChannel = this.outputService.getChannel(TaskService.OutputChannelId);
		this._providers = new Map<number, ITaskProvider>();
537
		this.configurationService.onDidChangeConfiguration(() => {
538
			if (!this._taskSystem && !this._workspaceTasksPromise) {
539 540
				return;
			}
541 542 543
			if (!this._taskSystem || this._taskSystem instanceof TerminalTaskSystem) {
				this._outputChannel.clear();
			}
D
Dirk Baeumer 已提交
544
			let folderSetup = this.computeWorkspaceFolderSetup();
D
Dirk Baeumer 已提交
545
			if (this.executionEngine !== folderSetup[2]) {
546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564
				if (this._taskSystem && this._taskSystem.getActiveTasks().length > 0) {
					this.messageService.show(
						Severity.Info,
						{
							message: nls.localize(
								'TaskSystem.noHotSwap',
								'Changing the task execution engine with an active task running requires to reload the Window'
							),
							actions: [
								new ReloadWindowAction(ReloadWindowAction.ID, ReloadWindowAction.LABEL, this._windowServive),
								new CloseMessageAction()
							]
						}
					);
					return;
				} else {
					this.disposeTaskSystemListeners();
					this._taskSystem = undefined;
				}
D
Dirk Baeumer 已提交
565
			}
D
Dirk Baeumer 已提交
566
			this.updateSetup(folderSetup);
D
Dirk Baeumer 已提交
567
			this.updateWorkspaceTasks();
E
Erich Gamma 已提交
568
		});
569
		lifecycleService.onWillShutdown(event => event.veto(this.beforeShutdown()));
570 571 572 573
		this.registerCommands();
	}

	private registerCommands(): void {
574
		CommandsRegistry.registerCommand('workbench.action.tasks.runTask', (accessor, arg) => {
575 576 577
			this.runTaskCommand(accessor, arg);
		});

578 579 580 581
		CommandsRegistry.registerCommand('workbench.action.tasks.restartTask', (accessor, arg) => {
			this.runRestartTaskCommand(accessor, arg);
		});

582 583 584 585 586 587 588 589 590 591 592 593 594 595 596
		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;
			}
597
			this.runBuildCommand();
598 599 600 601 602 603 604 605 606 607 608 609
		});

		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;
610
			}
611
			this.runTestCommand();
612
		});
613

614 615 616 617
		CommandsRegistry.registerCommand('workbench.action.tasks.configureTaskRunner', () => {
			this.runConfigureTasks();
		});

618 619 620 621 622 623 624
		CommandsRegistry.registerCommand('workbench.action.tasks.configureDefaultBuildTask', () => {
			this.runConfigureDefaultBuildTask();
		});

		CommandsRegistry.registerCommand('workbench.action.tasks.configureDefaultTestTask', () => {
			this.runConfigureDefaultTestTask();
		});
625 626 627 628

		CommandsRegistry.registerCommand('workbench.action.tasks.showTasks', () => {
			this.runShowTasks();
		});
E
Erich Gamma 已提交
629 630
	}

D
Dirk Baeumer 已提交
631 632 633 634 635 636 637
	private get workspaceFolders(): IWorkspaceFolder[] {
		if (!this.__workspaceFolders) {
			this.updateSetup();
		}
		return this.__workspaceFolders;
	}

D
Dirk Baeumer 已提交
638 639 640 641 642 643 644
	private get ignoredWorkspaceFolders(): IWorkspaceFolder[] {
		if (!this.__ignoredWorkspaceFolders) {
			this.updateSetup();
		}
		return this.__ignoredWorkspaceFolders;
	}

D
Dirk Baeumer 已提交
645 646 647 648 649 650 651 652 653 654 655 656 657 658
	private get executionEngine(): ExecutionEngine {
		if (this.__executionEngine === void 0) {
			this.updateSetup();
		}
		return this.__executionEngine;
	}

	private get schemaVersion(): JsonSchemaVersion {
		if (this.__schemaVersion === void 0) {
			this.updateSetup();
		}
		return this.__schemaVersion;
	}

D
Dirk Baeumer 已提交
659 660 661 662 663 664 665 666
	private get showIgnoreMessage(): boolean {
		if (this.__showIgnoreMessage === void 0) {
			this.__showIgnoreMessage = !this.storageService.getBoolean(TaskService.IgnoreTask010DonotShowAgain_key, StorageScope.WORKSPACE, false);
		}
		return this.__showIgnoreMessage;
	}

	private updateSetup(setup?: [IWorkspaceFolder[], IWorkspaceFolder[], ExecutionEngine, JsonSchemaVersion]): void {
D
Dirk Baeumer 已提交
667 668 669 670
		if (!setup) {
			setup = this.computeWorkspaceFolderSetup();
		}
		this.__workspaceFolders = setup[0];
D
Dirk Baeumer 已提交
671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687
		if (this.__ignoredWorkspaceFolders) {
			if (this.__ignoredWorkspaceFolders.length !== setup[1].length) {
				this.__showIgnoreMessage = undefined;
			} else {
				let set: Set<string> = new Set();
				this.__ignoredWorkspaceFolders.forEach(folder => set.add(folder.uri.toString()));
				for (let folder of setup[1]) {
					if (!set.has(folder.uri.toString())) {
						this.__showIgnoreMessage = undefined;
						break;
					}
				}
			}
		}
		this.__ignoredWorkspaceFolders = setup[1];
		this.__executionEngine = setup[2];
		this.__schemaVersion = setup[3];
D
Dirk Baeumer 已提交
688 689
	}

690
	private showOutput(): void {
691
		this._outputChannel.show(true);
692 693
	}

E
Erich Gamma 已提交
694
	private disposeTaskSystemListeners(): void {
695
		this._taskSystemListeners = dispose(this._taskSystemListeners);
E
Erich Gamma 已提交
696 697
	}

698 699 700 701
	public registerTaskProvider(handle: number, provider: ITaskProvider): void {
		if (!provider) {
			return;
		}
702
		this._providers.set(handle, provider);
703 704 705
	}

	public unregisterTaskProvider(handle: number): boolean {
706
		return this._providers.delete(handle);
707 708
	}

S
Sandeep Somavarapu 已提交
709
	public getTask(folder: IWorkspaceFolder | string, alias: string): TPromise<Task> {
D
Dirk Baeumer 已提交
710 711 712 713
		let name = Types.isString(folder) ? folder : folder.name;
		if (this.ignoredWorkspaceFolders.some(ignored => ignored.name === name)) {
			return TPromise.wrapError(new Error(nls.localize('TaskServer.folderIgnored', 'The folder {0} is ignored since it uses task version 0.1.0', name)));
		}
714 715 716 717 718 719 720 721 722
		return this.getGroupedTasks().then((map) => {
			let values = map.get(folder);
			if (!values) {
				return undefined;
			}
			for (let task of values) {
				if (Task.matches(task, alias)) {
					return task;
				}
723
			}
724
			return undefined;
725 726 727
		});
	}

728
	public tasks(): TPromise<Task[]> {
729
		return this.getGroupedTasks().then(result => result.all());
730
	}
731

732 733 734 735
	public createSorter(): TaskSorter {
		return new TaskSorter(this.contextService.getWorkspace() ? this.contextService.getWorkspace().folders : []);
	}

736 737 738 739 740 741 742
	public isActive(): TPromise<boolean> {
		if (!this._taskSystem) {
			return TPromise.as(false);
		}
		return this._taskSystem.isActive();
	}

743 744 745 746 747 748 749
	public getActiveTasks(): TPromise<Task[]> {
		if (!this._taskSystem) {
			return TPromise.as([]);
		}
		return TPromise.as(this._taskSystem.getActiveTasks());
	}

750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780
	public getRecentlyUsedTasks(): LinkedMap<string, string> {
		if (this._recentlyUsedTasks) {
			return this._recentlyUsedTasks;
		}
		this._recentlyUsedTasks = new LinkedMap<string, string>();
		let storageValue = this.storageService.get(TaskService.RecentlyUsedTasks_Key, StorageScope.WORKSPACE);
		if (storageValue) {
			try {
				let values: string[] = JSON.parse(storageValue);
				if (Array.isArray(values)) {
					for (let value of values) {
						this._recentlyUsedTasks.set(value, value);
					}
				}
			} catch (error) {
				// Ignore. We use the empty result
			}
		}
		return this._recentlyUsedTasks;
	}

	private saveRecentlyUsedTasks(): void {
		if (!this._recentlyUsedTasks) {
			return;
		}
		let values = this._recentlyUsedTasks.values();
		if (values.length > 30) {
			values = values.slice(0, 30);
		}
		this.storageService.store(TaskService.RecentlyUsedTasks_Key, JSON.stringify(values), StorageScope.WORKSPACE);
	}
781

782
	private openDocumentation(): void {
783 784 785
		this.openerService.open(URI.parse('https://go.microsoft.com/fwlink/?LinkId=733558'));
	}

786
	public build(): TPromise<ITaskSummary> {
787
		return this.getGroupedTasks().then((tasks) => {
D
Dirk Baeumer 已提交
788
			let runnable = this.createRunnableTask(tasks, TaskGroup.Build);
789
			if (!runnable || !runnable.task) {
D
Dirk Baeumer 已提交
790
				if (this.schemaVersion === JsonSchemaVersion.V0_1_0) {
791 792 793 794
					throw new TaskError(Severity.Info, nls.localize('TaskService.noBuildTask1', 'No build task defined. Mark a task with \'isBuildCommand\' in the tasks.json file.'), TaskErrors.NoBuildTask);
				} else {
					throw new TaskError(Severity.Info, nls.localize('TaskService.noBuildTask2', 'No build task defined. Mark a task with as a \'build\' group in the tasks.json file.'), TaskErrors.NoBuildTask);
				}
795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811
			}
			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> {
812
		return this.getGroupedTasks().then((tasks) => {
D
Dirk Baeumer 已提交
813
			let runnable = this.createRunnableTask(tasks, TaskGroup.Test);
814
			if (!runnable || !runnable.task) {
D
Dirk Baeumer 已提交
815
				if (this.schemaVersion === JsonSchemaVersion.V0_1_0) {
816 817 818 819
					throw new TaskError(Severity.Info, nls.localize('TaskService.noTestTask1', 'No test task defined. Mark a task with \'isTestCommand\' in the tasks.json file.'), TaskErrors.NoTestTask);
				} else {
					throw new TaskError(Severity.Info, nls.localize('TaskService.noTestTask2', 'No test task defined. Mark a task with as a \'test\' group in the tasks.json file.'), TaskErrors.NoTestTask);
				}
820 821 822 823 824 825 826 827
			}
			return this.executeTask(runnable.task, runnable.resolver);
		}).then(value => value, (error) => {
			this.handleError(error);
			return TPromise.wrapError(error);
		});
	}

828 829 830 831
	public run(task: Task, options?: RunOptions): TPromise<ITaskSummary> {
		return this.getGroupedTasks().then((grouped) => {
			if (!task) {
				throw new TaskError(Severity.Info, nls.localize('TaskServer.noTask', 'Requested task {0} to execute not found.', task.name), TaskErrors.TaskNotFound);
832
			} else {
833
				let resolver = this.createResolver(grouped);
834
				if (options && options.attachProblemMatcher && this.shouldAttachProblemMatcher(task) && !InMemoryTask.is(task)) {
835
					return this.attachProblemMatcher(task).then((toExecute) => {
836 837 838 839 840 841 842
						if (toExecute) {
							return this.executeTask(toExecute, resolver);
						} else {
							return TPromise.as(undefined);
						}
					});
				}
843
				return this.executeTask(task, resolver);
844
			}
845 846 847 848 849 850
		}).then(value => value, (error) => {
			this.handleError(error);
			return TPromise.wrapError(error);
		});
	}

851
	private shouldAttachProblemMatcher(task: Task): boolean {
D
Dirk Baeumer 已提交
852
		if (!this.canCustomize(task)) {
853 854
			return false;
		}
855 856 857
		if (task.group !== void 0 && task.group !== TaskGroup.Build) {
			return false;
		}
858 859 860
		if (task.problemMatchers !== void 0 && task.problemMatchers.length > 0) {
			return false;
		}
861
		if (ContributedTask.is(task)) {
862
			return !task.hasDefinedMatchers && task.problemMatchers.length === 0;
863
		}
864 865 866 867 868
		if (CustomTask.is(task)) {
			let configProperties: TaskConfig.ConfigurationProperties = task._source.config.element;
			return configProperties.problemMatcher === void 0;
		}
		return false;
869 870
	}

871
	private attachProblemMatcher(task: ContributedTask | CustomTask): TPromise<Task> {
872 873
		interface ProblemMatcherPickEntry extends IPickOpenEntry {
			matcher: NamedProblemMatcher;
874
			never?: boolean;
875 876 877 878 879
			learnMore?: boolean;
		}
		let entries: ProblemMatcherPickEntry[] = [];
		for (let key of ProblemMatcherRegistry.keys()) {
			let matcher = ProblemMatcherRegistry.get(key);
880 881 882
			if (matcher.deprecated) {
				continue;
			}
883 884 885 886 887 888 889 890 891 892 893 894
			if (matcher.name === matcher.label) {
				entries.push({ label: matcher.name, matcher: matcher });
			} else {
				entries.push({
					label: matcher.label,
					description: `$${matcher.name}`,
					matcher: matcher
				});
			}
		}
		if (entries.length > 0) {
			entries = entries.sort((a, b) => a.label.localeCompare(b.label));
895
			entries[0].separator = { border: true, label: nls.localize('TaskService.associate', 'associate') };
896
			entries.unshift(
897 898 899
				{ label: nls.localize('TaskService.attachProblemMatcher.continueWithout', 'Continue without scanning the task output'), matcher: undefined },
				{ label: nls.localize('TaskService.attachProblemMatcher.never', 'Never scan the task output'), matcher: undefined, never: true },
				{ label: nls.localize('TaskService.attachProblemMatcher.learnMoreAbout', 'Learn more about scanning the task output'), matcher: undefined, learnMore: true }
900 901
			);
			return this.quickOpenService.pick(entries, {
902
				placeHolder: nls.localize('selectProblemMatcher', 'Select for which kind of errors and warnings to scan the task output'),
903 904 905 906 907 908
				autoFocus: { autoFocusFirstEntry: true }
			}).then((selected) => {
				if (selected) {
					if (selected.learnMore) {
						this.openDocumentation();
						return undefined;
909 910 911
					} else if (selected.never) {
						this.customize(task, { problemMatcher: [] }, true);
						return task;
912
					} else if (selected.matcher) {
913
						let newTask = Task.clone(task);
914
						let matcherReference = `$${selected.matcher.name}`;
915
						let properties: CustomizationProperties = { problemMatcher: [matcherReference] };
916
						newTask.problemMatchers = [matcherReference];
917 918 919 920 921 922
						let matcher = ProblemMatcherRegistry.get(selected.matcher.name);
						if (matcher && matcher.watching !== void 0) {
							properties.isBackground = true;
							newTask.isBackground = true;
						}
						this.customize(task, properties, true);
923 924 925 926 927
						return newTask;
					} else {
						return task;
					}
				} else {
928
					return undefined;
929 930 931 932 933 934
				}
			});
		}
		return TPromise.as(task);
	}

935
	public getTasksForGroup(group: string): TPromise<Task[]> {
936
		return this.getGroupedTasks().then((groups) => {
937
			let result: Task[] = [];
938 939 940 941 942
			groups.forEach((tasks) => {
				for (let task of tasks) {
					if (task.group === group) {
						result.push(task);
					}
943
				}
944
			});
945 946 947 948
			return result;
		});
	}

949 950
	public needsFolderQualification(): boolean {
		return this.contextService.getWorkbenchState() === WorkbenchState.WORKSPACE;
D
Dirk Baeumer 已提交
951 952 953
	}

	public canCustomize(task: Task): boolean {
D
Dirk Baeumer 已提交
954
		if (this.schemaVersion !== JsonSchemaVersion.V2_0_0) {
D
Dirk Baeumer 已提交
955 956 957 958 959 960 961 962 963
			return false;
		}
		if (CustomTask.is(task)) {
			return true;
		}
		if (ContributedTask.is(task)) {
			return !!Task.getWorkspaceFolder(task);
		}
		return false;
964 965
	}

966
	public customize(task: ContributedTask | CustomTask, properties?: CustomizationProperties, openConfig?: boolean): TPromise<void> {
D
Dirk Baeumer 已提交
967 968
		let workspaceFolder = Task.getWorkspaceFolder(task);
		if (!workspaceFolder) {
969
			return TPromise.wrap<void>(undefined);
D
Dirk Baeumer 已提交
970 971
		}
		let configuration = this.getConfiguration(workspaceFolder);
D
Dirk Baeumer 已提交
972 973
		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.'));
974
			return TPromise.wrap<void>(undefined);
D
Dirk Baeumer 已提交
975
		}
976

D
Dirk Baeumer 已提交
977
		let fileConfig = configuration.config;
978
		let index: number;
979
		let toCustomize: TaskConfig.CustomTask | TaskConfig.ConfiguringTask;
980
		let taskConfig = CustomTask.is(task) ? task._source.config : undefined;
981 982 983
		if (taskConfig && taskConfig.element) {
			index = taskConfig.index;
			toCustomize = taskConfig.element;
984 985 986 987 988 989
		} else if (ContributedTask.is(task)) {
			toCustomize = {
			};
			let identifier: TaskConfig.TaskIdentifier = Objects.assign(Object.create(null), task.defines);
			delete identifier['_key'];
			Object.keys(identifier).forEach(key => toCustomize[key] = identifier[key]);
990 991 992
			if (task.problemMatchers && task.problemMatchers.length > 0 && Types.isStringArray(task.problemMatchers)) {
				toCustomize.problemMatcher = task.problemMatchers;
			}
993 994 995 996
		}
		if (!toCustomize) {
			return TPromise.as(undefined);
		}
997 998 999 1000
		if (properties) {
			for (let property of Object.getOwnPropertyNames(properties)) {
				let value = properties[property];
				if (value !== void 0 && value !== null) {
1001
					toCustomize[property] = value;
1002 1003 1004
				}
			}
		} else {
1005
			if (toCustomize.problemMatcher === void 0 && task.problemMatchers === void 0 || task.problemMatchers.length === 0) {
1006
				toCustomize.problemMatcher = [];
1007
			}
1008
		}
1009

1010
		let promise: TPromise<void>;
D
Dirk Baeumer 已提交
1011
		if (!fileConfig) {
1012
			let value = {
D
Dirk Baeumer 已提交
1013
				version: '2.0.0',
1014
				tasks: [toCustomize]
D
Dirk Baeumer 已提交
1015
			};
1016 1017 1018 1019 1020
			let content = [
				'{',
				'\t// See https://go.microsoft.com/fwlink/?LinkId=733558',
				'\t// for the documentation about the tasks.json format',
			].join('\n') + JSON.stringify(value, null, '\t').substr(1);
1021
			let editorConfig = this.configurationService.getValue<any>();
1022 1023 1024
			if (editorConfig.editor.insertSpaces) {
				content = content.replace(/(\n)(\t+)/g, (_, s1, s2) => s1 + strings.repeat(' ', s2.length * editorConfig.editor.tabSize));
			}
1025
			promise = this.fileService.createFile(workspaceFolder.toResource('.vscode/tasks.json'), content).then(() => { });
D
Dirk Baeumer 已提交
1026
		} else {
1027 1028
			// We have a global task configuration
			if (index === -1) {
1029 1030
				if (properties.problemMatcher !== void 0) {
					fileConfig.problemMatcher = properties.problemMatcher;
1031
					promise = this.writeConfiguration(workspaceFolder, 'tasks.problemMatchers', fileConfig.problemMatcher);
1032 1033
				} else if (properties.group !== void 0) {
					fileConfig.group = properties.group;
1034
					promise = this.writeConfiguration(workspaceFolder, 'tasks.group', fileConfig.group);
1035
				}
1036 1037 1038 1039 1040
			} else {
				if (!Array.isArray(fileConfig.tasks)) {
					fileConfig.tasks = [];
				}
				if (index === void 0) {
1041 1042 1043 1044
					fileConfig.tasks.push(toCustomize);
				} else {
					fileConfig.tasks[index] = toCustomize;
				}
1045
				promise = this.writeConfiguration(workspaceFolder, 'tasks.tasks', fileConfig.tasks);
D
Dirk Baeumer 已提交
1046
			}
1047
		}
1048 1049 1050
		if (!promise) {
			return TPromise.as(undefined);
		}
1051
		return promise.then(() => {
1052 1053 1054
			let event: TaskCustomizationTelementryEvent = {
				properties: properties ? Object.getOwnPropertyNames(properties) : []
			};
K
kieferrm 已提交
1055
			/* __GDPR__
K
kieferrm 已提交
1056 1057 1058 1059
				"taskService.customize" : {
					"properties" : { "classification": "SystemMetaData", "purpose": "FeatureInsight" }
				}
			*/
1060
			this.telemetryService.publicLog(TaskService.CustomizationTelemetryEventName, event);
D
Dirk Baeumer 已提交
1061
			if (openConfig) {
1062
				let resource = workspaceFolder.toResource('.vscode/tasks.json');
D
Dirk Baeumer 已提交
1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073
				this.editorService.openEditor({
					resource: resource,
					options: {
						forceOpen: true,
						pinned: false
					}
				}, false);
			}
		});
	}

1074
	private writeConfiguration(workspaceFolder: IWorkspaceFolder, key: string, value: any): TPromise<void, any> {
D
Dirk Baeumer 已提交
1075
		if (this.contextService.getWorkbenchState() === WorkbenchState.FOLDER) {
1076
			return this.configurationService.updateValue(key, value, { resource: workspaceFolder.uri }, ConfigurationTarget.WORKSPACE);
D
Dirk Baeumer 已提交
1077
		} else if (this.contextService.getWorkbenchState() === WorkbenchState.WORKSPACE) {
1078
			return this.configurationService.updateValue(key, value, { resource: workspaceFolder.uri }, ConfigurationTarget.WORKSPACE_FOLDER);
D
Dirk Baeumer 已提交
1079 1080 1081 1082 1083
		} else {
			return undefined;
		}
	}

1084
	public openConfig(task: CustomTask): TPromise<void> {
1085
		let resource = Task.getWorkspaceFolder(task).toResource(task._source.config.file);
1086 1087 1088 1089 1090 1091 1092 1093 1094
		return this.editorService.openEditor({
			resource: resource,
			options: {
				forceOpen: true,
				pinned: false
			}
		}, false).then(() => undefined);
	}

1095 1096 1097 1098 1099 1100
	private createRunnableTask(tasks: TaskMap, group: TaskGroup): { task: Task; resolver: ITaskResolver } {
		interface ResolverData {
			id: Map<string, Task>;
			label: Map<string, Task>;
			identifier: Map<string, Task>;
		}
1101

1102
		let resolverData: Map<string, ResolverData> = new Map();
1103 1104
		let workspaceTasks: Task[] = [];
		let extensionTasks: Task[] = [];
1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124
		tasks.forEach((tasks, folder) => {
			let data = resolverData.get(folder);
			if (!data) {
				data = {
					id: new Map<string, Task>(),
					label: new Map<string, Task>(),
					identifier: new Map<string, Task>()
				};
				resolverData.set(folder, data);
			}
			for (let task of tasks) {
				data.id.set(task._id, task);
				data.label.set(task._label, task);
				data.identifier.set(task.identifier, task);
				if (group && task.group === group) {
					if (task._source.kind === TaskSourceKind.Workspace) {
						workspaceTasks.push(task);
					} else {
						extensionTasks.push(task);
					}
1125
				}
D
Dirk Baeumer 已提交
1126
			}
1127 1128
		});
		let resolver: ITaskResolver = {
S
Sandeep Somavarapu 已提交
1129
			resolve: (workspaceFolder: IWorkspaceFolder, alias: string) => {
1130 1131 1132 1133 1134
				let data = resolverData.get(workspaceFolder.uri.toString());
				if (!data) {
					return undefined;
				}
				return data.id.get(alias) || data.label.get(alias) || data.identifier.get(alias);
1135 1136
			}
		};
1137 1138 1139 1140 1141 1142 1143 1144 1145 1146
		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;
		}

1147 1148
		// We can only have extension tasks if we are in version 2.0.0. Then we can even run
		// multiple build tasks.
1149 1150
		if (extensionTasks.length === 1) {
			return { task: extensionTasks[0], resolver };
1151 1152
		} else {
			let id: string = UUID.generateUuid();
1153
			let task: InMemoryTask = {
1154
				_id: id,
1155
				_source: { kind: TaskSourceKind.InMemory, label: 'inMemory' },
1156
				_label: id,
1157
				type: 'inMemory',
1158 1159
				name: id,
				identifier: id,
1160
				dependsOn: extensionTasks.map((task) => { return { workspaceFolder: Task.getWorkspaceFolder(task), task: task._id }; })
1161 1162
			};
			return { task, resolver };
E
Erich Gamma 已提交
1163 1164 1165
		}
	}

1166 1167 1168 1169 1170
	private createResolver(grouped: TaskMap): ITaskResolver {
		interface ResolverData {
			label: Map<string, Task>;
			identifier: Map<string, Task>;
		}
1171

1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182
		let resolverData: Map<string, ResolverData> = new Map();
		grouped.forEach((tasks, folder) => {
			let data = resolverData.get(folder);
			if (!data) {
				data = { label: new Map<string, Task>(), identifier: new Map<string, Task>() };
				resolverData.set(folder, data);
			}
			for (let task of tasks) {
				data.label.set(task._label, task);
				data.identifier.set(task.identifier, task);
			}
1183 1184
		});
		return {
S
Sandeep Somavarapu 已提交
1185
			resolve: (workspaceFolder: IWorkspaceFolder, alias: string) => {
1186 1187 1188 1189 1190
				let data = resolverData.get(workspaceFolder.uri.toString());
				if (!data) {
					return undefined;
				}
				return data.label.get(alias) || data.identifier.get(alias);
1191
			}
1192 1193 1194 1195
		};
	}

	private executeTask(task: Task, resolver: ITaskResolver): TPromise<ITaskSummary> {
T
t-amqi 已提交
1196 1197
		if (!this.storageService.get(TaskService.RanTaskBefore_Key, StorageScope.GLOBAL)) {
			this.storageService.store(TaskService.RanTaskBefore_Key, true, StorageScope.GLOBAL);
T
t-amqi 已提交
1198
		}
1199 1200 1201
		return ProblemMatcherRegistry.onReady().then(() => {
			return this.textFileService.saveAll().then((value) => { // make sure all dirty files are saved
				let executeResult = this.getTaskSystem().run(task, resolver);
1202 1203 1204 1205
				let key = Task.getRecentlyUsedKey(task);
				if (key) {
					this.getRecentlyUsedTasks().set(key, key, Touch.First);
				}
1206 1207
				if (executeResult.kind === TaskExecuteKind.Active) {
					let active = executeResult.active;
1208 1209
					if (active.same) {
						if (active.background) {
1210
							this.messageService.show(Severity.Info, nls.localize('TaskSystem.activeSame.background', 'The task \'{0}\' is already active and in background mode. To terminate it use `Terminate Task...` from the Tasks menu.', Task.getQualifiedLabel(task)));
1211
						} else {
1212
							this.messageService.show(Severity.Info, nls.localize('TaskSystem.activeSame.noBackground', 'The task \'{0}\' is already active. To terminate it use `Terminate Task...` from the Tasks menu.', Task.getQualifiedLabel(task)));
1213
						}
1214 1215 1216
					} 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);
					}
1217
				}
1218 1219
				return executeResult.promise;
			});
1220 1221 1222
		});
	}

1223
	public restart(task: Task): void {
1224 1225 1226
		if (!this._taskSystem) {
			return;
		}
1227
		this._taskSystem.terminate(task).then((response) => {
1228 1229 1230 1231 1232 1233 1234 1235 1236 1237
			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;
		});
	}

1238
	public terminate(task: Task): TPromise<TaskTerminateResponse> {
1239
		if (!this._taskSystem) {
1240
			return TPromise.as({ success: true, task: undefined });
1241
		}
1242
		return this._taskSystem.terminate(task);
1243 1244
	}

1245
	public terminateAll(): TPromise<TaskTerminateResponse[]> {
1246
		if (!this._taskSystem) {
1247
			return TPromise.as<TaskTerminateResponse[]>([]);
1248
		}
1249
		return this._taskSystem.terminateAll();
1250 1251 1252 1253 1254 1255
	}

	private getTaskSystem(): ITaskSystem {
		if (this._taskSystem) {
			return this._taskSystem;
		}
D
Dirk Baeumer 已提交
1256
		if (this.executionEngine === ExecutionEngine.Terminal) {
1257 1258 1259
			this._taskSystem = new TerminalTaskSystem(
				this.terminalService, this.outputService, this.markerService,
				this.modelService, this.configurationResolverService, this.telemetryService,
D
Dirk Baeumer 已提交
1260
				this.contextService, TaskService.OutputChannelId
1261 1262 1263 1264
			);
		} else {
			let system = new ProcessTaskSystem(
				this.markerService, this.modelService, this.telemetryService, this.outputService,
D
Dirk Baeumer 已提交
1265
				this.configurationResolverService, TaskService.OutputChannelId,
1266 1267 1268 1269
			);
			system.hasErrors(this._configHasErrors);
			this._taskSystem = system;
		}
A
Alex Dima 已提交
1270 1271
		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)));
1272
		this._taskSystemListeners.push(this._taskSystem.addListener(TaskSystemEvents.Terminated, (event) => this.emit(TaskServiceEvents.Terminated, event)));
1273
		this._taskSystemListeners.push(this._taskSystem.addListener(TaskSystemEvents.Changed, () => this.emit(TaskServiceEvents.Changed)));
1274 1275 1276
		return this._taskSystem;
	}

1277
	private getGroupedTasks(): TPromise<TaskMap> {
D
Dirk Baeumer 已提交
1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289
		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);
					}
				};
1290 1291 1292
				let error = (error: any) => {
					try {
						if (Types.isString(error.message)) {
1293
							this._outputChannel.append('Error: ');
1294
							this._outputChannel.append(error.message);
1295
							this._outputChannel.append('\n');
1296 1297 1298 1299 1300 1301
							this._outputChannel.show(true);
						}
					} finally {
						if (--counter === 0) {
							resolve(result);
						}
D
Dirk Baeumer 已提交
1302 1303
					}
				};
D
Dirk Baeumer 已提交
1304
				if (this.schemaVersion === JsonSchemaVersion.V2_0_0 && this._providers.size > 0) {
D
Dirk Baeumer 已提交
1305 1306 1307 1308 1309
					this._providers.forEach((provider) => {
						counter++;
						provider.provideTasks().done(done, error);
					});
				} else {
1310 1311
					resolve(result);
				}
D
Dirk Baeumer 已提交
1312
			});
D
Dirk Baeumer 已提交
1313
		}).then((contributedTaskSets) => {
1314 1315
			let result: TaskMap = new TaskMap();
			let contributedTasks: TaskMap = new TaskMap();
D
Dirk Baeumer 已提交
1316 1317
			for (let set of contributedTaskSets) {
				for (let task of set.tasks) {
1318
					let workspaceFolder = Task.getWorkspaceFolder(task);
D
Dirk Baeumer 已提交
1319
					if (workspaceFolder) {
1320
						contributedTasks.add(workspaceFolder, task);
D
Dirk Baeumer 已提交
1321 1322 1323 1324 1325 1326
					}
				}
			}
			return this.getWorkspaceTasks().then((customTasks) => {
				customTasks.forEach((folderTasks, key) => {
					let contributed = contributedTasks.get(key);
1327 1328
					if (!folderTasks.set) {
						if (contributed) {
1329
							result.add(key, ...contributed);
1330 1331 1332 1333
						}
						return;
					}

D
Dirk Baeumer 已提交
1334
					if (!contributed) {
1335
						result.add(key, ...folderTasks.set.tasks);
D
Dirk Baeumer 已提交
1336 1337 1338 1339 1340
					} else {
						let configurations = folderTasks.configurations;
						let legacyTaskConfigurations = folderTasks.set ? this.getLegacyTaskConfigurations(folderTasks.set) : undefined;
						let customTasksToDelete: Task[] = [];
						if (configurations || legacyTaskConfigurations) {
D
Dirk Baeumer 已提交
1341
							let unUsedConfigurations: Set<string> = new Set<string>();
1342 1343 1344
							if (configurations) {
								Object.keys(configurations.byIdentifier).forEach(key => unUsedConfigurations.add(key));
							}
D
Dirk Baeumer 已提交
1345 1346
							for (let task of contributed) {
								if (!ContributedTask.is(task)) {
1347 1348
									continue;
								}
D
Dirk Baeumer 已提交
1349 1350 1351
								if (configurations) {
									let configuringTask = configurations.byIdentifier[task.defines._key];
									if (configuringTask) {
D
Dirk Baeumer 已提交
1352
										unUsedConfigurations.delete(task.defines._key);
1353
										result.add(key, TaskConfig.createCustomTask(task, configuringTask));
D
Dirk Baeumer 已提交
1354
									} else {
1355
										result.add(key, task);
D
Dirk Baeumer 已提交
1356 1357 1358 1359
									}
								} else if (legacyTaskConfigurations) {
									let configuringTask = legacyTaskConfigurations[task.defines._key];
									if (configuringTask) {
1360
										result.add(key, TaskConfig.createCustomTask(task, configuringTask));
D
Dirk Baeumer 已提交
1361
										customTasksToDelete.push(configuringTask);
D
Dirk Baeumer 已提交
1362
									} else {
1363
										result.add(key, task);
D
Dirk Baeumer 已提交
1364 1365
									}
								} else {
1366
									result.add(key, task);
D
Dirk Baeumer 已提交
1367
								}
1368
							}
D
Dirk Baeumer 已提交
1369 1370 1371 1372 1373 1374 1375 1376 1377
							if (customTasksToDelete.length > 0) {
								let toDelete = customTasksToDelete.reduce<IStringDictionary<boolean>>((map, task) => {
									map[task._id] = true;
									return map;
								}, Object.create(null));
								for (let task of folderTasks.set.tasks) {
									if (toDelete[task._id]) {
										continue;
									}
1378
									result.add(key, task);
1379
								}
D
Dirk Baeumer 已提交
1380
							} else {
1381
								result.add(key, ...folderTasks.set.tasks);
1382
							}
D
Dirk Baeumer 已提交
1383 1384 1385 1386
							unUsedConfigurations.forEach((value) => {
								let configuringTask = configurations.byIdentifier[value];
								this._outputChannel.append(nls.localize(
									'TaskService.noConfiguration',
1387 1388
									'Error: The {0} task detection didn\'t contribute a task for the following configuration:\n{1}\nThe task will be ignored.\n',
									configuringTask.configures.type,
D
Dirk Baeumer 已提交
1389 1390 1391 1392
									JSON.stringify(configuringTask._source.config.element, undefined, 4)
								));
								this.showOutput();
							});
D
Dirk Baeumer 已提交
1393
						} else {
1394 1395
							result.add(key, ...folderTasks.set.tasks);
							result.add(key, ...contributed);
1396 1397
						}
					}
D
Dirk Baeumer 已提交
1398
				});
1399 1400 1401
				return result;
			}, () => {
				// If we can't read the tasks.json file provide at least the contributed tasks
1402
				let result: TaskMap = new TaskMap();
D
Dirk Baeumer 已提交
1403
				for (let set of contributedTaskSets) {
1404 1405 1406
					for (let task of set.tasks) {
						result.add(Task.getWorkspaceFolder(task), task);
					}
D
Dirk Baeumer 已提交
1407
				}
1408 1409
				return result;
			});
1410 1411 1412
		});
	}

1413 1414
	private getLegacyTaskConfigurations(workspaceTasks: TaskSet): IStringDictionary<CustomTask> {
		let result: IStringDictionary<CustomTask>;
1415 1416 1417 1418 1419 1420 1421 1422
		function getResult() {
			if (result) {
				return result;
			}
			result = Object.create(null);
			return result;
		}
		for (let task of workspaceTasks.tasks) {
1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433
			if (CustomTask.is(task)) {
				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') {
					let identifier: TaskIdentifier = TaskConfig.getTaskIdentifier({
						type: commandName,
						task: task.name
					} as TaskConfig.TaskIdentifier);
					getResult()[identifier._key] = task;
				}
1434 1435 1436 1437 1438
			}
		}
		return result;
	}

D
Dirk Baeumer 已提交
1439
	private getWorkspaceTasks(): TPromise<Map<string, WorkspaceFolderTaskResult>> {
1440 1441 1442
		if (this._workspaceTasksPromise) {
			return this._workspaceTasksPromise;
		}
1443
		this.updateWorkspaceTasks();
1444 1445 1446 1447 1448
		return this._workspaceTasksPromise;
	}

	private updateWorkspaceTasks(): void {
		this._workspaceTasksPromise = this.computeWorkspaceTasks().then(value => {
D
Dirk Baeumer 已提交
1449
			if (this.executionEngine === ExecutionEngine.Process && this._taskSystem instanceof ProcessTaskSystem) {
D
Dirk Baeumer 已提交
1450 1451 1452 1453 1454
				// We can only have a process engine if we have one folder.
				value.forEach((value) => {
					this._configHasErrors = value.hasErrors;
					(this._taskSystem as ProcessTaskSystem).hasErrors(this._configHasErrors);
				});
1455 1456
			}
			return value;
1457 1458 1459
		});
	}

1460
	private computeWorkspaceTasks(): TPromise<Map<string, WorkspaceFolderTaskResult>> {
D
Dirk Baeumer 已提交
1461
		if (this.workspaceFolders.length === 0) {
1462 1463 1464
			return TPromise.as(new Map<string, WorkspaceFolderTaskResult>());
		} else {
			let promises: TPromise<WorkspaceFolderTaskResult>[] = [];
D
Dirk Baeumer 已提交
1465
			for (let folder of this.workspaceFolders) {
1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479
				promises.push(this.computeWorkspaceFolderTasks(folder).then((value) => value, () => undefined));
			}
			return TPromise.join(promises).then((values) => {
				let result = new Map<string, WorkspaceFolderTaskResult>();
				for (let value of values) {
					if (value) {
						result.set(value.workspaceFolder.uri.toString(), value);
					}
				}
				return result;
			});
		}
	}

S
Sandeep Somavarapu 已提交
1480
	private computeWorkspaceFolderTasks(workspaceFolder: IWorkspaceFolder): TPromise<WorkspaceFolderTaskResult> {
D
Dirk Baeumer 已提交
1481
		return (this.executionEngine === ExecutionEngine.Process
1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513
			? this.computeLegacyConfiguration(workspaceFolder)
			: this.computeConfiguration(workspaceFolder)).
			then((workspaceFolderConfiguration) => {
				if (!workspaceFolderConfiguration || !workspaceFolderConfiguration.config || workspaceFolderConfiguration.hasErrors) {
					return TPromise.as({ workspaceFolder, set: undefined, configurations: undefined, hasErrors: workspaceFolderConfiguration ? workspaceFolderConfiguration.hasErrors : false });
				}
				return ProblemMatcherRegistry.onReady().then((): WorkspaceFolderTaskResult => {
					let problemReporter = new ProblemReporter(this._outputChannel);
					let parseResult = TaskConfig.parse(workspaceFolder, workspaceFolderConfiguration.config, problemReporter);
					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.'));
						return { workspaceFolder, set: undefined, configurations: undefined, hasErrors };
					}
					let customizedTasks: { byIdentifier: IStringDictionary<ConfiguringTask>; };
					if (parseResult.configured && parseResult.configured.length > 0) {
						customizedTasks = {
							byIdentifier: Object.create(null)
						};
						for (let task of parseResult.configured) {
							customizedTasks.byIdentifier[task.configures._key] = task;
						}
					}
					return { workspaceFolder, set: { tasks: parseResult.custom }, configurations: customizedTasks, hasErrors };
				});
			});
	}

S
Sandeep Somavarapu 已提交
1514
	private computeConfiguration(workspaceFolder: IWorkspaceFolder): TPromise<WorkspaceFolderConfigurationResult> {
1515 1516 1517 1518
		let { config, hasParseErrors } = this.getConfiguration(workspaceFolder);
		return TPromise.as<WorkspaceFolderConfigurationResult>({ workspaceFolder, config, hasErrors: hasParseErrors });
	}

S
Sandeep Somavarapu 已提交
1519
	private computeLegacyConfiguration(workspaceFolder: IWorkspaceFolder): TPromise<WorkspaceFolderConfigurationResult> {
1520 1521 1522 1523 1524 1525
		let { config, hasParseErrors } = this.getConfiguration(workspaceFolder);
		if (hasParseErrors) {
			return TPromise.as({ workspaceFolder: workspaceFolder, hasErrors: true, config: undefined });
		}
		if (config) {
			if (this.hasDetectorSupport(config)) {
D
Dirk Baeumer 已提交
1526
				return new ProcessRunnerDetector(workspaceFolder, this.fileService, this.contextService, this.configurationResolverService, config).detect(true).then((value): WorkspaceFolderConfigurationResult => {
1527 1528 1529 1530 1531
					let hasErrors = this.printStderr(value.stderr);
					let detectedConfig = value.config;
					if (!detectedConfig) {
						return { workspaceFolder, config, hasErrors };
					}
J
Johannes Rieken 已提交
1532
					let result: TaskConfig.ExternalTaskRunnerConfiguration = Objects.deepClone(config);
1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551
					let configuredTasks: IStringDictionary<TaskConfig.CustomTask> = Object.create(null);
					if (!result.tasks) {
						if (detectedConfig.tasks) {
							result.tasks = detectedConfig.tasks;
						}
					} else {
						result.tasks.forEach(task => configuredTasks[task.taskName] = task);
						detectedConfig.tasks.forEach((task) => {
							if (!configuredTasks[task.taskName]) {
								result.tasks.push(task);
							}
						});
					}
					return { workspaceFolder, config: result, hasErrors };
				});
			} else {
				return TPromise.as({ workspaceFolder, config, hasErrors: false });
			}
		} else {
D
Dirk Baeumer 已提交
1552
			return new ProcessRunnerDetector(workspaceFolder, this.fileService, this.contextService, this.configurationResolverService).detect(true).then((value) => {
1553 1554 1555 1556 1557 1558
				let hasErrors = this.printStderr(value.stderr);
				return { workspaceFolder, config: value.config, hasErrors };
			});
		}
	}

D
Dirk Baeumer 已提交
1559
	private computeWorkspaceFolderSetup(): [IWorkspaceFolder[], IWorkspaceFolder[], ExecutionEngine, JsonSchemaVersion] {
S
Sandeep Somavarapu 已提交
1560
		let workspaceFolders: IWorkspaceFolder[] = [];
D
Dirk Baeumer 已提交
1561
		let ignoredWorkspaceFolders: IWorkspaceFolder[] = [];
D
Dirk Baeumer 已提交
1562 1563 1564
		let executionEngine = ExecutionEngine.Terminal;
		let schemaVersion = JsonSchemaVersion.V2_0_0;

D
Dirk Baeumer 已提交
1565
		if (this.contextService.getWorkbenchState() === WorkbenchState.FOLDER) {
S
Sandeep Somavarapu 已提交
1566
			let workspaceFolder: IWorkspaceFolder = this.contextService.getWorkspace().folders[0];
D
Dirk Baeumer 已提交
1567 1568 1569
			workspaceFolders.push(workspaceFolder);
			executionEngine = this.computeExecutionEngine(workspaceFolder);
			schemaVersion = this.computeJsonSchemaVersion(workspaceFolder);
D
Dirk Baeumer 已提交
1570
		} else if (this.contextService.getWorkbenchState() === WorkbenchState.WORKSPACE) {
1571
			for (let workspaceFolder of this.contextService.getWorkspace().folders) {
D
Dirk Baeumer 已提交
1572
				if (schemaVersion === this.computeJsonSchemaVersion(workspaceFolder)) {
D
Dirk Baeumer 已提交
1573
					workspaceFolders.push(workspaceFolder);
1574
				} else {
D
Dirk Baeumer 已提交
1575
					ignoredWorkspaceFolders.push(workspaceFolder);
1576 1577
					this._outputChannel.append(nls.localize(
						'taskService.ignoreingFolder',
1578
						'Ignoring task configurations for workspace folder {0}. Multi folder workspace task support requires that all folders use task version 2.0.0\n',
1579
						workspaceFolder.uri.fsPath));
1580 1581 1582
				}
			}
		}
D
Dirk Baeumer 已提交
1583
		return [workspaceFolders, ignoredWorkspaceFolders, executionEngine, schemaVersion];
1584
	}
1585

S
Sandeep Somavarapu 已提交
1586
	private computeExecutionEngine(workspaceFolder: IWorkspaceFolder): ExecutionEngine {
1587
		let { config } = this.getConfiguration(workspaceFolder);
1588
		if (!config) {
1589
			return ExecutionEngine._default;
1590 1591 1592 1593
		}
		return TaskConfig.ExecutionEngine.from(config);
	}

S
Sandeep Somavarapu 已提交
1594
	private computeJsonSchemaVersion(workspaceFolder: IWorkspaceFolder): JsonSchemaVersion {
1595
		let { config } = this.getConfiguration(workspaceFolder);
1596 1597 1598 1599 1600 1601
		if (!config) {
			return JsonSchemaVersion.V2_0_0;
		}
		return TaskConfig.JsonSchemaVersion.from(config);
	}

S
Sandeep Somavarapu 已提交
1602
	private getConfiguration(workspaceFolder: IWorkspaceFolder): { config: TaskConfig.ExternalTaskRunnerConfiguration; hasParseErrors: boolean } {
D
Dirk Baeumer 已提交
1603
		let result = this.contextService.getWorkbenchState() !== WorkbenchState.EMPTY
J
Johannes Rieken 已提交
1604
			? Objects.deepClone(this.configurationService.getValue<TaskConfig.ExternalTaskRunnerConfiguration>('tasks', { resource: workspaceFolder.uri }))
1605
			: undefined;
1606
		if (!result) {
1607
			return { config: undefined, hasParseErrors: false };
1608 1609 1610 1611 1612 1613 1614 1615 1616
		}
		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;
				}
1617
			}
1618
			if (isAffected) {
1619
				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'));
1620
				this.showOutput();
1621
				return { config: undefined, hasParseErrors: true };
1622
			}
1623 1624
		}
		return { config: result, hasParseErrors: false };
1625 1626
	}

E
Erich Gamma 已提交
1627
	private printStderr(stderr: string[]): boolean {
1628
		let result = false;
E
Erich Gamma 已提交
1629 1630
		if (stderr && stderr.length > 0) {
			stderr.forEach((line) => {
1631
				result = true;
1632
				this._outputChannel.append(line + '\n');
E
Erich Gamma 已提交
1633
			});
1634
			this._outputChannel.show(true);
E
Erich Gamma 已提交
1635 1636 1637 1638
		}
		return result;
	}

1639
	public inTerminal(): boolean {
1640 1641 1642
		if (this._taskSystem) {
			return this._taskSystem instanceof TerminalTaskSystem;
		}
D
Dirk Baeumer 已提交
1643
		return this.executionEngine === ExecutionEngine.Terminal;
1644 1645
	}

1646
	private hasDetectorSupport(config: TaskConfig.ExternalTaskRunnerConfiguration): boolean {
1647
		if (!config.command || this.contextService.getWorkbenchState() === WorkbenchState.EMPTY) {
E
Erich Gamma 已提交
1648 1649 1650 1651 1652
			return false;
		}
		return ProcessRunnerDetector.supports(config.command);
	}

1653
	public configureAction(): Action {
1654 1655 1656 1657 1658 1659
		let run = () => { this.runConfigureTasks(); return TPromise.as(undefined); };
		return new class extends Action {
			constructor() {
				super(ConfigureTaskAction.ID, ConfigureTaskAction.TEXT, undefined, true, run);
			}
		};
1660 1661
	}

1662
	private configureBuildTask(): Action {
1663 1664 1665 1666 1667 1668
		let run = () => { this.runConfigureTasks(); return TPromise.as(undefined); };
		return new class extends Action {
			constructor() {
				super(ConfigureTaskAction.ID, ConfigureTaskAction.TEXT, undefined, true, run);
			}
		};
1669 1670
	}

E
Erich Gamma 已提交
1671
	public beforeShutdown(): boolean | TPromise<boolean> {
1672 1673 1674
		if (!this._taskSystem) {
			return false;
		}
1675
		this.saveRecentlyUsedTasks();
1676 1677 1678 1679 1680 1681 1682 1683
		if (!this._taskSystem.isActiveSync()) {
			return false;
		}
		// The terminal service kills all terminal on shutdown. So there
		// is nothing we can do to prevent this here.
		if (this._taskSystem instanceof TerminalTaskSystem) {
			return false;
		}
1684
		if (this._taskSystem.canAutoTerminate() || this.messageService.confirmSync({
1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697
			message: nls.localize('TaskSystem.runningTask', 'There is a task running. Do you want to terminate it?'),
			primaryButton: nls.localize({ key: 'TaskSystem.terminateTask', comment: ['&& denotes a mnemonic'] }, "&&Terminate Task"),
			type: 'question'
		})) {
			return this._taskSystem.terminateAll().then((responses) => {
				let success = true;
				let code: number = undefined;
				for (let response of responses) {
					success = success && response.success;
					// We only have a code in the old output runner which only has one task
					// So we can use the first code.
					if (code === void 0 && response.code !== void 0) {
						code = response.code;
E
Erich Gamma 已提交
1698
					}
1699 1700 1701 1702 1703 1704 1705
				}
				if (success) {
					this.emit(TaskServiceEvents.Terminated, {});
					this._taskSystem = null;
					this.disposeTaskSystemListeners();
					return false; // no veto
				} else if (code && code === TerminateResponseCode.ProcessNotFound) {
1706
					return !this.messageService.confirmSync({
1707 1708 1709 1710 1711
						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"),
						type: 'info'
					});
				}
E
Erich Gamma 已提交
1712
				return true; // veto
1713 1714 1715 1716 1717
			}, (err) => {
				return true; // veto
			});
		} else {
			return true; // veto
E
Erich Gamma 已提交
1718 1719 1720
		}
	}

1721
	private getConfigureAction(code: TaskErrors): Action {
J
Johannes Rieken 已提交
1722
		switch (code) {
1723 1724 1725 1726 1727 1728
			case TaskErrors.NoBuildTask:
				return this.configureBuildTask();
			default:
				return this.configureAction();
		}
	}
1729

J
Johannes Rieken 已提交
1730
	private handleError(err: any): void {
E
Erich Gamma 已提交
1731 1732 1733
		let showOutput = true;
		if (err instanceof TaskError) {
			let buildError = <TaskError>err;
1734 1735 1736
			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 已提交
1737
				let closeAction = new CloseMessageAction();
1738
				let action: Action = needsConfig
1739
					? this.getConfigureAction(buildError.code)
1740 1741
					: new Action(
						'workbench.action.tasks.terminate',
1742
						nls.localize('TerminateAction.label', "Terminate Task"),
1743
						undefined, true, () => { this.runTerminateCommand(); return TPromise.wrap<void>(undefined); });
J
Johannes Rieken 已提交
1744
				closeAction.closeFunction = this.messageService.show(buildError.severity, { message: buildError.message, actions: [action, closeAction] });
E
Erich Gamma 已提交
1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756
			} 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) {
1757
			this._outputChannel.show(true);
E
Erich Gamma 已提交
1758 1759
		}
	}
1760 1761

	private canRunCommand(): boolean {
1762
		if (this.contextService.getWorkbenchState() === WorkbenchState.EMPTY) {
1763 1764 1765 1766 1767 1768
			this.messageService.show(Severity.Info, nls.localize('TaskService.noWorkspace', 'Tasks are only available on a workspace folder.'));
			return false;
		}
		return true;
	}

1769
	private createTaskQuickPickEntries(tasks: Task[], group: boolean = false, sort: boolean = false): TaskQuickPickEntry[] {
1770
		if (tasks === void 0 || tasks === null || tasks.length === 0) {
1771
			return [];
1772
		}
1773
		const TaskQuickPickEntry = (task: Task): TaskQuickPickEntry => {
1774
			let description: string;
1775
			if (this.needsFolderQualification()) {
1776 1777
				let workspaceFolder = Task.getWorkspaceFolder(task);
				if (workspaceFolder) {
1778
					description = workspaceFolder.name;
1779 1780 1781 1782
				}
			}
			return { label: task._label, description, task };
		};
1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799
		let taskService = this;
		let action = new class extends Action implements IPickOpenAction {
			constructor() {
				super('configureAction', 'Configure Task', 'quick-open-task-configure', true);
			}
			public run(item: IPickOpenItem): TPromise<boolean> {
				let task: Task = item.getPayload();
				taskService.quickOpenService.close();
				if (ContributedTask.is(task)) {
					taskService.customize(task, undefined, true);
				} else if (CustomTask.is(task)) {
					taskService.openConfig(task);
				}
				return TPromise.as(false);
			}
		};
		function fillEntries(entries: TaskQuickPickEntry[], tasks: Task[], groupLabel: string, withBorder: boolean = false): void {
1800 1801
			let first = true;
			for (let task of tasks) {
1802
				let entry: TaskQuickPickEntry = TaskQuickPickEntry(task);
1803 1804 1805 1806
				if (first) {
					first = false;
					entry.separator = { label: groupLabel, border: withBorder };
				}
1807 1808 1809
				entry.action = action;
				entry.payload = task;
				entries.push(entry);
1810 1811
			}
		}
1812
		let entries: TaskQuickPickEntry[];
1813 1814 1815
		if (group) {
			entries = [];
			if (tasks.length === 1) {
1816
				entries.push(TaskQuickPickEntry(tasks[0]));
1817 1818 1819 1820 1821 1822
			} else {
				let recentlyUsedTasks = this.getRecentlyUsedTasks();
				let recent: Task[] = [];
				let configured: Task[] = [];
				let detected: Task[] = [];
				let taskMap: IStringDictionary<Task> = Object.create(null);
1823 1824 1825 1826 1827 1828
				tasks.forEach(task => {
					let key = Task.getRecentlyUsedKey(task);
					if (key) {
						taskMap[key] = task;
					}
				});
1829 1830 1831 1832 1833 1834 1835
				recentlyUsedTasks.keys().forEach(key => {
					let task = taskMap[key];
					if (task) {
						recent.push(task);
					}
				});
				for (let task of tasks) {
1836 1837
					let key = Task.getRecentlyUsedKey(task);
					if (!key || !recentlyUsedTasks.has(key)) {
1838 1839 1840 1841 1842 1843 1844
						if (task._source.kind === TaskSourceKind.Workspace) {
							configured.push(task);
						} else {
							detected.push(task);
						}
					}
				}
1845
				const sorter = this.createSorter();
1846 1847
				let hasRecentlyUsed: boolean = recent.length > 0;
				fillEntries(entries, recent, nls.localize('recentlyUsed', 'recently used tasks'));
1848
				configured = configured.sort((a, b) => sorter.compare(a, b));
1849 1850
				let hasConfigured = configured.length > 0;
				fillEntries(entries, configured, nls.localize('configured', 'configured tasks'), hasRecentlyUsed);
1851
				detected = detected.sort((a, b) => sorter.compare(a, b));
1852 1853 1854 1855
				fillEntries(entries, detected, nls.localize('detected', 'detected tasks'), hasRecentlyUsed || hasConfigured);
			}
		} else {
			if (sort) {
1856 1857
				const sorter = this.createSorter();
				tasks = tasks.sort((a, b) => sorter.compare(a, b));
1858
			}
1859
			entries = tasks.map<TaskQuickPickEntry>(task => TaskQuickPickEntry(task));
1860
		}
1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877
		return entries;
	}

	private showQuickPick(tasks: TPromise<Task[]> | Task[], placeHolder: string, defaultEntry?: TaskQuickPickEntry, group: boolean = false, sort: boolean = false): TPromise<Task> {
		let _createEntries = (): TPromise<TaskQuickPickEntry[]> => {
			if (Array.isArray(tasks)) {
				return TPromise.as(this.createTaskQuickPickEntries(tasks, group, sort));
			} else {
				return tasks.then((tasks) => this.createTaskQuickPickEntries(tasks, group, sort));
			}
		};
		return this.quickOpenService.pick(_createEntries().then((entries) => {
			if (entries.length === 0 && defaultEntry) {
				entries.push(defaultEntry);
			}
			return entries;
		}), { placeHolder, autoFocus: { autoFocusFirstEntry: true } }).then(entry => entry ? entry.task : undefined);
1878 1879
	}

D
Dirk Baeumer 已提交
1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902
	private showIgnoredFoldersMessage(): TPromise<void> {
		if (this.ignoredWorkspaceFolders.length === 0 || !this.showIgnoreMessage) {
			return TPromise.as(undefined);
		}
		let message: string = nls.localize('TaskService.ignoredFolder', 'The following workspace folders are ignored since they use task version 0.1.0: ');
		for (let i = 0; i < this.ignoredWorkspaceFolders.length; i++) {
			message = message + this.ignoredWorkspaceFolders[i].name;
			if (i < this.ignoredWorkspaceFolders.length - 1) {
				message = message + ', ';
			}
		}

		let notAgain = nls.localize('TaskService.notAgain', 'Don\'t Show Again');
		let ok = nls.localize('TaskService.ok', 'OK');
		return this.choiceService.choose(Severity.Info, message, [notAgain, ok], 0).then((choice) => {
			if (choice === 0) {
				this.storageService.store(TaskService.IgnoreTask010DonotShowAgain_key, true, StorageScope.WORKSPACE);
			}
			this.__showIgnoreMessage = false;
			return undefined;
		}, () => undefined);
	}

1903 1904 1905 1906 1907
	private runTaskCommand(accessor: ServicesAccessor, arg: any): void {
		if (!this.canRunCommand()) {
			return;
		}
		if (Types.isString(arg)) {
1908 1909 1910 1911 1912 1913 1914 1915 1916
			this.getGroupedTasks().then((grouped) => {
				let resolver = this.createResolver(grouped);
				let folders = this.contextService.getWorkspace().folders;
				for (let folder of folders) {
					let task = resolver.resolve(folder, arg);
					if (task) {
						this.run(task);
						return;
					}
1917
				}
1918
				this.doRunTaskCommand(grouped.all());
1919
			}, () => {
1920
				this.doRunTaskCommand();
1921 1922
			});
		} else {
1923
			this.doRunTaskCommand();
1924 1925 1926
		}
	}

1927
	private doRunTaskCommand(tasks?: Task[]): void {
D
Dirk Baeumer 已提交
1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944 1945 1946
		this.showIgnoredFoldersMessage().then(() => {
			this.showQuickPick(tasks ? tasks : this.tasks(),
				nls.localize('TaskService.pickRunTask', 'Select the task to run'),
				{
					label: nls.localize('TaslService.noEntryToRun', 'No task to run found. Configure Tasks...'),
					task: null
				},
				true).
				then((task) => {
					if (task === void 0) {
						return;
					}
					if (task === null) {
						this.runConfigureTasks();
					} else {
						this.run(task, { attachProblemMatcher: true });
					}
				});
		});
1947 1948
	}

1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963 1964
	private splitPerGroupType(tasks: Task[]): { none: Task[], defaults: Task[], users: Task[] } {
		let none: Task[] = [];
		let defaults: Task[] = [];
		let users: Task[] = [];
		for (let task of tasks) {
			if (task.groupType === GroupType.default) {
				defaults.push(task);
			} else if (task.groupType === GroupType.user) {
				users.push(task);
			} else {
				none.push(task);
			}
		}
		return { none, defaults, users };
	}

1965 1966 1967 1968
	private runBuildCommand(): void {
		if (!this.canRunCommand()) {
			return;
		}
D
Dirk Baeumer 已提交
1969
		if (this.schemaVersion === JsonSchemaVersion.V0_1_0) {
1970 1971 1972
			this.build();
			return;
		}
1973 1974 1975 1976 1977
		let options: IProgressOptions = {
			location: ProgressLocation.Window,
			title: nls.localize('TaskService.fetchingBuildTasks', 'Fetching build tasks...')
		};
		let promise = this.getTasksForGroup(TaskGroup.Build).then((tasks) => {
1978
			if (tasks.length > 0) {
D
Dirk Baeumer 已提交
1979
				let { defaults, users } = this.splitPerGroupType(tasks);
1980 1981
				if (defaults.length === 1) {
					this.run(defaults[0]);
1982
					return;
1983 1984
				} else if (defaults.length + users.length > 0) {
					tasks = defaults.concat(users);
D
Dirk Baeumer 已提交
1985 1986
				}
			}
D
Dirk Baeumer 已提交
1987 1988 1989 1990
			this.showIgnoredFoldersMessage().then(() => {
				this.showQuickPick(tasks,
					nls.localize('TaskService.pickBuildTask', 'Select the build task to run'),
					{
1991
						label: nls.localize('TaskService.noBuildTask', 'No build task to run found. Configure Build Task...'),
D
Dirk Baeumer 已提交
1992 1993 1994 1995 1996 1997 1998
						task: null
					},
					true).then((task) => {
						if (task === void 0) {
							return;
						}
						if (task === null) {
1999
							this.runConfigureDefaultBuildTask();
D
Dirk Baeumer 已提交
2000 2001 2002 2003 2004
							return;
						}
						this.run(task, { attachProblemMatcher: true });
					});
			});
2005
		});
2006
		this.progressService.withProgress(options, () => promise);
2007 2008 2009 2010 2011 2012
	}

	private runTestCommand(): void {
		if (!this.canRunCommand()) {
			return;
		}
D
Dirk Baeumer 已提交
2013
		if (this.schemaVersion === JsonSchemaVersion.V0_1_0) {
2014
			this.runTest();
2015 2016
			return;
		}
2017 2018 2019 2020 2021
		let options: IProgressOptions = {
			location: ProgressLocation.Window,
			title: nls.localize('TaskService.fetchingTestTasks', 'Fetching test tasks...')
		};
		let promise = this.getTasksForGroup(TaskGroup.Test).then((tasks) => {
2022
			if (tasks.length > 0) {
D
Dirk Baeumer 已提交
2023
				let { defaults, users } = this.splitPerGroupType(tasks);
2024 2025
				if (defaults.length === 1) {
					this.run(defaults[0]);
2026
					return;
2027 2028
				} else if (defaults.length + users.length > 0) {
					tasks = defaults.concat(users);
D
Dirk Baeumer 已提交
2029 2030
				}
			}
D
Dirk Baeumer 已提交
2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047
			this.showIgnoredFoldersMessage().then(() => {
				this.showQuickPick(tasks,
					nls.localize('TaskService.pickTestTask', 'Select the test task to run'),
					{
						label: nls.localize('TaskService.noTestTaskTerminal', 'No test task to run found. Configure Tasks...'),
						task: null
					}, true
				).then((task) => {
					if (task === void 0) {
						return;
					}
					if (task === null) {
						this.runConfigureTasks();
						return;
					}
					this.run(task);
				});
2048
			});
2049
		});
2050
		this.progressService.withProgress(options, () => promise);
2051 2052
	}

2053 2054 2055 2056 2057
	private runTerminateCommand(): void {
		if (!this.canRunCommand()) {
			return;
		}
		if (this.inTerminal()) {
2058 2059 2060 2061 2062 2063 2064 2065 2066
			this.showQuickPick(this.getActiveTasks(),
				nls.localize('TaskService.tastToTerminate', 'Select task to terminate'),
				{
					label: nls.localize('TaskService.noTaskRunning', 'No task is currently running'),
					task: null
				},
				false, true
			).then(task => {
				if (task === void 0 || task === null) {
2067 2068
					return;
				}
2069
				this.terminate(task);
2070
			});
2071 2072 2073
		} else {
			this.isActive().then((active) => {
				if (active) {
2074 2075 2076
					this.terminateAll().then((responses) => {
						// the output runner has only one task
						let response = responses[0];
2077
						if (response.success) {
2078 2079 2080
							return;
						}
						if (response.code && response.code === TerminateResponseCode.ProcessNotFound) {
2081 2082
							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 {
2083
							this.messageService.show(Severity.Error, nls.localize('TerminateAction.failed', 'Failed to terminate running task'));
2084 2085 2086 2087 2088 2089
						}
					});
				}
			});
		}
	}
2090 2091 2092 2093 2094 2095

	private runRestartTaskCommand(accessor: ServicesAccessor, arg: any): void {
		if (!this.canRunCommand()) {
			return;
		}
		if (this.inTerminal()) {
2096 2097 2098 2099 2100 2101 2102 2103 2104
			this.showQuickPick(this.getActiveTasks(),
				nls.localize('TaskService.tastToRestart', 'Select the task to restart'),
				{
					label: nls.localize('TaskService.noTaskToRestart', 'No task to restart'),
					task: null
				},
				false, true
			).then(task => {
				if (task === void 0 || task === null) {
2105 2106
					return;
				}
2107
				this.restart(task);
2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118
			});
		} else {
			this.getActiveTasks().then((activeTasks) => {
				if (activeTasks.length === 0) {
					return;
				}
				let task = activeTasks[0];
				this.restart(task);
			});
		}
	}
2119

2120 2121 2122 2123 2124
	private runConfigureTasks(): void {
		if (!this.canRunCommand()) {
			return undefined;
		}
		let taskPromise: TPromise<TaskMap>;
D
Dirk Baeumer 已提交
2125
		if (this.schemaVersion === JsonSchemaVersion.V2_0_0) {
2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141 2142
			taskPromise = this.getGroupedTasks();
		} else {
			taskPromise = TPromise.as(new TaskMap());
		}

		let openTaskFile = (workspaceFolder: IWorkspaceFolder): void => {
			let resource = workspaceFolder.toResource('.vscode/tasks.json');
			let configFileCreated = false;
			this.fileService.resolveFile(resource).then((stat) => stat, () => undefined).then((stat) => {
				if (stat) {
					return stat.resource;
				}
				return this.quickOpenService.pick(taskTemplates, { placeHolder: nls.localize('TaskService.template', 'Select a Task Template') }).then((selection) => {
					if (!selection) {
						return undefined;
					}
					let content = selection.content;
2143
					let editorConfig = this.configurationService.getValue<any>();
2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209
					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(resource, content).then((result): URI => {
						this.telemetryService.publicLog(TaskService.TemplateTelemetryEventName, {
							templateId: selection.id,
							autoDetect: selection.autoDetect
						});
						return result.resource;
					});
				});
			}).then((resource) => {
				if (!resource) {
					return;
				}
				this.editorService.openEditor({
					resource: resource,
					options: {
						forceOpen: true,
						pinned: configFileCreated // pin only if config file is created #8727
					}
				}, false);
			});
		};

		let configureTask = (task: Task): void => {
			if (ContributedTask.is(task)) {
				this.customize(task, undefined, true);
			} else if (CustomTask.is(task)) {
				this.openConfig(task);
			}
		};

		function isTaskEntry(value: IPickOpenEntry): value is IPickOpenEntry & { task: Task } {
			let candidate: IPickOpenEntry & { task: Task } = value as any;
			return candidate && !!candidate.task;
		}

		let stats = this.contextService.getWorkspace().folders.map<TPromise<IFileStat>>((folder) => {
			return this.fileService.resolveFile(folder.toResource('.vscode/tasks.json')).then(stat => stat, () => undefined);
		});

		let createLabel = nls.localize('TaskService.createJsonFile', 'Create tasks.json file from template');
		let openLabel = nls.localize('TaskService.openJsonFile', 'Open tasks.json file');
		let entries = TPromise.join(stats).then((stats) => {
			return taskPromise.then((taskMap) => {
				type EntryType = (IPickOpenEntry & { task: Task; }) | (IPickOpenEntry & { folder: IWorkspaceFolder; });
				let entries: EntryType[] = [];
				if (this.contextService.getWorkbenchState() === WorkbenchState.FOLDER) {
					let tasks = taskMap.all();
					if (tasks.length > 0) {
						tasks = tasks.sort((a, b) => a._label.localeCompare(b._label));
						entries = tasks.map(task => { return { label: task._label, task }; });
					} else {
						let label = stats[0] !== void 0 ? openLabel : createLabel;
						entries.push({ label, folder: this.contextService.getWorkspace().folders[0] });
					}
				} else {
					let folders = this.contextService.getWorkspace().folders;
					let index = 0;
					for (let folder of folders) {
						let tasks = taskMap.get(folder);
						if (tasks.length > 0) {
							tasks = tasks.slice().sort((a, b) => a._label.localeCompare(b._label));
							for (let i = 0; i < tasks.length; i++) {
2210
								let entry: EntryType = { label: tasks[i]._label, task: tasks[i], description: folder.name };
2211 2212 2213 2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228
								if (i === 0) {
									entry.separator = { label: folder.name, border: index > 0 };
								}
								entries.push(entry);
							}
						} else {
							let label = stats[index] !== void 0 ? openLabel : createLabel;
							let entry: EntryType = { label, folder: folder };
							entry.separator = { label: folder.name, border: index > 0 };
							entries.push(entry);
						}
						index++;
					}
				}
				return entries;
			});
		});

D
Dirk Baeumer 已提交
2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240
		this.quickOpenService.pick(entries,
			{ placeHolder: nls.localize('TaskService.pickTask', 'Select a task to configure'), autoFocus: { autoFocusFirstEntry: true } }).
			then((selection) => {
				if (!selection) {
					return;
				}
				if (isTaskEntry(selection)) {
					configureTask(selection.task);
				} else {
					openTaskFile(selection.folder);
				}
			});
2241 2242
	}

2243 2244 2245 2246
	private runConfigureDefaultBuildTask(): void {
		if (!this.canRunCommand()) {
			return;
		}
D
Dirk Baeumer 已提交
2247
		if (this.schemaVersion === JsonSchemaVersion.V2_0_0) {
2248 2249
			this.tasks().then((tasks => {
				if (tasks.length === 0) {
2250
					this.runConfigureTasks();
2251 2252 2253
					return;
				}
				let defaultTask: Task;
2254
				let defaultEntry: TaskQuickPickEntry;
2255
				for (let task of tasks) {
2256
					if (task.group === TaskGroup.Build && task.groupType === GroupType.default) {
2257 2258 2259 2260 2261
						defaultTask = task;
						break;
					}
				}
				if (defaultTask) {
2262 2263 2264 2265 2266
					tasks = [];
					defaultEntry = {
						label: nls.localize('TaskService.defaultBuildTaskExists', '{0} is already marked as the default build task', Task.getQualifiedLabel(defaultTask)),
						task: defaultTask
					};
2267
				}
D
Dirk Baeumer 已提交
2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282
				this.showIgnoredFoldersMessage().then(() => {
					this.showQuickPick(tasks,
						nls.localize('TaskService.pickDefaultBuildTask', 'Select the task to be used as the default build task'), defaultEntry, true).
						then((task) => {
							if (task === void 0) {
								return;
							}
							if (task === defaultTask && CustomTask.is(task)) {
								this.openConfig(task);
							}
							if (!InMemoryTask.is(task)) {
								this.customize(task, { group: { kind: 'build', isDefault: true } }, true);
							}
						});
				});
2283 2284
			}));
		} else {
2285
			this.runConfigureTasks();
2286 2287 2288 2289 2290 2291 2292
		}
	}

	private runConfigureDefaultTestTask(): void {
		if (!this.canRunCommand()) {
			return;
		}
D
Dirk Baeumer 已提交
2293
		if (this.schemaVersion === JsonSchemaVersion.V2_0_0) {
2294 2295
			this.tasks().then((tasks => {
				if (tasks.length === 0) {
2296
					this.runConfigureTasks();
2297 2298 2299
				}
				let defaultTask: Task;
				for (let task of tasks) {
2300
					if (task.group === TaskGroup.Test && task.groupType === GroupType.default) {
2301 2302 2303 2304 2305
						defaultTask = task;
						break;
					}
				}
				if (defaultTask) {
2306
					this.messageService.show(Severity.Info, nls.localize('TaskService.defaultTestTaskExists', '{0} is already marked as the default test task.', Task.getQualifiedLabel(defaultTask)));
2307 2308
					return;
				}
D
Dirk Baeumer 已提交
2309 2310 2311 2312 2313 2314 2315 2316 2317
				this.showIgnoredFoldersMessage().then(() => {
					this.showQuickPick(tasks, nls.localize('TaskService.pickDefaultTestTask', 'Select the task to be used as the default test task'), undefined, true).then((task) => {
						if (!task) {
							return;
						}
						if (!InMemoryTask.is(task)) {
							this.customize(task, { group: { kind: 'test', isDefault: true } }, true);
						}
					});
2318 2319 2320
				});
			}));
		} else {
2321
			this.runConfigureTasks();
2322 2323
		}
	}
2324 2325 2326 2327 2328

	public runShowTasks(): void {
		if (!this.canRunCommand()) {
			return;
		}
2329 2330 2331 2332 2333 2334 2335 2336 2337 2338
		this.showQuickPick(this.getActiveTasks(),
			nls.localize('TaskService.pickShowTask', 'Select the task to show its output'),
			{
				label: nls.localize('TaskService.noTaskIsRunning', 'No task is running'),
				task: null
			},
			false, true
		).then((task) => {
			if (task === void 0 || task === null) {
				return;
2339
			}
2340
			this._taskSystem.revealTask(task);
2341 2342
		});
	}
E
Erich Gamma 已提交
2343 2344
}

2345
MenuRegistry.addCommand({ id: ConfigureTaskAction.ID, title: { value: ConfigureTaskAction.TEXT, original: 'Configure Task' }, category: { value: tasksCategory, original: 'Tasks' } });
2346 2347
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' } });
2348
MenuRegistry.addCommand({ id: 'workbench.action.tasks.restartTask', title: { value: nls.localize('RestartTaskAction.label', "Restart Running Task"), original: 'Restart Running Task' }, category: { value: tasksCategory, original: 'Tasks' } });
2349
MenuRegistry.addCommand({ id: 'workbench.action.tasks.showTasks', title: { value: nls.localize('ShowTasksAction.label', "Show Running Tasks"), original: 'Show Running Tasks' }, category: { value: tasksCategory, original: 'Tasks' } });
2350
MenuRegistry.addCommand({ id: 'workbench.action.tasks.terminate', title: { value: nls.localize('TerminateAction.label', "Terminate Task"), original: 'Terminate Task' }, category: { value: tasksCategory, original: 'Tasks' } });
2351 2352
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' } });
2353 2354
MenuRegistry.addCommand({ id: 'workbench.action.tasks.configureDefaultBuildTask', title: { value: nls.localize('ConfigureDefaultBuildTask.label', "Configure Default Build Task"), original: 'Configure Default Build Task' }, category: { value: tasksCategory, original: 'Tasks' } });
MenuRegistry.addCommand({ id: 'workbench.action.tasks.configureDefaultTestTask', title: { value: nls.localize('ConfigureDefaultTestTask.label', "Configure Default Test Task"), original: 'Configure Default Test Task' }, category: { value: tasksCategory, original: 'Tasks' } });
2355 2356
// 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 });
2357 2358 2359 2360 2361

// Task Service
registerSingleton(ITaskService, TaskService);

// Register Quick Open
2362
const quickOpenRegistry = (<IQuickOpenRegistry>Registry.as(QuickOpenExtensions.Quickopen));
2363
const tasksPickerContextKey = 'inTasksPicker';
2364 2365

quickOpenRegistry.registerQuickOpenHandler(
2366
	new QuickOpenHandlerDescriptor(
2367 2368
		QuickOpenHandler,
		QuickOpenHandler.ID,
2369
		'task ',
2370
		tasksPickerContextKey,
2371 2372 2373 2374
		nls.localize('quickOpen.task', "Run Task")
	)
);

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

2378 2379
// Status bar
let statusbarRegistry = <IStatusbarRegistry>Registry.as(StatusbarExtensions.Statusbar);
2380 2381
statusbarRegistry.registerStatusbarItem(new StatusbarItemDescriptor(BuildStatusBarItem, StatusbarAlignment.LEFT, 50 /* Medium Priority */));
statusbarRegistry.registerStatusbarItem(new StatusbarItemDescriptor(TaskStatusBarItem, StatusbarAlignment.LEFT, 50 /* Medium Priority */));
2382 2383 2384 2385 2386 2387 2388

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

// tasks.json validation
let schemaId = 'vscode://schemas/tasks';
D
Dirk Baeumer 已提交
2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399
let schema: IJSONSchema = {
	id: schemaId,
	description: 'Task definition file',
	type: 'object',
	default: {
		version: '0.1.0',
		command: 'myCommand',
		isShellCommand: false,
		args: [],
		showOutput: 'always',
		tasks: [
2400
			{
D
Dirk Baeumer 已提交
2401 2402 2403 2404
				taskName: 'build',
				showOutput: 'silent',
				isBuildCommand: true,
				problemMatcher: ['$tsc', '$lessCompile']
2405 2406
			}
		]
D
Dirk Baeumer 已提交
2407 2408 2409 2410 2411 2412 2413 2414 2415
	}
};

import schemaVersion1 from './jsonSchema_v1';
import schemaVersion2 from './jsonSchema_v2';
schema.definitions = {
	...schemaVersion1.definitions,
	...schemaVersion2.definitions,
};
2416
schema.oneOf = [...schemaVersion2.oneOf, ...schemaVersion1.oneOf];
D
Dirk Baeumer 已提交
2417 2418


2419
let jsonRegistry = <jsonContributionRegistry.IJSONContributionRegistry>Registry.as(jsonContributionRegistry.Extensions.JSONContribution);
J
Johannes Rieken 已提交
2420
jsonRegistry.registerSchema(schemaId, schema);