mirror of https://github.com/portainer/portainer
fix(security): block non-admins from user info listing EE-5825 (#10242)
parent
f74704fca4
commit
bbc26682dd
|
@ -26,24 +26,23 @@ import (
|
||||||
// @failure 500 "Server error"
|
// @failure 500 "Server error"
|
||||||
// @router /users [get]
|
// @router /users [get]
|
||||||
func (handler *Handler) userList(w http.ResponseWriter, r *http.Request) *httperror.HandlerError {
|
func (handler *Handler) userList(w http.ResponseWriter, r *http.Request) *httperror.HandlerError {
|
||||||
users, err := handler.DataStore.User().ReadAll()
|
|
||||||
if err != nil {
|
|
||||||
return httperror.InternalServerError("Unable to retrieve users from the database", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
securityContext, err := security.RetrieveRestrictedRequestContext(r)
|
securityContext, err := security.RetrieveRestrictedRequestContext(r)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return httperror.InternalServerError("Unable to retrieve info from request context", err)
|
return httperror.InternalServerError("Unable to retrieve info from request context", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
availableUsers := security.FilterUsers(users, securityContext)
|
if !securityContext.IsAdmin {
|
||||||
for i := range availableUsers {
|
return httperror.Forbidden("Permission denied to access users list", err)
|
||||||
hideFields(&availableUsers[i])
|
}
|
||||||
|
|
||||||
|
users, err := handler.DataStore.User().ReadAll()
|
||||||
|
if err != nil {
|
||||||
|
return httperror.InternalServerError("Unable to retrieve users from the database", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
endpointID, _ := request.RetrieveNumericQueryParameter(r, "environmentId", true)
|
endpointID, _ := request.RetrieveNumericQueryParameter(r, "environmentId", true)
|
||||||
if endpointID == 0 {
|
if endpointID == 0 {
|
||||||
return response.JSON(w, availableUsers)
|
return response.JSON(w, users)
|
||||||
}
|
}
|
||||||
|
|
||||||
// filter out users who do not have access to the specific endpoint
|
// filter out users who do not have access to the specific endpoint
|
||||||
|
@ -58,7 +57,7 @@ func (handler *Handler) userList(w http.ResponseWriter, r *http.Request) *httper
|
||||||
}
|
}
|
||||||
|
|
||||||
canAccessEndpoint := make([]portainer.User, 0)
|
canAccessEndpoint := make([]portainer.User, 0)
|
||||||
for _, user := range availableUsers {
|
for _, user := range users {
|
||||||
// the users who have the endpoint authorization
|
// the users who have the endpoint authorization
|
||||||
if _, ok := user.EndpointAuthorizations[endpoint.ID]; ok {
|
if _, ok := user.EndpointAuthorizations[endpoint.ID]; ok {
|
||||||
canAccessEndpoint = append(canAccessEndpoint, user)
|
canAccessEndpoint = append(canAccessEndpoint, user)
|
||||||
|
|
|
@ -111,28 +111,14 @@ func Test_userList(t *testing.T) {
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("standard user cannot list amdin users", func(t *testing.T) {
|
t.Run("standard user cannot list users", func(t *testing.T) {
|
||||||
req := httptest.NewRequest(http.MethodGet, "/users", nil)
|
req := httptest.NewRequest(http.MethodGet, "/users", nil)
|
||||||
req.Header.Add("Authorization", fmt.Sprintf("Bearer %s", jwt))
|
req.Header.Add("Authorization", fmt.Sprintf("Bearer %s", jwt))
|
||||||
|
|
||||||
rr := httptest.NewRecorder()
|
rr := httptest.NewRecorder()
|
||||||
h.ServeHTTP(rr, req)
|
h.ServeHTTP(rr, req)
|
||||||
|
|
||||||
is.Equal(http.StatusOK, rr.Code)
|
is.Equal(http.StatusForbidden, rr.Code)
|
||||||
|
|
||||||
body, err := io.ReadAll(rr.Body)
|
|
||||||
is.NoError(err, "ReadAll should not return error")
|
|
||||||
|
|
||||||
var resp []portainer.User
|
|
||||||
err = json.Unmarshal(body, &resp)
|
|
||||||
is.NoError(err, "response should be list json")
|
|
||||||
|
|
||||||
is.Len(resp, 2)
|
|
||||||
if len(resp) > 0 {
|
|
||||||
for _, user := range resp {
|
|
||||||
is.NotEqual(portainer.AdministratorRole, user.Role)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
})
|
||||||
|
|
||||||
// Case 2: the user is under an environment group and the environment group has endpoint access.
|
// Case 2: the user is under an environment group and the environment group has endpoint access.
|
||||||
|
|
|
@ -6,10 +6,11 @@ import { isLimitedToBE } from '@/react/portainer/feature-flags/feature-flags.ser
|
||||||
|
|
||||||
class PorAccessManagementController {
|
class PorAccessManagementController {
|
||||||
/* @ngInject */
|
/* @ngInject */
|
||||||
constructor($scope, Notifications, AccessService, RoleService) {
|
constructor($scope, $state, Notifications, AccessService, RoleService) {
|
||||||
Object.assign(this, { $scope, Notifications, AccessService, RoleService });
|
Object.assign(this, { $scope, $state, Notifications, AccessService, RoleService });
|
||||||
|
|
||||||
this.limitedToBE = false;
|
this.limitedToBE = false;
|
||||||
|
this.$state = $state;
|
||||||
|
|
||||||
this.unauthorizeAccess = this.unauthorizeAccess.bind(this);
|
this.unauthorizeAccess = this.unauthorizeAccess.bind(this);
|
||||||
this.updateAction = this.updateAction.bind(this);
|
this.updateAction = this.updateAction.bind(this);
|
||||||
|
@ -105,6 +106,7 @@ class PorAccessManagementController {
|
||||||
this.availableUsersAndTeams = _.orderBy(data.availableUsersAndTeams, 'Name', 'asc');
|
this.availableUsersAndTeams = _.orderBy(data.availableUsersAndTeams, 'Name', 'asc');
|
||||||
this.authorizedUsersAndTeams = data.authorizedUsersAndTeams;
|
this.authorizedUsersAndTeams = data.authorizedUsersAndTeams;
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
|
this.$state.go('portainer.home');
|
||||||
this.availableUsersAndTeams = [];
|
this.availableUsersAndTeams = [];
|
||||||
this.authorizedUsersAndTeams = [];
|
this.authorizedUsersAndTeams = [];
|
||||||
this.Notifications.error('Failure', err, 'Unable to retrieve accesses');
|
this.Notifications.error('Failure', err, 'Unable to retrieve accesses');
|
||||||
|
|
Loading…
Reference in New Issue