Fixes & cleanup

src/lg-airco-accessory.ts

@@ -14,8 +14,9 @@ import {
     Units
 } from "homebridge";
 
-import {AirCooler, HSwingMode, Mode, VSwingMode, WideqAdapter} from "./lg/wideq-adapter";
+import {AirCooler, FanSpeed, HSwingMode, Mode, VSwingMode, WideqAdapter} from "./lg/wideq-adapter";
 import {LgAircoController} from "./lg/lg-airco-controller";
+import {AsyncUtils} from "./utils/async-utils";
 
 export class LgAirCoolerAccessory implements AccessoryPlugin {
 
@@ -29,6 +30,8 @@ export class LgAirCoolerAccessory implements AccessoryPlugin {
     private airCooler: AirCooler;
     private controller: LgAircoController;
 
+    private handleRotationSpeedSetWithDebounce: Function;
+
     constructor(log: Logging, config: AccessoryConfig, api: API) {
         this.hap = api.hap;
         this.log = log;
@@ -61,8 +64,12 @@ export class LgAirCoolerAccessory implements AccessoryPlugin {
                 this.log('No air coolers found!');
                 return;
             }
+
             //TODO: Update interval from config, default now is 30 seconds.
             this.controller = new LgAircoController(this.airCooler);
+            this.handleRotationSpeedSetWithDebounce = AsyncUtils.debounce((newFanSpeed: FanSpeed) => {
+                this.controller.setFanSpeed(newFanSpeed);
+            }, 5000);
 
             this.heaterCoolerService.getCharacteristic(this.hap.Characteristic.Active)
                 .on(CharacteristicEventTypes.GET, this.handleActiveGet.bind(this))
@@ -223,7 +230,7 @@ export class LgAirCoolerAccessory implements AccessoryPlugin {
 
     private handleRotationSpeedSet(value: CharacteristicValue, callback: CharacteristicSetCallback): void {
         console.log('Setting FAN SPEED: ' + value);
-        //TODO: Implement!
+        this.handleRotationSpeedSetWithDebounce(value);
         callback(null);
     }
 

src/lg/lg-airco-controller.ts

@@ -128,14 +128,17 @@ export class LgAircoController {
     }
 
     public async setFanSpeed(newFanSpeed: FanSpeed): Promise<void> {
-        if (this.fanSpeed !== newFanSpeed) {
+        /*if (this.fanSpeed !== newFanSpeed) {
             const succeeded: boolean = await this.adapter.setFanSpeed(this.airCooler.deviceId, newFanSpeed);
             if (succeeded) {
                 this.isOn = true;
                 this.fanSpeed = newFanSpeed;
             } else {
                 throw new Error('Could not set new fan speed of the AC unit!');
             }
-        }
+        }*/
+        console.log('SPEED SET!');
+        this.isOn = true;
+        this.fanSpeed = newFanSpeed;
     }
 }

src/utils/async-utils.ts

@@ -0,0 +1,16 @@
+export class AsyncUtils {
+
+    public static debounce = <F extends (...args: any[]) => any>(func: F, waitFor: number) => {
+        let timeout: ReturnType<typeof setTimeout> | null = null;
+
+        const debounced = (...args: Parameters<F>) => {
+            if (timeout !== null) {
+                clearTimeout(timeout);
+                timeout = null;
+            }
+            timeout = setTimeout(() => func(...args), waitFor);
+        };
+
+        return debounced as (...args: Parameters<F>) => ReturnType<F>;
+    };
+}