source: binary-improvements/MapRendering/WebCommandResult.cs@ 464

using System;
using System.Collections.Generic;
using System.IO;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;
using Utf8Json;
using Webserver;

namespace AllocsFixes.Web {
        public class WebCommandResult : IConsoleConnection {
                public enum ResultType {
                        Full,
                        ResultOnly,
                        Raw,
                }

                public static int handlingCount;
                public static int currentHandlers;
                public static long totalHandlingTime;
                private readonly string command;
                private readonly string parameters;

                private readonly RequestContext context;
                private readonly ResultType responseType;

                public WebCommandResult (string _command, string _parameters, ResultType _resultType, RequestContext _context) {
                        Interlocked.Increment (ref handlingCount);
                        Interlocked.Increment (ref currentHandlers);

                        context = _context;
                        command = _command;
                        parameters = _parameters;
                        responseType = _resultType;
                }
                
                private static readonly byte[] jsonKeyCommand = JsonWriter.GetEncodedPropertyNameWithBeginObject ("command");
                private static readonly byte[] jsonKeyParameters = JsonWriter.GetEncodedPropertyNameWithPrefixValueSeparator ("parameters");
                private static readonly byte[] jsonKeyResult = JsonWriter.GetEncodedPropertyNameWithPrefixValueSeparator ("result");

                public void SendLines (List<string> _output) {
//                      MicroStopwatch msw = new MicroStopwatch ();

                        StringBuilder sb = new StringBuilder ();
                        foreach (string line in _output) {
                                sb.AppendLine (line);
                        }

                        string result = sb.ToString ();

                        try {
                                context.Response.SendChunked = false;

                                if (responseType == ResultType.Raw) {
                                        WebUtils.WriteText (context.Response, result);
                                } else {
                                        JsonWriter writer = new JsonWriter ();

                                        if (responseType == ResultType.ResultOnly) {
                                                writer.WriteString (result);
                                        } else {
                                                writer.WriteRaw (jsonKeyCommand);
                                                writer.WriteString (command);
                                                
                                                writer.WriteRaw (jsonKeyParameters);
                                                writer.WriteString (parameters);
                                                
                                                writer.WriteRaw (jsonKeyResult);
                                                writer.WriteString (result);
                                                
                                                writer.WriteEndObject ();
                                        }

                                        WebUtils.WriteJsonData (context.Response, ref writer);
                                }
                        } catch (IOException e) {
                                if (e.InnerException is SocketException) {
                                        Log.Out ($"Error in WebCommandResult.SendLines(): Remote host closed connection: {e.InnerException.Message}");
                                } else {
                                        Log.Out ($"Error (IO) in WebCommandResult.SendLines(): {e}");
                                }
                        } catch (Exception e) {
                                Log.Out ($"Error in WebCommandResult.SendLines(): {e}");
                        } finally {
                                context.Response?.Close ();

                                //                              msw.Stop ();
//                              if (GamePrefs.GetInt (EnumGamePrefs.HideCommandExecutionLog) < 1) {
//                                      totalHandlingTime += msw.ElapsedMicroseconds;
//                                      Log.Out ("WebCommandResult.SendLines(): Took {0} µs", msw.ElapsedMicroseconds);
//                              }

                                Interlocked.Decrement (ref currentHandlers);
                        }
                }

                public void SendLine (string _text) {
                        //throw new NotImplementedException ();
                }

                public void SendLog (string _formattedMessage, string _plainMessage, string _trace, LogType _type, DateTime _timestamp, long _uptime) {
                        //throw new NotImplementedException ();
                }

                public void EnableLogLevel (LogType _type, bool _enable) {
                        //throw new NotImplementedException ();
                }

                public string GetDescription () {
                        return $"WebCommandResult_for_{command}";
                }
        }
}