add info logs

Author: lorux0

src/DCLPulse/Messaging/HandshakeHandler.cs

@@ -12,7 +12,8 @@ public class HandshakeHandler(MessagePipe messagePipe,
     PeerStateFactory peerStateFactory,
     SnapshotBoard snapshotBoard,
     IdentityBoard identityBoard,
-    ITransport transport) : IMessageHandler
+    ITransport transport,
+    ILogger<HandshakeHandler> logger) : IMessageHandler
 {
     public void Handle(Dictionary<PeerIndex, PeerState> peers, PeerIndex from, ClientMessage message)
     {
@@ -31,6 +32,8 @@ public void Handle(Dictionary<PeerIndex, PeerState> peers, PeerIndex from, Clien
                 },
             }, ITransport.PacketMode.RELIABLE));
 
+            logger.LogInformation("Handshake validation failed: cannot parse auth-chain");
+
             return;
         }
 
@@ -60,8 +63,13 @@ public void Handle(Dictionary<PeerIndex, PeerState> peers, PeerIndex from, Clien
             peers[from] = peer;
 
             if (identityBoard.TryGetPeerIndexByWallet(peer.WalletId, out PeerIndex duplicatedPeer))
+            {
                 if (duplicatedPeer != from)
+                {
                     transport.Disconnect(duplicatedPeer, ITransport.DisconnectReason.DuplicateSession);
+                    logger.LogInformation("Duplicated peer found {Wallet}, disconnecting peer {Peer}", result.UserAddress, duplicatedPeer);
+                }
+            }
 
             identityBoard.Set(from, result.UserAddress);
             snapshotBoard.SetActive(from);
@@ -73,6 +81,8 @@ public void Handle(Dictionary<PeerIndex, PeerState> peers, PeerIndex from, Clien
                     Success = true,
                 },
             }, ITransport.PacketMode.RELIABLE));
+
+            logger.LogInformation("Peer handshake accepted with wallet {Wallet} - peerId {Peer}", result.UserAddress, from);
         }
         catch (Exception e)
         {
@@ -84,6 +94,8 @@ public void Handle(Dictionary<PeerIndex, PeerState> peers, PeerIndex from, Clien
                     Error = e.Message,
                 },
             }, ITransport.PacketMode.RELIABLE));
+
+            logger.LogInformation("Handshake validation failed: {Error}", e.Message);
         }
     }
 }

src/DCLPulse/Peers/PeerIndex.cs

@@ -5,14 +5,9 @@ namespace Pulse.Peers;
 ///     It's up to the Transport Service implementation to ensure Indexing (instead of non-sequential IDs).
 ///     Always in the range [0, maxPeers). Safe to use as a direct array index.
 /// </summary>
-public readonly struct PeerIndex : IEquatable<PeerIndex>
+public readonly struct PeerIndex(uint value) : IEquatable<PeerIndex>
 {
-    public readonly uint Value;
-
-    public PeerIndex(uint value)
-    {
-        Value = value;
-    }
+    public readonly uint Value = value;
 
     public static implicit operator uint(PeerIndex id) =>
         id.Value;
@@ -25,4 +20,13 @@ public override bool Equals(object? obj) =>
 
     public override int GetHashCode() =>
         (int)Value;
+
+    public override string ToString() =>
+        Value.ToString();
+
+    public static bool operator ==(PeerIndex left, PeerIndex right) =>
+        left.Equals(right);
+
+    public static bool operator !=(PeerIndex left, PeerIndex right) =>
+        !(left == right);
 }

src/DCLPulse/Peers/PeersManager.cs

