mirror of
https://github.com/navidrome/navidrome.git
synced 2026-03-04 06:35:52 +00:00
55 lines
1.1 KiB
Go
55 lines
1.1 KiB
Go
package plugins
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/navidrome/navidrome/model"
|
|
"github.com/navidrome/navidrome/plugins/host"
|
|
"github.com/navidrome/navidrome/utils/slice"
|
|
)
|
|
|
|
type usersServiceImpl struct {
|
|
ds model.DataStore
|
|
userAccess UserAccess
|
|
}
|
|
|
|
func newUsersService(ds model.DataStore, userAccess UserAccess) host.UsersService {
|
|
return &usersServiceImpl{
|
|
ds: ds,
|
|
userAccess: userAccess,
|
|
}
|
|
}
|
|
|
|
func (s *usersServiceImpl) GetUsers(ctx context.Context) ([]host.User, error) {
|
|
users, err := s.ds.User(ctx).GetAll()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var result []host.User
|
|
for _, u := range users {
|
|
if s.userAccess.IsAllowed(u.ID) {
|
|
result = append(result, host.User{
|
|
UserName: u.UserName,
|
|
Name: u.Name,
|
|
IsAdmin: u.IsAdmin,
|
|
})
|
|
}
|
|
}
|
|
|
|
return result, nil
|
|
}
|
|
|
|
func (s *usersServiceImpl) GetAdmins(ctx context.Context) ([]host.User, error) {
|
|
users, err := s.GetUsers(ctx)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return slice.Filter(users, func(u host.User) bool {
|
|
return u.IsAdmin
|
|
}), nil
|
|
}
|
|
|
|
var _ host.UsersService = (*usersServiceImpl)(nil)
|