Function UpdateUserPassword

db/users/update_password.go:13–86

(ctx context.Context, app, addonUUID, username string)

)

func UpdateUserPassword(ctx context.Context, app, addonUUID, username string) error {
	isSupported, err := doesDatabaseHandleUserManagement(ctx, app, addonUUID)
	if err != nil {
		return errors.Wrap(ctx, err, "get user management information")
	}

	if !isSupported {
		io.Error(ErrDatabaseNotSupportUserManagement)
		return nil
	}

	if usernameValidation, ok := isUsernameValid(username); !ok {
		io.Error(usernameValidation)
		return nil
	}

	c, err := config.ScalingoClient(ctx)
	if err != nil {
		return errors.Wrap(ctx, err, "get Scalingo client")
	}

	l, err := c.DatabaseListUsers(ctx, app, addonUUID)
	if err != nil {
		return errors.Wrap(ctx, err, "list the database's users")
	}
	// Check if the userParam exists and is not protected
	var user *scalingo.DatabaseUser
	for _, u := range l {
		if u.Name == username {
			user = &u
			break
		}
	}
	if user == nil {
		return errors.New(ctx, fmt.Sprintf("User \"%s\" does not exist", username))
	}
	if user.Protected {
		return errors.New(ctx, fmt.Sprintf("User \"%s\" is protected", username))
	}

	password, confirmedPassword, err := askForPasswordWithRetry(ctx, 3)
	if err != nil {
		io.Error(err)
		return nil
	}

	isPasswordGenerated := password == ""

	var databaseUser scalingo.DatabaseUser

	// We have two different API calls here to avoid breaking backwards compatibility of the CLI
	if !isPasswordGenerated {
		userUpdateParam := scalingo.DatabaseUpdateUserParam{
			DatabaseID:           addonUUID,
			Password:             password,
			PasswordConfirmation: confirmedPassword,
		}
		databaseUser, err = c.DatabaseUpdateUser(ctx, app, addonUUID, username, userUpdateParam)