Fixed echo test in webrtccmdline.

Author: sipsorcery

examples/webrtccmdline/EchoServer.cs

@@ -156,7 +156,12 @@ private async static Task Offer(IHttpContext context, int pcTimeout)
                             pc.close();
                         }
                     }, null, pcTimeout * 1000, Timeout.Infinite);
-                    pc.OnClosed += timeout.Dispose;
+
+                    pc.OnClosed += () =>
+                    {
+                        timeout.Dispose();
+                        logger.LogInformation("Echo test completed successfully.");
+                    };
                 }
             }
         }
@@ -244,6 +249,7 @@ public async Task<RTCPeerConnection> GotOffer(RTCSessionDescriptionInit offer)
                 {
                     logger.LogInformation($"Data channel got message: {Encoding.UTF8.GetString(data)}");
                     rdc.send(Encoding.UTF8.GetString(data));
+                    pc.Close("test successfully completed");
                 };
             };
 

examples/webrtccmdline/Program.cs

@@ -358,6 +358,41 @@ private static async Task RunCommand(Options options, bool noOptions)
                         {
                             Console.WriteLine($"Set remote description failed {setAnswerResult}.");
                         }
+                        else
+                        {
+                            Console.WriteLine("WebRTC echo server connection established.");
+
+                            var dc = pc.DataChannels.FirstOrDefault();
+
+                            if (dc != null)
+                            {
+                                var pseudo = Crypto.GetRandomString(5);
+
+                                dc.onopen += () =>
+                                {
+                                    logger.LogInformation($"Data channel {dc.label}, stream ID {dc.id} opened.");
+                                    dc.send(pseudo);
+                                };
+
+                                dc.onmessage += async (dc, proto, data) =>
+                                {
+                                    string echoMsg = Encoding.UTF8.GetString(data);
+                                    logger.LogDebug($"data channel onmessage {proto}: {echoMsg}.");
+
+                                    if (echoMsg == pseudo)
+                                    {
+                                        logger.LogInformation($"Data channel echo test success.");
+                                        pc.Close("test success");
+                                        await Task.Delay(500);
+                                        exitCts.Cancel();
+                                    }
+                                    else
+                                    {
+                                        logger.LogWarning($"Data channel echo test failed, echoed message of {echoMsg} did not match original of {pseudo}.");
+                                    }
+                                };
+                            }
+                        }
                     }
                     else
                     {