package server

import (
	"time"

	"github.com/haileyok/cocoon/internal/helpers"
	"github.com/haileyok/cocoon/models"
	"github.com/labstack/echo/v4"
)

type ComAtprotoServerUpdateEmailRequest struct {
	Email           string `json:"email" validate:"required"`
	EmailAuthFactor bool   `json:"emailAuthFactor"`
	Token           string `json:"token" validate:"required"`
}

func (s *Server) handleServerUpdateEmail(e echo.Context) error {
	urepo := e.Get("repo").(*models.RepoActor)

	var req ComAtprotoServerUpdateEmailRequest
	if err := e.Bind(&req); err != nil {
		s.logger.Error("error binding", "error", err)
		return helpers.ServerError(e, nil)
	}

	if err := e.Validate(req); err != nil {
		return helpers.InputError(e, nil)
	}

	if urepo.EmailUpdateCode == nil || urepo.EmailUpdateCodeExpiresAt == nil {
		return helpers.InvalidTokenError(e)
	}

	if *urepo.EmailUpdateCode != req.Token {
		return helpers.InvalidTokenError(e)
	}

	if time.Now().UTC().After(*urepo.EmailUpdateCodeExpiresAt) {
		return helpers.ExpiredTokenError(e)
	}

	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 {
		s.logger.Error("error updating repo", "error", err)
		return helpers.ServerError(e, nil)
	}

	return e.NoContent(200)
}