inspectIT#1269: Fixed InfluxExporterServiceIntTest

heiko-holz · Jan 17, 2022 · 8a826dc · 8a826dc
1 parent f07db85
commit 8a826dc
Showing 1 changed file with 13 additions and 8 deletions.
diff --git a/...core/src/test/java/rocks/inspectit/ocelot/core/exporter/InfluxExporterServiceIntTest.java b/...core/src/test/java/rocks/inspectit/ocelot/core/exporter/InfluxExporterServiceIntTest.java
@@ -8,6 +8,7 @@
 import io.opencensus.tags.TagKey;
 import io.opencensus.tags.TagValue;
 import io.opencensus.tags.Tags;
+import org.influxdb.InfluxDB;
 import org.influxdb.InfluxDBFactory;
 import org.influxdb.dto.Query;
 import org.influxdb.dto.QueryResult;
@@ -37,11 +38,9 @@ public class InfluxExporterServiceIntTest extends SpringTestBase {
     void startInfluxDB() throws Exception {
         InfluxServer.Builder builder = new InfluxServer.Builder();
         int freeHttpPort = Network.getFreeServerPort();
-        InfluxConfigurationWriter influxConfig = new InfluxConfigurationWriter.Builder()
-                .setHttp(freeHttpPort) // by default auth is disabled
+        InfluxConfigurationWriter influxConfig = new InfluxConfigurationWriter.Builder().setHttp(freeHttpPort) // by default auth is disabled
                 .build();
         builder.setInfluxConfiguration(influxConfig);
-
         influx = builder.build();
         influx.start();
         url = "http://localhost:" + freeHttpPort;
@@ -52,12 +51,20 @@ void shutdownInfluxDB() throws Exception {
         influx.cleanup();
     }
 
+    private final String user = "w00t";
+
+    private final String password = "password";
+
     @Test
     void verifyInfluxDataWritten() {
         updateProperties(props -> {
+            props.setProperty("inspectit.exporters.metrics.influx.enabled", true);
             props.setProperty("inspectit.exporters.metrics.influx.export-interval", "1s");
             props.setProperty("inspectit.exporters.metrics.influx.url", url);
             props.setProperty("inspectit.exporters.metrics.influx.database", DATABASE);
+            // note: user and password are mandatory as of v1.15.0
+            props.setProperty("inspectit.exporters.metrics.influx.user", user);
+            props.setProperty("inspectit.exporters.metrics.influx.password", password);
         });
 
         TagKey testTag = TagKey.create("my_tag");
@@ -76,20 +83,18 @@ void verifyInfluxDataWritten() {
         }
 
         await().atMost(30, TimeUnit.SECONDS).untilAsserted(() -> {
-            QueryResult result = InfluxDBFactory.connect(url).query(new Query("SELECT LAST(cool_data) FROM " + DATABASE + ".autogen.my_test_measure GROUP BY *"));
+            InfluxDB iDB = InfluxDBFactory.connect(url, user, password); // note: user and password are mandatory as of v1.15.0
+            QueryResult result = iDB.query(new Query("SELECT LAST(cool_data) FROM " + DATABASE + ".autogen.my_test_measure GROUP BY *"));
 
             List<QueryResult.Result> results = result.getResults();
             assertThat(results).hasSize(1);
             QueryResult.Result data = results.get(0);
             assertThat(data.getSeries()).hasSize(1);
             QueryResult.Series series = data.getSeries().get(0);
-            assertThat(series.getTags())
-                    .hasSize(1)
-                    .containsEntry("my_tag", "myval");
+            assertThat(series.getTags()).hasSize(1).containsEntry("my_tag", "myval");
             assertThat(series.getValues().get(0).get(1)).isEqualTo(42.0);
 
         });
     }
 
-
 }