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

I
isidor 已提交
6
import { TPromise } from 'vs/base/common/winjs.base';
E
Erich Gamma 已提交
7 8
import nls = require('vs/nls');
import lifecycle = require('vs/base/common/lifecycle');
9
import Event, { Emitter } from 'vs/base/common/event';
E
Erich Gamma 已提交
10
import uuid = require('vs/base/common/uuid');
I
isidor 已提交
11
import objects = require('vs/base/common/objects');
E
Erich Gamma 已提交
12 13 14 15
import severity from 'vs/base/common/severity';
import types = require('vs/base/common/types');
import arrays = require('vs/base/common/arrays');
import debug = require('vs/workbench/parts/debug/common/debug');
I
isidor 已提交
16
import { Source } from 'vs/workbench/parts/debug/common/debugSource';
E
Erich Gamma 已提交
17

18
const MAX_REPL_LENGTH = 10000;
I
isidor 已提交
19
const UNKNOWN_SOURCE_LABEL = nls.localize('unknownSource', "Unknown Source");
20

E
Erich Gamma 已提交
21 22 23 24
function massageValue(value: string): string {
	return value ? value.replace(/\n/g, '\\n').replace(/\r/g, '\\r').replace(/\t/g, '\\t') : value;
}

I
isidor 已提交
25 26 27 28 29
export function evaluateExpression(session: debug.IRawDebugSession, stackFrame: debug.IStackFrame, expression: Expression, context: string): TPromise<Expression> {
	if (!session) {
		expression.value = context === 'repl' ? nls.localize('startDebugFirst', "Please start a debug session to evaluate") : Expression.DEFAULT_VALUE;
		expression.available = false;
		expression.reference = 0;
A
Alex Dima 已提交
30
		return TPromise.as(expression);
I
isidor 已提交
31 32 33 34 35 36 37
	}

	return session.evaluate({
		expression: expression.name,
		frameId: stackFrame ? stackFrame.frameId : undefined,
		context
	}).then(response => {
I
isidor 已提交
38 39 40 41
		expression.available = !!response.body;
		if (response.body) {
			expression.value = response.body.result;
			expression.reference = response.body.variablesReference;
I
isidor 已提交
42
			expression.childrenCount = response.body.totalCount;
I
isidor 已提交
43
		}
I
isidor 已提交
44 45 46 47 48 49 50 51 52 53 54

		return expression;
	}, err => {
		expression.value = err.message;
		expression.available = false;
		expression.reference = 0;

		return expression;
	});
}

I
isidor 已提交
55 56
const notPropertySyntax = /^[a-zA-Z_][a-zA-Z0-9_]*$/;
const arrayElementSyntax = /\[.*\]$/;
I
isidor 已提交
57

58 59 60
export function getFullExpressionName(expression: debug.IExpression, sessionType: string): string {
	let names = [expression.name];
	if (expression instanceof Variable) {
I
isidor 已提交
61
		let v = (<Variable> expression).parent;
62 63 64 65 66 67 68 69 70 71 72
		while (v instanceof Variable || v instanceof Expression) {
			names.push((<Variable> v).name);
			v = (<Variable> v).parent;
		}
	}
	names = names.reverse();

	let result = null;
	names.forEach(name => {
		if (!result) {
			result = name;
I
isidor 已提交
73
		} else if (arrayElementSyntax.test(name) || (sessionType === 'node' && !notPropertySyntax.test(name))) {
I
isidor 已提交
74
			// use safe way to access node properties a['property_name']. Also handles array elements.
75 76 77 78 79 80 81 82 83
			result = name && name.indexOf('[') === 0 ? `${ result }${ name }` : `${ result }['${ name }']`;
		} else {
			result = `${ result }.${ name }`;
		}
	});

	return result;
}

E
Erich Gamma 已提交
84
export class Thread implements debug.IThread {
85 86
	private promisedCallStack: TPromise<debug.IStackFrame[]>;
	private cachedCallStack: debug.IStackFrame[];
I
isidor 已提交
87
	public stoppedDetails: debug.IRawStoppedDetails;
88
	public stopped: boolean;
E
Erich Gamma 已提交
89

I
isidor 已提交
90
	constructor(public name: string, public threadId: number) {
91
		this.promisedCallStack = undefined;
I
isidor 已提交
92
		this.stoppedDetails = undefined;
93 94
		this.cachedCallStack = undefined;
		this.stopped = false;
E
Erich Gamma 已提交
95 96 97 98 99
	}

