mirror of
https://github.com/grafana/grafana.git
synced 2025-07-30 16:43:07 +08:00
Security: Add fix for CVE-2025-3580 (#105976)
baldm0mma/ add main/404-202504151210.patch to main
This commit is contained in:
@ -686,6 +686,15 @@ func (ss *sqlStore) RemoveOrgUser(ctx context.Context, cmd *org.RemoveOrgUserCom
|
||||
return user.ErrUserNotFound
|
||||
}
|
||||
|
||||
// check if user belongs to org
|
||||
var orgUser org.OrgUser
|
||||
if exists, err := sess.Where("org_id=? AND user_id=?", cmd.OrgID, cmd.UserID).Get(&orgUser); err != nil {
|
||||
return err
|
||||
} else if !exists {
|
||||
ss.log.Debug("User not in org, nothing to do", "user_id", cmd.UserID, "org_id", cmd.OrgID)
|
||||
return nil
|
||||
}
|
||||
|
||||
deletes := []string{
|
||||
"DELETE FROM org_user WHERE org_id=? and user_id=?",
|
||||
"DELETE FROM dashboard_acl WHERE org_id=? and user_id = ?",
|
||||
@ -732,7 +741,7 @@ func (ss *sqlStore) RemoveOrgUser(ctx context.Context, cmd *org.RemoveOrgUserCom
|
||||
return err
|
||||
}
|
||||
}
|
||||
} else if cmd.ShouldDeleteOrphanedUser {
|
||||
} else if cmd.ShouldDeleteOrphanedUser && !usr.IsAdmin {
|
||||
// no other orgs, delete the full user
|
||||
if err := ss.deleteUserInTransaction(sess, &user.DeleteUserCommand{UserID: usr.ID}); err != nil {
|
||||
return err
|
||||
|
@ -12,6 +12,7 @@ import (
|
||||
|
||||
"github.com/grafana/grafana/pkg/apimachinery/identity"
|
||||
"github.com/grafana/grafana/pkg/infra/db"
|
||||
"github.com/grafana/grafana/pkg/infra/log"
|
||||
"github.com/grafana/grafana/pkg/infra/tracing"
|
||||
"github.com/grafana/grafana/pkg/services/accesscontrol"
|
||||
"github.com/grafana/grafana/pkg/services/org"
|
||||
@ -40,6 +41,7 @@ func TestIntegrationOrgDataAccess(t *testing.T) {
|
||||
orgStore := sqlStore{
|
||||
db: ss,
|
||||
dialect: ss.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
|
||||
t.Run("org not found", func(t *testing.T) {
|
||||
@ -281,6 +283,7 @@ func TestIntegrationOrgUserDataAccess(t *testing.T) {
|
||||
orgUserStore := sqlStore{
|
||||
db: ss,
|
||||
dialect: ss.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
|
||||
t.Run("org user inserted", func(t *testing.T) {
|
||||
@ -356,7 +359,7 @@ func TestIntegrationOrgUserDataAccess(t *testing.T) {
|
||||
ss, cfg := db.InitTestDBWithCfg(t)
|
||||
_, usrSvc := createOrgAndUserSvc(t, ss, cfg)
|
||||
ac1cmd := &user.CreateUserCommand{Login: "ac1", Email: "ac1@test.com", Name: "ac1 name"}
|
||||
ac2cmd := &user.CreateUserCommand{Login: "ac2", Email: "ac2@test.com", Name: "ac2 name", IsAdmin: true}
|
||||
ac2cmd := &user.CreateUserCommand{Login: "ac2", Email: "ac2@test.com", Name: "ac2 name"}
|
||||
ac1, err := usrSvc.Create(context.Background(), ac1cmd)
|
||||
require.NoError(t, err)
|
||||
ac2, err := usrSvc.Create(context.Background(), ac2cmd)
|
||||
@ -483,6 +486,15 @@ func TestIntegrationOrgUserDataAccess(t *testing.T) {
|
||||
err := orgUserStore.Delete(context.Background(), &org.DeleteOrgCommand{ID: ac2.OrgID})
|
||||
require.NoError(t, err)
|
||||
|
||||
// make sure ac2 is in ac1 org
|
||||
cmd := org.AddOrgUserCommand{
|
||||
OrgID: ac1.OrgID,
|
||||
UserID: ac2.ID,
|
||||
Role: org.RoleViewer,
|
||||
}
|
||||
err = orgUserStore.AddOrgUser(context.Background(), &cmd)
|
||||
require.NoError(t, err)
|
||||
|
||||
// remove ac2 user from ac1 org
|
||||
remCmd := org.RemoveOrgUserCommand{OrgID: ac1.OrgID, UserID: ac2.ID, ShouldDeleteOrphanedUser: true}
|
||||
err = orgUserStore.RemoveOrgUser(context.Background(), &remCmd)
|
||||
@ -568,6 +580,7 @@ func TestIntegrationSQLStore_AddOrgUser(t *testing.T) {
|
||||
orgUserStore := sqlStore{
|
||||
db: store,
|
||||
dialect: store.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
orgSvc, usrSvc := createOrgAndUserSvc(t, store, cfg)
|
||||
|
||||
@ -633,6 +646,7 @@ func TestIntegration_SQLStore_GetOrgUsers(t *testing.T) {
|
||||
orgUserStore := sqlStore{
|
||||
db: store,
|
||||
dialect: store.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
cfg.IsEnterprise = true
|
||||
defer func() {
|
||||
@ -751,6 +765,7 @@ func TestIntegration_SQLStore_GetOrgUsers_PopulatesCorrectly(t *testing.T) {
|
||||
orgUserStore := sqlStore{
|
||||
db: store,
|
||||
dialect: store.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
_, usrSvc := createOrgAndUserSvc(t, store, cfg)
|
||||
|
||||
@ -812,6 +827,7 @@ func TestIntegration_SQLStore_SearchOrgUsers(t *testing.T) {
|
||||
orgUserStore := sqlStore{
|
||||
db: store,
|
||||
dialect: store.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
// orgUserStore.cfg.Skip
|
||||
orgSvc, userSvc := createOrgAndUserSvc(t, store, cfg)
|
||||
@ -888,12 +904,18 @@ func TestIntegration_SQLStore_RemoveOrgUser(t *testing.T) {
|
||||
orgUserStore := sqlStore{
|
||||
db: store,
|
||||
dialect: store.GetDialect(),
|
||||
log: log.NewNopLogger(),
|
||||
}
|
||||
|
||||
orgSvc, usrSvc := createOrgAndUserSvc(t, store, cfg)
|
||||
|
||||
o, err := orgSvc.CreateWithMember(context.Background(), &org.CreateOrgCommand{Name: MainOrgName})
|
||||
require.NoError(t, err)
|
||||
|
||||
// create 2nd org
|
||||
o2, err := orgSvc.CreateWithMember(context.Background(), &org.CreateOrgCommand{Name: "test org 2"})
|
||||
require.NoError(t, err)
|
||||
|
||||
// create org and admin
|
||||
_, err = usrSvc.Create(context.Background(), &user.CreateUserCommand{
|
||||
Login: "admin",
|
||||
@ -902,28 +924,116 @@ func TestIntegration_SQLStore_RemoveOrgUser(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
|
||||
// create a user with no org
|
||||
_, err = usrSvc.Create(context.Background(), &user.CreateUserCommand{
|
||||
Login: "user",
|
||||
OrgID: 1,
|
||||
viewer, err := usrSvc.Create(context.Background(), &user.CreateUserCommand{
|
||||
Login: "viewer",
|
||||
SkipOrgSetup: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// create a user with no org
|
||||
viewer2, err := usrSvc.Create(context.Background(), &user.CreateUserCommand{
|
||||
Login: "viewer2",
|
||||
SkipOrgSetup: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// create a user with no org
|
||||
viewer3, err := usrSvc.Create(context.Background(), &user.CreateUserCommand{
|
||||
Login: "viewer3",
|
||||
SkipOrgSetup: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// create an admin user with no org
|
||||
admin, err := usrSvc.Create(context.Background(), &user.CreateUserCommand{
|
||||
Login: "serverAdmin",
|
||||
SkipOrgSetup: true,
|
||||
IsAdmin: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// assign the user to the org
|
||||
err = orgUserStore.AddOrgUser(context.Background(), &org.AddOrgUserCommand{
|
||||
Role: "Viewer",
|
||||
OrgID: 1,
|
||||
UserID: 2,
|
||||
OrgID: o.ID,
|
||||
UserID: viewer.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// assign the admin user to the org
|
||||
err = orgUserStore.AddOrgUser(context.Background(), &org.AddOrgUserCommand{
|
||||
Role: "Admin",
|
||||
OrgID: o.ID,
|
||||
UserID: admin.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// assign the viewer3 user to the 2nd org
|
||||
err = orgUserStore.AddOrgUser(context.Background(), &org.AddOrgUserCommand{
|
||||
Role: "Viewer",
|
||||
OrgID: o2.ID,
|
||||
UserID: viewer3.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// remove the user org
|
||||
err = orgUserStore.RemoveOrgUser(context.Background(), &org.RemoveOrgUserCommand{
|
||||
UserID: 2,
|
||||
OrgID: 1,
|
||||
ShouldDeleteOrphanedUser: false,
|
||||
UserID: viewer.ID,
|
||||
OrgID: o.ID,
|
||||
ShouldDeleteOrphanedUser: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// remove the admin user
|
||||
err = orgUserStore.RemoveOrgUser(context.Background(), &org.RemoveOrgUserCommand{
|
||||
UserID: admin.ID,
|
||||
OrgID: o.ID,
|
||||
ShouldDeleteOrphanedUser: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// remove the viewer3 user from first org they don't belong to
|
||||
err = orgUserStore.RemoveOrgUser(context.Background(), &org.RemoveOrgUserCommand{
|
||||
UserID: viewer3.ID,
|
||||
OrgID: o.ID,
|
||||
ShouldDeleteOrphanedUser: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// remove the viewer2 user from first org they don't belong to
|
||||
err = orgUserStore.RemoveOrgUser(context.Background(), &org.RemoveOrgUserCommand{
|
||||
UserID: viewer2.ID,
|
||||
OrgID: o.ID,
|
||||
ShouldDeleteOrphanedUser: true,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
|
||||
// verify the user is deleted
|
||||
_, err = usrSvc.GetByID(context.Background(), &user.GetUserByIDQuery{
|
||||
ID: viewer.ID,
|
||||
})
|
||||
require.ErrorIs(t, err, user.ErrUserNotFound)
|
||||
|
||||
// verify the admin user is not deleted
|
||||
usr, err := usrSvc.GetByID(context.Background(), &user.GetUserByIDQuery{
|
||||
ID: admin.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
assert.NotNil(t, usr)
|
||||
|
||||
// verify the viewer2 user is not deleted
|
||||
_, err = usrSvc.GetByID(context.Background(), &user.GetUserByIDQuery{
|
||||
ID: viewer2.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
assert.NotNil(t, usr)
|
||||
|
||||
// verify the viewer3 user is not deleted
|
||||
_, err = usrSvc.GetByID(context.Background(), &user.GetUserByIDQuery{
|
||||
ID: viewer3.ID,
|
||||
})
|
||||
require.NoError(t, err)
|
||||
assert.NotNil(t, usr)
|
||||
}
|
||||
|
||||
func createOrgAndUserSvc(t *testing.T, store db.DB, cfg *setting.Cfg) (org.Service, user.Service) {
|
||||
|
Reference in New Issue
Block a user