Fixing pipeline

.drone.yml

@@ -5,6 +5,9 @@ name: default
 clone:
   disable: true
 
+node:
+  lan: internal
+
 steps:
   - name: clone
     image: alpine/git
@@ -34,14 +37,14 @@ steps:
           - master
 
   - name: publish pre
-    image: plugins/npm
-    settings:
-      username:
-        from_secret: npm_username
-      password:
-        from_secret: npm_password
-      email: brandon@watsonlabs.net
-      registry: "http://10.44.1.6:4873/"
+    image: node
+    environment:
+      token:
+        from_secret: npm_token
+    commands:
+      - npm config set @watsonb8:registry https://gitea.watsonlabs.net/api/packages/watsonb8/npm/
+      - npm config set -- '//gitea.watsonlabs.net/api/packages/watsonb8/npm/:_authToken' "$token"
+      - npm publish
     when:
       event:
         exclude:
@@ -52,14 +55,70 @@ steps:
           - master
 
   - name: publish tagged version
-    image: plugins/npm
+    image: node
+    environment:
+      token:
+        from_secret: npm_token
+    commands:
+      - npm config set @watsonb8:registry https://gitea.watsonlabs.net/api/packages/watsonb8/npm/
+      - npm config set -- '//gitea.watsonlabs.net/api/packages/watsonb8/npm/:_authToken' "$token"
+      - npm publish
+    when:
+      event:
+        - tag
+      exclude:
+        - pull_request
+
+  - name: remove old package
+    image: appleboy/drone-ssh
+    environment:
+      SSH_USER:
+        from_secret: ssh_user
     settings:
+      host: homebridge.me
+      envs:
+        - SSH_USER
       username:
-        from_secret: npm_username
-      password:
-        from_secret: npm_password
-      email: brandon@watsonlabs.net
-      registry: "http://10.44.1.6:4873/"
+        from_secret: ssh_user
+      key:
+        from_secret: ssh_key
+      port: 22
+      script:
+        - rm -r /home/$SSH_USER/.npm-global/lib/node_modules/@watsonb8/homebridge-harmony-control || true
+    when:
+      event:
+        - tag
+      exclude:
+        - pull_request
+
+  - name: deploy
+    image: appleboy/drone-ssh
+    settings:
+      host: homebridge.me
+      username:
+        from_secret: ssh_user
+      key:
+        from_secret: ssh_key
+      port: 22
+      script:
+        - npm install -g @watsonb8/homebridge-harmony-control
+    when:
+      event:
+        - tag
+      exclude:
+        - pull_request
+
+  - name: restart homebridge
+    image: appleboy/drone-ssh
+    settings:
+      host: homebridge.me
+      username:
+        from_secret: elevated_ssh_user
+      key:
+        from_secret: ssh_key
+      port: 22
+      script:
+        - systemctl restart homebridge
     when:
       event:
         - tag

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@watsonb8/homebridge-harmony-control",
-  "version": "1.2.0",
+  "version": "1.2.3",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,10 +1,10 @@
 {
     "name": "@watsonb8/homebridge-harmony-control",
-    "version": "1.2.0",
+    "version": "1.3.0",
     "description": "Homebridge platform to control smart home equipment by room.",
     "main": "bin/index.js",
     "publishConfig": {
-        "registry": "http://10.44.1.6:4873/"
+        "registry": "https://gitea.watsonlabs.net"
     },
     "scripts": {
         "build": "tsc --build",
@@ -44,4 +44,4 @@
         "request": "^2.88.0",
         "tsyringe": "^4.6.0"
     }
-}
+}

src/accessories/controlUnit.ts

