issues #413 : Debug mode which allows HTTP requests being sent to the…

pom.xml

@@ -245,6 +245,12 @@
       <version>2.18.3</version>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>com.github.stephenc.jcip</groupId>
+      <artifactId>jcip-annotations</artifactId>
+      <version>1.0-1</version>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>com.squareup.retrofit2</groupId>
       <artifactId>retrofit</artifactId>

src/main/java/org/influxdb/InfluxDB.java

@@ -26,6 +26,12 @@
  */
 public interface InfluxDB {
 
+  /**
+   * The system property key to set the http logging level across the JVM.
+   * @see LogLevel for available values
+   */
+  public static final String LOG_LEVEL_PROP = "org.influxdb.InfluxDB.logLevel";
+
   /** Controls the level of logging of the REST layer. */
   public enum LogLevel {
     /** No logging. */

src/main/java/org/influxdb/impl/InfluxDBImpl.java

@@ -87,7 +87,7 @@ public InfluxDBImpl(final String url, final String username, final String passwo
     this.username = username;
     this.password = password;
     this.loggingInterceptor = new HttpLoggingInterceptor();
-    this.loggingInterceptor.setLevel(Level.NONE);
+    initLogLevel();
     this.gzipRequestInterceptor = new GzipRequestInterceptor();
     this.retrofit = new Retrofit.Builder()
         .baseUrl(url)
@@ -105,7 +105,7 @@ public InfluxDBImpl(final String url, final String username, final String passwo
         this.username = username;
         this.password = password;
         this.loggingInterceptor = new HttpLoggingInterceptor();
-        this.loggingInterceptor.setLevel(Level.NONE);
+        initLogLevel();
         this.gzipRequestInterceptor = new GzipRequestInterceptor();
         this.retrofit = new Retrofit.Builder()
                 .baseUrl(url)
@@ -739,4 +739,26 @@ public void dropRetentionPolicy(final String rpName, final String database) {
     execute(this.influxDBService.postQuery(this.username, this.password,
         Query.encode(queryBuilder.toString())));
   }
+
+  private void initLogLevel() {
+    String value = System.getProperty(LOG_LEVEL_PROP);
+
+    LogLevel logLevel = LogLevel.NONE;
+
+    if (value != null) {
+      switch (value.toUpperCase()) {
+      case "BASIC":
+        logLevel = LogLevel.BASIC;
+        break;
+      case "HEADERS":
+        logLevel = LogLevel.HEADERS;
+        break;
+      case "FULL":
+        logLevel = LogLevel.FULL;
+        break;
+      default:
+      }
+    }
+    setLogLevel(logLevel);
+  }
 }

src/test/java/org/influxdb/InfluxDBLogLevelTest.java

@@ -0,0 +1,53 @@
+package org.influxdb;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Optional;
+
+import org.influxdb.dto.Pong;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.platform.runner.JUnitPlatform;
+import org.junit.runner.RunWith;
+
+import net.jcip.annotations.NotThreadSafe;
+
+/**
+ * Test the InfluxDBimpl log level setting from system property.
+ *
+ * @author hoan.le [at] bonitoo.io
+ *
+ */
+@RunWith(JUnitPlatform.class)
+@NotThreadSafe
+public class InfluxDBLogLevelTest {
+  @Test
+  public void testLogLevelProperties() {
+    String oldLogLevel = System.getProperty(InfluxDB.LOG_LEVEL_PROP);
+    try {
+      List<String> logLevels = Arrays.asList(null, "NONE", "BASIC", "HEADERS", "FULL", "abc");
+      logLevels.forEach(logLevel -> {
+        System.out.println("LogLevel = " + logLevel);
+        Optional.ofNullable(logLevel).ifPresent(value -> {
+          System.setProperty(InfluxDB.LOG_LEVEL_PROP, value);
+        });
+
+        try {
+          InfluxDB influxDB = TestUtils.connectToInfluxDB();
+          Pong result = influxDB.ping();
+          Assertions.assertNotNull(result);
+          influxDB.close();
+        } catch (Exception e) {
+          Assertions.fail(e);
+        }
+      });
+    } finally {
+      if (oldLogLevel == null) {
+        System.clearProperty(InfluxDB.LOG_LEVEL_PROP);
+      } else {
+        System.setProperty(InfluxDB.LOG_LEVEL_PROP, oldLogLevel);
+      }
+    }
+
+  }
+}