clean Sample Code

Author: doghappy

src/SocketIOClient.Sample/Program.cs

@@ -1,9 +1,7 @@
-using SocketIOClient.WebSocketClient;
-using System;
+using System;
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Text;
-using System.Text.Json.Serialization;
 using System.Threading.Tasks;
 
 namespace SocketIOClient.Sample
@@ -16,24 +14,16 @@ static async Task Main(string[] args)
             Console.OutputEncoding = Encoding.UTF8;
             Trace.Listeners.Add(new TextWriterTraceListener(Console.Out));
 
-            //var uri = new Uri("http://localhost:11003/nsp");
-            var uri = new Uri("http://localhost:11000");
-            //var uri = new Uri("http://localhost:11003");
-            //var uri = new Uri("http://jd.doghappy.wang:11000");
-            //var uri = new Uri("https://socket-io.doghappy.wang");
+            var uri = new Uri("http://localhost:11003");
 
             var socket = new SocketIO(uri, new SocketIOOptions
             {
                 Query = new Dictionary<string, string>
                 {
-                    {"token", "io" }
-                    //{"token", "v3" }
-                },
-                //EIO = 4
+                    {"token", "V3" }
+                }
             });
 
-            socket.GetConnectInterval = () => new MyConnectInterval();
-
 
             //var client = socket.Socket as ClientWebSocket;
             //client.Config = options =>
@@ -60,38 +50,12 @@ static async Task Main(string[] args)
 
             await socket.ConnectAsync();
 
-            socket.On("ContinuouslyReceiveData", response =>
-            {
-                var data = response.GetValue<ContinuouslyReceiveData>();
-                Console.WriteLine(data.Index);
-            });
-
-            //socket.On("bytes", response =>
-            //{
-            //    var bytes = response.GetValue<ByteResponse>();
-            //    Console.WriteLine($"bytes.Source = {bytes.Source}");
-            //    Console.WriteLine($"bytes.ClientSource = {bytes.ClientSource}");
-            //    Console.WriteLine($"bytes.Buffer.Length = {bytes.Buffer.Length}");
-            //    Console.WriteLine($"bytes.Buffer.ToString() = {Encoding.UTF8.GetString(bytes.Buffer)}");
-            //});
-            //socket.OnReceivedEvent += (sender, e) =>
-            //{
-            //    if (e.Event == "bytes")
-            //    {
-            //        var bytes = e.Response.GetValue<ByteResponse>();
-            //        Console.WriteLine($"OnReceivedEvent.Source = {bytes.Source}");
-            //        Console.WriteLine($"OnReceivedEvent.ClientSource = {bytes.ClientSource}");
-            //        Console.WriteLine($"OnReceivedEvent.Buffer.Length = {bytes.Buffer.Length}");
-            //        Console.WriteLine($"OnReceivedEvent.Buffer.ToString() = {Encoding.UTF8.GetString(bytes.Buffer)}");
-            //    }
-            //};
-
             Console.ReadLine();
         }
 
         private static void Socket_OnReconnecting(object sender, int e)
         {
-            Console.WriteLine($"Reconnecting: attempt = {e}");
+            Console.WriteLine($"{DateTime.Now} Reconnecting: attempt = {e}");
         }
 
         private static void Socket_OnDisconnected(object sender, string e)
@@ -105,49 +69,7 @@ private static async void Socket_OnConnected(object sender, EventArgs e)
             var socket = sender as SocketIO;
             Console.WriteLine("Socket.Id:" + socket.Id);
 
-            await socket.EmitAsync("ContinuouslyReceiveData", new
-            {
-                count = 100,
-                path = "设计表.rar"
-            });
-            //string path = "设计表.rar";
-            //var bytes = System.IO.File.ReadAllBytes(path);
-            //int i = -1;
-            //while (true)
-            //{
-            //    i++;
-            //    await socket.EmitAsync("items_updated", new
-            //    {
-            //        progress = i,
-            //        binary = bytes
-            //    });
-            //}
-            //await socket.EmitAsync("hi", "SocketIOClient.Sample");
-
-
-            //await socket.EmitAsync("ack", response =>
-            //{
-            //    Console.WriteLine(response.ToString());
-            //}, "SocketIOClient.Sample");
-
-            //await socket.EmitAsync("bytes", "c#", new
-            //{
-            //    source = "client007",
-            //    bytes = Encoding.UTF8.GetBytes("dot net")
-            //});
-
-            //socket.On("client binary callback", async response =>
-            //{
-            //    await response.CallbackAsync();
-            //});
-
-            //await socket.EmitAsync("client binary callback", Encoding.UTF8.GetBytes("SocketIOClient.Sample"));
-
-            //socket.On("client message callback", async response =>
-            //{
-            //    await response.CallbackAsync(Encoding.UTF8.GetBytes("CallbackAsync();"));
-            //});
-            //await socket.EmitAsync("client message callback", "SocketIOClient.Sample");
+            await socket.EmitAsync("hi", "SocketIOClient.Sample");
         }
 
         private static void Socket_OnPing(object sender, EventArgs e)
@@ -160,29 +82,4 @@ private static void Socket_OnPong(object sender, TimeSpan e)
             Console.WriteLine("Pong: " + e.TotalMilliseconds);
         }
     }
-
-    class ByteResponse
-    {
-        public string ClientSource { get; set; }
-
-        public string Source { get; set; }
-
-        public byte[] Buffer { get; set; }
-    }
-
-    class ClientCallbackResponse
-    {
-        public string Text { get; set; }
-
-        public byte[] Bytes { get; set; }
-    }
-
-    class ContinuouslyReceiveData
-    {
-        [JsonPropertyName("index")]
-        public int Index { get; set; }
-
-        [JsonPropertyName("file")]
-        public byte[] File { get; set; }
-    }
 }