Merge pull request #26 from compas-dev/zenoh

Add support for Zenoh transport

Author: gonzalocasas

.github/copilot-instructions.md

@@ -31,9 +31,10 @@ jobs:
     if: "!contains(github.event.pull_request.labels.*.name, 'docs-only')"
     runs-on: 'ubuntu-latest'
     steps:
-      - name: Set up docker container
+      - name: Set up docker containers
         run: |
           docker run -d --name nanomq -p 1883:1883 -p 8083:8083 -p 8883:8883 emqx/nanomq:latest
+          docker run -d --name zenoh --init -p 7447:7447/tcp -p 8000:8000/tcp eclipse/zenoh
           docker ps -a
       - uses: compas-dev/compas-actions.build@v4
         with:
@@ -49,6 +50,7 @@ jobs:
       - name: Tear down docker container
         run: |
           docker rm -f nanomq
+          docker rm -f zenoh
 
   build-cpython-components:
     runs-on: windows-latest

.github/workflows/build.yml

@@ -9,6 +9,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+* Add support for Zenoh transport protocol.
+
 ### Changed
 
 ### Removed

CHANGELOG.md

@@ -44,6 +44,7 @@ Or using `conda`:
 * Publisher/subscriber communication model (N-to-N communication)
 * In-process events
 * MQTT support
+* Zenoh support
 * Extensible codec system for message serialization (JSON, Protocol Buffers)
 
 ## Examples
@@ -87,6 +88,25 @@ for i in range(10):
 This example shows how to send and receive from a single script, but
 running publishers and subscribers on different scripts, different processes, or even different computers will work the exact same way.
 
+### Zenoh
+
+Apache Zenoh is a pub/sub/query protocol. In many ways, it is similar to MQTT but with some additional features and optimizations. COMPAS EVE also supports Zenoh as a transport protocol with an identical API to MQTT:
+
+```python
+import compas_eve as eve
+from compas_eve.zenoh import ZenohTransport
+
+tx = ZenohTransport()
+eve.set_default_transport(tx)
+
+pub = eve.Publisher("/hello_world")
+sub = eve.EchoSubscriber("/hello_world")
+sub.subscribe()
+
+for i in range(10):
+    pub.publish(dict(text=f"Hello World {i}"))
+```
+
 ### Using different codecs
 
 By default, COMPAS EVE uses JSON for message serialization. However, you can use different codecs for more efficient serialization:

README.md

@@ -9,5 +9,6 @@ API Reference
     api/compas_eve.codecs
     api/compas_eve.memory
     api/compas_eve.mqtt
+    api/compas_eve.zenoh
     api/compas_eve.ghpython
 

docs/api.rst

@@ -0,0 +1,2 @@
+
+.. automodule:: compas_eve.zenoh

docs/api/compas_eve.zenoh.rst

@@ -0,0 +1,16 @@
+import time
+
+from compas_eve import Publisher
+from compas_eve import Topic
+from compas_eve.zenoh import ZenohTransport
+
+topic = Topic("/hello/zenoh")
+tx = ZenohTransport()
+
+publisher = Publisher(topic, transport=tx)
+
+for i in range(20):
+    msg = dict(text=f"Hello world #{i} over Zenoh")
+    print(f"Publishing message: {msg}")
+    publisher.publish(msg)
+    time.sleep(1)

docs/examples/05_zenoh_distributed_world_pub.py

@@ -0,0 +1,18 @@
+import time
+
+from compas_eve import Subscriber
+from compas_eve import Topic
+from compas_eve.zenoh import ZenohTransport
+
+topic = Topic("/hello/zenoh")
+tx = ZenohTransport()
+
+subcriber = Subscriber(topic, callback=lambda msg: print(f"Received message: {msg}"), transport=tx)
+subcriber.subscribe()
+
+print("Waiting for messages, press CTRL+C to cancel")
+try:
+    while True:
+        time.sleep(1)
+finally:
+    subcriber.unsubscribe()

docs/examples/05_zenoh_distributed_world_sub.py

@@ -36,7 +36,7 @@ classifiers = [
 [tool.setuptools.dynamic]
 version = { attr = "compas_eve.__version__" }
 dependencies = { file = "requirements.txt" }
-optional-dependencies = { dev = { file = "requirements-dev.txt" } }
+optional-dependencies = { dev = { file = "requirements-dev.txt" }, zenoh = { file = "requirements-zenoh.txt" } }
 
 [project.entry-points.'compas_pb.plugins']
 serializers = 'compas_eve.codecs.conversions'

pyproject.toml

@@ -0,0 +1 @@
+eclipse-zenoh