Upd with EmitPeers function

Author: joente

README.md

@@ -23,6 +23,7 @@
     * [Run(scope, procedure, args) -> interface{}, error](#Run)
     * [RunRaw(scope, procedure, args) -> []byte, error](#RunRaw)
     * [Emit(scope, roomId, event, args) -> error](#Emit-Conn)
+    * [EmitPeers(scope, roomId, event, args) -> error](#EmitPeers-Conn)
     * [Close()](#Close)
   * [Room](#Room)
     * [NewRoom(scope, code) -> *Room](#NewRoom)
@@ -34,6 +35,7 @@
     * [Join(conn, wait) -> error](#Join)
     * [Leave() -> error](#Leave)
     * [Emit(event, args) -> error](#Emit)
+    * [EmitPeers(event, args) -> error](#EmitPeers)
 
 ---------------------------------------
 
@@ -303,6 +305,10 @@ err := conn.Emit(
 );
 ```
 
+### EmitPeers-Conn
+
+Like [Emit](#Emit-Conn), but without echo back. It emits the event to peers only.
+
 ### Close
 
 Close an open connection.
@@ -455,3 +461,8 @@ err := room.Emit(
     args            // Arguments (may be nil)
 );
 ```
+
+### EmitPeers
+
+Like [Emit](#Emit), but without echo back. It emits the event to peers only.
+

conn.go

@@ -304,6 +304,31 @@ func (conn *Conn) Emit(scope string, roomId uint64, event string, args []interfa
 	return err
 }
 
+// Emit an even to a room to peers only (no echo back).
+//
+// If a `Room` is created for the given `roomId`, you probable want to
+// use EmitPeers(..) on the `Room` type.
+//
+// Example:
+//
+//	args := []interface{}{"This is a message"}
+//
+//	err := conn.EmitPeers(
+//	    "//stuff",      // scope of the Room
+//	    123,            // Room Id
+//	    "new-message",  // Event to emit
+//	    args            // Arguments (may be nil)
+//	);
+func (conn *Conn) EmitPeers(scope string, roomId uint64, event string, args []interface{}) error {
+	data := []interface{}{scope, roomId, event}
+	if args != nil {
+		data = append(data, args...)
+	}
+
+	_, err := conn.ensureWrite(ProtoReqEmitPeers, data)
+	return err
+}
+
 // Close an open connection.
 //
 // > Warning: After calling Close(), the `conn.AutoReconnect` property will be

go.mod

@@ -1,10 +1,10 @@
 module github.com/thingsdb/go-thingsdb
 
-go 1.15
+go 1.19
+
+require github.com/vmihailenco/msgpack/v5 v5.4.1
 
 require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/kr/pretty v0.1.0 // indirect
-	github.com/vmihailenco/msgpack/v5 v5.4.1
-	gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 // indirect
+	github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
 )

go.sum

@@ -1,22 +1,9 @@
-github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=
-github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
-github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
-github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
-github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
-github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8=
 github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok=
 github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
 github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
-gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

proto.go

@@ -58,4 +58,6 @@ const (
 	ProtoReqLeave Proto = 39
 	// ProtoReqEmit requires `[scope, roomId, event, arguments...]`
 	ProtoReqEmit Proto = 40
+	// ProtoReqEmitPeers requires `[scope, roomId, event, arguments...]`
+	ProtoReqEmitPeers Proto = 41
 )

room.go

@@ -211,6 +211,23 @@ func (room *Room) Emit(event string, args []interface{}) error {
 	return room.conn.Emit(room.scope, room.id, event, args)
 }
 
+// Emit an even to a room to peers only (no echo back).
+//
+// Example:
+//
+//	args := []interface{}{"Just some chat message"}
+//
+//	err := room.EmitPeers(
+//	    "new-message",  // Event to emit to peers
+//	    args            // Arguments (may be nil)
+//	);
+func (room *Room) EmitPeers(event string, args []interface{}) error {
+	if room.conn == nil {
+		return fmt.Errorf("Room Id %d is not joined", room.id)
+	}
+	return room.conn.EmitPeers(room.scope, room.id, event, args)
+}
+
 func (room *Room) join(conn *Conn) error {
 	conn.rooms.mux.Lock()
 	defer conn.rooms.mux.Unlock()

version.go

@@ -1,7 +1,7 @@
 package thingsdb
 
 // Version exposes the go-thingsdb version
-const Version = "1.0.7"
+const Version = "1.0.8"
 
 //Publish module:
 //