	public getId(): string {
		return `thread:${ this.name }:${ this.threadId }`;
	}
100 101 102 103 104 105 106 107 108 109

	public clearCallStack(): void {
		this.promisedCallStack = undefined;
		this.cachedCallStack = undefined;
	}

	public getCachedCallStack(): debug.IStackFrame[] {
		return this.cachedCallStack;
	}

I
isidor 已提交
110
	public getCallStack(debugService: debug.IDebugService, getAdditionalStackFrames = false): TPromise<debug.IStackFrame[]> {
111 112 113
		if (!this.stopped) {
			return TPromise.as([]);
		}
I
isidor 已提交
114

115
		if (!this.promisedCallStack) {
I
isidor 已提交
116 117 118 119 120 121 122 123 124
			this.promisedCallStack = this.getCallStackImpl(debugService, 0).then(callStack => {
				this.cachedCallStack = callStack;
				return callStack;
			});
		} else if (getAdditionalStackFrames) {
			this.promisedCallStack = this.promisedCallStack.then(callStackFirstPart => this.getCallStackImpl(debugService, callStackFirstPart.length).then(callStackSecondPart => {
				this.cachedCallStack = callStackFirstPart.concat(callStackSecondPart);
				return this.cachedCallStack;
			}));
125 126 127 128 129
		}

		return this.promisedCallStack;
	}

I
isidor 已提交
130
	private getCallStackImpl(debugService: debug.IDebugService, startFrame: number): TPromise<debug.IStackFrame[]> {
131
		let session = debugService.getActiveSession();
I
isidor 已提交
132
		return session.stackTrace({ threadId: this.threadId, startFrame, levels: 20 }).then(response => {
133
			this.stoppedDetails.totalFrames = response.body.totalFrames;
134 135
			return response.body.stackFrames.map((rsf, level) => {
				if (!rsf) {
I
isidor 已提交
136
					return new StackFrame(this.threadId, 0, new Source({ name: UNKNOWN_SOURCE_LABEL }, false), nls.localize('unknownStack', "Unknown stack location"), undefined, undefined);
137 138
				}

I
isidor 已提交
139
				return new StackFrame(this.threadId, rsf.id, rsf.source ? new Source(rsf.source) : new Source({ name: UNKNOWN_SOURCE_LABEL }, false), rsf.name, rsf.line, rsf.column);
140
			});
141 142 143
		}, (err: Error) => {
			this.stoppedDetails.framesErrorMessage = err.message;
			return [];
144 145
		});
	}
E
Erich Gamma 已提交
146 147 148
}

export class OutputElement implements debug.ITreeElement {
149
	private static ID_COUNTER = 0;
E
Erich Gamma 已提交
150

151
	constructor(private id = OutputElement.ID_COUNTER++) {
I
isidor 已提交
152
		// noop
E
Erich Gamma 已提交
153 154 155
	}

	public getId(): string {
I
isidor 已提交
156
		return `outputelement:${ this.id }`;
E
Erich Gamma 已提交
157 158 159 160 161
	}
}

export class ValueOutputElement extends OutputElement {

I
isidor 已提交
162 163
	constructor(public value: string, public severity: severity, public category?: string, public counter:number = 1) {
		super();
E
Erich Gamma 已提交
164 165 166 167 168 169 170 171 172 173
	}
}

export class KeyValueOutputElement extends OutputElement {

	private static MAX_CHILDREN = 1000; // upper bound of children per value

	private children: debug.ITreeElement[];
	private _valueName: string;

I
isidor 已提交
174 175
	constructor(public key: string, public valueObj: any, public annotation?: string) {
		super();
E
Erich Gamma 已提交
176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204

		this._valueName = null;
	}

	public get value(): string {
		if (this._valueName === null) {
			if (this.valueObj === null) {
				this._valueName = 'null';
			} else if (Array.isArray(this.valueObj)) {
				this._valueName = `Array[${this.valueObj.length}]`;
			} else if (types.isObject(this.valueObj)) {
				this._valueName = 'Object';
			} else if (types.isString(this.valueObj)) {
				this._valueName = `"${massageValue(this.valueObj)}"`;
			} else {
				this._valueName = String(this.valueObj);
			}

			if (!this._valueName) {
				this._valueName = '';
			}
		}

		return this._valueName;
	}

