Class DeviceManager

src/modules/device-management/device.manager.ts:9–152

import { APP_ENV } from "../../config/config";

class DeviceManager {
	private static instance: DeviceManager;
	private devices: Map<string, Device> = new Map();
	private mutex = new Mutex();
	iosListenProcess = new SubProcess("ios", ["listen"]);

	constructor() {
		this.listenToDeviceEvents();
	}

	public static getInstance(): DeviceManager {
		if (!DeviceManager.instance) {
			DeviceManager.instance = new DeviceManager();
		}
		return DeviceManager.instance;
	}

	private async attachedEvent(deviceId: number, properties: any) {
		const release = await this.mutex.acquire();
		try {
			const udid = properties.SerialNumber;
			let device = this.devices.get(udid);
			if (device) {
				device.id = deviceId;
				device.status = Status.AVAILABLE;
			} else {
				const deviceSize = getDeviceSize(properties.productType);
				device = {
					id: deviceId,
					name: getDeviceName(properties.productType),
					udid: udid,
					version: properties.version,
					status: Status.AVAILABLE,
					dpr: deviceSize.dpr,
					height: deviceSize.viewportHeight,
					width: deviceSize.viewportWidth,
				};
				this.devices.set(udid, device);
			}
			logger.info(`Device (${device.udid}) is now available`);
		} finally {
			release();
		}
	}

	private async datachedEvent(deviceId: number) {
		const release = await this.mutex.acquire();
		try {
			let device = this.getDeviceById(deviceId);
			if (device) {
				device.status = Status.OFFLINE;
				logger.info(`Device (${device?.udid}) is offline`);
			} else {
				logger.error(`Device (${deviceId}) was not found`);
			}
		} finally {
			release();
		}