WIP: add checkout sdk

Author: jenschude

commercetools/commercetools-sdk-java-checkout/build.gradle

@@ -0,0 +1,14 @@
+
+dependencies {
+    api project(':rmf:rmf-java-base')
+    api jackson_core.annotations
+    api jackson_core.databind
+    implementation google.findbugs
+    implementation javax.validation
+    api commons.lang3
+
+    integrationTestImplementation project(':commercetools:commercetools-http-client')
+}
+
+sourceSets.main.java.srcDirs += "src/main/java-generated"
+sourceSets.test.java.srcDirs += "src/test/java-generated"

commercetools/commercetools-sdk-java-checkout/src/integrationTest/java/com/commercetools/checkout/client/ProjectApiRootTest.java

@@ -0,0 +1,43 @@
+
+package com.commercetools.checkout.client;
+
+import java.lang.reflect.Method;
+import java.lang.reflect.Modifier;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.assertj.core.api.Assertions;
+import org.assertj.core.util.Lists;
+import org.junit.jupiter.api.Test;
+
+public class ProjectApiRootTest {
+
+    private static final List<String> ignoreMethods = Lists.newArrayList();
+
+    /**
+     * Retrieves all public methods of the {@link ProjectScopedApiRoot} and the public methods of the {@link ByProjectKeyRequestBuilder} and
+     * checks if project request builder methods are present in ProjectApiRoot methods
+     */
+    @Test
+    public void allSubResourcesSupported() {
+
+        final List<String> projectApiRootMethods = Lists.newArrayList(ProjectScopedApiRoot.class.getDeclaredMethods())
+                .stream()
+                .filter(method -> Modifier.isPublic(method.getModifiers()))
+                .map(Method::getName)
+                .distinct()
+                .collect(Collectors.toList());
+
+        final List<String> resourceMethods = Lists.newArrayList(ByProjectKeyRequestBuilder.class.getDeclaredMethods())
+                .stream()
+                .filter(method -> Modifier.isPublic(method.getModifiers()))
+                .map(Method::getName)
+                .filter(methodName -> !ignoreMethods.contains(methodName))
+                .filter(methodName -> !projectApiRootMethods.contains(methodName))
+                .collect(Collectors.toList());
+
+        Assertions.assertThat(resourceMethods)
+                .withFailMessage("missing endpoints in ProjectApiRoot: %s", resourceMethods)
+                .isEmpty();
+    }
+}

commercetools/commercetools-sdk-java-checkout/src/integrationTest/java/com/commercetools/checkout/defaultconfig/CheckoutApiTestUtils.java

@@ -0,0 +1,107 @@
+
+package com.commercetools.checkout.defaultconfig;
+
+import java.time.Duration;
+import java.util.UUID;
+import java.util.function.Consumer;
+
+import com.commercetools.checkout.client.ProjectApiRoot;
+
+import io.vrap.rmf.base.client.oauth2.ClientCredentials;
+
+import org.apache.commons.lang3.StringUtils;
+import org.assertj.core.api.SoftAssertions;
+
+public class CheckoutApiTestUtils {
+
+    private static final ProjectApiRoot projectRoot;
+
+    static {
+        String logLevel = System.getenv("CTP_JVM_SDK_LOG_LEVEL");
+        if ("OFF".equals(logLevel)) {
+            projectRoot = CheckoutApiRootBuilder.of()
+                    .defaultClient(
+                        ClientCredentials.of().withClientId(getClientId()).withClientSecret(getClientSecret()).build(),
+                        ServiceRegion.GCP_EUROPE_WEST1)
+                    .build(getProjectKey());
+        }
+        else {
+            projectRoot = CheckoutApiRootBuilder.of()
+                    .defaultClient(
+                        ClientCredentials.of().withClientId(getClientId()).withClientSecret(getClientSecret()).build(),
+                        ServiceRegion.GCP_EUROPE_WEST1)
+                    .build(getProjectKey());
+        }
+    }
+
+    public static String randomString() {
+        return "random-string-" + UUID.randomUUID().toString();
+    }
+
+    public static String randomId() {
+        return "random-id-" + UUID.randomUUID().toString();
+    }
+
+    public static String randomKey() {
+        return "random-key-" + UUID.randomUUID().toString();
+    }
+
+    public static String getProjectKey() {
+        return System.getenv("CTP_PROJECT_KEY");
+    }
+
+    public static String getClientId() {
+        return System.getenv("CTP_CLIENT_ID");
+    }
+
+    public static String getClientSecret() {
+        return System.getenv("CTP_CLIENT_SECRET");
+    }
+
+    public static ProjectApiRoot getProjectRoot() {
+        return projectRoot;
+    }
+
+    public static void assertEventually(final Duration maxWaitTime, final Duration waitBeforeRetry,
+            final Runnable block) {
+        final long timeOutAt = System.currentTimeMillis() + maxWaitTime.toMillis();
+        while (true) {
+            try {
+                block.run();
+
+                // the block executed without throwing an exception, return
+                return;
+            }
+            catch (AssertionError e) {
+                if (System.currentTimeMillis() > timeOutAt) {
+                    throw e;
+                }
+            }
+
+            try {
+                Thread.sleep(waitBeforeRetry.toMillis());
+            }
+            catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+        }
+    }
+
+    public static void assertEventually(final Consumer<SoftAssertions> assertionsConsumer) {
+        final Runnable block = () -> {
+            final SoftAssertions softly = new SoftAssertions();
+            assertionsConsumer.accept(softly);
+            softly.assertAll();
+        };
+        assertEventually(block);
+    }
+
+    public static void assertEventually(final Runnable block) {
+        final Boolean useLongTimeout = "true".equals(System.getenv("TRAVIS"))
+                || StringUtils.isNotEmpty(System.getenv("TEAMCITY_VERSION"))
+                || StringUtils.isNoneEmpty(System.getenv("GITHUB_WORKSPACE"));
+        final Duration maxWaitTime = Duration.ofSeconds(useLongTimeout ? 60 : 30);
+        final Duration waitBeforeRetry = Duration.ofMillis(100);
+        assertEventually(maxWaitTime, waitBeforeRetry, block);
+    }
+}

