Log incoming and outgoing messages

src/FieldElementSubsystems/Connections/EulynxBaseline4R1/PointToInterlockingConnection.cs

@@ -155,6 +155,7 @@ public async Task<GenericPointPosition> ReceiveMovePointCommand(CancellationToke
 
     private async Task SendMessage(Message message)
     {
+        _logger.LogInformation("Sending SCI message: {}", message);
         await SendMessage(message.ToByteArray());
     }
 
@@ -170,6 +171,7 @@ private async Task<T> ReceiveMessage<T>(CancellationToken cancellationToken) whe
         if (CurrentConnection == null) throw new InvalidOperationException("Connection is null. Did you call Connect()?");
 
         var message = Message.FromBytes(await CurrentConnection.ReceiveAsync(cancellationToken));
+        _logger.LogInformation("Received SCI message: {}", message);
         if (message is T tMessage) return tMessage;
         _logger.LogError("Unexpected message: {}", message);
         throw new InvalidOperationException("Unexpected message.");

src/FieldElementSubsystems/Connections/EulynxBaseline4R2/PointToInterlockingConnection.cs

@@ -155,6 +155,7 @@ public async Task<GenericPointPosition> ReceiveMovePointCommand(CancellationToke
 
     private async Task SendMessage(Message message)
     {
+        _logger.LogInformation("Sending SCI message: {}", message);
         await SendMessage(message.ToByteArray());
     }
 
@@ -170,6 +171,7 @@ private async Task<T> ReceiveMessage<T>(CancellationToken cancellationToken) whe
         if (CurrentConnection == null) throw new InvalidOperationException("Connection is null. Did you call Connect()?");
 
         var message = Message.FromBytes(await CurrentConnection.ReceiveAsync(cancellationToken));
+        _logger.LogInformation("Received SCI message: {}", message);
         if (message is T tMessage) return tMessage;
         _logger.LogError("Unexpected message: {}", message);
         throw new InvalidOperationException("Unexpected message.");

src/Point/Connections/GrpcConnection.cs

@@ -14,12 +14,9 @@ namespace EulynxLive.Point.Connections;
 class GrpcConnection : IConnection
 {
     readonly AsyncDuplexStreamingCall<SciPacket, SciPacket>? _connection;
-    private readonly CancellationToken _stoppingToken;
 
     public GrpcConnection(Metadata? metadata, string remoteEndpoint, CancellationToken stoppingToken)
     {
-        _stoppingToken = stoppingToken;
-
         var channel = GrpcChannel.ForAddress(remoteEndpoint);
         var client = new RastaClient(channel);
         _connection = client.Stream(metadata, cancellationToken: stoppingToken);