users_controller.go

package webui

import (
	"fmt"
	"net/http"
	"strconv"
	"strings"
	"time"

	"github.com/APTrust/registry/common"
	"github.com/APTrust/registry/constants"
	"github.com/APTrust/registry/forms"
	"github.com/APTrust/registry/helpers"
	"github.com/APTrust/registry/middleware"
	"github.com/APTrust/registry/pgmodels"
	"github.com/APTrust/registry/web/api"
	"github.com/gin-gonic/gin"
	"github.com/google/uuid"
)

// UserCreate a new user. Handles submission of new user form.
// POST /users/new
func UserCreate(c *gin.Context) {
	saveUserForm(c)
}

// UserDelete deletes a user.
// DELETE or POST /users/delete/:id
func UserDelete(c *gin.Context) {
	req := NewRequest(c)
	user, err := pgmodels.UserByID(req.Auth.ResourceID)
	if AbortIfError(c, err) {
		return
	}
	err = user.Delete()
	if AbortIfError(c, err) {
		return
	}
	c.Redirect(http.StatusFound, "/users")
}

// UserUndelete reactivates a user.
// POST or PUT /users/undelete/:id
func UserUndelete(c *gin.Context) {
	req := NewRequest(c)
	user, err := pgmodels.UserByID(req.Auth.ResourceID)
	if AbortIfError(c, err) {
		return
	}
	err = user.Undelete()
	if AbortIfError(c, err) {
		return
	}
	location := fmt.Sprintf("/users/show/%d", user.ID)
	c.Redirect(http.StatusFound, location)
}

// UserIndex shows list of users.
// GET /users
func UserIndex(c *gin.Context) {
	req := NewRequest(c)
	template := "users/index.html"
	var users []*pgmodels.UserView
	err := req.LoadResourceList(&users, "name", "asc", forms.NewUserFilterForm)
	if AbortIfError(c, err) {
		return
	}
	c.HTML(http.StatusOK, template, req.TemplateData)
}

// UserNew returns a blank form for the user to create a new user.
// GET /users/new
func UserNew(c *gin.Context) {
	req := NewRequest(c)
	form, err := forms.NewUserForm(&pgmodels.User{}, req.CurrentUser)
	if AbortIfError(c, err) {
		return
	}
	req.TemplateData["form"] = form
	c.HTML(http.StatusOK, form.Template, req.TemplateData)
}

// UserShow returns the user with the specified id.
// GET /users/show/:id
func UserShow(c *gin.Context) {
	req := NewRequest(c)
	user, err := pgmodels.UserByID(req.Auth.ResourceID)
	if AbortIfError(c, err) {
		return
	}
	req.TemplateData["user"] = user
	c.HTML(http.StatusOK, "users/show.html", req.TemplateData)
}

// UserUpdate saves changes to an exiting user.
// PUT /users/edit/:id
func UserUpdate(c *gin.Context) {
	saveUserForm(c)
}

// UserEdit shows a form to edit an exiting user.
// GET /users/edit/:id
func UserEdit(c *gin.Context) {
	req := NewRequest(c)
	userToEdit, err := pgmodels.UserByID(req.Auth.ResourceID)
	if AbortIfError(c, err) {
		return
	}
	form, err := forms.NewUserForm(userToEdit, req.CurrentUser)
	if AbortIfError(c, err) {
		return
	}
	req.TemplateData["form"] = form
	c.HTML(http.StatusOK, form.Template, req.TemplateData)
}

// UserSignInShow shows the user sign-in form.
// GET /users/sign_in
func UserSignInShow(c *gin.Context) {
	// Check to see if the user is already logged in.
	// If they are, send them to the dashboard.
	// We do this because users often bookmark the root url
	// and go there when they still have a valid session.
	// Instead of forcing them to sign in again, just push
	// them to the dashboard.
	user, _ := middleware.GetUser(c)
	if user != nil && user.InstitutionID > 0 {
		common.Context().Log.Info().Msgf("User %s is already logged in. Redirecting to dashboard.", user.Email)
		location := c.DefaultQuery("requrl", "/dashboard")
		c.Redirect(http.StatusFound, location)
	}

	// For these environments, prefill logins defined in fixtures
	// to make dev's life easier. These envs contain only fixture
	// and test data.
	envName := common.Context().Config.EnvName
	preFillTestLogins := envName == "test" || envName == "integration"
	c.HTML(200, "users/sign_in.html", gin.H{
		"cover":             helpers.GetCover(),
		"preFillTestLogins": preFillTestLogins,
	})
}

