feat: force reply Pong

planetarium · Dec 12, 2024 · 87973e4 · 87973e4
1 parent 4778de3
commit 87973e4
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/src/Libplanet.Net/Transports/NetMQTransport.cs b/src/Libplanet.Net/Transports/NetMQTransport.cs
@@ -715,6 +715,23 @@ await ReplyMessageAsync(
                                     exc,
                                     "Something went wrong during message processing. {@Frames}",
                                     copied.ToArray());
+
+                                if (e.Socket.TrySendMultipartMessage(
+                                        _messageCodec.Encode(
+                                            new PongMsg(),
+                                            _privateKey,
+                                            _appProtocolVersionOptions.AppProtocolVersion,
+                                            AsPeer,
+                                            DateTimeOffset.UtcNow)))
+                                {
+                                    _logger.Debug("Socket reply has sent to {Socket}", e.Socket);
+                                }
+                                else
+                                {
+                                    _logger.Debug(
+                                        "Socket reply failed to send to {Socket}",
+                                        e.Socket);
+                                }
                             }
                         },
                         CancellationToken.None,