wip

Author: CypherPotato

src/Entity/StringValue.cs

@@ -7,18 +7,20 @@
 // File name:   StringValue.cs
 // Repository:  https://github.com/sisk-http/core
 
+using System.Runtime.CompilerServices;
+
 namespace Sisk.Core.Entity;
 
 /// <summary>
 /// Represents an instance that hosts a string value and allows conversion to common types.
 /// </summary>
 /// <definition>
-/// public class StringValue
+/// public struct StringValue
 /// </definition>
 /// <type>
 /// Class
 /// </type>
-public class StringValue
+public struct StringValue
 {
     private readonly string? _ref;
     private readonly string argName;
@@ -105,6 +107,20 @@ public string GetString()
         return _ref!;
     }
 
+    /// <summary>
+    /// Gets a <see cref="char"/> from this <see cref="StringValue"/>. This method will throw an <see cref="NullReferenceException"/> if
+    /// the value stored in this instance is null.
+    /// </summary>
+    /// <returns>An non-null char value.</returns>
+    public char GetChar()
+    {
+        ThrowIfNull();
+        if (_ref!.Length != 1)
+            throw new FormatException(string.Format(SR.ValueItem_CastException, _ref, argName, "char"));
+
+        return _ref[0];
+    }
+
     /// <summary>
     /// Gets a <see cref="Int32"/> from this <see cref="StringValue"/>.
     /// </summary>
@@ -257,6 +273,17 @@ public Guid GetGuid()
         }
     }
 
+    /// <summary>
+    /// Gets an not null value from the specified <typeparamref name="T"/>.
+    /// </summary>
+    /// <typeparam name="T">The type to convert the value to.</typeparam>
+    public T Get<T>() where T : struct
+    {
+        ThrowIfNull();
+        object result = Internal.Parseable.ParseInternal<T>(_ref!);
+        return Unsafe.Unbox<T>(result);
+    }
+
     void ThrowIfNull()
     {
         if (IsNull)

src/Ext/CircularBuffer.cs

@@ -9,7 +9,7 @@
 
 using System.Collections;
 
-namespace System;
+namespace Sisk.Core.Entity;
 
 /// <summary>
 /// Represents an thread-safe, fixed-capacity circular buffer that stores elements of <typeparamref name="T"/>.
@@ -18,7 +18,7 @@ namespace System;
 /// <nodoc/>
 public class CircularBuffer<T> : IEnumerable<T>
 {
-    readonly T[] items;
+    T[] items;
 
     int capacity = 0;
 
@@ -51,12 +51,36 @@ public void Add(T item)
         }
     }
 
+    /// <summary>
+    /// Clears the circular buffer contents and recreates the array.
+    /// </summary>
+    public void Clear()
+    {
+        items = new T[capacity];
+    }
+
+    /// <summary>
+    /// Changes the capacity of elements in this circular buffer to the specified new size.
+    /// </summary>
+    /// <param name="capacity">The new size for this circular buffer.</param>
+    public void Resize(int capacity)
+    {
+        if (capacity <= 0) throw new ArgumentException("Capacity cannot be less or equals to zero.");
+        Array.Resize(ref items, capacity);
+        this.capacity = capacity;
+    }
+
     /// <summary>
     /// Returns an array representation of this <see cref="CircularBuffer{T}"/> items in their defined
     /// positions within the capacity.
     /// </summary>
     public T[] ToArray() => items;
 
+    /// <summary>
+    /// Creates an new <see cref="ReadOnlySpan{T}"/> over the circular buffer.
+    /// </summary>
+    public ReadOnlySpan<T> ToSpan() => new ReadOnlySpan<T>(items);
+
     /// <summary>
     /// Gets the current capacity of this <see cref="CircularBuffer{T}"/>.
     /// </summary>

src/Http/Handlers/HttpServerHandler.cs

@@ -49,6 +49,34 @@ protected virtual void OnServerStarting(HttpServer server) { }
     protected virtual void OnServerStarted(HttpServer server) { }
     internal void InvokeOnServerStarted(HttpServer server) => OnServerStarted(server);
 