@@ -26,6 +26,7 @@ public sealed class PeersManager : BackgroundService
 {
     private readonly MessagePipe messagePipe;
     private readonly ILogger<PeersManager> logger;
+    private readonly ILogger<PeerSimulation> peerSimulationLogger;
     private readonly ITimeProvider timeProvider;
     private readonly PeerStateFactory peerStateFactory;
     private readonly IAreaOfInterest areaOfInterest;
@@ -55,13 +56,15 @@ public PeersManager(
         IdentityBoard identityBoard,
         PeerOptions peerOptions,
         ILogger<PeersManager> logger,
+        ILogger<PeerSimulation> peerSimulationLogger,
         ITimeProvider timeProvider,
         Dictionary<ClientMessage.MessageOneofCase, IMessageHandler> messageHandlers,
         ITransport transport,
         ProfileBoard profileBoard)
     {
         this.messagePipe = messagePipe;
         this.logger = logger;
+        this.peerSimulationLogger = peerSimulationLogger;
         this.timeProvider = timeProvider;
         this.messageHandlers = messageHandlers;
         this.transport = transport;
@@ -100,7 +103,7 @@ protected override Task ExecuteAsync(CancellationToken stoppingToken)
         {
             var simulation = new PeerSimulation(
                 areaOfInterest, snapshotBoard, spatialGrid, identityBoard,
-                messagePipe, peerOptions.SimulationSteps, timeProvider, transport, profileBoard);
+                messagePipe, peerOptions.SimulationSteps, timeProvider, transport, profileBoard, peerSimulationLogger);
 
             tasks[i + 1] = WorkerAsync(i, messageChannels[i].Reader,
                 peerLifeCycleChannels[i].Reader, simulation, stoppingToken);
@@ -197,6 +200,8 @@ internal void DrainPeerLifeCycleEvents(ChannelReader<PeerLifeCycleEvent> reader,
                     peerState.ConnectionState = PeerConnectionState.PENDING_AUTH;
                     peerState.TransportState = peerState.TransportState with { ConnectionTime = timeProvider.MonotonicTime };
                     peers[from] = peerState;
+
+                    logger.LogInformation("Peer connected {Peer}", from);
                 }
                 else if (evt.Type == PeerEventType.Disconnected)
                 {
@@ -211,6 +216,8 @@ internal void DrainPeerLifeCycleEvents(ChannelReader<PeerLifeCycleEvent> reader,
                     };
 
                     peers[from] = peerState;
+
+                    logger.LogInformation("Peer disconnected {Peer}", from);
                 }
             }
             catch (Exception ex)

src/DCLPulse/Peers/Simulation/PeerSimulation.cs

@@ -30,6 +30,7 @@ public sealed class PeerSimulation : IPeerSimulation
     private readonly ITimeProvider timeProvider;
     private readonly ITransport transport;
     private readonly ProfileBoard profileBoard;
+    private readonly ILogger<PeerSimulation> logger;
 
     /// <summary>
     ///     Per-observer views: observer PeerIndex → (subject PeerIndex → view).
@@ -66,7 +67,8 @@ public PeerSimulation(
         uint[] simulationSteps,
         ITimeProvider timeProvider,
         ITransport transport,
-        ProfileBoard profileBoard)
+        ProfileBoard profileBoard,
+        ILogger<PeerSimulation> logger)
     {
         this.areaOfInterest = areaOfInterest;
         this.snapshotBoard = snapshotBoard;
@@ -77,6 +79,7 @@ public PeerSimulation(
         this.timeProvider = timeProvider;
         this.transport = transport;
         this.profileBoard = profileBoard;
+        this.logger = logger;
 
         BaseTickMs = simulationSteps[0];
         tierDivisors = new uint[simulationSteps.Length];
@@ -98,6 +101,7 @@ public void SimulateTick(Dictionary<PeerIndex, PeerState> peers, uint tickCounte
                 {
                     // Trigger disconnection flow which will mark the peer as DISCONNECTING and eventually removed
                     transport.Disconnect(observerId, ITransport.DisconnectReason.AuthTimeout);
+                    logger.LogInformation("Peer {Peer} disconnected due to authentication timed out", observerId);
                     continue;
                 }
             }
@@ -112,6 +116,7 @@ public void SimulateTick(Dictionary<PeerIndex, PeerState> peers, uint tickCounte
                     identityBoard.Clear(observerId);
                     observerViews.Remove(observerId);
                     peersToBeRemoved.Add(observerId);
+                    logger.LogInformation("Peer {Peer} removed after disconnected", observerId);
                     continue;
                 }
             }