Class FlutterDeviceManager

src/shared/vscode/device_manager.ts:16–806

import { Context } from "./workspace";

export class FlutterDeviceManager implements IAmDisposable {
	private readonly unresponsiveTimeoutPeriodSeconds = 5;
	private subscriptions: IAmDisposable[] = [];
	private statusBarItem: vs.StatusBarItem;
	public currentDevice?: f.Device;
	private devices: f.Device[] = [];
	private emulators: Emulator[] = [];
	private readonly knownEmulatorNames: Record<string, string> = {};
	protected readonly onCurrentDeviceChangedEmitter = new vs.EventEmitter<f.Device | undefined>();
	public readonly onCurrentDeviceChanged = this.onCurrentDeviceChangedEmitter.event;
	protected readonly onDevicesChangedEmitter = new vs.EventEmitter<void>();
	public readonly onDevicesChanged = this.onDevicesChangedEmitter.event;
	protected readonly onDeviceAddedEmitter = new vs.EventEmitter<f.Device>();
	public readonly onDeviceAdded = this.onDeviceAddedEmitter.event;
	protected readonly onDeviceRemovedEmitter = new vs.EventEmitter<string>();
	public readonly onDeviceRemoved = this.onDeviceRemovedEmitter.event;
	protected readonly onDeviceChangedEmitter = new vs.EventEmitter<f.Device>();
	public readonly onDeviceChanged = this.onDeviceChangedEmitter.event;

	constructor(
		private readonly logger: Logger,
		private daemon: IFlutterDaemon,
		private readonly config: { flutterCustomEmulators: CustomEmulatorDefinition[], flutterRememberSelectedDevice: boolean, flutterSelectDeviceWhenConnected: boolean, flutterShowEmulators: "local" | "always" | "never", projectSearchDepth: number },
		private readonly workspaceContext: WorkspaceContext,
		private readonly extContext: Context,
		runIfNoDevices?: () => void,
		readonly daemonPortOverride?: number
	) {
		this.statusBarItem = vs.window.createStatusBarItem("dartStatusFlutterDevice", vs.StatusBarAlignment.Right, 1);
		this.statusBarItem.name = "Flutter Device";
		this.statusBarItem.tooltip = "Flutter";
		this.statusBarItem.command = "flutter.selectDevice";
		this.statusBarItem.show();
		void this.updateStatusBar();

		// Force a request for emulators to stash their names, so we can display
		// the better name if the automatically-selected device happens to be an
		// emulator.
		this.getEmulators().then(() => this.updateStatusBar()).catch((e) => this.logger.error(e));

		this.subscriptions.push(this.statusBarItem);

		daemon.registerForDeviceAdded(this.deviceAdded.bind(this));
		daemon.registerForDeviceRemoved(this.deviceRemoved.bind(this));
		if (runIfNoDevices) {
			setTimeout(() => {
				if (this.devices.length === 0) {
					runIfNoDevices();
				}
			}, 10000).unref();
		}
	}

	public dispose() {
		disposeAll(this.subscriptions);
	}

	public isSupported(types: f.PlatformType[] | undefined, device: { platformType?: f.PlatformType | null | undefined } | undefined) {