commercetools/commercetools-sdk-java-checkout/src/integrationTest/java/com/commercetools/checkout/defaultconfig/CheckoutIntegrationTests.java

@@ -0,0 +1,14 @@
+
+package com.commercetools.checkout.defaultconfig;
+
+public class CheckoutIntegrationTests {
+
+    //    @Test
+    //    public void createAndDelete() {
+    //        final ApiHttpResponse<RecordPagedQueryResponse> response = CheckoutApiTestUtils.getProjectRoot()
+    //                .()
+    //                .executeBlocking();
+    //
+    //        Assertions.assertNotNull(response.getBody());
+    //    }
+}

commercetools/commercetools-sdk-java-checkout/src/integrationTest/resources/logback-test.xml

@@ -0,0 +1,17 @@
+<configuration debug="false">
+    <contextListener class="ch.qos.logback.classic.jul.LevelChangePropagator">
+        <resetJUL>true</resetJUL>
+    </contextListener>
+
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <logger name="commercetools" level="WARN"/>
+
+    <root level="INFO">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>

commercetools/commercetools-sdk-java-checkout/src/main/java/com/commercetools/checkout/client/CheckoutCorrelationIdProvider.java

@@ -0,0 +1,19 @@
+
+package com.commercetools.checkout.client;
+
+import java.util.UUID;
+
+import io.vrap.rmf.base.client.http.CorrelationIdProvider;
+
+public class CheckoutCorrelationIdProvider implements CorrelationIdProvider {
+    private final String projectKey;
+
+    public CheckoutCorrelationIdProvider(String projectKey) {
+        this.projectKey = projectKey;
+    }
+
+    @Override
+    public String getCorrelationId() {
+        return projectKey + "/" + UUID.randomUUID();
+    }
+}

commercetools/commercetools-sdk-java-checkout/src/main/java/com/commercetools/checkout/client/ProjectApiRoot.java

@@ -0,0 +1,46 @@
+
+package com.commercetools.checkout.client;
+
+import java.io.Closeable;
+
+import io.vrap.rmf.base.client.ApiHttpClient;
+import io.vrap.rmf.base.client.SerializerOnlyApiHttpClient;
+
+public class ProjectApiRoot implements Closeable, ProjectScopedApiRoot {
+    private final String projectKey;
+    private final ApiHttpClient apiHttpClient;
+
+    private ProjectApiRoot(final String projectKey, final ApiHttpClient apiHttpClient) {
+        this.projectKey = projectKey;
+        this.apiHttpClient = apiHttpClient;
+    }
+
+    public static ProjectApiRoot of(final String projectKey) {
+        return new ProjectApiRoot(projectKey, SerializerOnlyApiHttpClient.of());
+    }
+
+    public static ProjectApiRoot fromClient(final String projectKey, final ApiHttpClient apiHttpClient) {
+        return new ProjectApiRoot(projectKey, apiHttpClient);
+    }
+
+    @Override
+    public ByProjectKeyRequestBuilder with() {
+        return ApiRoot.fromClient(apiHttpClient).withProjectKey(projectKey);
+    }
+
+    public ByProjectKeyRequestBuilder withProjectKey(final String projectKey) {
+        return ApiRoot.fromClient(apiHttpClient).withProjectKey(projectKey);
+    }
+
+    @Override
+    public void close() {
+        if (apiHttpClient == null) {
+            return;
+        }
+        try {
+            apiHttpClient.close();
+        }
+        catch (final Throwable ignored) {
+        }
+    }
+}

commercetools/commercetools-sdk-java-checkout/src/main/java/com/commercetools/checkout/client/ProjectScopedApiRoot.java

@@ -0,0 +1,6 @@
+
+package com.commercetools.checkout.client;
+
+public interface ProjectScopedApiRoot {
+    ByProjectKeyRequestBuilder with();
+}