@@ -85,24 +85,23 @@ default boolean checkPreConditions(SecurityIndexManager.State securityIndexManag
8585
8686 public static final Integer ROLE_METADATA_FLATTENED_MIGRATION_VERSION = 1 ;
8787 public static final Integer ROLE_MAPPING_CLEANUP_DUPLICATES = 2 ;
88+ private static final Logger logger = LogManager .getLogger (SecurityMigration .class );
8889
8990 public static final TreeMap <Integer , SecurityMigration > MIGRATIONS_BY_VERSION = new TreeMap <>(
9091 Map .of (ROLE_METADATA_FLATTENED_MIGRATION_VERSION , new SecurityMigration () {
91- private static final Logger logger = LogManager .getLogger (SecurityMigration .class );
92-
9392 @ Override
94- public void migrate (SecurityIndexManager securityIndexManager , Client client , ActionListener <Void > listener ) {
93+ public void migrate (SecurityIndexManager indexManager , Client client , ActionListener <Void > listener ) {
9594 BoolQueryBuilder filterQuery = new BoolQueryBuilder ().filter (QueryBuilders .termQuery ("type" , "role" ))
9695 .mustNot (QueryBuilders .existsQuery ("metadata_flattened" ));
9796 SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder ().query (filterQuery ).size (0 ).trackTotalHits (true );
98- SearchRequest countRequest = new SearchRequest (securityIndexManager .getConcreteIndexName ());
97+ SearchRequest countRequest = new SearchRequest (indexManager .getConcreteIndexName ());
9998 countRequest .source (searchSourceBuilder );
10099
101100 client .search (countRequest , ActionListener .wrap (response -> {
102101 // If there are no roles, skip migration
103102 if (response .getHits ().getTotalHits ().value > 0 ) {
104103 logger .info ("Preparing to migrate [" + response .getHits ().getTotalHits ().value + "] roles" );
105- updateRolesByQuery (securityIndexManager .getConcreteIndexName (), client , filterQuery , listener );
104+ updateRolesByQuery (indexManager .getConcreteIndexName (), client , filterQuery , listener );
106105 } else {
107106 listener .onResponse (null );
108107 }
@@ -138,11 +137,9 @@ public int minMappingVersion() {
138137 return ADD_REMOTE_CLUSTER_AND_DESCRIPTION_FIELDS .id ();
139138 }
140139 }, ROLE_MAPPING_CLEANUP_DUPLICATES , new SecurityMigration () {
141- private static final Logger logger = LogManager .getLogger (SecurityMigration .class );
142-
143140 @ Override
144- public void migrate (SecurityIndexManager securityIndexManager , Client client , ActionListener <Void > listener ) {
145- Set <String > clusterStateRoleMappingNames = securityIndexManager .getReservedStateRoleMappingNames ();
141+ public void migrate (SecurityIndexManager indexManager , Client client , ActionListener <Void > listener ) {
142+ Set <String > clusterStateRoleMappingNames = indexManager .getReservedStateRoleMappingNames ();
146143
147144 // No role mappings in cluster state -> no cleanup needed
148145 if (clusterStateRoleMappingNames .isEmpty ()) {
0 commit comments