Program.cs

using System.Text.Json;
using System.Text.Json.Serialization;
using ClaudeCodeProxy;
using ClaudeCodeProxy.Configuration;
using ClaudeCodeProxy.Infrastructure;
using ClaudeCodeProxy.Middleware;
using ClaudeCodeProxy.Models;
using ClaudeCodeProxy.Services;
using LlmTornado;
using LlmTornado.Code.Vendor;
using Microsoft.AspNetCore.Mvc;
using Serilog;
using Serilog.Settings.Configuration;

Console.OutputEncoding = System.Text.Encoding.UTF8;
Console.InputEncoding = System.Text.Encoding.UTF8;
var configurationAssemblies = new[]
{
    typeof(ConsoleLoggerConfigurationExtensions).Assembly,
    typeof(FileLoggerConfigurationExtensions).Assembly,
};
var builder = WebApplication.CreateSlimBuilder(args);
builder.Logging.ClearProviders();
builder.Logging.UseDebugSerilog(
    builder.Configuration,
    out var serilogger,
    new ConfigurationReaderOptions(configurationAssemblies)
);
builder.Services.AddProblemDetails();
builder.Services.ConfigureHttpJsonOptions(options =>
{
    options.SerializerOptions.TypeInfoResolverChain.Insert(0, AppJsonSerializerContext.Default);
    options.SerializerOptions.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
    options.SerializerOptions.PropertyNamingPolicy = JsonNamingPolicy.SnakeCaseLower;
});
builder.Services.AddSingleton<IConfiguration>(builder.Configuration);
builder.Services.AddSingleton<ModelMappingService>();
builder.Services.AddSingleton<RateLimitHandlerService>();
builder.Services.AddSingleton<ITokenCountService, NaiveTokenCountService>();
builder.Services.AddSingleton<AnthropicProxyService>();
builder
    .Services.AddOptionsFromRootAndValidateOnStart<Options>(builder.Configuration)
    .Validate(
        o =>
        {
            var res = o.TryParse(out var parsed);
            if (res != null)
                serilogger.Information(res.ToLogString());
            return res != null;
        },
        "Invalid options configuration"
    );
builder.Services.AddSingleton(sp => sp.GetOptions<Options>().Parse());
builder.Services.AddOpenApi();
var app = builder.Build();

// Add traffic logging middleware to capture ALL HTTP traffic
app.UseTrafficLogging();

app.MapGet(
    "/",
    () => Results.Ok("Anthropic Proxy for LlmTornado, proudly powered by ASP.NET Core 10.0")
);
app.MapPost(
    "/v1/messages",
    static async (
        [FromBody] MessagesRequest request,
        AnthropicProxyService proxyService,
        RateLimitHandlerService rateLimitHandler
    ) =>
    {
        try
        {
            return request.Stream ?? false
                ? TypedResults.ServerSentEvents(proxyService.CreateStreamingResponse(request))
                : Results.Json(
                    await proxyService.CreateCompletion(request),
                    AppJsonSerializerContext.Default.MessagesResponse
                );
        }
        catch (Exception ex) when (rateLimitHandler.IsRateLimitError(ex))
        {
            return rateLimitHandler.CreateRateLimitResult(ex);
        }
    }
);
app.MapPost(
    "/v1/messages/count_tokens",
    static (TokenCountRequest request, ITokenCountService proxyService) =>
    {
        var response = proxyService.CountTokens(request);
        return Results.Json(response, AppJsonSerializerContext.Default.TokenCountResponse);
    }
);
app.Run();