	public getChildren(): debug.ITreeElement[] {
		if (!this.children) {
			if (Array.isArray(this.valueObj)) {
I
isidor 已提交
205
				this.children = (<any[]>this.valueObj).slice(0, KeyValueOutputElement.MAX_CHILDREN).map((v, index) => new KeyValueOutputElement(String(index), v, null));
E
Erich Gamma 已提交
206
			} else if (types.isObject(this.valueObj)) {
I
isidor 已提交
207
				this.children = Object.getOwnPropertyNames(this.valueObj).slice(0, KeyValueOutputElement.MAX_CHILDREN).map(key => new KeyValueOutputElement(key, this.valueObj[key], null));
E
Erich Gamma 已提交
208 209 210 211 212 213 214 215 216
			} else {
				this.children = [];
			}
		}

		return this.children;
	}
}

217
export abstract class ExpressionContainer implements debug.IExpressionContainer {
E
Erich Gamma 已提交
218

219
	public static allValues: { [id: string]: string } = {};
I
isidor 已提交
220 221 222 223 224
	// Use chunks to support variable paging #9537
	private static CHUNK_SIZE = 100;

	public valueChanged: boolean;
	private children: TPromise<debug.IExpression[]>;
225
	private _value: string;
E
Erich Gamma 已提交
226

I
isidor 已提交
227 228
	constructor(public reference: number, private id: string, private cacheChildren: boolean, public childrenCount: number, private chunkIndex = 0) {
		// noop
E
Erich Gamma 已提交
229 230 231
	}

	public getChildren(debugService: debug.IDebugService): TPromise<debug.IExpression[]> {
I
isidor 已提交
232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258
		if (!this.cacheChildren || !this.children) {
			const session = debugService.getActiveSession();
			// only variables with reference > 0 have children.
			if (!session || this.reference <= 0) {
				this.children = TPromise.as([]);
			} else {
				if (this.childrenCount > ExpressionContainer.CHUNK_SIZE) {
					// There are a lot of children, create fake intermediate values that represent chunks #9537
					const chunks = [];
					const numberOfChunks = this.childrenCount / ExpressionContainer.CHUNK_SIZE;
					for (let i = 0; i < numberOfChunks; i++) {
						const chunkName = `${i * ExpressionContainer.CHUNK_SIZE}..${(i + 1) * ExpressionContainer.CHUNK_SIZE - 1}`;
						chunks.push(new Variable(this, this.reference, chunkName, '', ExpressionContainer.CHUNK_SIZE, null, true, i));
					}
					this.children = TPromise.as(chunks);
				} else {
					this.children = session.variables({
						variablesReference: this.reference,
						start: this.chunkIndex * ExpressionContainer.CHUNK_SIZE,
						count: ExpressionContainer.CHUNK_SIZE
					}).then(response => {
						return arrays.distinct(response.body.variables.filter(v => !!v), v => v.name).map(
							v => new Variable(this, v.variablesReference, v.name, v.value, v.totalCount, v.type)
						);
					}, (e: Error) => [new Variable(this, 0, null, e.message, 0, null, false)]);
				}
			}
E
Erich Gamma 已提交
259 260 261 262
		}

		return this.children;
	}
263 264 265 266 267

	public getId(): string {
		return this.id;
	}

268 269 270 271 272 273 274 275 276 277
	public get value(): string {
		return this._value;
	}

	public set value(value: string) {
		this._value = massageValue(value);
		this.valueChanged = ExpressionContainer.allValues[this.getId()] &&
			ExpressionContainer.allValues[this.getId()] !== Expression.DEFAULT_VALUE && ExpressionContainer.allValues[this.getId()] !== value;
		ExpressionContainer.allValues[this.getId()] = value;
	}
E
Erich Gamma 已提交
278 279
}

280 281
export class Expression extends ExpressionContainer implements debug.IExpression {
	static DEFAULT_VALUE = 'not available';
E
Erich Gamma 已提交
282

283
	public available: boolean;
E
Erich Gamma 已提交
284

285
	constructor(public name: string, cacheChildren: boolean, id = uuid.generateUuid()) {
I
isidor 已提交
286
		super(0, id, cacheChildren, 0);
287 288
		this.value = Expression.DEFAULT_VALUE;
		this.available = false;
E
Erich Gamma 已提交
289
	}
290
}
E
Erich Gamma 已提交
291

