test: client works with and without slash at the and of url (influxdata/influxdb-client-python#87)

Author: bednar

client/src/test/java/com/influxdb/client/ITChecksApi.java

@@ -46,7 +46,6 @@
 
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -342,8 +341,6 @@ void labelAddNotExists() {
     }
 
     @Test
-    //TODO wait to v2.0.0-beta.7
-    @Disabled
     void labelDeleteNotExists() {
 
         GreaterThreshold greater = new GreaterThreshold();

client/src/test/java/com/influxdb/client/ITDashboardsApi.java

@@ -46,7 +46,6 @@
 
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -276,8 +275,6 @@ void labelAddNotExists() {
                 .isInstanceOf(NotFoundException.class);
     }
 
-    //TODO wait to v2.0.0-beta.7
-    @Disabled
     @Test
     void labelDeleteNotExists() {
 

client/src/test/java/com/influxdb/client/ITNotificationEndpointsApi.java

@@ -42,7 +42,6 @@
 
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -585,8 +584,6 @@ void labelAddNotExists() {
                 .isInstanceOf(NotFoundException.class);
     }
 
-    //TODO wait to v2.0.0-beta.7
-    @Disabled
     @Test
     void labelDeleteNotExists() {
 

client/src/test/java/com/influxdb/client/ITNotificationRulesApi.java

@@ -52,7 +52,6 @@
 
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -450,8 +449,6 @@ void labelAddNotExists() {
                 .isInstanceOf(NotFoundException.class);
     }
 
-    //TODO wait to v2.0.0-beta.7
-    @Disabled
     @Test
     void labelDeleteNotExists() {
 

client/src/test/java/com/influxdb/client/ITOrganizationsApi.java

@@ -43,6 +43,7 @@
 
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -293,6 +294,8 @@ void labels() {
         Assertions.assertThat(labels).hasSize(0);
     }
 
+    //TODO https://github.com/influxdata/influxdb/issues/18048
+    @Disabled
     @Test
     void findOrganizationLogs() {
 
@@ -309,6 +312,8 @@ void findOrganizationLogsNotFound() {
         Assertions.assertThat(userLogs).isEmpty();
     }
 
+    //TODO https://github.com/influxdata/influxdb/issues/18048
+    @Disabled
     @Test
     void findOrganizationLogsPaging() {
 

client/src/test/java/com/influxdb/client/ITTelegrafsApi.java

@@ -40,7 +40,6 @@
 import com.moandjiezana.toml.Toml;
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -369,8 +368,6 @@ void labelAddNotExists() {
                 .isInstanceOf(NotFoundException.class);
     }
 
-    //TODO wait to v2.0.0-beta.7
-    @Disabled
     @Test
     void labelDeleteNotExists() {
 

client/src/test/java/com/influxdb/client/ITUsersApi.java

@@ -220,6 +220,8 @@ void updatePasswordById() {
         usersApi.updateUserPassword(user.getId(), "my-password", "my-password");
     }
 
+    //TODO https://github.com/influxdata/influxdb/issues/18048
+    @Disabled
     @Test
     void findUserLogs() {
 
@@ -243,6 +245,8 @@ void findUserLogsNotFound() {
         Assertions.assertThat(userLogs).isEmpty();
     }
 
+    //TODO https://github.com/influxdata/influxdb/issues/18048
+    @Disabled
     @Test
     void findUserLogsPaging() {
 

client/src/test/java/com/influxdb/client/ITVariablesApi.java

@@ -38,7 +38,6 @@
 
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.platform.runner.JUnitPlatform;
 import org.junit.runner.RunWith;
@@ -328,8 +327,6 @@ void labelAddNotExists() {
                 .isInstanceOf(NotFoundException.class);
     }
 
-    //TODO wait to v2.0.0-beta.7
-    @Disabled
     @Test
     void labelDeleteNotExists() {
 

client/src/test/java/com/influxdb/client/InfluxDBClientTest.java

@@ -24,6 +24,7 @@
 import com.influxdb.LogLevel;
 import com.influxdb.client.domain.Authorization;
 import com.influxdb.client.domain.OperationLogs;
+import com.influxdb.client.domain.WritePrecision;
 import com.influxdb.client.internal.AbstractInfluxDBClientTest;
 
 import okhttp3.mockwebserver.MockResponse;
@@ -183,8 +184,33 @@ void parseDateTime() {
 
     @Test
     public void autoClosable() {
-        try (InfluxDBClient client = InfluxDBClientFactory.create(mockServer.url("/").url().toString())){
+        try (InfluxDBClient client = InfluxDBClientFactory.create(mockServer.url("/").url().toString())) {
             Assertions.assertThat(client).isNotNull();
         }
     }
+
+    @Test
+    public void testTrailingSlashInUrl() throws InterruptedException {
+        mockServer.enqueue(new MockResponse());
+        mockServer.enqueue(new MockResponse());
+
+        String path = mockServer.url("/").toString();
+        InfluxDBClient influxDBClient = InfluxDBClientFactory
+                .create(path, "my-token".toCharArray());
+
+        influxDBClient.getWriteApiBlocking().writeRecord("my-bucket", "my-org", WritePrecision.NS, "record,tag=a value=1");
+
+        RecordedRequest request = mockServer.takeRequest();
+        Assertions.assertThat(request.getRequestUrl().toString()).isEqualTo(path + "api/v2/write?org=my-org&bucket=my-bucket&precision=ns");
+        influxDBClient.close();
+
+        influxDBClient = InfluxDBClientFactory
+                .create(path.substring(0, path.length() - 1), "my-token".toCharArray());
+
+        influxDBClient.getWriteApiBlocking().writeRecord("my-bucket", "my-org", WritePrecision.NS, "record,tag=a value=1");
+
+        request = mockServer.takeRequest();
+        Assertions.assertThat(request.getRequestUrl().toString()).isEqualTo(path + "api/v2/write?org=my-org&bucket=my-bucket&precision=ns");
+        influxDBClient.close();
+    }
 }