// UserSignIn signs the user in.
// POST /users/sign_in
func UserSignIn(c *gin.Context) {
	status, redirectTo, err := SignInUser(c)
	if err == nil {
		c.Redirect(status, redirectTo)
	} else {
		c.HTML(status, "users/sign_in.html", gin.H{
			"error": err.Error(),
			"cover": helpers.GetCover(),
		})
	}
}

// UserSignOut signs the user out.
// GET /users/sign_out
func UserSignOut(c *gin.Context) {
	req := NewRequest(c)
	if req.CurrentUser != nil {
		req.CurrentUser.SignOut()
	}
	helpers.DeleteSessionCookie(c)
	helpers.DeleteCSRFCookie(c)
	c.HTML(http.StatusOK, "users/sign_in.html", gin.H{
		"cover":             helpers.GetCover(),
		"preFillTestLogins": common.Context().Config.EnvName == "test",
		"error":             req.TemplateData["flash"],
	})
}

// UserShowChangePassword displays the change password page
// for the user with the specified ID.
//
// GET /users/change_password/:id
func UserShowChangePassword(c *gin.Context) {
	req, userToEdit, err := reqAndUserForPwdEdit(c)
	if err != nil {
		AbortIfError(c, err)
		return
	}
	form := forms.NewPasswordResetForm(userToEdit)
	req.TemplateData["form"] = form
	req.TemplateData["user"] = userToEdit

	// Not the prettiest solution, but for now, don't show
	// top and side nav if user is editing their own password.
	// On a forced password reset, we want the user to change
	// their password, not navigate to another page.
	//
	// This may annoy users changing their own password, and
	// it won't deter anyone from manually typing in a URL,
	// but it will suffice for now. No sense building in complex
	// logic now if ST is going to redo the UI anyway.
	// We'll come back to this one.
	if req.CurrentUser.ResetPasswordToken != "" {
		req.TemplateData["suppressTopNav"] = true
		req.TemplateData["suppressSideNav"] = true
	}

	c.HTML(http.StatusOK, form.Template, req.TemplateData)
}

// UserChangePassword changes a user's password. The user gets
// to specify what the new password will be.
//
// POST /users/change_password/:id
func UserChangePassword(c *gin.Context) {
	req, userToEdit, err := reqAndUserForPwdEdit(c)
	if err != nil {
		AbortIfError(c, err)
		return
	}

	pwd := c.PostForm("NewPassword")
	confirm := c.PostForm("ConfirmNewPassword")
	if pwd != confirm {
		err := fmt.Errorf("passwords don't match")
		AbortIfError(c, err)
		return
	}
	if !common.PasswordMeetsRequirements(pwd) {
		AbortIfError(c, common.ErrPasswordReqs)
		return
	}
	encPassword, err := common.EncryptPassword(pwd)
	if AbortIfError(c, err) {
		return
	}
	userToEdit.EncryptedPassword = encPassword
	userToEdit.PasswordChangedAt = time.Now().UTC()

	userToEdit.ResetPasswordToken = ""
	userToEdit.ResetPasswordSentAt = time.Time{}
	userToEdit.ForcePasswordUpdate = false
	err = userToEdit.Save()
	if AbortIfError(c, err) {
		return
	}

	// Create a password changed alert, so we know this
	// happened and user knows too. If user gets a suspicious
	// "password changed" alert, they can contact us.
	_, err = CreatePasswordChangedAlert(req, userToEdit)
	if err != nil {
		common.Context().Log.Error().Msgf("UserChangePassword error: %v", err)
	}

	helpers.SetFlashCookie(c, "Your password has been changed.")
	redirectURL := fmt.Sprintf("/users/show/%d", userToEdit.ID)
	if !req.CurrentUser.HasPermission(constants.UserRead, userToEdit.InstitutionID) {
		redirectURL = "/users/my_account"
	}
	c.Redirect(http.StatusFound, redirectURL)
}

func reqAndUserForPwdEdit(c *gin.Context) (*Request, *pgmodels.User, error) {
	req := NewRequest(c)
	userToEdit, err := pgmodels.UserByID(req.Auth.ResourceID)
	if err != nil {
		return req, nil, err
	}

	// Let's be real clear about the permissions governing who can
	// change a user's password.

	// Is the current user editing him/herself?
	isEditingSelf := req.CurrentUser.ID == req.Auth.ResourceID

	// Is current user an inst admin editing a user at their own institution?
	canEditInstUser := req.CurrentUser.HasPermission(constants.UserUpdate, userToEdit.InstitutionID)

	// Is current user sys admin?
	isSysAdmin := req.CurrentUser.IsAdmin()

	// Does the current user meet any of the three use cases above
	// that would allow them to change the password of the subject
	// user (userToEdit)?
	canEditSubject := isEditingSelf || canEditInstUser || isSysAdmin

	if !canEditSubject {
		return nil, nil, common.ErrPermissionDenied
	}

	// If the current user has a password reset token, they should
	// be resetting their own password, not someone else's... even
	// if they are otherwise allowed to perform this kind of edit.
	if req.CurrentUser.ResetPasswordToken != "" && req.CurrentUser.ID != req.Auth.ResourceID {
		return nil, nil, common.ErrMustCompleteReset
	}

	return req, userToEdit, err
}