292 293
export class Variable extends ExpressionContainer implements debug.IExpression {

294 295 296
	// Used to show the error message coming from the adapter when setting the value #7807
	public errorMessage: string;

I
isidor 已提交
297 298
	constructor(public parent: debug.IExpressionContainer, reference: number, public name: string, value: string, childrenCount: number, public type: string = null, public available = true, chunkIndex = 0) {
		super(reference, `variable:${ parent.getId() }:${ name }`, true, childrenCount, chunkIndex);
299
		this.value = massageValue(value);
E
Erich Gamma 已提交
300 301 302
	}
}

303
export class Scope extends ExpressionContainer implements debug.IScope {
E
Erich Gamma 已提交
304

I
isidor 已提交
305 306
	constructor(private threadId: number, public name: string, reference: number, public expensive: boolean, childrenCount: number) {
		super(reference, `scope:${threadId}:${name}:${reference}`, true, childrenCount);
E
Erich Gamma 已提交
307 308 309 310 311 312 313
	}
}

export class StackFrame implements debug.IStackFrame {

	private scopes: TPromise<Scope[]>;

I
isidor 已提交
314
	constructor(public threadId: number, public frameId: number, public source: Source, public name: string, public lineNumber: number, public column: number) {
E
Erich Gamma 已提交
315 316 317 318
		this.scopes = null;
	}

	public getId(): string {
319
		return `stackframe:${ this.threadId }:${ this.frameId }`;
E
Erich Gamma 已提交
320 321 322 323 324
	}

	public getScopes(debugService: debug.IDebugService): TPromise<debug.IScope[]> {
		if (!this.scopes) {
			this.scopes = debugService.getActiveSession().scopes({ frameId: this.frameId }).then(response => {
I
isidor 已提交
325
				return response.body.scopes.map(rs => new Scope(this.threadId, rs.name, rs.variablesReference, rs.expensive, rs.totalCount));
326
			}, err => []);
E
Erich Gamma 已提交
327 328 329 330 331 332 333 334 335
		}

		return this.scopes;
	}
}

export class Breakpoint implements debug.IBreakpoint {

	public lineNumber: number;
336
	public verified: boolean;
337
	public idFromAdapter: number;
I
isidor 已提交
338
	public message: string;
E
Erich Gamma 已提交
339 340
	private id: string;

I
isidor 已提交
341
	constructor(public source: Source, public desiredLineNumber: number, public enabled: boolean, public condition: string) {
342 343 344
		if (enabled === undefined) {
			this.enabled = true;
		}
E
Erich Gamma 已提交
345
		this.lineNumber = this.desiredLineNumber;
346
		this.verified = false;
E
Erich Gamma 已提交
347 348 349 350 351 352 353 354
		this.id = uuid.generateUuid();
	}

	public getId(): string {
		return this.id;
	}
}

I
isidor 已提交
355 356 357
export class FunctionBreakpoint implements debug.IFunctionBreakpoint {

	private id: string;
I
isidor 已提交
358
	public verified: boolean;
359
	public idFromAdapter: number;
I
isidor 已提交
360

361
	constructor(public name: string, public enabled: boolean) {
I
isidor 已提交
362
		this.verified = false;
I
isidor 已提交
363 364 365 366 367 368 369 370
		this.id = uuid.generateUuid();
	}

	public getId(): string {
		return this.id;
	}
}

E
Erich Gamma 已提交
371 372 373 374
export class ExceptionBreakpoint implements debug.IExceptionBreakpoint {

	private id: string;

375
	constructor(public filter: string, public label: string, public enabled: boolean) {
E
Erich Gamma 已提交
376 377 378 379 380 381 382 383
		this.id = uuid.generateUuid();
	}

	public getId(): string {
		return this.id;
	}
}

384
export class Model implements debug.IModel {
E
Erich Gamma 已提交
385 386 387 388

