Add files via upload

Improvments and changed message, that will be returned.
arne-fuchs · Sep 13, 2021 · 3c3d578 · 3c3d578
1 parent 27c9234
commit 3c3d578
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/plugin.go b/plugin.go
@@ -74,7 +74,7 @@ func run(_ *node.Plugin) {
 	notifyNewMsg := events.NewClosure(func(messageID tangle.MessageID) {
 		messagelayer.Tangle().Storage.Message(messageID).Consume(func(message *tangle.Message) {
 			go func() {
-				server.Broadcast(message.Bytes())
+				server.Broadcast([]byte(message.String()))
 			}()
 		})
 	})

diff --git a/server/server.go b/server/server.go
@@ -135,11 +135,12 @@ func Broadcast(data []byte) {
 
 	idx := int(index.Load())
 	for i := 0; i < idx; i++ {
-		if connectionList[i].active {
-			if _, err := connectionList[i].bufferedConn.Write(data); err != nil {
-				connectionList[i].log.LogInfof("Error writing on connection: %s", err)
-				connectionList[i].active = false
-			}
+		if !connectionList[i].active {
+			continue
+		}
+		if _, err := connectionList[i].bufferedConn.Write(data); err != nil {
+			connectionList[i].log.LogInfof("Error writing on connection: %s", err)
+			connectionList[i].active = false
 		}
 	}
 	//Tidy up array of unused connections