Changeset 402 for binary-improvements2/WebServer/src/SSE/AbsEvent.cs

Timestamp:

Jan 27, 2023, 7:28:00 PM (22 months ago)

Author:

alloc

Message:

• Major refactoring
• Using Utf8Json for (de)serialization
• Moving APIs to REST
• Removing dependencies from WebServer and MapRenderer to ServerFixes

File:

• binary-improvements2/WebServer/src/SSE/AbsEvent.cs (modified) (4 diffs)

binary-improvements2/WebServer/src/SSE/AbsEvent.cs

@@ -4 +4 @@
 using System.Net.Sockets;
 using System.Text;
-using AllocsFixes.JSON;
 using Webserver.UrlHandlers;
 using HttpListenerResponse = SpaceWizards.HttpListener.HttpListenerResponse;
@@ -20 +19 @@
                 private readonly List<HttpListenerResponse> openStreams = new List<HttpListenerResponse> ();
 
-                private readonly BlockingQueue<(string _eventName, object _data)> sendQueue =
-                        new BlockingQueue<(string _eventName, object _data)> ();
+                private readonly BlockingQueue<(string _eventName, string _data)> sendQueue =
+                        new BlockingQueue<(string _eventName, string _data)> ();
 
                 private int currentlyOpen;
@@ -42 +41 @@
                 }
 
-                protected void SendData (string _eventName, object _data) {
+                protected void SendData (string _eventName, string _data) {
                         sendQueue.Enqueue ((_eventName, _data));
                         Parent.SignalSendQueue ();
                 }
 
-
                 public void ProcessSendQueue () {
                         while (sendQueue.HasData ()) {
-                                (string eventName, object data) = sendQueue.Dequeue ();
+                                (string eventName, string data) = sendQueue.Dequeue ();
                                 
                                 stringBuilder.Append ("event: ");
                                 stringBuilder.AppendLine (eventName);
                                 stringBuilder.Append ("data: ");
-                                
-                                switch (data) {
-                                        case string dataString:
-                                                stringBuilder.AppendLine (dataString);
-                                                break;
-                                        case JsonNode dataJson:
-                                                dataJson.ToString (stringBuilder);
-                                                stringBuilder.AppendLine ("");
-                                                break;
-                                        default:
-                                                logError ("Data is neither string nor JSON.", false);
-                                                continue;
-                                }
+                                stringBuilder.AppendLine (data);
                                 
                                 stringBuilder.AppendLine ("");
+
                                 string output = stringBuilder.ToString ();
                                 stringBuilder.Clear ();
@@ -111 +98 @@
                                                 if (e.InnerException is SocketException se) {
                                                         if (se.SocketErrorCode != SocketError.ConnectionAborted && se.SocketErrorCode != SocketError.Shutdown) {
-                                                                logError ($"SocketError ({se.SocketErrorCode}) while trying to write", true);
+                                                                logError ($"SocketError ({se.SocketErrorCode.ToStringCached ()}) while trying to write", true);
                                                         }
                                                 } else {