	private threads: { [reference: number]: debug.IThread; };
	private toDispose: lifecycle.IDisposable[];
	private replElements: debug.ITreeElement[];
389 390 391 392
	private _onDidChangeBreakpoints: Emitter<void>;
	private _onDidChangeCallStack: Emitter<void>;
	private _onDidChangeWatchExpressions: Emitter<debug.IExpression>;
	private _onDidChangeREPLElements: Emitter<void>;
E
Erich Gamma 已提交
393

I
isidor 已提交
394
	constructor(private breakpoints: debug.IBreakpoint[], private breakpointsActivated: boolean, private functionBreakpoints: debug.IFunctionBreakpoint[],
E
Erich Gamma 已提交
395 396 397 398 399
		private exceptionBreakpoints: debug.IExceptionBreakpoint[], private watchExpressions: Expression[]) {

		this.threads = {};
		this.replElements = [];
		this.toDispose = [];
400 401 402 403
		this._onDidChangeBreakpoints = new Emitter<void>();
		this._onDidChangeCallStack = new Emitter<void>();
		this._onDidChangeWatchExpressions = new Emitter<debug.IExpression>();
		this._onDidChangeREPLElements = new Emitter<void>();
E
Erich Gamma 已提交
404 405 406 407 408 409
	}

	public getId(): string {
		return 'root';
	}

410 411 412 413 414 415 416 417 418 419 420 421
	public get onDidChangeBreakpoints(): Event<void> {
		return this._onDidChangeBreakpoints.event;
	}

	public get onDidChangeCallStack(): Event<void> {
		return this._onDidChangeCallStack.event;
	}

	public get onDidChangeWatchExpressions(): Event<debug.IExpression> {
		return this._onDidChangeWatchExpressions.event;
	}

422
	public get onDidChangeReplElements(): Event<void> {
423 424 425
		return this._onDidChangeREPLElements.event;
	}

E
Erich Gamma 已提交
426 427 428 429 430 431
	public getThreads(): { [reference: number]: debug.IThread; } {
		return this.threads;
	}

	public clearThreads(removeThreads: boolean, reference: number = undefined): void {
		if (reference) {
432 433 434 435
			if (this.threads[reference]) {
				this.threads[reference].clearCallStack();
				this.threads[reference].stoppedDetails = undefined;
				this.threads[reference].stopped = false;
I
isidor 已提交
436

437 438 439
				if (removeThreads) {
					delete this.threads[reference];
				}
E
Erich Gamma 已提交
440 441
			}
		} else {
I
isidor 已提交
442 443 444
			Object.keys(this.threads).forEach(ref => {
				this.threads[ref].clearCallStack();
				this.threads[ref].stoppedDetails = undefined;
445
				this.threads[ref].stopped = false;
I
isidor 已提交
446 447
			});

E
Erich Gamma 已提交
448 449
			if (removeThreads) {
				this.threads = {};
450
				ExpressionContainer.allValues = {};
E
Erich Gamma 已提交
451 452 453
			}
		}

454
		this._onDidChangeCallStack.fire();
E
Erich Gamma 已提交
455 456 457 458 459 460
	}

