summaryrefslogtreecommitdiff
path: root/pkg
diff options
context:
space:
mode:
authorSanto Cariotti <santo@dcariotti.me>2025-04-18 12:45:35 +0200
committerSanto Cariotti <santo@dcariotti.me>2025-04-18 12:45:35 +0200
commit0f21452248783d627ec1a3b4e8a3f8f0d9a69a10 (patch)
treef092883f8e6214667020cfc9f8712bf2cf961f2b /pkg
parent544977d54effa7804386aa40f30a87f5e2365efa (diff)
Log sent messages
Diffstat (limited to 'pkg')
-rw-r--r--pkg/p2p/network.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/pkg/p2p/network.go b/pkg/p2p/network.go
index 3362b4a..2ebec43 100644
--- a/pkg/p2p/network.go
+++ b/pkg/p2p/network.go
@@ -86,13 +86,13 @@ func (n *TCPNetwork) Send(remoteID NetworkID, payload []byte) error {
return fmt.Errorf("not connected to peer %s", remoteID)
}
- msg := Message{
+ message := Message{
Payload: payload,
Source: n.listener.Addr().String(),
Timestamp: time.Now().Unix(),
}
- data, err := json.Marshal(msg)
+ data, err := json.Marshal(message)
if err != nil {
return fmt.Errorf("failed to marshal message: %v", err)
}
@@ -107,6 +107,8 @@ func (n *TCPNetwork) Send(remoteID NetworkID, payload []byte) error {
go n.retryConnect(remoteID, "")
return fmt.Errorf("failed to send message: %v", err)
+ } else {
+ n.Logger.Sugar().Infof("Sent message to '%s': %s", conn.LocalAddr(), message.Payload)
}
return nil