X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=influxlogger%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fpmlog%2FIntegration.java;h=ea932b6f1e06226ca3f45a02b4313c8ad0f5556c;hb=fbccee5729fb23f3424046c1d122d29f0fec545a;hp=840298d486315e02a7cc406ff3bc929a17038a40;hpb=6dfbff6834c3a9da2d8f06b15eb94048cbad2d88;p=nonrtric%2Fplt%2Franpm.git

diff --git a/influxlogger/src/test/java/org/oran/pmlog/Integration.java b/influxlogger/src/test/java/org/oran/pmlog/Integration.java
index 840298d..ea932b6 100644
--- a/influxlogger/src/test/java/org/oran/pmlog/Integration.java
+++ b/influxlogger/src/test/java/org/oran/pmlog/Integration.java
@@ -58,7 +58,9 @@ import reactor.kafka.sender.SenderRecord;
         "server.ssl.key-store=./config/keystore.jks", //
         "app.webclient.trust-store=./config/truststore.jks", //
         "app.configuration-filepath=./src/test/resources/test_application_configuration.json", //
-        "app.pm-files-path=./src/test/resources/" //
+        "app.pm-files-path=./src/test/resources/", //
+        "app.auth-token-file=src/test/resources/jwtToken.b64", //
+        "app.kafka.use-oath-token=false" //
 }) //
 class Integration {
 
@@ -114,6 +116,7 @@ class Integration {
         props.put(ProducerConfig.ACKS_CONFIG, "all");
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
+        this.applicationConfig.addKafkaSecurityProps(props);
         return SenderOptions.create(props);
     }
 
@@ -164,6 +167,13 @@ class Integration {
     final String PM_REPORT_FILE_BIG = "./src/test/resources/A20000626.2315+0200-2330+0200_HTTPS-6-73.json";
     final String PM_REPORT_FILE = "./src/test/resources/pm_report.json";
 
+    /**
+     * Generate a PM report
+     * 
+     * @param sequenceValue used for generating counter values
+     * @param noOfObjects used for generating counter values
+     * @return
+     */
     String pmReport(int sequenceValue, int noOfObjects) {
         try {
             String str = Files.readString(Path.of(PM_REPORT_FILE), Charset.defaultCharset());
@@ -190,6 +200,9 @@ class Integration {
 
     }
 
+    // Store PM data for 24 hours in influx. The the data contains genenerated
+    // counter values
+    // that varies over time.
     @Test
     void testStoreReportsInflux() throws Exception {
         final int NO_OF_OBJECTS = 24 * 4;