@@ -137,7 +137,10 @@ export class ControlUnit {
         break;
       //Turn on with first activity
       case 1:
-        this._activityService.startActivity(
+        if (this._activityService.getIsActive(this._accessory.displayName)) {
+          break;
+        }
+        this._activityService.startLastOrDefaultActivity(
           this._accessory.displayName,
           this._activities[0]
         );
@@ -150,7 +153,8 @@ export class ControlUnit {
    */
   private onGetAccessoryActive = async () => {
     //@ts-ignore
-    return this._activityService.getIsActive(this._accessory.displayName)
+    return this._activityService.getCurrentActivity(this._accessory.displayName)
+      ?.DisplayName
       ? this._platform.Characteristic.Active.ACTIVE
       : this._platform.Characteristic.Active.INACTIVE;
   };
@@ -176,7 +180,7 @@ export class ControlUnit {
    * Event handler for GET active identifier characteristic
    */
   private onGetActiveIdentifier = async () => {
-    let currentActivity: IActivity = this._activityService.getIsActive(
+    let currentActivity: IActivity = this._activityService.getCurrentActivity(
       this._accessory.displayName
     )!;
     let identifier: number = 0;

src/dataProviders/stateDataProvider.ts

@@ -9,18 +9,30 @@ export class StateDataProvider {
   } = {};
 
   public updateState(activity: IActivity, controlUnitName: string): void {
-    this._states[controlUnitName] = { currentActivity: activity };
+    const oldState = this._states[controlUnitName];
+    this._states[controlUnitName] = {
+      currentActivity: activity,
+      lastActivity: oldState?.lastActivity,
+    };
+  }
+
+  public deactivateState(controlUnitName: string): void {
+    const oldState = this._states[controlUnitName];
+    this._states[controlUnitName] = {
+      currentActivity: undefined,
+      lastActivity: oldState?.currentActivity,
+    };
   }
 
   public removeState(controlUnitName: string): void {
     this._states[controlUnitName] = undefined;
   }
 
-  public getState(controlUnitName: string) {
+  public getState(controlUnitName: string): IActivityState | undefined {
     if (!this._states[controlUnitName]) {
       return undefined;
     }
-    return this._states[controlUnitName]!.currentActivity;
+    return this._states[controlUnitName];
   }
 
   public get states(): {

src/models/activityState.ts

@@ -1,5 +1,6 @@
 import { IActivity } from "./config";
 
 export interface IActivityState {
-  currentActivity: IActivity;
+  currentActivity?: IActivity;
+  lastActivity?: IActivity;
 }

src/services/activityService.ts

@@ -22,6 +22,18 @@ export class ActivityService {
     @inject("log") private _log: Logging
   ) {}
 
+  public startLastOrDefaultActivity = async (
+    controlUnitName: string,
+    defaultActivity: IActivity
+  ) => {
+    const lastActivity = this.getLastActivity(controlUnitName);
+    if (!lastActivity) {
+      return this.startActivity(controlUnitName, defaultActivity);
+    }
+
+    return this.startActivity(controlUnitName, lastActivity);
+  };
+
   public startActivity = async (
     controlUnitName: string,
     activity: IActivity
@@ -68,19 +80,24 @@ export class ActivityService {
     );
     await this._harmonyDataProvider.powerOffDevices(devicesToTurnOff);
 
-    this._stateDataProvider.removeState(controlUnitName);
+    this._stateDataProvider.deactivateState(controlUnitName);
   };
 
   public getCurrentActivity(controlUnitName: string): IActivity | undefined {
-    return this._stateDataProvider.getState(controlUnitName);
+    return this._stateDataProvider.getState(controlUnitName)?.currentActivity;
+  }
+
+  public getLastActivity(controlUnitName: string): IActivity | undefined {
+    return this._stateDataProvider.getState(controlUnitName)?.lastActivity;
   }
 
   /**
    * Return if a control unit is active
    * @param controlUnitName
    */
-  public getIsActive(controlUnitName: string): IActivity | undefined {
-    return this._stateDataProvider.getState(controlUnitName);
+  public getIsActive(controlUnitName: string): boolean {
+    const state = this._stateDataProvider.getState(controlUnitName);
+    return state != undefined && state.currentActivity != undefined;
   }
 
   /**
@@ -100,11 +117,11 @@ export class ActivityService {
       let currentOtherState: IActivityState =
         this._stateDataProvider.states[controlUnitKey]!;
 
-      if (!currentOtherState) {
+      if (!currentOtherState || !currentOtherState.currentActivity) {
         return devicesToTurnOn;
       }
 
-      currentOtherState.currentActivity.DeviceSetupList.forEach(
+      currentOtherState.currentActivity!.DeviceSetupList.forEach(
         (value: IDeviceSetupItem) => {
           //there are devices to remove
           if (devicesToTurnOn.some((e) => e && e.name === value.DeviceName)) {

src/services/commandService.ts

@@ -24,7 +24,7 @@ export class CommandService {
       let commandName: string = "";
 
       let device: HarmonyDevice = this._harmonyDataProvider.getDeviceByName(
-        currentActivity.ControlDevice
+        currentActivity.currentActivity!.ControlDevice
       );
       switch (key) {
         case RemoteKey.ARROW_UP: {

src/services/volumeService.ts

@@ -16,10 +16,12 @@ export class VolumeService {
    */
   public volumeUp = async (controlUnitName: string) => {
     let volumeUpCommand: string = "Volume Up";
-    let currentActivity = this._stateDataProvider.getState(controlUnitName);
-    if (currentActivity) {
+    let currentState = this._stateDataProvider.getState(controlUnitName);
+    if (currentState) {
       let volumeDevice: HarmonyDevice =
-        this._harmonyDataProvider.getDeviceByName(currentActivity.VolumeDevice);
+        this._harmonyDataProvider.getDeviceByName(
+          currentState.currentActivity!.VolumeDevice
+        );
       await this._harmonyDataProvider.sendCommand(
         volumeUpCommand,
         volumeDevice
@@ -32,10 +34,12 @@ export class VolumeService {
    */
   public volumeDown = async (controlUnitName: string) => {
     let volumeDownCommand: string = "Volume Down";
-    let currentActivity = this._stateDataProvider.getState(controlUnitName);
-    if (currentActivity) {
+    let currentState = this._stateDataProvider.getState(controlUnitName);
+    if (currentState) {
       let volumeDevice: HarmonyDevice =
-        this._harmonyDataProvider.getDeviceByName(currentActivity.VolumeDevice);
+        this._harmonyDataProvider.getDeviceByName(
+          currentState.currentActivity!.VolumeDevice
+        );
       await this._harmonyDataProvider.sendCommand(
         volumeDownCommand,
         volumeDevice