Added emit peers

Author: joente

README.md

@@ -32,6 +32,7 @@
     * [Join](#join)
     * [NoJoin](#nojoin)
     * [Emit](#emit)
+    * [EmitPeers](#emitpeers)
     * [Leave](#leave)
   * [Unpack](#unpack)
     * [Deserialize](#deserialize)
@@ -398,6 +399,10 @@ Emit an event to the room.
 await myRoom.Emit("new-message", "This is a test message!");
 ```
 
+### EmitPeers
+
+Equal to [Emit](#emit) but to peers only _(no echo back)_.
+
 ### Leave
 ```csharp
 public async Task Leave();

ThingsDB/Connector.cs

@@ -198,6 +198,28 @@ internal async Task Emit<T>(Room room, string eventName, T[]? args)
             result.RaiseOnErr();
         }
 
+        internal async Task EmitPeers<T>(Room room, string eventName, T[]? args)
+        {
+            int n = args?.Length ?? 0;
+            object[] emit = new object[3 + n];
+            emit[0] = room.Scope();
+            emit[1] = room.Id();
+            emit[2] = eventName;
+            for (var i = 0; i < n; i++)
+            {
+#pragma warning disable CS8602 // Dereference of a possibly null reference.
+#pragma warning disable CS8601 // Possible null reference assignment.
+                emit[3 + i] = args[i];
+#pragma warning restore CS8601 // Possible null reference assignment.
+#pragma warning restore CS8602 // Dereference of a possibly null reference.
+            }
+
+            byte[] data = MessagePackSerializer.Serialize(emit);
+            Package pkg = new(PackageType.ReqEmitPeers, GetNextPid(), data);
+            Package result = await EnsureWrite(pkg, DefaultTimeout);
+            result.RaiseOnErr();
+        }
+
         internal void SetRoom(Room room)
         {
             roomLookup[room.Id()] = room;

ThingsDB/PackageType.cs

@@ -17,12 +17,13 @@ public enum PackageType : byte
         ResError = 19,  // {error_msg: ..., error_code: x}
 
         ReqPing = 32,   // Empty
-        ReqAuth = 33,   // [user, pass] or token            
+        ReqAuth = 33,   // [user, pass] or token
         ReqQuery = 34,  // [scope, code, {variable}]
 
         ReqRun = 37,    // [scope, procedure, [[args]/{kw}]
         ReqJoin = 38,   // [scope, ...room ids]
         ReqLeave = 39,  // [scope, ...room ids]
         ReqEmit = 40,   // [scope, room_id, event, ...args]
+        ReqEmitPeers = 41,   // [scope, room_id, event, ...args]
     }
 }

ThingsDB/Room.cs

@@ -124,6 +124,14 @@ public async Task Emit<T>(string eventName, params T[]? args)
         {
             await Conn.Emit(this, eventName, args);
         }
+        public async Task EmitPeers(string eventName)
+        {
+            await EmitPeers<string>(eventName, null);
+        }
+        public async Task EmitPeers<T>(string eventName, params T[]? args)
+        {
+            await Conn.EmitPeers(this, eventName, args);
+        }
         internal void OnEvent(RoomEvent ev)
         {
             switch (ev.Tp)

ThingsDB/ThingsDB.csproj

@@ -4,7 +4,7 @@
     <TargetFramework>net8.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
-    <Version>1.0.2</Version>
+    <Version>1.0.3</Version>
     <Company>Cesbit</Company>
     <Product>ThingsDB Connector</Product>
     <PackageReadmeFile>README.md</PackageReadmeFile>

build.py

@@ -4,6 +4,7 @@
   * Update version in ThingsDB.csproj
   * Run (From the ThingsDB folder): dotnet pack
   * Run this script: python build.py <VERSION>
+    Example python build.py 1.0.3
 """
 import sys
 import os