Add Zenoh component

Author: gonzalocasas

src/compas_eve/ghpython/components/Ce_ZenohConnect/code.py

@@ -0,0 +1,37 @@
+# r: compas_eve>=2.1.1
+"""
+Initialize a Zenoh transport.
+"""
+
+from threading import Event
+
+import Grasshopper
+from compas_ghpython import create_id
+from scriptcontext import sticky as st
+
+from compas_eve.zenoh import ZenohTransport
+
+
+class ZenohConnectComponent(Grasshopper.Kernel.GH_ScriptInstance):
+    def RunScript(self, connect: bool):
+        zenoh_transport = None
+
+        key = create_id(ghenv.Component, "zenoh_transport")  # noqa: F821
+        zenoh_transport = st.get(key, None)
+
+        if zenoh_transport:
+            st[key].close()
+
+        if connect:
+            event = Event()
+            transport = ZenohTransport()
+            transport.on_ready(event.set)
+
+            if not event.wait(5):
+                raise Exception("Failed to initialize Zenoh router transport.")
+
+            st[key] = transport
+
+        zenoh_transport = st.get(key, None)
+        is_connected = zenoh_transport._is_connected if zenoh_transport else False
+        return (zenoh_transport, is_connected)

src/compas_eve/ghpython/components/Ce_ZenohConnect/icon.png

@@ -0,0 +1,30 @@
+{
+    "name": "Zenoh Transport",
+    "nickname": "Zenoh",
+    "category": "COMPAS EVE",
+    "subcategory": "Events",
+    "description": "Initialize a Zenoh transport.",
+    "exposure": 2,
+
+    "ghpython": {
+        "isAdvancedMode": true,
+        "iconDisplay": 2,
+        "inputParameters": [
+            {
+                "name": "connect",
+                "description": "If True, initializes a Zenoh transport. If False, removes it. Defaults to False.",
+                "typeHintID": "bool"
+            }
+        ],
+        "outputParameters": [
+            {
+                "name": "zenoh_transport",
+                "description": "The Zenoh transport instance."
+            },
+            {
+                "name": "is_connected",
+                "description": "True if initialization has been processed."
+            }
+        ]
+    }
+}