init proxy

Author: mgravell

StackExchange.Redis.slnx

@@ -24,6 +24,7 @@
   </Folder>
   <Folder Name="/src/">
     <File Path="src/Directory.Build.props" />
+    <Project Path="src/RESPite.Proxy/RESPite.Proxy.csproj" />
     <Project Path="src/RESPite/RESPite.csproj" />
     <Project Path="src/StackExchange.Redis/StackExchange.Redis.csproj" />
   </Folder>

src/RESPite.Proxy/Program.cs

@@ -0,0 +1,43 @@
+using System.Net;
+using Microsoft.AspNetCore.Connections;
+using RESPite.Proxy;
+
+var server = new ProxyServer()
+{
+    Password = "letmein",
+};
+
+/*
+// demonstrate cluster spoofing
+server.ServerType = ServerType.Cluster;
+var ep = server.AddEmptyNode();
+server.Migrate("key", ep);
+*/
+
+var builder = WebApplication.CreateBuilder(args);
+builder.Services.AddSingleton<ProxyServer>(server);
+builder.WebHost.ConfigureKestrel(options =>
+{
+    // HTTP 5000 (test/debug API only)
+    options.ListenLocalhost(5000);
+
+    // this is the core of using Kestrel to create a TCP server
+    // TCP 6379
+    Action<Microsoft.AspNetCore.Server.Kestrel.Core.ListenOptions> builder = builder => builder.UseConnectionHandler<ProxyHandler>();
+    foreach (var ep in server.GetEndPoints())
+    {
+        if (ep is IPEndPoint ip && ip.Address.Equals(IPAddress.Loopback))
+        {
+            options.ListenLocalhost(ip.Port, builder);
+        }
+        else
+        {
+            options.Listen(ep, builder);
+        }
+    }
+});
+
+var app = builder.Build();
+
+// run the server
+await app.RunAsync();

src/RESPite.Proxy/ProxyClient.cs

@@ -0,0 +1,6 @@
+namespace RESPite.Proxy;
+
+public class ProxyClient
+{
+    private int _db;
+}

src/RESPite.Proxy/ProxyHandler.cs

@@ -0,0 +1,9 @@
+using Microsoft.AspNetCore.Connections;
+
+namespace RESPite.Proxy;
+
+public sealed class ProxyHandler(ProxyServer server) : ConnectionHandler
+{
+    public override Task OnConnectedAsync(ConnectionContext connection)
+        => server.RunClientAsync(connection.Transport);
+}

src/RESPite.Proxy/ProxyServer.cs

@@ -0,0 +1,19 @@
+using System.IO.Pipelines;
+using System.Net;
+
+namespace RESPite.Proxy;
+
+public class ProxyServer
+{
+    public string Password { get; set; } = "";
+
+    public IEnumerable<EndPoint> GetEndPoints()
+    {
+        yield return new IPEndPoint(IPAddress.Loopback, 6379);
+    }
+
+    public Task RunClientAsync(IDuplexPipe connectionTransport)
+    {
+        throw new NotImplementedException();
+    }
+}

src/RESPite.Proxy/RESPite.Proxy.csproj

@@ -0,0 +1,15 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net10.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+    </PropertyGroup>
+  
+  <ItemGroup>
+    <PackageReference Remove="Microsoft.CodeAnalysis.PublicApiAnalyzers" />
+    <ProjectReference Include="../RESPite/RESPite.csproj" />
+  </ItemGroup>
+
+</Project>