Skip to content

Commit 3aa180b

Browse files
authored
fix(rdb): listing user crash with filter (#3106)
1 parent cfab8f1 commit 3aa180b

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

internal/namespaces/rdb/v1/custom_user.go

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,17 +55,22 @@ func userListBuilder(c *core.Command) *core.Command {
5555
}
5656

5757
for _, privilege := range listPrivileges.Privileges {
58+
user, userExists := index[privilege.UserName]
59+
if !userExists {
60+
continue
61+
}
62+
5863
switch privilege.Permission {
5964
case rdb.PermissionAll:
60-
index[privilege.UserName].All = append(index[privilege.UserName].All, privilege.DatabaseName)
65+
user.All = append(user.All, privilege.DatabaseName)
6166
case rdb.PermissionReadonly:
62-
index[privilege.UserName].ReadOnly = append(index[privilege.UserName].ReadOnly, privilege.DatabaseName)
67+
user.ReadOnly = append(user.ReadOnly, privilege.DatabaseName)
6368
case rdb.PermissionCustom:
64-
index[privilege.UserName].Custom = append(index[privilege.UserName].Custom, privilege.DatabaseName)
69+
user.Custom = append(user.Custom, privilege.DatabaseName)
6570
case rdb.PermissionNone:
66-
index[privilege.UserName].None = append(index[privilege.UserName].None, privilege.DatabaseName)
71+
user.None = append(user.None, privilege.DatabaseName)
6772
case rdb.PermissionReadwrite:
68-
index[privilege.UserName].ReadWrite = append(index[privilege.UserName].ReadWrite, privilege.DatabaseName)
73+
user.ReadWrite = append(user.ReadWrite, privilege.DatabaseName)
6974
default:
7075
core.ExtractLogger(ctx).Errorf("unsupported permission value %s", privilege.Permission)
7176
}

0 commit comments

Comments
 (0)