fix(time): Handle onStateChanged errors

zachowj · Sep 24, 2023 · 8365b5a · 8365b5a
1 parent 4b12a49
commit 8365b5a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 15 deletions.
diff --git a/src/nodes/time/events.ts b/src/nodes/time/events.ts
@@ -1,6 +1,4 @@
-import BaseError from '../../common/errors/BaseError';
 import ClientEvents from '../../common/events/ClientEvents';
-import Status from '../../common/status/Status';
 import { TypedInputTypes } from '../../const';
 import { getEntitiesFromJsonata } from '../../helpers/utils';
 import HomeAssistant from '../../homeAssistant/HomeAssistant';
@@ -11,19 +9,8 @@ export function startListener(
     clientEvents: ClientEvents,
     controller: TimeController,
     homeAssistant: HomeAssistant,
-    node: TimeNode,
-    status: Status
+    node: TimeNode
 ) {
-    if (homeAssistant.isHomeAssistantRunning) {
-        try {
-            controller.onStateChanged();
-        } catch (e) {
-            if (e instanceof BaseError) {
-                status.setError(e.message);
-            }
-            throw e;
-        }
-    }
     clientEvents.addListener(
         'ha_client:ready',
         controller.onStateChanged.bind(controller)
@@ -46,4 +33,8 @@ export function startListener(
             );
         });
     }
+
+    if (homeAssistant.isHomeAssistantRunning) {
+        clientEvents.emit(`ha_events:state_changed:${node.config.entityId}`);
+    }
 }
diff --git a/src/nodes/time/index.ts b/src/nodes/time/index.ts
@@ -66,5 +66,5 @@ export default function timeNode(this: TimeNode, config: TimeNodeProperties) {
         ...controllerDeps,
     });
 
-    startListener(clientEvents, controller, homeAssistant, this, status);
+    startListener(clientEvents, controller, homeAssistant, this);
 }