replaced zmq with minimal internal implementation to avoid zmq requirement

Author: craigbarratt

README.md

@@ -606,7 +606,7 @@ Four logging functions are provided, with increasing levels of severity:
 The [Logger](/integrations/logger/) component can be used to specify the logging level. Log messages
 below the configured level will not appear in the log. Each log message function uses a log name of
 the form:
-```python
+```yaml
 homeassistant.components.pyscript.file.FILENAME.FUNCNAME
 ```
 where `FUNCNAME` is the name of the top-level Python function (e.g., the one called by a trigger or

custom_components/pyscript/__init__.py

@@ -122,6 +122,12 @@ async def jupyter_kernel_start(call):
     async def state_changed(event):
         var_name = event.data["entity_id"]
         # attr = event.data["new_state"].attributes
+        if "new_state" not in event.data or event.data["new_state"] is None:
+            _LOGGER.debug(
+                "state_changed: missing new_state in event.data=%s; ignoring",
+                event.data,
+            )
+            return
         new_val = event.data["new_state"].state
         old_val = event.data["old_state"].state if event.data["old_state"] else None
         new_vars = {var_name: new_val, f"{var_name}.old": old_val}

custom_components/pyscript/global_ctx.py

@@ -3,14 +3,15 @@
 from collections import OrderedDict
 import io
 import logging
+
 import yaml
 
 from homeassistant.const import SERVICE_RELOAD
 from homeassistant.exceptions import HomeAssistantError
 from homeassistant.helpers.service import async_set_service_schema
 
 from .const import DOMAIN, LOGGER_PATH, SERVICE_JUPYTER_KERNEL_START
-from .eval import AstEval, EvalFunc
+from .eval import AstEval
 from .trigger import TrigInfo
 
 
@@ -42,6 +43,7 @@ def __init__(
         self.auto_start = False
 
     async def trigger_init(self, func):
+        """Initialize any decorator triggers for a newly defined function."""
         func_name = func.get_name()
         trig_args = {}
         got_reqd_dec = False
@@ -238,6 +240,7 @@ async def do_service_call(func, ast_ctx, data):
             await self.start()
 
     def set_auto_start(self, auto_start):
+        """Set the auto-start flag."""
         self.auto_start = auto_start
 
     async def start(self):