/* * Copyright OpenSearch Contributors * SPDX-License-Identifier: Apache-2.0 */ package org.opensearch.securityanalytics; import org.junit.Assert; import org.opensearch.action.admin.cluster.node.info.NodeInfo; import org.opensearch.action.admin.cluster.node.info.NodesInfoRequest; import org.opensearch.action.admin.cluster.node.info.NodesInfoResponse; import org.opensearch.action.admin.cluster.node.info.PluginsAndModules; import org.opensearch.plugins.PluginInfo; import org.opensearch.test.OpenSearchIntegTestCase; import java.util.List; import java.util.function.Function; import java.util.stream.Collectors; import java.util.stream.Stream; /*public class SecurityAnalyticsPluginTransportIT extends OpenSearchIntegTestCase { public void testPluginsAreInstalled() { NodesInfoRequest nodesInfoRequest = new NodesInfoRequest(); nodesInfoRequest.addMetric(NodesInfoRequest.Metric.PLUGINS.metricName()); NodesInfoResponse nodesInfoResponse = OpenSearchIntegTestCase.client().admin().cluster().nodesInfo(nodesInfoRequest) .actionGet(); List pluginInfos = nodesInfoResponse.getNodes().stream() .flatMap((Function>) nodeInfo -> nodeInfo.getInfo(PluginsAndModules.class) .getPluginInfos().stream()).collect(Collectors.toList()); Assert.assertTrue(pluginInfos.stream().anyMatch(pluginInfo -> pluginInfo.getName() .equals("opensearch-security-analytics"))); } }*/