|
42 | 42 | import java.util.Map; |
43 | 43 | import java.util.Objects; |
44 | 44 | import java.util.Set; |
| 45 | +import java.util.stream.Collectors; |
45 | 46 |
|
46 | 47 | public interface Role { |
47 | 48 |
|
@@ -462,8 +463,7 @@ static SimpleRole buildFromRoleDescriptor( |
462 | 463 | ); |
463 | 464 |
|
464 | 465 | for (RoleDescriptor.IndicesPrivileges indexPrivilege : roleDescriptor.getIndicesPrivileges()) { |
465 | | - // TODO properly handle this |
466 | | - if (Arrays.asList(indexPrivilege.getIndices()).contains("*")) { |
| 466 | + if (Arrays.stream(indexPrivilege.getPrivileges()).map(String::toLowerCase).collect(Collectors.toSet()).contains("all")) { |
467 | 467 | builder.add( |
468 | 468 | fieldPermissionsCache.getFieldPermissions( |
469 | 469 | new FieldPermissionsDefinition(indexPrivilege.getGrantedFields(), indexPrivilege.getDeniedFields()) |
@@ -492,20 +492,6 @@ static SimpleRole buildFromRoleDescriptor( |
492 | 492 | assert Arrays.equals(new String[] { "*" }, clusterAliases) |
493 | 493 | : "reserved role should not define remote indices privileges for specific clusters"; |
494 | 494 | final RoleDescriptor.IndicesPrivileges indicesPrivileges = remoteIndicesPrivileges.indicesPrivileges(); |
495 | | - // TODO properly handle this |
496 | | - if (Arrays.asList(indicesPrivileges.getIndices()).contains("*")) { |
497 | | - builder.addRemoteIndicesGroup( |
498 | | - Set.of(clusterAliases), |
499 | | - fieldPermissionsCache.getFieldPermissions( |
500 | | - new FieldPermissionsDefinition(indicesPrivileges.getGrantedFields(), indicesPrivileges.getDeniedFields()) |
501 | | - ), |
502 | | - indicesPrivileges.getQuery() == null ? null : Collections.singleton(indicesPrivileges.getQuery()), |
503 | | - IndexPrivilege.get(Set.of(indicesPrivileges.getPrivileges())), |
504 | | - indicesPrivileges.allowRestrictedIndices(), |
505 | | - IndexComponentSelector.FAILURES, |
506 | | - indicesPrivileges.getIndices() |
507 | | - ); |
508 | | - } |
509 | 495 | builder.addRemoteIndicesGroup( |
510 | 496 | Set.of(clusterAliases), |
511 | 497 | fieldPermissionsCache.getFieldPermissions( |
|
0 commit comments