willdot.net
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 ComAtprotoServerRequestPasswordResetRequest struct {
13 Email string `json:"email" validate:"required"`
14}
15
16func (s *Server) handleServerRequestPasswordReset(e echo.Context) error {
17 ctx := e.Request().Context()
18 logger := s.logger.With("name", "handleServerRequestPasswordReset")
19
20 urepo, ok := e.Get("repo").(*models.RepoActor)
21 if !ok {
22 var req ComAtprotoServerRequestPasswordResetRequest
23 if err := e.Bind(&req); err != nil {
24 return err
25 }
26
27 if err := e.Validate(req); err != nil {
28 return err
29 }
30
31 murepo, err := s.getRepoActorByEmail(ctx, req.Email)
32 if err != nil {
33 return err
34 }
35
36 urepo = murepo
37 }
38
39 code := fmt.Sprintf("%s-%s", helpers.RandomVarchar(5), helpers.RandomVarchar(5))
40 eat := time.Now().Add(10 * time.Minute).UTC()
41
42 if err := s.db.Exec(ctx, "UPDATE repos SET password_reset_code = ?, password_reset_code_expires_at = ? WHERE did = ?", nil, code, eat, urepo.Repo.Did).Error; err != nil {
43 logger.Error("error updating repo", "error", err)
44 return helpers.ServerError(e, nil)
45 }
46
47 if err := s.sendPasswordReset(urepo.Email, urepo.Handle, code); err != nil {
48 logger.Error("error sending email", "error", err)
49 return helpers.ServerError(e, nil)
50 }
51
52 return e.NoContent(200)
53}