hailey.at
1package server
2
3import (
4 "fmt"
5 "time"
6
7 "github.com/haileyok/cocoon/internal/helpers"
8 "github.com/haileyok/cocoon/models"
9 "github.com/labstack/echo/v4"
10)
11
12type ComAtprotoRequestEmailUpdateResponse struct {
13 TokenRequired bool `json:"tokenRequired"`
14}
15
16func (s *Server) handleServerRequestEmailUpdate(e echo.Context) error {
17 ctx := e.Request().Context()
18
19 urepo := e.Get("repo").(*models.RepoActor)
20
21 if urepo.EmailConfirmedAt != nil {
22 code := fmt.Sprintf("%s-%s", helpers.RandomVarchar(5), helpers.RandomVarchar(5))
23 eat := time.Now().Add(10 * time.Minute).UTC()
24
25 if err := s.db.Exec(ctx, "UPDATE repos SET email_update_code = ?, email_update_code_expires_at = ? WHERE did = ?", nil, code, eat, urepo.Repo.Did).Error; err != nil {
26 s.logger.Error("error updating repo", "error", err)
27 return helpers.ServerError(e, nil)
28 }
29
30 if err := s.sendEmailUpdate(urepo.Email, urepo.Handle, code); err != nil {
31 s.logger.Error("error sending email", "error", err)
32 return helpers.ServerError(e, nil)
33 }
34 }
35
36 return e.JSON(200, ComAtprotoRequestEmailUpdateResponse{
37 TokenRequired: urepo.EmailConfirmedAt != nil,
38 })
39}