From 4b407903147d351f8100f9146c1882890575e49e Mon Sep 17 00:00:00 2001 From: Hoyt Summers Pittman Date: Tue, 17 Aug 2021 15:52:00 -0400 Subject: [PATCH 1/4] test: creating verification tests project --- examples/pom.xml | 114 ++++++++++++++++++ .../com/redhat/cloud/KafkaManagementIT.java | 36 ++++++ pom.xml | 3 +- 3 files changed, 152 insertions(+), 1 deletion(-) create mode 100644 examples/pom.xml create mode 100644 examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java diff --git a/examples/pom.xml b/examples/pom.xml new file mode 100644 index 00000000..5f96620f --- /dev/null +++ b/examples/pom.xml @@ -0,0 +1,114 @@ + + + 4.0.0 + + com.redhat.cloud + sdk-tests + 0.1.0-SNAPSHOT + jar + sdk-tests + http://console.redhat.com + + com.redhat.cloud + rhoas-sdk-java + 0.1.0-SNAPSHOT + + + 16 + 16 + 5.7.2 + 1.7.2 + + + + + com.redhat.cloud + kafka-management-sdk + 1.1.2 + + + javax.annotation + javax.annotation-api + 1.3.2 + + + org.junit.jupiter + junit-jupiter-api + ${junit.jupiter.version} + test + + + org.junit.jupiter + junit-jupiter-params + ${junit.jupiter.version} + test + + + org.junit.jupiter + junit-jupiter-engine + ${junit.jupiter.version} + test + + + org.junit.platform + junit-platform-commons + ${junit.platform.version} + test + + + + + + + io.fabric8 + docker-maven-plugin + 0.26.0 + + + start + pre-integration-test + + start + + + + stop + post-integration-test + + stop + + + + + + + + + quay.io/wtrocki/api-mock + + + 8080:8000 + + + + + + + + + + org.apache.maven.plugins + maven-failsafe-plugin + 2.22.2 + + + + integration-test + verify + + + + + + + \ No newline at end of file diff --git a/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java b/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java new file mode 100644 index 00000000..ae181de1 --- /dev/null +++ b/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java @@ -0,0 +1,36 @@ +package com.redhat.cloud; + +import static org.junit.jupiter.api.Assertions.fail; + +import org.junit.jupiter.api.Test; +import com.openshift.cloud.api.kas.invoker.*; +import com.openshift.cloud.api.kas.invoker.auth.*; +import com.openshift.cloud.api.kas.models.*; +import com.openshift.cloud.api.kas.DefaultApi; + +public class KafkaManagementIT { + @Test + public void testPass() { + ApiClient defaultClient = Configuration.getDefaultApiClient(); + defaultClient.setBasePath("http://localhost:8080"); + + // Configure HTTP bearer authorization: Bearer + HttpBearerAuth Bearer = (HttpBearerAuth) defaultClient.getAuthentication("Bearer"); + Bearer.setBearerToken("BEARER TOKEN"); + + DefaultApi apiInstance = new DefaultApi(defaultClient); + Boolean async = true; // Boolean | Perform the action in an asynchronous manner + KafkaRequestPayload kafkaRequestPayload = new KafkaRequestPayload(); // KafkaRequestPayload | Kafka data + kafkaRequestPayload.setName("name"); + try { + KafkaRequest result = apiInstance.createKafka(async, kafkaRequestPayload); + System.out.println(result); + } catch (ApiException e) { + System.err.println("Exception when calling DefaultApi#createKafka"); + System.err.println("Status code: " + e.getCode()); + System.err.println("Reason: " + e.getResponseBody()); + System.err.println("Response headers: " + e.getResponseHeaders()); + e.printStackTrace(); + } + } +} diff --git a/pom.xml b/pom.xml index e8445ebc..20438bb4 100644 --- a/pom.xml +++ b/pom.xml @@ -14,6 +14,7 @@ packages/kafka-management-sdk packages/registry-management-sdk packages/kafka-instance-sdk + examples @@ -85,4 +86,4 @@ - \ No newline at end of file + From 7f3a68c1b20aa442c06468a159294e9658d7abb7 Mon Sep 17 00:00:00 2001 From: Summers Pittman Date: Thu, 19 Aug 2021 10:23:44 -0400 Subject: [PATCH 2/4] chore: correcting java version --- examples/pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/pom.xml b/examples/pom.xml index 5f96620f..56b349e5 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -14,8 +14,8 @@ 0.1.0-SNAPSHOT - 16 - 16 + 11 + 11 5.7.2 1.7.2 From c198ea142c59d91e756d3509984852d21992329f Mon Sep 17 00:00:00 2001 From: Summers Pittman Date: Thu, 19 Aug 2021 16:25:11 -0400 Subject: [PATCH 3/4] tesT: adding more tests --- examples/pom.xml | 11 ++++- .../com/redhat/cloud/KafkaInstanceIT.java | 40 +++++++++++++++++ .../com/redhat/cloud/KafkaManagementIT.java | 31 +++++++++++-- .../com/redhat/cloud/ServiceAccountIT.java | 45 +++++++++++++++++++ 4 files changed, 122 insertions(+), 5 deletions(-) create mode 100644 examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java create mode 100644 examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java diff --git a/examples/pom.xml b/examples/pom.xml index 56b349e5..fcee4845 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -26,6 +26,13 @@ kafka-management-sdk 1.1.2 + + + com.redhat.cloud + kafka-instance-sdk + 0.3.0 + + javax.annotation javax.annotation-api @@ -62,7 +69,7 @@ io.fabric8 docker-maven-plugin - 0.26.0 + 0.37.0 start @@ -99,7 +106,7 @@ org.apache.maven.plugins maven-failsafe-plugin - 2.22.2 + 2.22.2 diff --git a/examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java b/examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java new file mode 100644 index 00000000..4ddc49a9 --- /dev/null +++ b/examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java @@ -0,0 +1,40 @@ +package com.redhat.cloud; + +import static org.junit.jupiter.api.Assertions.*; + +import java.util.concurrent.TimeUnit; + +import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.Timeout; + +import com.openshift.cloud.api.kas.auth.TopicsApi; +import com.openshift.cloud.api.kas.auth.invoker.*; +import com.openshift.cloud.api.kas.auth.invoker.auth.OAuth; +import com.openshift.cloud.api.kas.auth.models.*; + + +public class KafkaInstanceIT { + + @Test + public void testCreateExample() { + ApiClient defaultClient = Configuration.getDefaultApiClient(); + defaultClient.setBasePath("http://localhost:8080/rest"); + + OAuth oauth = (OAuth) defaultClient.getAuthentication("Bearer"); + oauth.setAccessToken("accessToken"); + + TopicsApi apiInstance = new TopicsApi(defaultClient); + + try { + TopicsList result = apiInstance.getTopics(null, null, null, null, null, null, null); + assertNotNull(result); + assertEquals(1, result.getItems().size()); + } catch (ApiException e) { + System.err.println("Exception when calling TopicsApi#getTopics"); + System.err.println("Status code: " + e.getCode()); + System.err.println("Reason: " + e.getResponseBody()); + System.err.println("Response headers: " + e.getResponseHeaders()); + e.printStackTrace(); + } + } +} diff --git a/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java b/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java index ae181de1..e74c6a8c 100644 --- a/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java +++ b/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java @@ -1,6 +1,6 @@ package com.redhat.cloud; -import static org.junit.jupiter.api.Assertions.fail; +import static org.junit.jupiter.api.Assertions.*; import org.junit.jupiter.api.Test; import com.openshift.cloud.api.kas.invoker.*; @@ -10,7 +10,7 @@ public class KafkaManagementIT { @Test - public void testPass() { + public void testCreateExample() { ApiClient defaultClient = Configuration.getDefaultApiClient(); defaultClient.setBasePath("http://localhost:8080"); @@ -24,7 +24,32 @@ public void testPass() { kafkaRequestPayload.setName("name"); try { KafkaRequest result = apiInstance.createKafka(async, kafkaRequestPayload); - System.out.println(result); + assertNotNull(result); + } catch (ApiException e) { + System.err.println("Exception when calling DefaultApi#createKafka"); + System.err.println("Status code: " + e.getCode()); + System.err.println("Reason: " + e.getResponseBody()); + System.err.println("Response headers: " + e.getResponseHeaders()); + e.printStackTrace(); + } + } + + @Test + public void testListExample() { + ApiClient defaultClient = Configuration.getDefaultApiClient(); + defaultClient.setBasePath("http://localhost:8080"); + + // Configure HTTP bearer authorization: Bearer + HttpBearerAuth Bearer = (HttpBearerAuth) defaultClient.getAuthentication("Bearer"); + Bearer.setBearerToken("BEARER TOKEN"); + + DefaultApi apiInstance = new DefaultApi(defaultClient); + + try { + KafkaRequestList result = apiInstance.getKafkas(null,null,null,null); + + assertNotNull(result); + assertEquals(1, result.getItems().size()); } catch (ApiException e) { System.err.println("Exception when calling DefaultApi#createKafka"); System.err.println("Status code: " + e.getCode()); diff --git a/examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java b/examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java new file mode 100644 index 00000000..7531f576 --- /dev/null +++ b/examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java @@ -0,0 +1,45 @@ +package com.redhat.cloud; + +import static org.junit.jupiter.api.Assertions.*; + +import org.junit.jupiter.api.Test; + +import com.openshift.cloud.api.kas.SecurityApi; +import com.openshift.cloud.api.kas.invoker.Configuration; +import com.openshift.cloud.api.kas.models.ServiceAccount; +import com.openshift.cloud.api.kas.models.ServiceAccountRequest; +import com.openshift.cloud.api.kas.invoker.auth.HttpBearerAuth; +import com.openshift.cloud.api.kas.invoker.ApiClient; +import com.openshift.cloud.api.kas.invoker.ApiException; + +public class ServiceAccountIT { + + @Test + public void testCreateExample() { + ApiClient defaultClient = Configuration.getDefaultApiClient(); + defaultClient.setBasePath("http://localhost:8080"); + + // Configure HTTP bearer authorization: Bearer + HttpBearerAuth Bearer = (HttpBearerAuth) defaultClient.getAuthentication("Bearer"); + Bearer.setBearerToken("TOKEN"); + + var apiInstance = new SecurityApi(defaultClient); + var serviceAccountRequest = new ServiceAccountRequest(); + serviceAccountRequest.setDescription("Description"); + serviceAccountRequest.setName("sa_name"); + try { + ServiceAccount result = apiInstance.createServiceAccount(serviceAccountRequest); + + assertNotNull(result); + + } catch (ApiException e) { + System.err.println("Exception when calling DefaultApi#createKafka"); + System.err.println("Status code: " + e.getCode()); + System.err.println("Reason: " + e.getResponseBody()); + System.err.println("Response headers: " + e.getResponseHeaders()); + e.printStackTrace(); + } + } + + +} From 5443bb3616c7593e6676a11ac830889d8abc7a3d Mon Sep 17 00:00:00 2001 From: Summers Pittman Date: Tue, 24 Aug 2021 17:31:04 -0400 Subject: [PATCH 4/4] todo: fixup --- examples/pom.xml | 6 ++- .../com/redhat/cloud/ServiceRegistryIT.java | 37 +++++++++++++++++++ 2 files changed, 42 insertions(+), 1 deletion(-) create mode 100644 examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java diff --git a/examples/pom.xml b/examples/pom.xml index fcee4845..676df211 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -26,7 +26,11 @@ kafka-management-sdk 1.1.2 - + + com.redhat.cloud + registry-management-sdk + 0.5.1 + com.redhat.cloud kafka-instance-sdk diff --git a/examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java b/examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java new file mode 100644 index 00000000..6fbf9f2b --- /dev/null +++ b/examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java @@ -0,0 +1,37 @@ +package com.redhat.cloud; + +import static org.junit.jupiter.api.Assertions.*; + +import org.junit.jupiter.api.Test; + +import com.openshift.cloud.api.srs.*; +import com.openshift.cloud.api.srs.invoker.*; +import com.openshift.cloud.api.srs.invoker.auth.*; +import com.openshift.cloud.api.srs.models.*; + + +public class ServiceRegistryIT { + + @Test + public void testListExample() { + var defaultClient = Configuration.getDefaultApiClient(); + defaultClient.setBasePath("http://localhost:8080"); + + var oauth = (HttpBearerAuth) defaultClient.getAuthentication("Bearer"); + oauth.setBearerToken("bearerToken"); + + var apiInstance = new RegistriesApi(defaultClient); + + try { + RegistryListRest result = apiInstance.getRegistries(null, null, null, null); + assertNotNull(result); + assertEquals(1, result.getItems().size()); + } catch (ApiException e) { + System.err.println("Exception when calling RegistriesApi#getRegistries"); + System.err.println("Status code: " + e.getCode()); + System.err.println("Reason: " + e.getResponseBody()); + System.err.println("Response headers: " + e.getResponseHeaders()); + e.printStackTrace(); + } + } +}