Merge pull request #476 from AArnott/traceTransmissionFailures

Trace message transmission failures

Author: AArnott

src/StreamJsonRpc.Tests/JsonRpcTests.cs

@@ -955,6 +955,18 @@ public async Task ReportProgressWithUnserializableData_LeavesTraceEvidence()
         }
     }
 
+    [Fact]
+    public async Task NotifyAsync_LeavesTraceEvidenceOnFailure()
+    {
+        var exception = await Assert.ThrowsAnyAsync<Exception>(() => this.clientRpc.NotifyAsync("DoesNotMatter", new TypeThrowsWhenSerialized()));
+
+        // Verify that the trace explains what went wrong with the original exception message.
+        while (!this.clientTraces.Messages.Any(m => m.Contains("Can't touch this")))
+        {
+            await this.clientTraces.MessageReceived.WaitAsync(this.TimeoutToken);
+        }
+    }
+
     [Fact]
     public async Task InvokeWithParameterObject_ProgressParameterAndFields()
     {

src/StreamJsonRpc/JsonRpc.cs

@@ -381,6 +381,11 @@ public enum TraceEvents
             /// Thus a failure recorded in this event may be followed by a successful deserialization to another parameter type and invocation of a different overload.
             /// </remarks>
             MethodArgumentDeserializationFailure,
+
+            /// <summary>
+            /// An outgoing RPC message was not sent due to an exception, possibly a serialization failure.
+            /// </summary>
+            TransmissionFailed,
         }
 
         /// <summary>
@@ -1721,11 +1726,6 @@ private RemoteRpcException CreateExceptionFromRpcError(JsonRpcError response, st
             {
                 throw new ConnectionLostException(Resources.ConnectionDropped, ex);
             }
-            catch (Exception)
-            {
-                this.OnRequestTransmissionAborted(request);
-                throw;
-            }
         }
 
         private JsonRpcError CreateError(JsonRpcRequest request, Exception exception)
@@ -2592,6 +2592,12 @@ private async ValueTask TransmitAsync(JsonRpcMessage message, CancellationToken
                     this.OnJsonRpcDisconnected(e);
                 }
 
+                this.TraceSource.TraceEvent(TraceEventType.Error, (int)TraceEvents.TransmissionFailed, "Exception thrown while transmitting message: {0}", exception);
+                if (message is JsonRpcRequest request)
+                {
+                    this.OnRequestTransmissionAborted(request);
+                }
+
                 throw;
             }
         }

src/StreamJsonRpc/netcoreapp2.1/PublicAPI.Unshipped.txt

@@ -1,5 +1,6 @@
 StreamJsonRpc.DisconnectedReason.RemoteProtocolViolation = 6 -> StreamJsonRpc.DisconnectedReason
 StreamJsonRpc.JsonRpc.DispatchCompletion.get -> System.Threading.Tasks.Task!
+StreamJsonRpc.JsonRpc.TraceEvents.TransmissionFailed = 18 -> StreamJsonRpc.JsonRpc.TraceEvents
 StreamJsonRpc.JsonRpcEnumerableSettings.Prefetch.get -> int
 StreamJsonRpc.JsonRpcEnumerableSettings.Prefetch.set -> void
 StreamJsonRpc.JsonRpcTargetOptions.UseSingleObjectParameterDeserialization.get -> bool

src/StreamJsonRpc/netstandard2.0/PublicAPI.Unshipped.txt

@@ -1,5 +1,6 @@
 StreamJsonRpc.DisconnectedReason.RemoteProtocolViolation = 6 -> StreamJsonRpc.DisconnectedReason
 StreamJsonRpc.JsonRpc.DispatchCompletion.get -> System.Threading.Tasks.Task!
+StreamJsonRpc.JsonRpc.TraceEvents.TransmissionFailed = 18 -> StreamJsonRpc.JsonRpc.TraceEvents
 StreamJsonRpc.JsonRpcEnumerableSettings.Prefetch.get -> int
 StreamJsonRpc.JsonRpcEnumerableSettings.Prefetch.set -> void
 StreamJsonRpc.JsonRpcTargetOptions.UseSingleObjectParameterDeserialization.get -> bool