feat(gateway): debug log data I/O

31333337 · Sep 28, 2023 · fecd5b3 · fecd5b3
1 parent d4fdaf8
commit fecd5b3
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cmd/xtrellis/gateway/gateway.go b/cmd/xtrellis/gateway/gateway.go
@@ -234,6 +234,8 @@ func GetMessageForClient(i *coord.RoundInfo, clientId int64) ([]byte, error) {
 			Data:     nil,
 		}
 		message, err = packetPack(packet)
+	} else {
+		utils.DebugLog("⭐ data IN")
 	}
 
 	return message, err
@@ -275,6 +277,7 @@ func CheckFinalMessages(messages [][]byte, numExpected int) bool {
 			panic(err)
 		}
 		msgQueueOut.Enqueue(message)
+		utils.DebugLog("⭐ data OUT [%d][%d] += '%s'", p.StreamId, p.Sequence, p.Data)
 	}
 
 	// compare unique messages with number expected
@@ -307,6 +310,8 @@ func sendPacket(packet *gatewayv1.Packet) {
 		panic(fmt.Sprintf("[Gateway] Error creating message from packet: %v\n", err))
 	}
 
+	utils.DebugLog("[Gateway] Send packet!\n🔶 %v", packet)
+
 	// stage message for a mix-net client to pick it up
 	msgQueueIn.Enqueue(message)
 }