	public getBreakpoints(): debug.IBreakpoint[] {
		return this.breakpoints;
	}

I
isidor 已提交
461 462 463 464
	public getFunctionBreakpoints(): debug.IFunctionBreakpoint[] {
		return this.functionBreakpoints;
	}

E
Erich Gamma 已提交
465 466 467 468
	public getExceptionBreakpoints(): debug.IExceptionBreakpoint[] {
		return this.exceptionBreakpoints;
	}

469
	public setExceptionBreakpoints(data: DebugProtocol.ExceptionBreakpointsFilter[]): void {
470
		if (data) {
471 472 473 474
			this.exceptionBreakpoints = data.map(d => {
				const ebp = this.exceptionBreakpoints.filter(ebp => ebp.filter === d.filter).pop();
				return new ExceptionBreakpoint(d.filter, d.label, ebp ? ebp.enabled : d.default);
			});
475 476 477
		}
	}

E
Erich Gamma 已提交
478 479 480 481
	public areBreakpointsActivated(): boolean {
		return this.breakpointsActivated;
	}

482 483
	public setBreakpointsActivated(activated: boolean): void {
		this.breakpointsActivated = activated;
484
		this._onDidChangeBreakpoints.fire();
E
Erich Gamma 已提交
485 486
	}

487
	public addBreakpoints(rawData: debug.IRawBreakpoint[]): void {
488 489
		this.breakpoints = this.breakpoints.concat(rawData.map(rawBp =>
			new Breakpoint(new Source(Source.toRawSource(rawBp.uri, this)), rawBp.lineNumber, rawBp.enabled, rawBp.condition)));
490
		this.breakpointsActivated = true;
491
		this._onDidChangeBreakpoints.fire();
492
	}
E
Erich Gamma 已提交
493

494 495
	public removeBreakpoints(toRemove: debug.IBreakpoint[]): void {
		this.breakpoints = this.breakpoints.filter(bp => !toRemove.some(toRemove => toRemove.getId() === bp.getId()));
496
		this._onDidChangeBreakpoints.fire();
E
Erich Gamma 已提交
497 498
	}

I
isidor 已提交
499
	public updateBreakpoints(data: { [id: string]: DebugProtocol.Breakpoint }): void {
500 501 502
		this.breakpoints.forEach(bp => {
			const bpData = data[bp.getId()];
			if (bpData) {
503
				bp.lineNumber = bpData.line ? bpData.line : bp.lineNumber;
504
				bp.verified = bpData.verified;
505
				bp.idFromAdapter = bpData.id;
I
isidor 已提交
506
				bp.message = bpData.message;
507 508
			}
		});
509
		this._onDidChangeBreakpoints.fire();
510 511
	}

512 513
	public setEnablement(element: debug.IEnablement, enable: boolean): void {
		element.enabled = enable;
E
Erich Gamma 已提交
514 515 516
		if (element instanceof Breakpoint && !element.enabled) {
			var breakpoint = <Breakpoint> element;
			breakpoint.lineNumber = breakpoint.desiredLineNumber;
517
			breakpoint.verified = false;
E
Erich Gamma 已提交
518 519
		}

520
		this._onDidChangeBreakpoints.fire();
E
Erich Gamma 已提交
521 522
	}

523
	public enableOrDisableAllBreakpoints(enable: boolean): void {
E
Erich Gamma 已提交
524
		this.breakpoints.forEach(bp => {
525 526
			bp.enabled = enable;
			if (!enable) {
E
Erich Gamma 已提交
527
				bp.lineNumber = bp.desiredLineNumber;
528
				bp.verified = false;
E
Erich Gamma 已提交
529 530
			}
		});
531 532
		this.exceptionBreakpoints.forEach(ebp => ebp.enabled = enable);
		this.functionBreakpoints.forEach(fbp => fbp.enabled = enable);
E
Erich Gamma 已提交
533

534
		this._onDidChangeBreakpoints.fire();
E
Erich Gamma 已提交
535 536
	}

I
isidor 已提交
537 538
	public addFunctionBreakpoint(functionName: string): void {
		this.functionBreakpoints.push(new FunctionBreakpoint(functionName, true));
539
		this._onDidChangeBreakpoints.fire();
I
isidor 已提交
540 541
	}

542
	public updateFunctionBreakpoints(data: { [id: string]: { name?: string, verified?: boolean; id?: number } }): void {
I
isidor 已提交
543 544 545 546 547
		this.functionBreakpoints.forEach(fbp => {
			const fbpData = data[fbp.getId()];
			if (fbpData) {
				fbp.name = fbpData.name || fbp.name;
				fbp.verified = fbpData.verified;
548
				fbp.idFromAdapter = fbpData.id;
I
isidor 已提交
549 550 551
			}
		});

552
		this._onDidChangeBreakpoints.fire();
I
isidor 已提交
553 554
	}

555
	public removeFunctionBreakpoints(id?: string): void {
I
isidor 已提交
556
		this.functionBreakpoints = id ? this.functionBreakpoints.filter(fbp => fbp.getId() !== id) : [];
557
		this._onDidChangeBreakpoints.fire();
558 559
	}

E
Erich Gamma 已提交
560 561 562 563
	public getReplElements(): debug.ITreeElement[] {
		return this.replElements;
	}

I
isidor 已提交
564
	public addReplExpression(session: debug.IRawDebugSession, stackFrame: debug.IStackFrame, name: string): TPromise<void> {
I
isidor 已提交
565
		const expression = new Expression(name, true);
566
		this.addReplElements([expression]);
567 568
		return evaluateExpression(session, stackFrame, expression, 'repl')
			.then(() => this._onDidChangeREPLElements.fire());
E
Erich Gamma 已提交
569 570
	}

571
	public logToRepl(value: string | { [key: string]: any }, severity?: severity): void {
E
Erich Gamma 已提交
572 573 574
		let elements:OutputElement[] = [];
		let previousOutput = this.replElements.length && (<ValueOutputElement>this.replElements[this.replElements.length - 1]);

I
isidor 已提交
575
		// string message
E
Erich Gamma 已提交
576 577 578 579
		if (typeof value === 'string') {
			if (value && value.trim() && previousOutput && previousOutput.value === value && previousOutput.severity === severity) {
				previousOutput.counter++; // we got the same output (but not an empty string when trimmed) so we just increment the counter
			} else {
I
isidor 已提交
580
				let lines = value.trim().split('\n');
E
Erich Gamma 已提交
581
				lines.forEach((line, index) => {
I
isidor 已提交
582
					elements.push(new ValueOutputElement(line, severity));
E
Erich Gamma 已提交
583 584 585 586
				});
			}
		}

I
isidor 已提交
587
		// key-value output
E
Erich Gamma 已提交
588
		else {
589
			elements.push(new KeyValueOutputElement((<any>value).prototype, value, nls.localize('snapshotObj', "Only primitive values are shown for this object.")));
E
Erich Gamma 已提交
590 591 592
		}

		if (elements.length) {
593
			this.addReplElements(elements);
E
Erich Gamma 已提交
594
		}
I
isidor 已提交
595
		this._onDidChangeREPLElements.fire();
E
Erich Gamma 已提交
596 597 598
	}

