Compare commits
1
Commits
master
..
61e2d39bee
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
61e2d39bee |
@@ -1,21 +0,0 @@
|
|||||||
MIT License
|
|
||||||
|
|
||||||
Copyright (c) 2024 00asdf, GHXX
|
|
||||||
|
|
||||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
||||||
of this software and associated documentation files (the "Software"), to deal
|
|
||||||
in the Software without restriction, including without limitation the rights
|
|
||||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
||||||
copies of the Software, and to permit persons to whom the Software is
|
|
||||||
furnished to do so, subject to the following conditions:
|
|
||||||
|
|
||||||
The above copyright notice and this permission notice shall be included in all
|
|
||||||
copies or substantial portions of the Software.
|
|
||||||
|
|
||||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
||||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
||||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
||||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
||||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
||||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
||||||
SOFTWARE.
|
|
||||||
@@ -24,7 +24,7 @@ public sealed class HttpServer {
|
|||||||
Port = port;
|
Port = port;
|
||||||
conf = configuration;
|
conf = configuration;
|
||||||
listener = new HttpListener();
|
listener = new HttpListener();
|
||||||
listener.Prefixes.Add($"http://127.0.0.1:{port}/");
|
listener.Prefixes.Add($"http://localhost:{port}/");
|
||||||
mainLogger = new(LogOutputTopic.Main, conf);
|
mainLogger = new(LogOutputTopic.Main, conf);
|
||||||
requestLogger = new(LogOutputTopic.Request, conf);
|
requestLogger = new(LogOutputTopic.Request, conf);
|
||||||
}
|
}
|
||||||
@@ -213,7 +213,7 @@ public sealed class HttpServer {
|
|||||||
|
|
||||||
private readonly Dictionary<Type, IParameterConverter> stringToTypeParameterConverters = new();
|
private readonly Dictionary<Type, IParameterConverter> stringToTypeParameterConverters = new();
|
||||||
|
|
||||||
private string NormalizeUrlPath(string url) {
|
private static string NormalizeUrlPath(string url) {
|
||||||
var fwdSlashUrl = url.Replace('\\', '/');
|
var fwdSlashUrl = url.Replace('\\', '/');
|
||||||
|
|
||||||
var segments = fwdSlashUrl.Trim('/').Split('/', StringSplitOptions.RemoveEmptyEntries).ToList();
|
var segments = fwdSlashUrl.Trim('/').Split('/', StringSplitOptions.RemoveEmptyEntries).ToList();
|
||||||
@@ -242,12 +242,7 @@ public sealed class HttpServer {
|
|||||||
}
|
}
|
||||||
rv.AppendJoin('/', simplifiedSegmentsReversed.Reverse<string>());
|
rv.AppendJoin('/', simplifiedSegmentsReversed.Reverse<string>());
|
||||||
|
|
||||||
var suffix = (rv.ToString().TrimEnd('/') + (fwdSlashUrl.EndsWith('/') ? "/" : "")).TrimStart('/');
|
return '/' + (rv.ToString().TrimEnd('/') + (fwdSlashUrl.EndsWith('/') ? "/" : "")).TrimStart('/');
|
||||||
if (conf.TrimTrailingSlash) {
|
|
||||||
suffix = suffix.TrimEnd('/');
|
|
||||||
}
|
|
||||||
|
|
||||||
return '/' + suffix;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task ProcessRequestAsync(HttpListenerContext ctx) {
|
private async Task ProcessRequestAsync(HttpListenerContext ctx) {
|
||||||
@@ -333,18 +328,10 @@ public sealed class HttpServer {
|
|||||||
var splittedReqPath = reqPath[1..].Split('/');
|
var splittedReqPath = reqPath[1..].Split('/');
|
||||||
for (int i = 0; i < pparams.Count; i++) {
|
for (int i = 0; i < pparams.Count; i++) {
|
||||||
var pparam = pparams[i];
|
var pparam = pparams[i];
|
||||||
string paramValue;
|
|
||||||
if (pparam.IsCatchAll)
|
if (pparam.IsCatchAll)
|
||||||
paramValue = string.Join('/', splittedReqPath[pparam.SegmentStartPos..]);
|
convertedMParamValues[pparam.ArgPos] = string.Join('/', splittedReqPath[pparam.SegmentStartPos..]);
|
||||||
else
|
else
|
||||||
paramValue = splittedReqPath[pparam.SegmentStartPos];
|
convertedMParamValues[pparam.ArgPos] = splittedReqPath[pparam.SegmentStartPos];
|
||||||
|
|
||||||
if (stringToTypeParameterConverters[pparam.Type].TryConvertFromString(paramValue, out var res))
|
|
||||||
convertedMParamValues[pparam.ArgPos] = res;
|
|
||||||
else {
|
|
||||||
await HandleDefaultErrorPageAsync(rc, HttpStatusCode.BadRequest);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -13,10 +13,6 @@ public class SimpleHttpServerConfiguration {
|
|||||||
/// See description of <see cref="DisableLogMessagePrinting"/>
|
/// See description of <see cref="DisableLogMessagePrinting"/>
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public CustomLogMessageHandler? LogMessageHandler { get; init; } = null;
|
public CustomLogMessageHandler? LogMessageHandler { get; init; } = null;
|
||||||
/// <summary>
|
|
||||||
/// If set to true, paths ending with / are identical to paths without said trailing slash. E.g. /index is then the same as /index/
|
|
||||||
/// </summary>
|
|
||||||
public bool TrimTrailingSlash { get; init; } = true;
|
|
||||||
|
|
||||||
public SimpleHttpServerConfiguration() { }
|
public SimpleHttpServerConfiguration() { }
|
||||||
|
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ internal record EndpointInvocationInfo {
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
internal readonly object? typeInstanceReference;
|
internal readonly object? typeInstanceReference;
|
||||||
|
|
||||||
public EndpointInvocationInfo(MethodInfo methodInfo, List<PathParameterInfo> pathParameters, List<QueryParameterInfo> queryParameters, InternalEndpointCheckAttribute[] requiredChecks,
|
public EndpointInvocationInfo(MethodInfo methodInfo, List<PathParameterInfo> pathParameters, List<QueryParameterInfo> queryParameters, InternalEndpointCheckAttribute[] requiredChecks,
|
||||||
object? typeInstanceReference) {
|
object? typeInstanceReference) {
|
||||||
|
|
||||||
this.methodInfo = methodInfo ?? throw new ArgumentNullException(nameof(methodInfo));
|
this.methodInfo = methodInfo ?? throw new ArgumentNullException(nameof(methodInfo));
|
||||||
|
|||||||
@@ -22,12 +22,12 @@ internal class PathTree<T> where T : class {
|
|||||||
throw new Exception($"Found illegal catchall-wildcard in path: '{string.Join('/', path)}'");
|
throw new Exception($"Found illegal catchall-wildcard in path: '{string.Join('/', path)}'");
|
||||||
}
|
}
|
||||||
|
|
||||||
var leafdata = unpackedLeafData[i] ?? throw new ArgumentNullException("Leafdata must not be null!");
|
var leafdata = unpackedLeafData[i];
|
||||||
rootNode.AddSuccessor(path, leafdata);
|
rootNode.AddSuccessor(path, leafdata);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
internal bool TryGetPath(string reqPath, [MaybeNullWhen(false)] out T endpoint) {
|
internal bool TryGetPath(string reqPath, [MaybeNullWhen(false)] out T? endpoint) {
|
||||||
if (rootNode == null) {
|
if (rootNode == null) {
|
||||||
endpoint = null;
|
endpoint = null;
|
||||||
return false;
|
return false;
|
||||||
@@ -58,16 +58,16 @@ internal class PathTree<T> where T : class {
|
|||||||
|
|
||||||
// return found path
|
// return found path
|
||||||
endpoint = currNode.leafData;
|
endpoint = currNode.leafData;
|
||||||
return endpoint != null;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
private class Node {
|
private class Node {
|
||||||
public T? leafData = null; // null means that this is a node without a value (e.g. when it is just part of a path)
|
public T? leafData = null;
|
||||||
public Dictionary<string, Node>? next = null;
|
public Dictionary<string, Node>? next = null;
|
||||||
public Node? pathWildcardNext = null; // path wildcard
|
public Node? pathWildcardNext = null; // path wildcard
|
||||||
public Node? catchAllNext = null; // trailing-catchall wildcard
|
public Node? catchAllNext = null; // trailing-catchall wildcard
|
||||||
|
|
||||||
public void AddSuccessor(string[] segments, T newLeafData) {
|
public void AddSuccessor(string[] segments, T? newLeafData) {
|
||||||
if (segments.Length == 0) { // actually add the data to this node
|
if (segments.Length == 0) { // actually add the data to this node
|
||||||
Assert(leafData == null);
|
Assert(leafData == null);
|
||||||
leafData = newLeafData;
|
leafData = newLeafData;
|
||||||
@@ -83,15 +83,18 @@ internal class PathTree<T> where T : class {
|
|||||||
catchAllNext = new();
|
catchAllNext = new();
|
||||||
catchAllNext.AddSuccessor(segments[1..], newLeafData);
|
catchAllNext.AddSuccessor(segments[1..], newLeafData);
|
||||||
return;
|
return;
|
||||||
} else { // must be single wildcard otherwise
|
} else { // must be single wildcard otherwise
|
||||||
pathWildcardNext ??= new();
|
Assert(pathWildcardNext == null);
|
||||||
|
pathWildcardNext = new();
|
||||||
pathWildcardNext.AddSuccessor(segments[1..], newLeafData);
|
pathWildcardNext.AddSuccessor(segments[1..], newLeafData);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// otherwise we want to add a new constant path successor
|
// otherwise we want to add a new constant path successor
|
||||||
next ??= new();
|
if (next == null) {
|
||||||
|
next = new();
|
||||||
|
}
|
||||||
|
|
||||||
if (next.TryGetValue(seg, out var existingNode)) {
|
if (next.TryGetValue(seg, out var existingNode)) {
|
||||||
existingNode.AddSuccessor(segments[1..], newLeafData);
|
existingNode.AddSuccessor(segments[1..], newLeafData);
|
||||||
|
|||||||
@@ -35,23 +35,22 @@ public class RequestContext : IDisposable {
|
|||||||
|
|
||||||
public void SetStatusCode(HttpStatusCode status) => SetStatusCode((int) status);
|
public void SetStatusCode(HttpStatusCode status) => SetStatusCode((int) status);
|
||||||
|
|
||||||
public async Task SetStatusCodeWriteLineDisposeAsync(HttpStatusCode status, string message) {
|
|
||||||
SetStatusCode(status);
|
|
||||||
await WriteLineToRespAsync(message);
|
|
||||||
await RespWriter.FlushAsync();
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task SetStatusCodeAndDisposeAsync(int status) {
|
public async Task SetStatusCodeAndDisposeAsync(int status) {
|
||||||
using (this) {
|
using (this) {
|
||||||
SetStatusCode(status);
|
SetStatusCode(status);
|
||||||
if (status != (int)HttpStatusCode.NotModified) { // NotModified must not write any data to response
|
await WriteToRespAsync("\n\n");
|
||||||
await WriteToRespAsync("\n\n");
|
await RespWriter.FlushAsync();
|
||||||
await RespWriter.FlushAsync();
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async Task SetStatusCodeAndDisposeAsync(HttpStatusCode status) {
|
||||||
|
using (this) {
|
||||||
|
SetStatusCode((int) status);
|
||||||
|
await WriteToRespAsync("\n\n");
|
||||||
|
await RespWriter.FlushAsync();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task SetStatusCodeAndDisposeAsync(HttpStatusCode status) => await SetStatusCodeAndDisposeAsync((int) status);
|
|
||||||
|
|
||||||
public async Task SetStatusCodeAndDisposeAsync(int status, string description) {
|
public async Task SetStatusCodeAndDisposeAsync(int status, string description) {
|
||||||
using (this) {
|
using (this) {
|
||||||
|
|||||||
Reference in New Issue
Block a user