Initial import.

2025-12-16 09:14:10 -08:00
commit b77ae6db2e
65 changed files with 1715 additions and 0 deletions
--- a/csks/Program.cs
+++ b/csks/Program.cs
@@ -0,0 +1,69 @@
+using Microsoft.AspNetCore.HttpLogging;
+using System.Diagnostics;
+
+namespace ghcs;
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        var builder = WebApplication.CreateBuilder(args);
+
+        builder.Services.AddAuthorization();
+        builder.Services.AddOpenApi(); // c.f. https://aka.ms/aspnet/openapi
+
+        builder.Services.AddSingleton<IKeyValueStore, KeyValueStore>();
+        builder.Services.AddHostedService<StorePersister>();
+
+        builder.Services.AddHttpLogging(opts =>
+        {
+
+            opts.LoggingFields = HttpLoggingFields.RequestPropertiesAndHeaders |
+                                 HttpLoggingFields.ResponsePropertiesAndHeaders;
+            opts.RequestHeaders.Add("X-Correlation-ID");
+            opts.ResponseHeaders.Add("X-Correlation-ID");
+        });
+        
+        var app = builder.Build();
+
+        // Configure the HTTP request pipeline.
+        if (app.Environment.IsDevelopment())
+        {
+            app.MapOpenApi();
+        }
+
+        app.UseHttpsRedirection();
+        app.UseAuthorization();
+        app.UseHttpLogging();
+
+        app.MapGet("/key/{key}", (string key, IKeyValueStore store, ILogger<Program> log) =>
+            {
+                log.LogInformation("GET /key/{key}", key);
+                var response = store.TryGet(key);
+                if (response.Present)
+                {
+                    log.LogInformation("Key {key} found", key);
+                    return Results.Ok(response);
+                }
+                
+                log.LogWarning("Key {key} not found", key);
+                return Results.NotFound(response);
+            }).WithName("GetKey");
+
+        app.MapPut("/key/{key}", (string key, string value, IKeyValueStore store, ILogger<Program> log) =>
+        {
+            log.LogInformation("PUT /key/{key}", key);
+            store.Set(key, value);
+            return Results.Ok(new Response(true, value));
+        });
+
+        app.MapGet("/checkpoint", async (IKeyValueStore store, CancellationToken ct, ILogger<Program> log) =>
+        {
+            log.LogInformation("checkpoint requested");
+            await store.SaveAsync(ct);
+            return Results.Ok();
+        });
+
+        app.Run();
+    }
+}