Handler.cs 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.EmailVerification.ValueObject;
  4. using SharedKernel.Results;
  5. using Microsoft.EntityFrameworkCore;
  6. namespace Application.Features.Api.MyPage.VerifyEmail;
  7. internal sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Result>
  8. {
  9. public async Task<Result> Handle(Query request, CancellationToken ct)
  10. {
  11. if (string.IsNullOrWhiteSpace(request.Token))
  12. {
  13. return Result.Failure(Error.Problem("MyPage.TokenRequired", "인증 토큰은 필수입니다."));
  14. }
  15. var verifyToken = await db.EmailVerifyToken.FirstOrDefaultAsync(t => t.Token == request.Token && t.Type == VerificationType.ChangedEmail, ct);
  16. if (verifyToken is null)
  17. {
  18. return Result.Failure(Error.NotFound("MyPage.TokenNotFound", "유효하지 않은 인증 토큰입니다."));
  19. }
  20. if (verifyToken.IsVerified)
  21. {
  22. return Result.Failure(Error.Problem("MyPage.AlreadyVerified", "이미 인증된 토큰입니다."));
  23. }
  24. if (verifyToken.Expiration < DateTime.UtcNow)
  25. {
  26. return Result.Failure(Error.Problem("MyPage.TokenExpired", "인증 토큰이 만료되었습니다."));
  27. }
  28. var member = await db.Member.FirstOrDefaultAsync(m => m.Email == verifyToken.Email, ct);
  29. if (member is null)
  30. {
  31. return Result.Failure(Error.NotFound("MyPage.MemberNotFound", "회원 정보를 찾을 수 없습니다."));
  32. }
  33. verifyToken.MarkVerified();
  34. member.MarkEmailVerified();
  35. await db.SaveChangesAsync(ct);
  36. return Result.Success();
  37. }
  38. }