+    /// <summary>
+    /// Method that is called before the <see cref="HttpServer"/> stop, when it is
+    /// stopping from listening requests.
+    /// </summary>
+    /// <param name="server">The Http server entity which is stopping.</param>
+    /// <definition>
+    /// protected virtual void OnServerStopping(HttpServer server)
+    /// </definition>
+    /// <type>
+    /// Virtual method
+    /// </type>
+    protected virtual void OnServerStopping(HttpServer server) { }
+    internal void InvokeOnServerStopping(HttpServer server) => OnServerStopping(server);
+
+    /// <summary>
+    /// Method that is called after the <see cref="HttpServer"/> is stopped, meaning
+    /// it has stopped from listening to requests.
+    /// </summary>
+    /// <param name="server">The Http server entity which has stopped.</param>
+    /// <definition>
+    /// protected virtual void OnServerStopped(HttpServer server)
+    /// </definition>
+    /// <type>
+    /// Virtual method
+    /// </type>
+    protected virtual void OnServerStopped(HttpServer server) { }
+    internal void InvokeOnServerStopped(HttpServer server) => OnServerStopped(server);
+
     /// <summary>
     /// Method that is called when an <see cref="Router"/> is binded to the Http server.
     /// </summary>

src/Http/Handlers/HttpServerHandlerRepository.cs

@@ -8,6 +8,9 @@
 // Repository:  https://github.com/sisk-http/core
 
 using Sisk.Core.Routing;
+using System.Reflection.Metadata;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
 
 namespace Sisk.Core.Http.Handlers;
 
@@ -28,7 +31,12 @@ public void RegisterHandler(HttpServerHandler handler)
 
     private void CallEvery(Action<HttpServerHandler> action)
     {
-        foreach (HttpServerHandler handler in handlers)
+        Span<HttpServerHandler> hspan = CollectionsMarshal.AsSpan<HttpServerHandler>(handlers);
+        ref HttpServerHandler hpointer = ref MemoryMarshal.GetReference(hspan);
+        for (int i = 0; i < hspan.Length; i++)
+        {
+            HttpServerHandler handler = Unsafe.Add(ref hpointer, i);
+
             try
             {
                 action(handler);
@@ -41,6 +49,7 @@ private void CallEvery(Action<HttpServerHandler> action)
                 }
                 else throw;
             }
+        }
     }
 
     internal void ServerStarting(HttpServer val) => CallEvery(handler => handler.InvokeOnServerStarting(val));
@@ -50,4 +59,6 @@ private void CallEvery(Action<HttpServerHandler> action)
     internal void HttpRequestOpen(HttpRequest val) => CallEvery(handler => handler.InvokeOnHttpRequestOpen(val));
     internal void HttpRequestClose(HttpServerExecutionResult val) => CallEvery(handler => handler.InvokeOnHttpRequestClose(val));
     internal void Exception(Exception val) => CallEvery(handler => handler.InvokeOnException(val));
+    internal void Stopping(HttpServer val) => CallEvery(handler => handler.InvokeOnServerStopping(val));
+    internal void Stopped(HttpServer val) => CallEvery(handler => handler.InvokeOnServerStopped(val));
 }

src/Http/HttpRequest.cs

@@ -609,8 +609,7 @@ public T GetContextBag<T>() where T : notnull
         /// <type>
         /// Method
         /// </type>
-        [Obsolete("This method is deprecated and will be removed in later versions. Use Query[queryKeyName] instead.")]
-        public string? GetQueryValue(string queryKeyName) => Query[queryKeyName];
+        public string? GetQueryValue(string queryKeyName) => Query[queryKeyName].Value;
 
         /// <summary>
         /// Gets the value stored from the <see cref="Query"/> and converts it to the given type.
@@ -619,32 +618,19 @@ public T GetContextBag<T>() where T : notnull
         /// <param name="queryKeyName">The name of the URL parameter. The search is ignore-case.</param>
         /// <param name="defaultValue">The default value that will be returned if the item is not found in the query.</param>
         /// <definition>
-        /// // in .NET 6
         /// public T GetQueryValue{{T}}(string queryKeyName, T defaultValue = default) where T : struct
-        /// 
-        /// // in .NET 7+
-        /// public T GetQueryValue{{T}}(string queryKeyName, T defaultValue = default) where T : struct, IParsable{{T}}
         /// </definition>
         /// <type>
         /// Method
         /// </type>
-        [Obsolete("This method is deprecated and will be removed in later versions. Use Query[queryKeyName] instead.")]
-#if NET6_0
         public T GetQueryValue<T>(string queryKeyName, T defaultValue = default) where T : struct
