Remove references to LegacyESVersion.V_7x constants (opensearch-project#2151)

* Remove references to LegacyESVersion.V_7x constants

Signed-off-by: Craig Perkins <[email protected]>
Signed-off-by: Stephen Crawford <[email protected]>

Author: cwperks

src/main/java/org/opensearch/security/action/configupdate/TransportConfigUpdateAction.java

@@ -34,7 +34,6 @@
 
 import org.opensearch.action.FailedNodeException;
 import org.opensearch.action.support.ActionFilters;
-import org.opensearch.action.support.nodes.BaseNodeRequest;
 import org.opensearch.action.support.nodes.TransportNodesAction;
 import org.opensearch.cluster.service.ClusterService;
 import org.opensearch.common.inject.Inject;
@@ -47,6 +46,7 @@
 import org.opensearch.security.securityconf.DynamicConfigFactory;
 import org.opensearch.security.securityconf.impl.CType;
 import org.opensearch.threadpool.ThreadPool;
+import org.opensearch.transport.TransportRequest;
 import org.opensearch.transport.TransportService;
 
 public class TransportConfigUpdateAction
@@ -72,7 +72,7 @@ public TransportConfigUpdateAction(final Settings settings,
         this.dynamicConfigFactory = dynamicConfigFactory;
     }
 
-    public static class NodeConfigUpdateRequest extends BaseNodeRequest {
+    public static class NodeConfigUpdateRequest extends TransportRequest {
 
         ConfigUpdateRequest request;
 

src/main/java/org/opensearch/security/configuration/ClusterInfoHolder.java

@@ -26,49 +26,23 @@
 
 package org.opensearch.security.configuration;
 
-import java.util.Iterator;
-import java.util.List;
-
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import org.opensearch.LegacyESVersion;
 import org.opensearch.cluster.ClusterChangedEvent;
-import org.opensearch.cluster.ClusterState;
 import org.opensearch.cluster.ClusterStateListener;
-import org.opensearch.cluster.metadata.IndexMetadata;
 import org.opensearch.cluster.node.DiscoveryNode;
 import org.opensearch.cluster.node.DiscoveryNodes;
-import org.opensearch.index.Index;
 
 public class ClusterInfoHolder implements ClusterStateListener {
 
     protected final Logger log = LogManager.getLogger(this.getClass());
-    private volatile Boolean has6xNodes = null;
-    private volatile Boolean has6xIndices = null;
     private volatile DiscoveryNodes nodes = null;
     private volatile Boolean isLocalNodeElectedClusterManager = null;
     private volatile boolean initialized;
 
     @Override
     public void clusterChanged(ClusterChangedEvent event) {
-        final boolean isTraceEnabled = log.isTraceEnabled();
-        if(has6xNodes == null || event.nodesChanged()) {
-            has6xNodes = Boolean.valueOf(clusterHas6xNodes(event.state()));
-            if (isTraceEnabled) {
-                log.trace("has6xNodes: {}", has6xNodes);
-            }
-        }
-        
-        final List<String> indicesCreated = event.indicesCreated();
-        final List<Index> indicesDeleted = event.indicesDeleted();
-        if(has6xIndices == null || !indicesCreated.isEmpty() || !indicesDeleted.isEmpty()) {
-            has6xIndices = Boolean.valueOf(clusterHas6xIndices(event.state()));
-            if (isTraceEnabled) {
-                log.trace("has6xIndices: {}", has6xIndices);
-            }
-        }
-        
         if(nodes == null || event.nodesChanged()) {
             nodes = event.state().nodes();
             if (log.isDebugEnabled()) {
@@ -80,14 +54,6 @@ public void clusterChanged(ClusterChangedEvent event) {
         isLocalNodeElectedClusterManager = event.localNodeClusterManager()?Boolean.TRUE:Boolean.FALSE;
     }
 
-    public Boolean getHas6xNodes() {
-        return has6xNodes;
-    }
-
-    public Boolean getHas6xIndices() {
-        return has6xIndices;
-    }
-
     public Boolean isLocalNodeElectedClusterManager() {
         return isLocalNodeElectedClusterManager;
     }
@@ -106,19 +72,4 @@ public Boolean hasNode(DiscoveryNode node) {
 
         return nodes.nodeExists(node)?Boolean.TRUE:Boolean.FALSE;
     }
-
-    private static boolean clusterHas6xNodes(ClusterState state) {
-        return state.nodes().getMinNodeVersion().before(LegacyESVersion.V_7_0_0);
-    }
-    
-    private static boolean clusterHas6xIndices(ClusterState state) {
-        final Iterator<IndexMetadata> indices = state.metadata().indices().valuesIt();
-        while (indices.hasNext()) {
-            final IndexMetadata indexMetadata = indices.next();
-            if (indexMetadata.getCreationVersion().before(LegacyESVersion.V_7_0_0)) {
-                return true;
-            }
-        }
-        return false;
-    }
 }

src/main/java/org/opensearch/security/configuration/ConfigurationLoaderSecurity7.java

@@ -39,7 +39,6 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import org.opensearch.LegacyESVersion;
 import org.opensearch.action.ActionListener;
 import org.opensearch.action.get.GetResponse;
 import org.opensearch.action.get.MultiGetItemResponse;
@@ -125,23 +124,6 @@ public void singleFailure(Failure failure) {
             public void noData(String id) {
                 CType cType = CType.fromString(id);
 
-                //when index was created with ES 6 there are no separate tenants. So we load just empty ones.
-                //when index was created with ES 7 and type not "security" (ES 6 type) there are no rolemappings anymore.
-                if(cs.state().metadata().index(securityIndex).getCreationVersion().before(LegacyESVersion.V_7_0_0)) {
-                    //created with SG 6
-                    //skip tenants
-
-                    if (isDebugEnabled) {
-                        log.debug("Skip tenants because we not yet migrated to ES 7 (index was created with ES 6)");
-                    }
-
-                    if(cType == CType.TENANTS) {
-                        rs.put(cType, SecurityDynamicConfiguration.empty());
-                        latch.countDown();
-                        return;
-                    }
-                }
-
                 // Since NODESDN is newly introduced data-type applying for existing clusters as well, we make it backward compatible by returning valid empty
                 // SecurityDynamicConfiguration.
                 // Same idea for new setting WHITELIST/ALLOWLIST

src/main/java/org/opensearch/security/dlic/rest/api/MigrateApiAction.java

@@ -20,8 +20,6 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import com.google.common.collect.ImmutableList;
 
-import org.opensearch.LegacyESVersion;
-import org.opensearch.Version;
 import org.opensearch.action.ActionListener;
 import org.opensearch.action.admin.indices.create.CreateIndexResponse;
 import org.opensearch.action.bulk.BulkRequestBuilder;
@@ -98,13 +96,6 @@ protected Endpoint getEndpoint() {
     @Override
     protected void handlePost(RestChannel channel, RestRequest request, Client client, final JsonNode content) throws IOException {
 
-        final Version oldestNodeVersion = cs.state().getNodes().getMinNodeVersion();
-
-        if(oldestNodeVersion.before(LegacyESVersion.V_7_0_0)) {
-            badRequestResponse(channel, "Can not migrate configuration because cluster is not fully migrated.");
-            return;
-        }
-
         final SecurityDynamicConfiguration<?> loadedConfig = load(CType.CONFIG, true);
 
         if (loadedConfig.getVersion() != 1) {