application-manager-base.ts

import { EventEmitter } from "events";
import { TARGET_FRAMEWORK_IDENTIFIERS } from "../constants";
import { IBuildData } from "../../definitions/build";
import { IDictionary, IHooksService } from "../declarations";
import * as _ from "lodash";

export abstract class ApplicationManagerBase
	extends EventEmitter
	implements Mobile.IDeviceApplicationManager {
	private lastInstalledAppIdentifiers: string[];
	private lastAvailableDebuggableApps: Mobile.IDeviceApplicationInformation[];
	private lastAvailableDebuggableAppViews: IDictionary<
		Mobile.IDebugWebViewInfo[]
	> = {};

	constructor(
		protected $logger: ILogger,
		protected $hooksService: IHooksService,
		protected $deviceLogProvider: Mobile.IDeviceLogProvider
	) {
		super();
	}

	public async setTransferredAppFiles(files: string[]): Promise<void> {
		for (const file of files) {
			await this.$deviceLogProvider.setSourceFileLocation(file);
		}
	}

	public async reinstallApplication(
		appIdentifier: string,
		packageFilePath: string,
		buildData?: IBuildData
	): Promise<void> {
		const isApplicationInstalled = await this.isApplicationInstalled(
			appIdentifier
		);

		if (isApplicationInstalled) {
			await this.uninstallApplication(appIdentifier);
		}

		await this.installApplication(packageFilePath, appIdentifier, buildData);
	}

	public async restartApplication(
		appData: Mobile.IApplicationData
	): Promise<void> {
		await this.stopApplication(appData);
		await this.startApplication(appData);
	}

	public async isApplicationInstalled(appIdentifier: string): Promise<boolean> {
		await this.checkForApplicationUpdates();
		return _.includes(this.lastInstalledAppIdentifiers, appIdentifier);
	}

	private checkForApplicationUpdatesPromise: Promise<void>;
	public async checkForApplicationUpdates(): Promise<void> {
		if (!this.checkForApplicationUpdatesPromise) {
			this.checkForApplicationUpdatesPromise = new Promise<void>(
				async (resolve, reject) => {
					let isFulfilled = false;
					// As this method is called on 500ms, but it's execution may last much longer
					// use locking, so the next executions will not get into the body, while the first one is still working.
					// In case we do not break the next executions, we'll report each app as newly installed several times.
					try {
						const currentlyInstalledAppIdentifiers = await this.getInstalledApplications();
						const previouslyInstalledAppIdentifiers =
							this.lastInstalledAppIdentifiers || [];

						const newAppIdentifiers = _.difference(
							currentlyInstalledAppIdentifiers,
							previouslyInstalledAppIdentifiers
						);
						const removedAppIdentifiers = _.difference(
							previouslyInstalledAppIdentifiers,
							currentlyInstalledAppIdentifiers
						);

						this.lastInstalledAppIdentifiers = currentlyInstalledAppIdentifiers;

						_.each(newAppIdentifiers, (appIdentifier) =>
							this.emit("applicationInstalled", appIdentifier)
						);
						_.each(removedAppIdentifiers, (appIdentifier) =>
							this.emit("applicationUninstalled", appIdentifier)
						);

						await this.checkForAvailableDebuggableAppsChanges();
					} catch (err) {
						isFulfilled = true;
						reject(err);
					} finally {
						this.checkForApplicationUpdatesPromise = null;

						if (!isFulfilled) {
							resolve();
						}
					}
				}
			);
		}

		return this.checkForApplicationUpdatesPromise;
	}

	public async tryStartApplication(
		appData: Mobile.IApplicationData
	): Promise<void> {
		try {
			await this.startApplication(appData);
		} catch (err) {
			this.$logger.trace(
				`Unable to start application ${appData.appId} with name ${appData.projectName}. Error is: ${err.message}`
			);
		}
	}

	public abstract installApplication(
		packageFilePath: string,
		appIdentifier?: string,
		buildData?: IBuildData
	): Promise<void>;
	public abstract uninstallApplication(
		appIdentifier: string
	): Promise<void>;
	public abstract startApplication(
		appData: Mobile.IApplicationData
	): Promise<void>;
	public abstract stopApplication(
		appData: Mobile.IApplicationData
	): Promise<void>;
	public abstract getInstalledApplications(): Promise<string[]>;
	public abstract getDebuggableApps(): Promise<
		Mobile.IDeviceApplicationInformation[]
	>;
	public abstract getDebuggableAppViews(
		appIdentifiers: string[]
	): Promise<IDictionary<Mobile.IDebugWebViewInfo[]>>;

	private async checkForAvailableDebuggableAppsChanges(): Promise<void> {
		const currentlyAvailableDebuggableApps = await this.getDebuggableApps();
		const previouslyAvailableDebuggableApps =
			this.lastAvailableDebuggableApps || [];

		const newAvailableDebuggableApps = _.differenceBy(
			currentlyAvailableDebuggableApps,
			previouslyAvailableDebuggableApps,
			"appIdentifier"
		);
		const notAvailableAppsForDebugging = _.differenceBy(
			previouslyAvailableDebuggableApps,
			currentlyAvailableDebuggableApps,
			"appIdentifier"
		);

		this.lastAvailableDebuggableApps = currentlyAvailableDebuggableApps;

		_.each(
			newAvailableDebuggableApps,
			(appInfo: Mobile.IDeviceApplicationInformation) => {
				this.emit("debuggableAppFound", appInfo);
			}
		);

		_.each(
			notAvailableAppsForDebugging,
			(appInfo: Mobile.IDeviceApplicationInformation) => {
				this.emit("debuggableAppLost", appInfo);

				if (
					_.has(this.lastAvailableDebuggableAppViews, appInfo.appIdentifier)
				) {
					// Prevent emitting debuggableViewLost when application cannot be debugged anymore.
					delete this.lastAvailableDebuggableAppViews[appInfo.appIdentifier];
				}
			}
		);

		const cordovaDebuggableAppIdentifiers = _(currentlyAvailableDebuggableApps)
			.filter((c) => c.framework === TARGET_FRAMEWORK_IDENTIFIERS.Cordova)
			.map((c) => c.appIdentifier)
			.value();

		const currentlyAvailableAppViews = await this.getDebuggableAppViews(
			cordovaDebuggableAppIdentifiers
		);

		_.each(
			currentlyAvailableAppViews,
			(currentlyAvailableViews, appIdentifier) => {
				const previouslyAvailableViews = this.lastAvailableDebuggableAppViews[
					appIdentifier
				];

				const newAvailableViews = _.differenceBy(
					currentlyAvailableViews,
					previouslyAvailableViews,
					"id"
				);
				const notAvailableViews = _.differenceBy(
					previouslyAvailableViews,
					currentlyAvailableViews,
					"id"
				);

				_.each(notAvailableViews, (debugWebViewInfo) => {
					this.emit("debuggableViewLost", appIdentifier, debugWebViewInfo);
				});

				_.each(newAvailableViews, (debugWebViewInfo) => {
					this.emit("debuggableViewFound", appIdentifier, debugWebViewInfo);
				});

				// Determine which of the views had changed since last check and raise debuggableViewChanged event for them:
				const keptViews = _.differenceBy(
					currentlyAvailableViews,
					newAvailableViews,
					"id"
				);
				_.each(keptViews, (view) => {
					const previousTimeViewInfo = _.find(
						previouslyAvailableViews,
						(previousView) => previousView.id === view.id
					);
					if (!_.isEqual(view, previousTimeViewInfo)) {
						this.emit("debuggableViewChanged", appIdentifier, view);
					}
				});

				this.lastAvailableDebuggableAppViews[
					appIdentifier
				] = currentlyAvailableViews;
			}
		);
	}
}