// UserInitPasswordReset resets a user's password to something
// random and sends them an email with a link that has an embedded
// login token. When they follow the link, they'll be automatically
// logged in and will have to choose a new password.
//
// TODO: This should be POST or PUT, not GET
//
// GET /users/init_password_reset/:id
func UserInitPasswordReset(c *gin.Context) {
	// This is admin triggering a password reset for another user,
	// so current user id does not need to match subject user id.
	req, userToEdit, err := reqAndUserForPwdEdit(c)
	if err != nil {
		AbortIfError(c, err)
		return
	}
	err = initPasswordReset(req, userToEdit)
	if AbortIfError(c, err) {
		return
	}
	req.TemplateData["user"] = userToEdit
	c.HTML(http.StatusOK, "users/reset_password_initiated.html", req.TemplateData)
}

// UserCompletePasswordReset allows a user to enter a token to reset
// their password. Why not embed the password in the URL? Because
// https://bit.ly/3u9GWEn.
//
// Note that this is one of the few pages that does
// not require a login.
//
// GET /users/complete_password_reset/:id
func UserStartPasswordReset(c *gin.Context) {
	userID, err := strconv.ParseInt(c.Param("id"), 10, 64)
	if userID == 0 || err != nil {
		AbortIfError(c, common.ErrInvalidParam)
		return
	}
	user, err := pgmodels.UserByID(userID)
	if AbortIfError(c, err) {
		return
	}
	if !user.DeactivatedAt.IsZero() {
		AbortIfError(c, common.ErrAccountDeactivated)
		return
	}

	// Assuming user is not logged in if they're hitting this page.
	// They'll need a CSRF csrfToken to post data. DO NOT set the
	// CurrentUser session variable until after we have the right
	// csrfToken and user has completed password reset.
	csrfToken, err := helpers.SetCSRFCookie(c)
	if AbortIfError(c, err) {
		return
	}
	templateData := gin.H{
		"id":                    userID,
		"suppressSideNav":       true,
		"suppressTopNav":        true,
		constants.CSRFTokenName: csrfToken,
	}
	c.HTML(http.StatusOK, "users/enter_password_reset_token.html", templateData)
}

// UserCompletePasswordReset allows a user to complete the password
// reset process. Note that this is one of the few pages that does
// not require a login.
//
// POST /users/complete_password_reset/:id
func UserCompletePasswordReset(c *gin.Context) {
	userID, err := strconv.ParseInt(c.Param("id"), 10, 64)
	if userID == 0 || err != nil {
		AbortIfError(c, common.ErrInvalidParam)
		return
	}
	token := c.PostForm("token")
	if token == "" {
		common.Context().Log.Error().Msgf("POST /users/complete_password_reset/%d got empty token", userID)
		AbortIfError(c, common.ErrInvalidToken)
		return
	}

	user, err := pgmodels.UserByID(userID)
	if AbortIfError(c, err) {
		return
	}
	if !user.DeactivatedAt.IsZero() {
		AbortIfError(c, common.ErrAccountDeactivated)
		return
	}
	// User may not have a token, which means they're not in the reset process.
	// But we don't want to tell hackers that, so we'll just let them fail.
	if !common.ComparePasswords(user.ResetPasswordToken, token) {
		common.Context().Log.Error().Msgf("POST /users/complete_password_reset/%d got wrong token", userID)
		AbortIfError(c, common.ErrInvalidToken)
		return
	}

	user.SignInCount = user.SignInCount + 1
	if user.CurrentSignInIP != "" {
		user.LastSignInIP = user.CurrentSignInIP
	}
	if user.CurrentSignInAt.IsZero() {
		user.LastSignInAt = user.CurrentSignInAt
	}
	user.CurrentSignInIP = c.ClientIP()
	user.CurrentSignInAt = time.Now().UTC()
	err = user.Save()
	if AbortIfError(c, err) {
		return
	}

	err = helpers.SetSessionCookie(c, user)
	if AbortIfError(c, err) {
		return
	}
	c.Set("CurrentUser", user)
	pageURL := fmt.Sprintf("/users/change_password/%d", user.ID)
	c.Redirect(http.StatusFound, pageURL)
}

