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 ComAtprotoServerUpdateEmailRequest struct {
13 Email string `json:"email" validate:"required"`
14 EmailAuthFactor bool `json:"emailAuthFactor"`
15 Token string `json:"token" validate:"required"`
16}
17
18func (s *Server) handleServerUpdateEmail(e echo.Context) error {
19 urepo := e.Get("repo").(*models.RepoActor)
20
21 var req ComAtprotoServerUpdateEmailRequest
22 if err := e.Bind(&req); err != nil {
23 s.logger.Error("error binding", "error", err)
24 return helpers.ServerError(e, nil)
25 }
26
27 if err := e.Validate(req); err != nil {
28 return helpers.InputError(e, nil)
29 }
30
31 if urepo.EmailUpdateCode == nil || urepo.EmailUpdateCodeExpiresAt == nil {
32 return helpers.InputError(e, to.StringPtr("InvalidToken"))
33 }
34
35 if *urepo.EmailUpdateCode != req.Token {
36 return helpers.InputError(e, to.StringPtr("InvalidToken"))
37 }
38
39 if time.Now().UTC().After(*urepo.EmailUpdateCodeExpiresAt) {
40 return helpers.InputError(e, to.StringPtr("ExpiredToken"))
41 }
42
43 if err := s.db.Exec("UPDATE repos SET email_update_code = NULL, email_update_code_expires_at = NULL, email_confirmed_at = NULL, email = ? WHERE did = ?", req.Email, urepo.Repo.Did).Error; err != nil {
44 s.logger.Error("error updating repo", "error", err)
45 return helpers.ServerError(e, nil)
46 }
47
48 return e.NoContent(200)
49}