41 lines
990 B
C#
41 lines
990 B
C#
|
#nullable enable
|
||
|
|
|
||
|
|
using Insight.Database;
|
||
|
|
using PlanTempus.Core.CommandQueries;
|
||
|
|
using PlanTempus.Core.Database;
|
||
|
|
|
||
|
|
namespace PlanTempus.Components.Accounts.ConfirmEmail;
|
||
|
|
|
||
|
|
public class ConfirmEmailHandler(IDatabaseOperations databaseOperations) : ICommandHandler<ConfirmEmailCommand>
|
||
|
|
{
|
||
|
|
public async Task<CommandResponse> Handle(ConfirmEmailCommand command)
|
||
|
|
{
|
||
|
|
using var db = databaseOperations.CreateScope(nameof(ConfirmEmailHandler));
|
||
|
|
|
||
|
|
var sql = @"
|
||
|
|
UPDATE system.accounts
|
||
|
|
SET email_confirmed = true
|
||
|
|
WHERE email = @Email AND security_stamp = @Token";
|
||
|
|
|
||
|
|
var affectedRows = await db.Connection.ExecuteSqlAsync(sql, new
|
||
|
|
{
|
||
|
|
command.Email,
|
||
|
|
command.Token
|
||
|
|
});
|
||
|
|
|
||
|
|
if (affectedRows == 0)
|
||
|
|
{
|
||
|
|
throw new InvalidTokenException();
|
||
|
|
}
|
||
|
|
|
||
|
|
return new CommandResponse(command.CorrelationId, command.GetType().Name, command.TransactionId);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public class InvalidTokenException : Exception
|
||
|
|
{
|
||
|
|
public InvalidTokenException() : base("Invalid or expired verification token")
|
||
|
|
{
|
||
|
|
}
|
||
|
|
}
|