-#elif NET7_0_OR_GREATER
-        public T GetQueryValue<T>(string queryKeyName, T defaultValue = default) where T : struct, IParsable<T>
-#endif
         {
-            string? value = Query[queryKeyName].MaybeNull()?.GetString();
-            if (value == null) return defaultValue;
+            StringValue value = Query[queryKeyName];
+            if (value.IsNull) return defaultValue;
 
             try
             {
-#if NET6_0
-                return (T)Parseable.ParseInternal<T>(value);
-#elif NET7_0_OR_GREATER
-                return T.Parse(value, null);
-#endif
+                return value.Get<T>();
             }
             catch (Exception)
             {

src/Http/HttpResponse.cs

@@ -7,6 +7,7 @@
 // File name:   HttpResponse.cs
 // Repository:  https://github.com/sisk-http/core
 
+using Sisk.Core.Entity;
 using Sisk.Core.Routing;
 using System.Collections.Specialized;
 using System.Net;
@@ -106,15 +107,15 @@ public static HttpResponse CreateRedirectResponse(RouteAction action)
         public HttpStatusCode Status { get => (HttpStatusCode)StatusInformation.StatusCode; set => StatusInformation = new HttpStatusInformation(value); }
 
         /// <summary>
-        /// Gets a <see cref="NameValueCollection"/> instance of the HTTP response headers.
+        /// Gets a <see cref="HttpHeaderCollection"/> instance of the HTTP response headers.
         /// </summary>
         /// <definition>
-        /// public NameValueCollection Headers { get; }
+        /// public HttpHeaderCollection Headers { get; }
         /// </definition>
         /// <type>
         /// Property
         /// </type>
-        public NameValueCollection Headers { get; private set; } = new NameValueCollection();
+        public HttpHeaderCollection Headers { get; private set; } = new HttpHeaderCollection();
 
         /// <summary>
         /// Gets or sets the HTTP response body contents.

src/Http/HttpServer.cs

@@ -58,7 +58,7 @@ public partial class HttpServer : IDisposable
         internal HttpWebSocketConnectionCollection _wsCollection = new HttpWebSocketConnectionCollection();
         internal List<string>? listeningPrefixes;
         internal HttpServerHandlerRepository handler;
-        
+
         internal AutoResetEvent waitNextEvent = new AutoResetEvent(false);
         internal bool isWaitingNextEvent = false;
         internal HttpServerExecutionResult? waitingExecutionResult;
@@ -221,36 +221,6 @@ out Router router
         /// </type>
         public HttpWebSocketConnectionCollection WebSockets { get => _wsCollection; }
 
-        /// <summary>
-        /// Event that is called when this <see cref="HttpServer"/> computes an request and it's response.
-        /// </summary>
-        /// <definition>
-        /// public event ServerExecutionEventHandler? OnConnectionClose;
-        /// </definition>
-        /// <remarks>
-        /// This event is now obsolete and will be removed in later Sisk versions. Use HttpServerHandlers instead.
-        /// </remarks>
-        /// <type>
-        /// Property
-        /// </type>
-        [Obsolete("This event is now obsolete and will be removed in later Sisk versions. Use HttpServerHandlers instead.")]
-        public event ServerExecutionEventHandler? OnConnectionClose;
-
-        /// <summary>
-        /// Event that is called when this <see cref="HttpServer"/> receives an request.
-        /// </summary>
-        /// <definition>
-        /// public event ReceiveRequestEventHandler? OnConnectionOpen;
-        /// </definition>
-        /// <remarks>
-        /// This event is now obsolete and will be removed in later Sisk versions. Use HttpServerHandlers instead.
-        /// </remarks>
-        /// <type>
-        /// Property
-        /// </type>
-        [Obsolete("This event is now obsolete and will be removed in later Sisk versions. Use HttpServerHandlers instead.")]
-        public event ReceiveRequestEventHandler? OnConnectionOpen;
-
         /// <summary>
         /// Get Sisk version label.
         /// </summary>
@@ -435,8 +405,12 @@ public void Start()
         /// </type>
         public void Stop()
         {
+            handler.Stopping(this);
             _isListening = false;
             httpListener.Stop();
+
+            UnbindRouters();
+            handler.Stopped(this);
         }
 
         /// <summary>
@@ -454,12 +428,5 @@ public void Dispose()
             httpListener.Close();
             ServerConfiguration.Dispose();
         }
-
-        private enum StreamMethodCallback
-        {
-            Nothing,
-            Abort,
-            Close
-        }
     }
 }

src/Http/HttpServerFlags.cs

@@ -238,7 +238,7 @@ public class HttpServerFlags
         /// <summary>
         /// Determines the maximum amount of time an route can process an request, including running request handlers,
         /// reading body and executing the route action. Specify zero for no limit. When the route action running time
-        /// reaches it's timeout, an <see cref="RequestTimeoutException"/> is thrown.
+        /// reaches it's timeout, an RequestTimeoutException is thrown.
         /// </summary>
         /// <docs>
         ///     <p>
@@ -251,6 +251,7 @@ public class HttpServerFlags
         /// <type>
         /// Field
         /// </type>
+        [Obsolete("This property was deprecated and will do nothing. It will be removed in later Sisk versions.", true)]
         public TimeSpan RouteActionTimeout = TimeSpan.Zero;
 
         /// <summary>