package handlers

import (
	"github.com/cortezaproject/corteza/server/auth/request"
	"github.com/cortezaproject/corteza/server/pkg/errors"
	"github.com/cortezaproject/corteza/server/system/service"
	"github.com/cortezaproject/corteza/server/system/types"
	"go.uber.org/zap"
)

func (h *AuthHandlers) requestPasswordResetForm(req *request.AuthReq) error {
	h.Log.Debug("showing request password reset form")
	req.Template = TmplRequestPasswordReset
	req.Data["form"] = req.PopKV()
	return nil
}

func (h *AuthHandlers) requestPasswordResetProc(req *request.AuthReq) (err error) {
	h.Log.Debug("processing password change request")

	email := req.Request.PostFormValue("email")
	err = h.AuthService.SendPasswordResetToken(req.Context(), email)

	if err == nil || errors.IsNotFound(err) {
		req.RedirectTo = GetLinks().PasswordResetRequested
		return nil
	}

	switch {
	case service.AuthErrPasswordResetDisabledByConfig().Is(err):
		h.passwordResetDisabledAlert(req)
		return nil

	default:
		h.Log.Error("unhandled error", zap.Error(err))
		return err
	}
}

func (h *AuthHandlers) passwordResetRequested(req *request.AuthReq) error {
	req.Template = TmplPasswordResetRequested
	return nil
}

func (h *AuthHandlers) resetPasswordForm(req *request.AuthReq) (err error) {
	h.Log.Debug("password reset form")

	req.Template = TmplResetPassword

	// user not set, expecting valid token in URL
	if token := req.Request.URL.Query().Get("token"); len(token) > 0 {
		var user *types.User

		user, err = h.AuthService.ValidatePasswordResetToken(req.Context(), token)
		if err == nil {
			// login user
			req.AuthUser = request.NewAuthUser(h.Settings, user, false)

			if req.AuthUser.PendingEmailOTP() {
				// Email OTP enabled & pending
				//
				// If we're here it means user clicked on a link in an email;
				// we are effectively confirming email OTP
				req.AuthUser.CompleteEmailOTP()
			}

			// redirect back to self (but without token and with user in session
			h.Log.Debug("valid password reset token found, refreshing page with stored user")
			req.RedirectTo = GetLinks().ResetPassword
			req.AuthUser.Save(req.Session)
			return nil
		}
	}

	if req.AuthUser == nil || err != nil {
		h.Log.Warn("invalid password reset token used", zap.Error(err))
		req.RedirectTo = GetLinks().RequestPasswordReset
		t := translator(req, "auth")
		req.NewAlerts = append(req.NewAlerts, request.Alert{
			Type: "warning",
			Text: t("password-reset-requested.alert.invalid-expired-password-token"),
		})
	}

	req.Data["form"] = req.PopKV()
	return nil
}

func (h *AuthHandlers) resetPasswordProc(req *request.AuthReq) (err error) {
	h.Log.Debug("password reset proc")

	err = h.AuthService.SetPassword(req.Context(), req.AuthUser.User.ID, req.Request.PostFormValue("password"))

	if err == nil {
		t := translator(req, "auth")
		req.NewAlerts = append(req.NewAlerts, request.Alert{
			Type: "primary",
			Text: t("password-reset-requested.alert.password-reset-success"),
		})

		req.RedirectTo = GetLinks().Profile
		return nil
	}

	switch {
	case service.AuthErrPasswordResetDisabledByConfig().Is(err):
		h.passwordResetDisabledAlert(req)
		return nil

	default:
		h.Log.Error("unhandled error", zap.Error(err))
		return err
	}
}

func (h *AuthHandlers) onlyIfPasswordResetEnabled(fn handlerFn) handlerFn {
	return func(req *request.AuthReq) error {
		if !h.Settings.PasswordResetEnabled || !h.Settings.LocalEnabled {
			h.passwordResetDisabledAlert(req)
			return nil
		}

		return fn(req)
	}
}

func (h *AuthHandlers) passwordResetDisabledAlert(req *request.AuthReq) {
	req.RedirectTo = GetLinks().Login
	t := translator(req, "auth")
	req.NewAlerts = append(req.NewAlerts, request.Alert{
		Type: "danger",
		Text: t("password-reset-requested.alert.password-reset-disabled"),
	})
}