	public appendReplOutput(value: string, severity?: severity): void {
I
isidor 已提交
599
		const elements: OutputElement[] = [];
E
Erich Gamma 已提交
600
		let previousOutput = this.replElements.length && (<ValueOutputElement>this.replElements[this.replElements.length - 1]);
601 602
		let lines = value.split('\n');
		let groupTogether = !!previousOutput && (previousOutput.category === 'output' && severity === previousOutput.severity);
E
Erich Gamma 已提交
603 604

		if (groupTogether) {
605 606 607 608 609
			// append to previous line if same group
			previousOutput.value += lines.shift();
		} else if (previousOutput && previousOutput.value === '') {
			// remove potential empty lines between different output types
			this.replElements.pop();
E
Erich Gamma 已提交
610 611 612 613
		}

		// fill in lines as output value elements
		lines.forEach((line, index) => {
I
isidor 已提交
614
			elements.push(new ValueOutputElement(line, severity, 'output'));
E
Erich Gamma 已提交
615 616
		});

617
		this.addReplElements(elements);
618
		this._onDidChangeREPLElements.fire();
E
Erich Gamma 已提交
619 620
	}

621 622 623 624 625 626 627
	private addReplElements(newElements: debug.ITreeElement[]): void {
		this.replElements.push(...newElements);
		if (this.replElements.length > MAX_REPL_LENGTH) {
			this.replElements.splice(0, this.replElements.length - MAX_REPL_LENGTH);
		}
	}

628
	public removeReplExpressions(): void {
629 630
		if (this.replElements.length > 0) {
			this.replElements = [];
631
			this._onDidChangeREPLElements.fire();
632
		}
E
Erich Gamma 已提交
633 634 635 636 637 638
	}

	public getWatchExpressions(): Expression[] {
		return this.watchExpressions;
	}

I
isidor 已提交
639
	public addWatchExpression(session: debug.IRawDebugSession, stackFrame: debug.IStackFrame, name: string): TPromise<void> {
I
isidor 已提交
640
		const we = new Expression(name, false);
E
Erich Gamma 已提交
641 642
		this.watchExpressions.push(we);
		if (!name) {
643
			this._onDidChangeWatchExpressions.fire(we);
A
Alex Dima 已提交
644
			return TPromise.as(null);
E
Erich Gamma 已提交
645 646 647 648 649
		}

		return this.evaluateWatchExpressions(session, stackFrame, we.getId());
	}

I
isidor 已提交
650
	public renameWatchExpression(session: debug.IRawDebugSession, stackFrame: debug.IStackFrame, id: string, newName: string): TPromise<void> {
I
isidor 已提交
651
		const filtered = this.watchExpressions.filter(we => we.getId() === id);
E
Erich Gamma 已提交
652 653
		if (filtered.length === 1) {
			filtered[0].name = newName;
I
isidor 已提交
654
			return evaluateExpression(session, stackFrame, filtered[0], 'watch').then(() => {
655
				this._onDidChangeWatchExpressions.fire(filtered[0]);
E
Erich Gamma 已提交
656 657 658
			});
		}

A
Alex Dima 已提交
659
		return TPromise.as(null);
E
Erich Gamma 已提交
660 661
	}

I
isidor 已提交
662
	public evaluateWatchExpressions(session: debug.IRawDebugSession, stackFrame: debug.IStackFrame, id: string = null): TPromise<void> {
E
Erich Gamma 已提交
663
		if (id) {
I
isidor 已提交
664
			const filtered = this.watchExpressions.filter(we => we.getId() === id);
E
Erich Gamma 已提交
665
			if (filtered.length !== 1) {
A
Alex Dima 已提交
666
				return TPromise.as(null);
E
Erich Gamma 已提交
667 668
			}

I
isidor 已提交
669
			return evaluateExpression(session, stackFrame, filtered[0], 'watch').then(() => {
670
				this._onDidChangeWatchExpressions.fire(filtered[0]);
E
Erich Gamma 已提交
671 672 673
			});
		}

I
isidor 已提交
674
		return TPromise.join(this.watchExpressions.map(we => evaluateExpression(session, stackFrame, we, 'watch'))).then(() => {
675
			this._onDidChangeWatchExpressions.fire();
E
Erich Gamma 已提交
676 677 678 679 680 681 682 683 684 685
		});
	}

