Program.cs

namespace Hint;


using System.Net;
using System.Text;
using System.Text.Json;
using System.IO;


class Program
{
    static async Task Main(string[] args)
    {
        var configPath = "serverconfig.json";
        var config = File.Exists(configPath)
        ? JsonSerializer.Deserialize<ServerConfig>(File.ReadAllText(configPath)) ?? new ServerConfig()
        : new ServerConfig();


        var exeDir = AppContext.BaseDirectory;
        config = config with { StaticRoot = Path.Combine(exeDir, config.StaticRoot) };
        Console.WriteLine($"[LOG] Static root: {config.StaticRoot}");


        var listener = new HttpListener();
        listener.Prefixes.Add($"http://*:{config.Port}/");
        listener.Start();


        var appManager = new AppManager(config.Apps);
        _ = appManager.EnsureAllRunningAsync();


        Console.WriteLine($"[LOG] Listening on port {config.Port}");


        while (true)
        {
            var ctx = await listener.GetContextAsync();
            _ = Task.Run(async () =>
            {
                var req = ctx.Request;
                var res = ctx.Response;


                Console.WriteLine($"[LOG] Incoming request: {req.HttpMethod} {req.Url.AbsolutePath}");


                try
                {
                    var path = req.Url.AbsolutePath.TrimStart('/');
                    var segments = path.Split('/', StringSplitOptions.RemoveEmptyEntries);


                    if (segments.Length > 0 && appManager.TryGetApp(segments[0], out var app))
                    {
                        Console.WriteLine($"[LOG] Forwarding request to app: {app.Name}");
                        var forwardPath = "/" + string.Join('/', segments.Skip(1));
                        await ProxyHandler.ProxyRequest(res, req, app, forwardPath);
                    }
                    else
                    {
                        Console.WriteLine($"[LOG] Serving static: {path}");
                        await StaticHandler.ServeStatic(res, config.StaticRoot, req.Url.AbsolutePath);
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"[ERROR] {ex}");
                    var bytes = Encoding.UTF8.GetBytes(ex.ToString());
                    res.StatusCode = 500;
                    res.ContentType = "text/plain; charset=utf-8";
                    await res.OutputStream.WriteAsync(bytes);
                }
                finally
                {
                    res.OutputStream.Close();
                }
            });
        }
    }
}