hailey.at
1package server
2
3import (
4 "time"
5
6 "github.com/Azure/go-autorest/autorest/to"
7 "github.com/haileyok/cocoon/internal/helpers"
8 "github.com/haileyok/cocoon/models"
9 "github.com/labstack/echo/v4"
10)
11
12type ComAtprotoServerConfirmEmailRequest struct {
13 Email string `json:"email" validate:"required"`
14 Token string `json:"token" validate:"required"`
15}
16
17func (s *Server) handleServerConfirmEmail(e echo.Context) error {
18 ctx := e.Request().Context()
19
20 urepo := e.Get("repo").(*models.RepoActor)
21
22 var req ComAtprotoServerConfirmEmailRequest
23 if err := e.Bind(&req); err != nil {
24 s.logger.Error("error binding", "error", err)
25 return helpers.ServerError(e, nil)
26 }
27
28 if err := e.Validate(req); err != nil {
29 return helpers.InputError(e, nil)
30 }
31
32 if urepo.EmailVerificationCode == nil || urepo.EmailVerificationCodeExpiresAt == nil {
33 return helpers.ExpiredTokenError(e)
34 }
35
36 if *urepo.EmailVerificationCode != req.Token {
37 return helpers.InputError(e, to.StringPtr("InvalidToken"))
38 }
39
40 if time.Now().UTC().After(*urepo.EmailVerificationCodeExpiresAt) {
41 return helpers.ExpiredTokenError(e)
42 }
43
44 now := time.Now().UTC()
45
46 if err := s.db.Exec(ctx, "UPDATE repos SET email_verification_code = NULL, email_verification_code_expires_at = NULL, email_confirmed_at = ? WHERE did = ?", nil, now, urepo.Repo.Did).Error; err != nil {
47 s.logger.Error("error updating user", "error", err)
48 return helpers.ServerError(e, nil)
49 }
50
51 return e.NoContent(200)
52}