Function initDebugger

src/debug/dart_debug_impl.ts:231–367

(uri: string)

	}

	protected async initDebugger(uri: string): Promise<void> {
		// On some cloud providers we get an IPv6 loopback which fails to connect
		// correctly. Assume that if we get this, it's safe to use the "localhost" hostname.
		uri = uri.replace("[::]", "localhost");
		this.log(`Initialising debugger for ${uri}`);
		// Send the uri back to the editor so it can be used to launch browsers etc.
		let browserFriendlyUri = uri;
		if (browserFriendlyUri.endsWith("/ws"))
			browserFriendlyUri = uri.substring(0, uri.length - 2);
		if (browserFriendlyUri.startsWith("ws:"))
			browserFriendlyUri = "http:" + browserFriendlyUri.substring(3);

		let vmServiceUri = uri;
		if (vmServiceUri.startsWith("http:"))
			vmServiceUri = "ws:" + browserFriendlyUri.substring(5);

		const evt = new Event("dart.debuggerUris", {
			vmServiceUri: vmServiceUri.toString(),
		});
		this.sendEvent(evt);

		if (!this.shouldConnectDebugger)
			return;

		this.debuggerInit = new Promise<void>((resolve, reject) => {
			this.log(`Connecting to VM Service at ${uri}`);
			this.logToUser(`Connecting to VM Service at ${uri}\n`);
			this.vmService = new VmServiceConnection(uri);
			this.vmService.onLogging((message) => this.log(message));
			// TODO: Extract some code here and change to async/await. This is
			// super confusing, for ex. it's not clear the resolve() inside onOpen
			// fires immediately opon opening, not when all the code in the getVM
			// callback fires (so it may as well have come first - unless it's
			// a bug/race and it was supposed to be after all the setup!).
			this.vmService.onOpen(async () => {
				if (!this.vmService)
					return;

				// Read the version to update capabilities before doing anything else.
				await this.vmService.getVersion().then(async (versionResult) => {
					const version: Version = versionResult.result as Version;
					this.vmServiceCapabilities.version = `${version.major}.${version.minor}.0`;

					if (!this.vmService)
						return;

					// Subscribe to streams before we get a list of active isolates, otherwise we could have a race
					// between getting the list and then starting to listen for events.
					await this.subscribeToStreams();

					await this.vmService.getVM().then(async (vmResult): Promise<void> => {
						if (!this.vmService)
							return;
						const vm: VM = vmResult.result as VM;

						// If we own this process (we launched it, didn't attach) and the PID we get from the VM service is different, then
						// we should keep a ref to this process to terminate when we quit. This avoids issues where our process is a shell
						// (we use shell execute to fix issues on Windows) and the kill signal isn't passed on correctly.