added trigger function closure support

Author: craigbarratt

custom_components/pyscript/__init__.py

@@ -68,7 +68,7 @@ async def reload_scripts_handler(call):
         for global_ctx_name, global_ctx in GlobalContextMgr.items():
             if not global_ctx_name.startswith("file."):
                 continue
-            await global_ctx.stop()
+            global_ctx.stop()
             global_ctx.set_auto_start(False)
             ctx_delete[global_ctx_name] = global_ctx
         for global_ctx_name, global_ctx in ctx_delete.items():
@@ -79,7 +79,7 @@ async def reload_scripts_handler(call):
         for global_ctx_name, global_ctx in GlobalContextMgr.items():
             if not global_ctx_name.startswith("file."):
                 continue
-            await global_ctx.start()
+            global_ctx.start()
 
     hass.services.async_register(DOMAIN, SERVICE_RELOAD, reload_scripts_handler)
 
@@ -130,15 +130,15 @@ async def start_triggers(event):
         for global_ctx_name, global_ctx in GlobalContextMgr.items():
             if not global_ctx_name.startswith("file."):
                 continue
-            await global_ctx.start()
+            global_ctx.start()
             global_ctx.set_auto_start(True)
 
     async def stop_triggers(event):
         _LOGGER.debug("stopping triggers")
         for global_ctx_name, global_ctx in GlobalContextMgr.items():
             if not global_ctx_name.startswith("file."):
                 continue
-            await global_ctx.stop()
+            global_ctx.stop()
 
     hass.bus.async_listen(EVENT_HOMEASSISTANT_STARTED, start_triggers)
     hass.bus.async_listen(EVENT_HOMEASSISTANT_STOP, stop_triggers)
@@ -179,10 +179,12 @@ def read_file(path):
         if not ast_ctx.parse(source, filename=file):
             exc = ast_ctx.get_exception_long()
             ast_ctx.get_logger().error(exc)
+            global_ctx.stop()
             continue
         await ast_ctx.eval()
         exc = ast_ctx.get_exception_long()
         if exc is not None:
             ast_ctx.get_logger().error(exc)
+            global_ctx.stop()
             continue
         GlobalContextMgr.set(global_ctx_name, global_ctx)