using System.Net.Http.Headers; using System.Security.Claims; using System.Text.Json; using System.Text.Json.Serialization; using Bifrost.Web.Configuration; using Bifrost.Web.Data; using Bifrost.Web.Domain; using Bifrost.Web.Features.Bridge; using Bifrost.Web.Features.ConceptVotes; using Bifrost.Web.Features.GitHub; using Bifrost.Web.Features.Heimdall; using Bifrost.Web.Features.Membership; using Bifrost.Web.Features.Motions; using Bifrost.Web.Features.Patronage; using Bifrost.Web.Features.Shared; using Microsoft.AspNetCore.Authentication; using Microsoft.AspNetCore.Authentication.Cookies; using Microsoft.AspNetCore.Authentication.OAuth; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.DataProtection; using Microsoft.AspNetCore.HttpOverrides; using Microsoft.AspNetCore.HttpLogging; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Options; using System.Net; // Host command: registers Mill concept subjects with configuration and the database only; no web app, no migrations. if (args.Length > 0 && args[0] == "concepts") { var host = Host.CreateApplicationBuilder([]); host.Services.AddDbContext(options => options.UseNpgsql(BifrostConnectionString(host.Configuration))); host.Services.AddSingleton(TimeProvider.System); host.Services.AddScoped(); host.Services.AddScoped(); using var commandHost = host.Build(); Environment.ExitCode = await ConceptCommand.RunAsync(args[1..], commandHost.Services, Console.Out); return; } static string BifrostConnectionString(IConfiguration configuration) => configuration.GetConnectionString("Bifrost") ?? "Host=127.0.0.1;Database=bifrost;Username=postgres;Password=postgres"; var builder = WebApplication.CreateBuilder(args); builder.Services .AddOptions() .BindConfiguration(GitHubOAuthOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(GitHubAppOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(BootstrapOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(BifrostHostOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(HeimdallOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(StripeOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(BridgeOptions.SectionName); builder.Services .AddOptions() .BindConfiguration(ConceptVoteOptions.SectionName); builder.Services.AddRazorPages(options => { options.Conventions.AuthorizePage("/Membership/Status"); options.Conventions.AuthorizeFolder("/App", ActiveMemberRequirement.PolicyName); options.Conventions.AllowAnonymousToFolder("/Mill"); }); builder.Services.ConfigureHttpJsonOptions(options => { options.SerializerOptions.Converters.Add(new JsonStringEnumConverter()); }); builder.Services.AddDbContext(options => { options.UseNpgsql(BifrostConnectionString(builder.Configuration)); }); builder.Services.AddHttpLogging(options => { options.LoggingFields = HttpLoggingFields.RequestMethod | HttpLoggingFields.RequestPath | HttpLoggingFields.ResponseStatusCode | HttpLoggingFields.Duration; }); builder.Services.AddHttpContextAccessor(); builder.Services.AddSingleton(TimeProvider.System); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddScoped(); builder.Services.AddSingleton(); builder.Services.AddScoped(); builder.Services.AddHttpClient((serviceProvider, client) => HeimdallAuthService.ConfigureClient(client, serviceProvider.GetRequiredService>().Value)) .RedactLoggedHeaders(header => string.Equals(header, HeimdallAuthService.AppSecretHeader, StringComparison.OrdinalIgnoreCase)); builder.Services.AddSingleton(); builder.Services.AddHttpClient(HeimdallTokenVerifier.ClientName, (serviceProvider, client) => HeimdallTokenVerifier.ConfigureClient(client, serviceProvider.GetRequiredService>().Value)); builder.Services.AddHttpClient(client => { client.BaseAddress = new Uri("https://api.stripe.com/"); }); var dataProtectionBuilder = builder.Services .AddDataProtection() .SetApplicationName("Bifrost"); var dataProtectionKeysPath = builder.Configuration["DataProtection:KeysPath"]; if (!string.IsNullOrWhiteSpace(dataProtectionKeysPath)) { dataProtectionBuilder.PersistKeysToFileSystem(new DirectoryInfo(dataProtectionKeysPath)); } // nginx on this host is the only proxy, and it connects from loopback. Trusting exactly // those addresses keeps a direct client from choosing its own address with X-Forwarded-For. builder.Services.Configure(options => { options.ForwardedHeaders = ForwardedHeaders.XForwardedFor | ForwardedHeaders.XForwardedProto; options.KnownNetworks.Clear(); options.KnownProxies.Clear(); options.KnownProxies.Add(IPAddress.Loopback); options.KnownProxies.Add(IPAddress.IPv6Loopback); options.KnownProxies.Add(IPAddress.Loopback.MapToIPv6()); options.ForwardLimit = 1; }); var configuredGitHubOAuthOptions = builder.Configuration .GetSection(GitHubOAuthOptions.SectionName) .Get() ?? new GitHubOAuthOptions(); var authenticationBuilder = builder.Services .AddAuthentication(CookieAuthenticationDefaults.AuthenticationScheme) .AddCookie(options => { options.LoginPath = "/auth/sign-in"; options.AccessDeniedPath = "/Membership/Status"; options.SlidingExpiration = true; }); if (configuredGitHubOAuthOptions.IsConfigured) { authenticationBuilder.AddOAuth(GitHubAuthenticationDefaults.AuthenticationScheme, options => { options.ClientId = configuredGitHubOAuthOptions.ClientId; options.ClientSecret = configuredGitHubOAuthOptions.ClientSecret; options.CallbackPath = configuredGitHubOAuthOptions.CallbackPath; options.AuthorizationEndpoint = "https://github.com/login/oauth/authorize"; options.TokenEndpoint = "https://github.com/login/oauth/access_token"; options.UserInformationEndpoint = "https://api.github.com/user"; options.SaveTokens = true; options.Scope.Add("read:user"); options.Scope.Add("user:email"); options.ClaimActions.MapJsonKey(ClaimTypes.NameIdentifier, "id"); options.ClaimActions.MapJsonKey(ClaimTypes.Name, "login"); options.ClaimActions.MapJsonKey(BifrostClaimTypes.GitHubLogin, "login"); options.ClaimActions.MapJsonKey(BifrostClaimTypes.DisplayName, "name"); options.ClaimActions.MapJsonKey(BifrostClaimTypes.AvatarUrl, "avatar_url"); options.Events = new OAuthEvents { OnCreatingTicket = async context => { using var request = new HttpRequestMessage(HttpMethod.Get, context.Options.UserInformationEndpoint); request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/vnd.github+json")); request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", context.AccessToken); request.Headers.UserAgent.ParseAdd("Bifrost"); using var response = await context.Backchannel.SendAsync( request, HttpCompletionOption.ResponseHeadersRead, context.HttpContext.RequestAborted); response.EnsureSuccessStatusCode(); await using var payloadStream = await response.Content.ReadAsStreamAsync(context.HttpContext.RequestAborted); using var payload = await JsonDocument.ParseAsync(payloadStream, cancellationToken: context.HttpContext.RequestAborted); context.RunClaimActions(payload.RootElement); } }; }); } builder.Services.AddAuthorization(options => { options.AddPolicy(ActiveMemberRequirement.PolicyName, policy => { policy.RequireAuthenticatedUser(); policy.AddRequirements(new ActiveMemberRequirement()); }); }); builder.Services.AddConceptTallyCors(); var app = builder.Build(); var appJsonSerializerOptions = CreateAppJsonSerializerOptions(); app.Services.GetRequiredService().Validate(); await using (var scope = app.Services.CreateAsyncScope()) { await scope.ServiceProvider .GetRequiredService() .RunAsync(CancellationToken.None); } app.UseForwardedHeaders(); if (!app.Environment.IsDevelopment()) { app.UseExceptionHandler("/Error"); app.UseHsts(); } app.UseHttpLogging(); app.UseHttpsRedirection(); app.UseStaticFiles(); app.UseRouting(); app.UseConceptTallyCors(); app.UseAuthentication(); app.UseMiddleware(); app.UseAuthorization(); app.MapGet("/healthz", () => Results.Text("ok")).AllowAnonymous(); app.MapGet("/readyz", async (ReadinessService readinessService, CancellationToken cancellationToken) => { var report = await readinessService.GetReportAsync(cancellationToken); return report.IsReady ? Results.Text("ready") : Results.Text( string.Join(Environment.NewLine, report.Failures), statusCode: StatusCodes.Status503ServiceUnavailable); }).AllowAnonymous(); app.MapConceptTallyExport(); app.MapPost("/github/webhooks", async ( HttpRequest request, GitHubWebhookService gitHubWebhookService, CancellationToken cancellationToken) => { using var reader = new StreamReader(request.Body); var payload = await reader.ReadToEndAsync(cancellationToken); var eventName = request.Headers["X-GitHub-Event"].ToString(); var deliveryId = request.Headers["X-GitHub-Delivery"].ToString(); var signature = request.Headers["X-Hub-Signature-256"].ToString(); var result = await gitHubWebhookService.ProcessAsync( eventName, deliveryId, signature, payload, cancellationToken); return result.Status switch { GitHubWebhookProcessStatus.Processed => Results.Text(result.Message, statusCode: StatusCodes.Status202Accepted), GitHubWebhookProcessStatus.Ignored => Results.Text(result.Message), GitHubWebhookProcessStatus.NotConfigured => Results.Text( result.Message, statusCode: StatusCodes.Status503ServiceUnavailable), _ => Results.Text( result.Message, statusCode: StatusCodes.Status401Unauthorized) }; }).AllowAnonymous(); app.MapGet("/auth/sign-in", async (HttpContext httpContext, IOptions gitHubOptions) => { var returnPath = LocalReturnPath.Parse(httpContext.Request.Query["returnUrl"].ToString()); var provider = httpContext.Request.Query["provider"].ToString(); if (string.IsNullOrWhiteSpace(provider)) { await WriteSignInChooserAsync(httpContext, returnPath.Value); return; } if (!provider.Equals("github", StringComparison.OrdinalIgnoreCase)) { httpContext.Response.Redirect($"/auth/heimdall/{Uri.EscapeDataString(provider)}?returnUrl={Uri.EscapeDataString(returnPath.Value)}"); return; } if (!gitHubOptions.Value.IsConfigured) { httpContext.Response.Redirect("/?auth=github-not-configured"); return; } await httpContext.ChallengeAsync( GitHubAuthenticationDefaults.AuthenticationScheme, new() { RedirectUri = returnPath.Value }); }).AllowAnonymous(); app.MapPost("/auth/bifrost/register", async ( NativeBifrostRegistrationRequest request, HttpContext httpContext, BifrostIdentityService bifrostIdentityService, CancellationToken cancellationToken) => { try { var userAccount = await bifrostIdentityService.RegisterNativeAsync( request.Identity, request.DisplayName, cancellationToken); await httpContext.SignInAsync( CookieAuthenticationDefaults.AuthenticationScheme, bifrostIdentityService.BuildPrincipal(userAccount)); var returnUrl = string.IsNullOrWhiteSpace(request.ReturnUrl) ? "/App" : request.ReturnUrl; return JsonResult( new NativeBifrostRegistrationResponse( userAccount.Id, userAccount.BifrostIdentity, userAccount.DisplayName, userAccount.Membership?.Status.ToString() ?? MembershipStatus.Authenticated.ToString(), returnUrl), appJsonSerializerOptions); } catch (BifrostIdentityException error) { return Results.Text(error.Message, statusCode: StatusCodes.Status400BadRequest); } }).AllowAnonymous(); app.MapGet("/auth/heimdall/{provider}", async ( string provider, HttpContext httpContext, HeimdallAuthService heimdallAuthService, IOptions hostOptions, ILogger logger, CancellationToken cancellationToken) => { try { var returnPath = LocalReturnPath.Parse(httpContext.Request.Query["returnUrl"].ToString()); var requireMemberAccess = string.Equals( httpContext.Request.Query["access"].ToString(), "member", StringComparison.OrdinalIgnoreCase); var start = await heimdallAuthService.StartAsync( provider, hostOptions.Value.PublicBaseUrl, returnPath, requireMemberAccess, httpContext.Request.Cookies, cancellationToken); httpContext.Response.Cookies.Append(start.CookieName, start.CookieValue, HeimdallAttemptCookie.Options()); return Results.Redirect(start.AuthorizationUrl.ToString()); } catch (HeimdallAuthException error) { logger.LogWarning("Heimdall start refused: {Reason}", error.Message); return Results.Redirect(HeimdallAuthService.ErrorRedirect); } }).AllowAnonymous(); app.MapPost("/heimdall/patron-support/events", async ( HttpRequest request, HeimdallPatronSupportIntakeService intakeService, CancellationToken cancellationToken) => { using var reader = new StreamReader(request.Body); var payload = await reader.ReadToEndAsync(cancellationToken); var signature = request.Headers["X-Heimdall-Signature-256"].ToString(); var result = await intakeService.ProcessAsync(signature, payload, cancellationToken); return result.Status switch { HeimdallPatronSupportIntakeStatus.Processed => Results.Text( result.Message, statusCode: StatusCodes.Status202Accepted), HeimdallPatronSupportIntakeStatus.BadRequest => Results.BadRequest(result.Message), HeimdallPatronSupportIntakeStatus.NotConfigured => Results.Text( result.Message, statusCode: StatusCodes.Status503ServiceUnavailable), _ => Results.Text(result.Message, statusCode: StatusCodes.Status401Unauthorized) }; }).AllowAnonymous(); app.MapGet("/patronage/{project}/checkout", async ( string project, HttpRequest request, ICurrentBifrostActorAccessor actorAccessor, StripeCheckoutService stripeCheckoutService, CancellationToken cancellationToken) => { var amountCentsText = request.Query["amountCents"].ToString(); if (!int.TryParse(amountCentsText, out var amountCents)) { return Results.Text( "Missing or invalid required amountCents query parameter.", statusCode: StatusCodes.Status400BadRequest); } var item = request.Query["item"].ToString(); if (string.IsNullOrWhiteSpace(item)) { return Results.Text( "Missing required item query parameter.", statusCode: StatusCodes.Status400BadRequest); } var actor = await actorAccessor.GetAsync(cancellationToken); if (!actor.IsAuthenticated || actor.UserAccount is null) { var returnUrl = Uri.EscapeDataString($"{request.Path}{request.QueryString}"); return Results.Redirect($"/auth/sign-in?returnUrl={returnUrl}"); } var result = await stripeCheckoutService.CreateProjectDonationCheckoutAsync( new StripeDonationCheckoutRequest( project, request.Query["project"].ToString(), item, amountCents, request.Query["currency"].ToString(), request.Query["source"].ToString()), actor.UserAccount, cancellationToken); return result.Status switch { StripeCheckoutStatus.Created => Results.Redirect(result.CheckoutUrl!.ToString()), StripeCheckoutStatus.InvalidRequest => Results.Text( result.Message, statusCode: StatusCodes.Status400BadRequest), StripeCheckoutStatus.UnknownProject => Results.Text( result.Message, statusCode: StatusCodes.Status404NotFound), StripeCheckoutStatus.NotConfigured => Results.Text( result.Message, statusCode: StatusCodes.Status503ServiceUnavailable), _ => Results.Text( result.Message, statusCode: StatusCodes.Status502BadGateway) }; }).AllowAnonymous(); app.MapPost("/patronage/stripe/webhook", async ( HttpRequest request, StripeWebhookService webhookService, CancellationToken cancellationToken) => { using var reader = new StreamReader(request.Body); var payload = await reader.ReadToEndAsync(cancellationToken); var signature = request.Headers["Stripe-Signature"].ToString(); var result = await webhookService.ProcessAsync(signature, payload, cancellationToken); return result.Status switch { StripeWebhookStatus.Processed => Results.Text( result.Message, statusCode: StatusCodes.Status202Accepted), StripeWebhookStatus.Ignored => Results.Text(result.Message), StripeWebhookStatus.BadRequest => Results.BadRequest(result.Message), StripeWebhookStatus.NotConfigured => Results.Text( result.Message, statusCode: StatusCodes.Status503ServiceUnavailable), _ => Results.Text(result.Message, statusCode: StatusCodes.Status401Unauthorized) }; }).AllowAnonymous(); var eveGovernance = app.MapGroup("/eve/governance") .RequireAuthorization(ActiveMemberRequirement.PolicyName); eveGovernance.MapGet("/surface", async ( ICurrentBifrostActorAccessor actorAccessor, MotionGovernanceService motionGovernanceService, MotionEveSurfaceService motionEveSurfaceService, CancellationToken cancellationToken) => { var actor = await actorAccessor.GetAsync(cancellationToken); var state = await motionGovernanceService.GetStateAsync(actor, cancellationToken); var surface = motionEveSurfaceService.BuildSurface(state); return Results.Text( JsonSerializer.Serialize(surface, appJsonSerializerOptions), "application/json"); }); app.MapGet("/auth/heimdall/complete", (HttpContext httpContext) => { httpContext.Response.Headers.CacheControl = "no-store"; httpContext.Response.Headers["Referrer-Policy"] = "no-referrer"; return Results.Content(HeimdallCompletePage.Html, "text/html", System.Text.Encoding.UTF8); }).AllowAnonymous(); app.MapPost("/auth/heimdall/complete", async ( HttpContext httpContext, HeimdallAuthService heimdallAuthService, IOptions hostOptions, ILogger logger, CancellationToken cancellationToken) => { var form = await ReadFormOrNullAsync(httpContext.Request, cancellationToken); var attempt = form?["attempt"].ToString(); var held = heimdallAuthService.FindAttemptCookie(httpContext.Request.Cookies, attempt); try { var signIn = await heimdallAuthService.CompleteAsync( hostOptions.Value.PublicBaseUrl, attempt, held?.Value, form?["code"].ToString(), cancellationToken); await httpContext.SignInAsync(CookieAuthenticationDefaults.AuthenticationScheme, signIn.Principal); httpContext.Response.Cookies.Delete(held!.Value.Name, HeimdallAttemptCookie.DeleteOptions()); return Results.LocalRedirect(signIn.ReturnPath.Value); } catch (HeimdallAuthException error) { logger.LogWarning("Heimdall completion refused: {Reason}", error.Message); if (held is not null) { httpContext.Response.Cookies.Delete(held.Value.Name, HeimdallAttemptCookie.DeleteOptions()); } return Results.Redirect(HeimdallAuthService.ErrorRedirect); } }).AllowAnonymous(); app.MapPost("/auth/sign-out", async (HttpContext httpContext) => { await httpContext.SignOutAsync(CookieAuthenticationDefaults.AuthenticationScheme); httpContext.Response.Redirect("/"); }).AllowAnonymous(); app.MapRazorPages(); app.Run(); static IResult JsonResult(T value, JsonSerializerOptions options, int statusCode = StatusCodes.Status200OK) => Results.Text( JsonSerializer.Serialize(value, options), "application/json", statusCode: statusCode); static async Task ReadFormOrNullAsync(HttpRequest request, CancellationToken cancellationToken) { if (!request.HasFormContentType) { return null; } try { return await request.ReadFormAsync(cancellationToken); } catch (Exception error) when (error is InvalidDataException or BadHttpRequestException) { return null; } } static async Task WriteSignInChooserAsync(HttpContext httpContext, string returnUrl) { httpContext.Response.ContentType = "text/html; charset=utf-8"; var encodedReturnUrl = Uri.EscapeDataString(returnUrl); var escapedReturnUrl = System.Net.WebUtility.HtmlEncode(returnUrl); await httpContext.Response.WriteAsync($$""" Sign in - Bifrost
Transport identity

Create or use a Bifrost patron account

Choose a provider to attach this checkout to a Bifrost account. Patron accounts do not automatically grant active member access.

After sign-in, Bifrost returns you to {{escapedReturnUrl}}.

"""); } static JsonSerializerOptions CreateAppJsonSerializerOptions() { var options = new JsonSerializerOptions(JsonSerializerDefaults.Web); options.Converters.Add(new JsonStringEnumConverter()); return options; } public partial class Program; public sealed record NativeBifrostRegistrationRequest( string Identity, string? DisplayName, string? ReturnUrl); public sealed record NativeBifrostRegistrationResponse( Guid UserAccountId, string BifrostIdentity, string DisplayName, string MembershipStatus, string ReturnUrl);