// UserGetAPIKey issues a new API key for the user, which replaces the
// user's existing API key. This key will be displayed once only.
//
// POST /users/get_api_key/:id
func UserGetAPIKey(c *gin.Context) {
	req := NewRequest(c)
	if req.CurrentUser.ID != req.Auth.ResourceID {
		common.Context().Log.Warn().Msgf("Permission denied: User %d requested API key for user %d", req.CurrentUser.ID, req.Auth.ResourceID)
		AbortIfError(c, common.ErrPermissionDenied)
	}
	apiKey := common.RandomToken()
	encKey, err := common.EncryptPassword(apiKey)
	if AbortIfError(c, err) {
		return
	}
	req.CurrentUser.EncryptedAPISecretKey = encKey
	err = req.CurrentUser.Save()
	if AbortIfError(c, err) {
		return
	}

	req.TemplateData["user"] = req.CurrentUser
	req.TemplateData["apiKey"] = apiKey
	req.TemplateData["showAsModal"] = true
	c.HTML(http.StatusOK, "users/show_api_key.html", req.TemplateData)
}

// UserMyAccount displays the user's account info. From this page, they
// can see account details, change their password, and get an API key.
//
// GET /users/my_account
func UserMyAccount(c *gin.Context) {
	req := NewRequest(c)
	c.HTML(http.StatusOK, "users/my_account.html", req.TemplateData)
}

// GET /users/forgot_password
func UserShowForgotPasswordForm(c *gin.Context) {
	req := NewRequest(c)
	req.TemplateData["suppressTopNav"] = true
	req.TemplateData["suppressSideNav"] = true
	token, err := helpers.SetCSRFCookie(c)
	if AbortIfError(c, err) {
		return
	}
	req.TemplateData[constants.CSRFTokenName] = token
	c.HTML(http.StatusOK, "users/forgot_password.html", req.TemplateData)
}

// POST /users/forgot_password
func UserSendForgotPasswordMessage(c *gin.Context) {
	req := NewRequest(c)
	req.TemplateData["suppressTopNav"] = true
	req.TemplateData["suppressSideNav"] = true
	email := c.PostForm("email")
	userToEdit, err := pgmodels.UserByEmail(email)
	if userToEdit == nil || userToEdit.ID == 0 || pgmodels.IsNoRowError(err) {
		AbortIfError(c, fmt.Errorf("We have no account associated with that email address."))
		return
	}
	if !userToEdit.DeactivatedAt.IsZero() {
		AbortIfError(c, fmt.Errorf("That account has been deactivated. Contact your local APTrust administrator."))
		return
	}
	// Handle unknown error
	if AbortIfError(c, err) {
		return
	}
	err = initPasswordReset(req, userToEdit)
	if AbortIfError(c, err) {
		return
	}
	c.HTML(http.StatusOK, "users/forgot_password_confirmation.html", req.TemplateData)
}

// SignInUser signs the user in with email and password.
// If user has two-factor auth, this is the first step of login.
func SignInUser(c *gin.Context) (int, string, error) {
	redirectTo := "/users/sign_in"
	user, err := pgmodels.UserSignIn(
		c.PostForm("email"),
		c.PostForm("password"),
		c.ClientIP(),
	)
	if err != nil {
		c.Error(err)
		helpers.DeleteSessionCookie(c)
		return http.StatusBadRequest, redirectTo, err
	}

	// Set this flag for two factor users.
	// Be sure to save this, or user can bypass 2fa on next request.
	user.AwaitingSecondFactor = user.IsTwoFactorUser()
	err = user.Save()
	if err != nil {
		return http.StatusInternalServerError, redirectTo, err
	}

	err = helpers.SetSessionCookie(c, user)
	if err != nil {
		return http.StatusInternalServerError, redirectTo, err
	}
	_, err = helpers.SetCSRFCookie(c)
	if AbortIfError(c, err) {
		return http.StatusInternalServerError, redirectTo, err
	}
	c.Set("CurrentUser", user)

	redirectTo = "/dashboard"
	if user.IsTwoFactorUser() {
		redirectTo = "/users/2fa_choose"
	}
	return http.StatusFound, redirectTo, nil
}