	public clearWatchExpressionValues(): void {
		this.watchExpressions.forEach(we => {
			we.value = Expression.DEFAULT_VALUE;
			we.available = false;
			we.reference = 0;
		});

686
		this._onDidChangeWatchExpressions.fire();
E
Erich Gamma 已提交
687 688
	}

689
	public removeWatchExpressions(id: string = null): void {
690
		this.watchExpressions = id ? this.watchExpressions.filter(we => we.getId() !== id) : [];
691
		this._onDidChangeWatchExpressions.fire();
E
Erich Gamma 已提交
692 693
	}

I
isidor 已提交
694
	public sourceIsUnavailable(source: Source): void {
695
		Object.keys(this.threads).forEach(key => {
696 697 698 699 700 701 702
			if (this.threads[key].getCachedCallStack()) {
				this.threads[key].getCachedCallStack().forEach(stackFrame => {
					if (stackFrame.source.uri.toString() === source.uri.toString()) {
						stackFrame.source.available = false;
					}
				});
			}
703 704
		});

705
		this._onDidChangeCallStack.fire();
E
Erich Gamma 已提交
706 707 708
	}

	public rawUpdate(data: debug.IRawModelUpdate): void {
I
isidor 已提交
709 710
		if (data.thread && !this.threads[data.threadId]) {
			// A new thread came in, initialize it.
711
			this.threads[data.threadId] = new Thread(data.thread.name, data.thread.id);
E
Erich Gamma 已提交
712 713
		}

714 715 716
		if (data.stoppedDetails) {
			// Set the availability of the threads' callstacks depending on
			// whether the thread is stopped or not
I
isidor 已提交
717 718 719 720 721
			if (data.allThreadsStopped) {
				Object.keys(this.threads).forEach(ref => {
					// Only update the details if all the threads are stopped
					// because we don't want to overwrite the details of other
					// threads that have stopped for a different reason
I
isidor 已提交
722
					this.threads[ref].stoppedDetails = objects.clone(data.stoppedDetails);
I
isidor 已提交
723
					this.threads[ref].stopped = true;
724
					this.threads[ref].clearCallStack();
I
isidor 已提交
725 726 727 728 729 730
				});
			} else {
				// One thread is stopped, only update that thread.
				this.threads[data.threadId].stoppedDetails = data.stoppedDetails;
				this.threads[data.threadId].clearCallStack();
				this.threads[data.threadId].stopped = true;
731
			}
E
Erich Gamma 已提交
732 733
		}

734
		this._onDidChangeCallStack.fire();
E
Erich Gamma 已提交
735 736 737 738 739 740
	}

	public dispose(): void {
		this.threads = null;
		this.breakpoints = null;
		this.exceptionBreakpoints = null;
I
isidor 已提交
741
		this.functionBreakpoints = null;
E
Erich Gamma 已提交
742 743
		this.watchExpressions = null;
		this.replElements = null;
J
Joao Moreno 已提交
744
		this.toDispose = lifecycle.dispose(this.toDispose);
E
Erich Gamma 已提交
745 746
	}
}