Suppor for peers only emits

Author: joente

README.md

@@ -572,7 +572,7 @@ Leave the room. If the room is not found, a `LookupError` will be raised.
 ### emit
 
 ```python
-Room().emit(event: str, *args: Any) -> asyncio.Future
+Room().emit(event: str, *args: Any, peers_only: bool = False) -> asyncio.Future
 ```
 
 Emit an event to a room.
@@ -583,6 +583,11 @@ Emit an event to a room.
     Name of the event to emit.
 - *\*args (any)*:
     Additional argument to send with the event.
+- *peers_only (bool)*:
+    If `True`, the event will only be sent to other
+    listeners (peers) and will not be echoed back to the
+    sender. Defaults to `False`, which sends to all
+    _(requires ThingsDB v1.7.7 or higher)_.
 
 #### Returns
 

thingsdb/client/baseprotocol.py

@@ -52,6 +52,7 @@ class Proto(enum.IntEnum):
     REQ_JOIN = 0x26
     REQ_LEAVE = 0x27
     REQ_EMIT = 0x28
+    REQ_EMIT_PEER = 0x29
 
 
 class Err(enum.IntEnum):

thingsdb/client/client.py

@@ -473,7 +473,8 @@ async def _emit(
             room_id: int | str,
             event: str,
             *args: Any,
-            scope: str | None = None):
+            scope: str | None = None,
+            peers_only: bool = False):
         """Emit an event.
 
         Use Room(room_id, scope=scope).emit(..) instead of this function to
@@ -500,7 +501,8 @@ async def _emit(
         """
         if scope is None:
             scope = self._scope
-        await self._write_pkg(Proto.REQ_EMIT, [scope, room_id, event, *args])
+        proto = Proto.REQ_EMIT_PEER if peers_only else Proto.REQ_EMIT
+        await self._write_pkg(proto, [scope, room_id, event, *args])
 
     def _join(self, *ids: int | str,
               scope: str | None = None

thingsdb/room/roombase.py

@@ -176,7 +176,7 @@ async def leave(self):
         if res[0] is None:
             raise LookupError(f'room Id {self._id} is not found (anymore)')
 
-    async def emit(self, event: str, *args):
+    async def emit(self, event: str, *args, peers_only: bool = False):
         """Emit an event.
 
         Args:
@@ -193,7 +193,9 @@ async def emit(self, event: str, *args):
         if self._client is None:
             raise RuntimeError(
                 'must call join(..) or no_join(..) before using emit')
-        await self._client._emit(self._id, event, *args, scope=self._scope)
+        await self._client._emit(self._id, event, *args,
+                                 scope=self._scope,
+                                 peers_only=peers_only)
 
     def _on_event(self, pkg) -> asyncio.Task | None:
         return self.__class__._ROOM_EVENT_MAP[pkg.tp](self, pkg.data)

thingsdb/version.py

@@ -1 +1 @@
-__version__ = '1.2.2'
+__version__ = '1.3.0'