// UserUpdateXHR handles updates to individual properties of the
// User object. These come from inline forms on the user view and
// user list pages. This allows edits to only the following fields:
//
// Name, Email, Phone, Password, Role, Status, and OTPRequiredForLogin.
//
// Note: Unlike most calls in this package, this one returns JSON,
// not HTML. This is a late addition based on UI mockups.
//
// PUT /users/edit_xhr/:id
func UserUpdateXHR(c *gin.Context) {
	req := NewRequest(c)
	userToEdit, err := pgmodels.UserByID(req.Auth.ResourceID)
	if api.AbortIfError(c, err) {
		return
	}
	if strings.TrimSpace(c.PostForm("Name")) != "" {
		userToEdit.Name = strings.TrimSpace(c.PostForm("Name"))
	}
	if strings.TrimSpace(c.PostForm("Email")) != "" {
		userToEdit.Email = strings.TrimSpace(c.PostForm("Email"))
	}
	if strings.TrimSpace(c.PostForm("PhoneNumber")) != "" {
		userToEdit.PhoneNumber = strings.TrimSpace(c.PostForm("PhoneNumber"))
	}
	// Consider routing this to UserChangePassword instead
	if strings.TrimSpace(c.PostForm("Password")) != "" {
		encPwd, err := common.EncryptPassword(strings.TrimSpace(c.PostForm("Password")))
		if api.AbortIfError(c, err) {
			return
		}
		userToEdit.EncryptedPassword = encPwd
		userToEdit.PasswordChangedAt = time.Now().UTC()
	}
	if strings.TrimSpace(c.PostForm("Role")) != "" {
		userToEdit.Role = strings.TrimSpace(c.PostForm("Role"))
	}
	if strings.TrimSpace(c.PostForm("Status")) != "" {
		if strings.ToLower(strings.TrimSpace(c.PostForm("Status"))) == "inactive" {
			userToEdit.DeactivatedAt = time.Now().UTC()
		} else {
			userToEdit.DeactivatedAt = time.Time{}
		}
	}
	if strings.TrimSpace(c.PostForm("OTPRequiredForLogin")) != "" {
		otpRequired := strings.TrimSpace(c.PostForm("OTPRequiredForLogin")) == "true"
		userToEdit.OTPRequiredForLogin = otpRequired
		userToEdit.GracePeriod = time.Now().UTC().Add(30 * 24 * time.Hour)
	}
	if api.AbortIfError(c, userToEdit.Save()) {
		return
	}
	returnValue := map[string]interface{}{
		"StatusCode": http.StatusOK,
		"Message":    "Update succeeded.",
	}
	c.JSON(http.StatusOK, returnValue)
}

func saveUserForm(c *gin.Context) {
	req := NewRequest(c)
	userToEdit := &pgmodels.User{}
	var err error
	if req.Auth.ResourceID > 0 {
		// Load existing user.
		userToEdit, err = pgmodels.UserByID(req.Auth.ResourceID)
		if AbortIfError(c, err) {
			return
		}
	} else {
		// Assign random password to new user. They'll get an email
		// asking them to reset their password.
		encPwd, err := common.EncryptPassword(uuid.New().String())
		if AbortIfError(c, err) {
			return
		}
		userToEdit.EncryptedPassword = encPwd
	}

	// Bind submitted form values in case we have to
	// re-display the form with an error message.
	c.ShouldBind(userToEdit)
	form, err := forms.NewUserForm(userToEdit, req.CurrentUser)
	if AbortIfError(c, err) {
		return
	}
	req.TemplateData["form"] = form
	if form.Save() {
		// If we just created a new user, send them a welcome email.
		if req.Auth.ResourceID == 0 {
			err = createNewUserAlert(req, userToEdit)
			if AbortIfError(c, err) {
				return
			}
		}
		c.Redirect(form.Status, form.PostSaveURL())
	} else {
		req.TemplateData["FormError"] = form.Error
		c.HTML(form.Status, form.Template, req.TemplateData)
	}
}

func createNewUserAlert(req *Request, newUser *pgmodels.User) error {
	token := common.RandomToken()
	encryptedToken, err := common.EncryptPassword(token)
	if err != nil {
		return err
	}
	newUser.ResetPasswordToken = encryptedToken
	newUser.ForcePasswordUpdate = true
	err = newUser.Save()
	if err != nil {
		return err
	}
	_, err = CreateNewAccountAlert(req, newUser, token)
	return err
}

func initPasswordReset(req *Request, userToEdit *pgmodels.User) error {
	token := common.RandomToken()
	encryptedToken, err := common.EncryptPassword(token)
	if err != nil {
		return err
	}
	userToEdit.ResetPasswordToken = encryptedToken
	userToEdit.ForcePasswordUpdate = true
	err = userToEdit.Save()
	if err != nil {
		return err
	}
	_, err = CreatePasswordResetAlert(req, userToEdit, token)
	return err
}