173 lines
4.1 KiB
Go
173 lines
4.1 KiB
Go
package usermngmt
|
|
|
|
import (
|
|
"github.com/Selly-Modules/usermngmt/cache"
|
|
"github.com/Selly-Modules/usermngmt/model"
|
|
"github.com/Selly-Modules/usermngmt/permission"
|
|
"github.com/Selly-Modules/usermngmt/role"
|
|
"github.com/Selly-Modules/usermngmt/user"
|
|
)
|
|
|
|
//
|
|
// User
|
|
//
|
|
|
|
// user methods
|
|
|
|
// CreateUser ...
|
|
func (s Service) CreateUser(payload model.UserCreateOptions) (id string, err error) {
|
|
return user.Create(payload)
|
|
}
|
|
|
|
// FindUser ...
|
|
func (s Service) FindUser(userID string) (model.User, error) {
|
|
return user.FindUser(userID)
|
|
}
|
|
|
|
// FindUserByEmail ...
|
|
func (s Service) FindUserByEmail(email string) (model.User, error) {
|
|
return user.FindUserByEmail(email)
|
|
}
|
|
|
|
// GetHashedPassword ...
|
|
func (s Service) GetHashedPassword(userID string) (string, error) {
|
|
return user.GetHashedPassword(userID)
|
|
}
|
|
|
|
// UpdateUser ...
|
|
func (s Service) UpdateUser(userID string, payload model.UserUpdateOptions) error {
|
|
return user.UpdateByUserID(userID, payload)
|
|
}
|
|
|
|
// ChangeUserPassword ...
|
|
func (s Service) ChangeUserPassword(userID string, payload model.ChangePasswordOptions) error {
|
|
return user.ChangeUserPassword(userID, payload)
|
|
}
|
|
|
|
// ResetUserPassword ...
|
|
func (s Service) ResetUserPassword(userID string, password string) error {
|
|
return user.ResetUserPassword(userID, password)
|
|
}
|
|
|
|
// ResetAndRequireToChangeUserPassword ...
|
|
func (s Service) ResetAndRequireToChangeUserPassword(userID string, password string) error {
|
|
return user.ResetAndRequireToChangeUserPassword(userID, password)
|
|
}
|
|
|
|
// ChangeUserStatus ...
|
|
func (s Service) ChangeUserStatus(userID, newStatus string) error {
|
|
return user.ChangeUserStatus(userID, newStatus)
|
|
}
|
|
|
|
// GetAllUsers ...
|
|
func (s Service) GetAllUsers(query model.UserAllQuery) model.UserAll {
|
|
return user.All(query)
|
|
}
|
|
|
|
// GetUsersByPermission ...
|
|
func (s Service) GetUsersByPermission(query model.UserByPermissionQuery) model.UserAll {
|
|
return user.GetUsersByPermission(query)
|
|
}
|
|
|
|
// CountAllUsers ...
|
|
func (s Service) CountAllUsers(query model.UserCountQuery) int64 {
|
|
return user.Count(query)
|
|
}
|
|
|
|
// ChangeAllUsersStatus ...
|
|
func (s Service) ChangeAllUsersStatus(roleID, status string) error {
|
|
return user.ChangeAllUsersStatus(roleID, status)
|
|
}
|
|
|
|
// LoginWithEmailAndPassword ...
|
|
func (s Service) LoginWithEmailAndPassword(email, password string) (model.User, error) {
|
|
return user.LoginWithEmailAndPassword(email, password)
|
|
}
|
|
|
|
// HasPermission ...
|
|
func (s Service) HasPermission(userID, permission string) bool {
|
|
return user.HasPermission(userID, permission)
|
|
}
|
|
|
|
// UpdateUserAvatar ...
|
|
func (s Service) UpdateUserAvatar(userID string, avatar interface{}) error {
|
|
return user.UpdateAvatar(userID, avatar)
|
|
}
|
|
|
|
// DeleteUser ...
|
|
func (s Service) DeleteUser(userID string) error {
|
|
return user.Delete(userID)
|
|
}
|
|
|
|
//
|
|
// Role
|
|
//
|
|
|
|
// role methods
|
|
|
|
// CreateRole ...
|
|
func (s Service) CreateRole(payload model.RoleCreateOptions) (id string, err error) {
|
|
id, err = role.Create(payload)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
cache.Roles()
|
|
return
|
|
}
|
|
|
|
// UpdateRole ...
|
|
func (s Service) UpdateRole(roleID string, payload model.RoleUpdateOptions) error {
|
|
return role.Update(roleID, payload)
|
|
}
|
|
|
|
// GetAllRoles ...
|
|
func (s Service) GetAllRoles(query model.RoleAllQuery) model.RoleAll {
|
|
return role.All(query)
|
|
}
|
|
|
|
// FindRole ...
|
|
func (s Service) FindRole(roleID string) (model.Role, error) {
|
|
return role.FindRole(roleID)
|
|
}
|
|
|
|
//
|
|
// Permission
|
|
//
|
|
|
|
// permission methods
|
|
|
|
// CreatePermission ...
|
|
func (s Service) CreatePermission(payload model.PermissionCreateOptions) (id string, err error) {
|
|
id, err = permission.Create(payload)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
cache.Roles()
|
|
return
|
|
}
|
|
|
|
// UpdatePermission ...
|
|
func (s Service) UpdatePermission(permissionID string, payload model.PermissionUpdateOptions) error {
|
|
if err := permission.Update(permissionID, payload); err != nil {
|
|
return err
|
|
}
|
|
cache.Roles()
|
|
return nil
|
|
}
|
|
|
|
// DeletePermission ...
|
|
func (s Service) DeletePermission(permissionID string) error {
|
|
if err := permission.Delete(permissionID); err != nil {
|
|
return err
|
|
}
|
|
cache.Roles()
|
|
return nil
|
|
}
|
|
|
|
// GetAllPermissions ...
|
|
func (s Service) GetAllPermissions(query model.PermissionAllQuery) model.PermissionAll {
|
|
return permission.All(query)
|
|
}
|