// Copyright (C) 2023-present sam/u1f320 (vulpine.solutions) // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published // by the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see . using System.Net; using System.Web; using EntityFramework.Exceptions.Common; using Foxnouns.Backend.Database; using Foxnouns.Backend.Database.Models; using Foxnouns.Backend.Dto; using Foxnouns.Backend.Extensions; using Foxnouns.Backend.Middleware; using Foxnouns.Backend.Services; using Foxnouns.Backend.Services.Auth; using Foxnouns.Backend.Utils; using JetBrains.Annotations; using Microsoft.AspNetCore.Mvc; using Microsoft.EntityFrameworkCore; using NodaTime; namespace Foxnouns.Backend.Controllers.Authentication; [Route("/api/internal/auth/discord")] [ApiExplorerSettings(IgnoreApi = true)] public class DiscordAuthController( [UsedImplicitly] Config config, ILogger logger, DatabaseContext db, KeyCacheService keyCacheService, AuthService authService, RemoteAuthService remoteAuthService ) : ApiControllerBase { private readonly ILogger _logger = logger.ForContext(); [HttpPost("callback")] [ProducesResponseType(StatusCodes.Status200OK)] public async Task CallbackAsync([FromBody] CallbackRequest req) { CheckRequirements(); await keyCacheService.ValidateAuthStateAsync(req.State); RemoteAuthService.RemoteUser remoteUser = await remoteAuthService.RequestDiscordTokenAsync( req.Code ); User? user = await authService.AuthenticateUserAsync(AuthType.Discord, remoteUser.Id); if (user != null) return Ok(await authService.GenerateUserTokenAsync(user)); _logger.Debug( "Discord user {Username} ({Id}) authenticated with no local account", remoteUser.Username, remoteUser.Id ); string ticket = AuthUtils.RandomToken(); await keyCacheService.SetKeyAsync( $"discord:{ticket}", remoteUser, Duration.FromMinutes(20) ); return Ok(new CallbackResponse(false, ticket, remoteUser.Username, null, null, null)); } [HttpPost("register")] [ProducesResponseType(StatusCodes.Status200OK)] public async Task RegisterAsync([FromBody] OauthRegisterRequest req) { RemoteAuthService.RemoteUser? remoteUser = await keyCacheService.GetKeyAsync( $"discord:{req.Ticket}" ); if (remoteUser == null) throw new ApiError.BadRequest("Invalid ticket", "ticket", req.Ticket); if ( await db.AuthMethods.AnyAsync(a => a.AuthType == AuthType.Discord && a.RemoteId == remoteUser.Id ) ) { _logger.Error( "Discord user {Id} has valid ticket but is already linked to an existing account", remoteUser.Id ); throw new ApiError.BadRequest("Invalid ticket", "ticket", req.Ticket); } User user = await authService.CreateUserWithRemoteAuthAsync( req.Username, AuthType.Discord, remoteUser.Id, remoteUser.Username ); return Ok(await authService.GenerateUserTokenAsync(user)); } [HttpGet("add-account")] [Authorize("*")] public async Task AddDiscordAccountAsync() { CheckRequirements(); string state = await remoteAuthService.ValidateAddAccountRequestAsync( CurrentUser!.Id, AuthType.Discord ); string url = "https://discord.com/oauth2/authorize?response_type=code" + $"&client_id={config.DiscordAuth.ClientId}&scope=identify" + $"&prompt=none&state={state}" + $"&redirect_uri={HttpUtility.UrlEncode($"{config.BaseUrl}/auth/callback/discord")}"; return Ok(new SingleUrlResponse(url)); } [HttpPost("add-account/callback")] [Authorize("*")] public async Task AddAccountCallbackAsync([FromBody] CallbackRequest req) { CheckRequirements(); await remoteAuthService.ValidateAddAccountStateAsync( req.State, CurrentUser!.Id, AuthType.Discord ); RemoteAuthService.RemoteUser remoteUser = await remoteAuthService.RequestDiscordTokenAsync( req.Code ); try { AuthMethod authMethod = await authService.AddAuthMethodAsync( CurrentUser.Id, AuthType.Discord, remoteUser.Id, remoteUser.Username ); _logger.Debug( "Added new Discord auth method {AuthMethodId} to user {UserId}", authMethod.Id, CurrentUser.Id ); return Ok( new AddOauthAccountResponse( authMethod.Id, AuthType.Discord, authMethod.RemoteId, authMethod.RemoteUsername ) ); } catch (UniqueConstraintException) { throw new ApiError( "That account is already linked.", HttpStatusCode.BadRequest, ErrorCode.AccountAlreadyLinked ); } } private void CheckRequirements() { if (!config.DiscordAuth.Enabled) { throw new ApiError.BadRequest( "Discord authentication is not enabled on this instance." ); } } }