184: Refactored ISM rest test cases to consider forwarded client. Extended test cases and created reusable methods

Signed-off-by: Stevan Buzejic <buzejic.stevan@gmail.com>

Author: stevanbz

.gitignore

@@ -14,5 +14,4 @@ src/test/resources/job-scheduler/
 src/test/resources/bwc/
 bin/
 spi/bin/
-src/test/resources/notifications*
-src/test/resources/security/opensearch-security*
+src/test/resources/notifications*

build.gradle

@@ -406,6 +406,12 @@ integTest {
             excludeTestsMatching "org.opensearch.indexmanagement.bwc.*IT"
         }
     }
+    // Exclude security test
+    if (System.getProperty("https") == null || System.getProperty("https") == "false") {
+        filter {
+            excludeTestsMatching "org.opensearch.*Security*IT"
+        }
+    }
 
     // TODO: Fix running notification test against remote cluster with security plugin installed
     if (System.getProperty("https") != null) {
@@ -446,11 +452,10 @@ task integTestRemote(type: RestIntegTestTask)  {
         }
     }
 
-    if (System.getProperty("tests.rest.bwcsuite") == null) {
-        filter {
-            excludeTestsMatching "org.opensearch.indexmanagement.bwc.*IT"
-        }
+    if (System.getProperty("test.debug") != null) {
+        jvmArgs '-agentlib:jdwp=transport=dt_socket,server=n,suspend=y,address=8000'
     }
+
     // Snapshot action integration tests rely on node level setting path.repo which we can't set remotely
     exclude 'org/opensearch/indexmanagement/indexstatemanagement/action/SnapshotActionIT.class'
 }

src/test/kotlin/org/opensearch/indexmanagement/AccessRoles.kt

@@ -5,25 +5,55 @@
 
 package org.opensearch.indexmanagement
 
+import org.opensearch.indexmanagement.indexstatemanagement.transport.action.addpolicy.AddPolicyAction
+import org.opensearch.indexmanagement.indexstatemanagement.transport.action.deletepolicy.DeletePolicyAction
 import org.opensearch.indexmanagement.indexstatemanagement.transport.action.explain.ExplainAction
 import org.opensearch.indexmanagement.indexstatemanagement.transport.action.getpolicy.GetPoliciesAction
 import org.opensearch.indexmanagement.indexstatemanagement.transport.action.getpolicy.GetPolicyAction
 import org.opensearch.indexmanagement.indexstatemanagement.transport.action.indexpolicy.IndexPolicyAction
 import org.opensearch.indexmanagement.indexstatemanagement.transport.action.managedIndex.ManagedIndexAction
+import org.opensearch.indexmanagement.rollup.action.delete.DeleteRollupAction
 import org.opensearch.indexmanagement.rollup.action.explain.ExplainRollupAction
 import org.opensearch.indexmanagement.rollup.action.get.GetRollupAction
 import org.opensearch.indexmanagement.rollup.action.index.IndexRollupAction
+import org.opensearch.indexmanagement.rollup.action.mapping.UpdateRollupMappingAction
+import org.opensearch.indexmanagement.transform.action.delete.DeleteTransformsAction
+import org.opensearch.indexmanagement.transform.action.explain.ExplainTransformAction
+import org.opensearch.indexmanagement.transform.action.get.GetTransformAction
+import org.opensearch.indexmanagement.transform.action.get.GetTransformsAction
+import org.opensearch.indexmanagement.transform.action.index.IndexTransformAction
+import org.opensearch.indexmanagement.transform.action.start.StartTransformAction
+import org.opensearch.indexmanagement.transform.action.stop.StopTransformAction
 
+// ISM
 const val WRITE_POLICY = IndexPolicyAction.NAME
+const val ADD_POLICY = AddPolicyAction.NAME
 const val GET_POLICIES = GetPoliciesAction.NAME
 const val GET_POLICY = GetPolicyAction.NAME
 const val EXPLAIN_INDEX = ExplainAction.NAME
 const val MANAGED_INDEX = ManagedIndexAction.NAME
+const val DELETE_POLICY = DeletePolicyAction.NAME
+// Rollup
 const val ROLLUP_ALL = "cluster:admin/opendistro/rollup/*"
 const val INDEX_ROLLUP = IndexRollupAction.NAME
 const val GET_ROLLUP = GetRollupAction.NAME
 const val EXPLAIN_ROLLUP = ExplainRollupAction.NAME
-
-// Index related
-const val GET_INDEX = "indices:admin/mappings/get"
+const val UPDATE_ROLLUP = UpdateRollupMappingAction.NAME
+const val DELETE_ROLLUP = DeleteRollupAction.NAME
+// Transform
+const val TRANSFORM_ACTION = IndexTransformAction.NAME
+const val GET_TRANSFORM = GetTransformAction.NAME
+const val EXPLAIN_TRANSFORM = ExplainTransformAction.NAME
+const val START_TRANSFORM = StartTransformAction.NAME
+const val DELETE_TRANSFORM = DeleteTransformsAction.NAME
+const val GET_TRANSFORMS = GetTransformsAction.NAME
+const val STOP_TRANSFORM = StopTransformAction.NAME
+// In order to execute transform, user need to have health privilege
+const val HEALTH = "cluster:monitor/health"
+// Index
+const val GET_INDEX_MAPPING = "indices:admin/mappings/get"
+const val PUT_INDEX_MAPPING = "indices:admin/mapping/put"
 const val SEARCH_INDEX = "indices:data/read/search"
+const val CREATE_INDEX = "indices:admin/create"
+const val WRITE_INDEX = "indices:data/write/index"
+const val BULK_WRITE_INDEX = "indices:data/write/bulk*"