hailey.at
1package server
2
3import (
4 "time"
5
6 "github.com/haileyok/cocoon/internal/helpers"
7 "github.com/haileyok/cocoon/models"
8 "github.com/labstack/echo/v4"
9)
10
11type ComAtprotoServerUpdateEmailRequest struct {
12 Email string `json:"email" validate:"required"`
13 EmailAuthFactor bool `json:"emailAuthFactor"`
14 Token string `json:"token" validate:"required"`
15}
16
17func (s *Server) handleServerUpdateEmail(e echo.Context) error {
18 urepo := e.Get("repo").(*models.RepoActor)
19
20 var req ComAtprotoServerUpdateEmailRequest
21 if err := e.Bind(&req); err != nil {
22 s.logger.Error("error binding", "error", err)
23 return helpers.ServerError(e, nil)
24 }
25
26 if err := e.Validate(req); err != nil {
27 return helpers.InputError(e, nil)
28 }
29
30 if urepo.EmailUpdateCode == nil || urepo.EmailUpdateCodeExpiresAt == nil {
31 return helpers.InvalidTokenError(e)
32 }
33
34 if *urepo.EmailUpdateCode != req.Token {
35 return helpers.InvalidTokenError(e)
36 }
37
38 if time.Now().UTC().After(*urepo.EmailUpdateCodeExpiresAt) {
39 return helpers.ExpiredTokenError(e)
40 }
41
42 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 = ?", nil, req.Email, urepo.Repo.Did).Error; err != nil {
43 s.logger.Error("error updating repo", "error", err)
44 return helpers.ServerError(e, nil)
45 }
46
47 return e.NoContent(200)
48}