From c1d6b48e9f1ab9e163d6cc78b8582917ca61172e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?R=C3=B3bert=20Kiss?= Date: Sat, 18 Jan 2025 18:22:45 +0100 Subject: [PATCH] refactor: remove unnecessary promises (#2496) --- .../uhk-agent/src/services/device.service.ts | 18 +++---- packages/uhk-usb/src/uhk-hid-device.ts | 51 +++++++++---------- 2 files changed, 32 insertions(+), 37 deletions(-) diff --git a/packages/uhk-agent/src/services/device.service.ts b/packages/uhk-agent/src/services/device.service.ts index bc8567dc983..83b8ab0992b 100644 --- a/packages/uhk-agent/src/services/device.service.ts +++ b/packages/uhk-agent/src/services/device.service.ts @@ -851,18 +851,16 @@ export class DeviceService { public async stopPollUhkDevice(): Promise { this.logService.misc('[DeviceService] stop poll UHK Device'); - return new Promise(async resolve => { - this._pollerAllowed = false; + this._pollerAllowed = false; - while (true) { - if (!this._uhkDevicePolling) { - this.logService.misc('[DeviceService] stopped poll UHK Device'); - return resolve(); - } - - await snooze(100); + while (true) { + if (!this._uhkDevicePolling) { + this.logService.misc('[DeviceService] stopped poll UHK Device'); + return; } - }); + + await snooze(100); + } } private async changeKeyboardLayout(event: Electron.IpcMainEvent, args): Promise { diff --git a/packages/uhk-usb/src/uhk-hid-device.ts b/packages/uhk-usb/src/uhk-hid-device.ts index ad1f2e7c677..ea2094b46d6 100644 --- a/packages/uhk-usb/src/uhk-hid-device.ts +++ b/packages/uhk-usb/src/uhk-hid-device.ts @@ -437,36 +437,33 @@ export class UhkHidDevice { * @returns {Promise} */ public async write(buffer: Buffer): Promise { - return new Promise(async (resolve, reject) => { - try { - const device = await this.getDevice(); - const reportId = this.getReportId(); - - this.logService.setUsbReportId(reportId); - const sendData = this.getTransferData(buffer, reportId); - this.logService.usb('[UhkHidDevice] USB[W]:', bufferToString(sendData)); - device.write(sendData); - await snooze(1); - const receivedData = device.readTimeout(1000); - const logString = bufferToString(receivedData); - this.logService.usb('[UhkHidDevice] USB[R]:', logString); - - if (reportId) { - receivedData.shift(); - } - - if (receivedData[0] !== 0) { - return reject(new Error(`Communications error with UHK. Response code: ${receivedData[0]}`)); - } + try { + const device = await this.getDevice(); + const reportId = this.getReportId(); + + this.logService.setUsbReportId(reportId); + const sendData = this.getTransferData(buffer, reportId); + this.logService.usb('[UhkHidDevice] USB[W]:', bufferToString(sendData)); + device.write(sendData); + await snooze(1); + const receivedData = device.readTimeout(1000); + const logString = bufferToString(receivedData); + this.logService.usb('[UhkHidDevice] USB[R]:', logString); + + if (reportId) { + receivedData.shift(); + } - return resolve(Buffer.from(receivedData)); - } catch (err) { - this.logService.error('[UhkHidDevice] Transfer error: ', err); - this.close(); - return reject(err); + if (receivedData[0] !== 0) { + throw new Error(`Communications error with UHK. Response code: ${receivedData[0]}`); } - }); + return Buffer.from(receivedData); + } catch (err) { + this.logService.error('[UhkHidDevice] Transfer error: ', err); + this.close(); + throw err; + } } /**