upgraded to 14.5 and GraphQL exercise

build.gradle

@@ -20,9 +20,9 @@ plugins {
 
 ext {
     versions = [
-        commercetools: "14.0.0",
-        slf4j: "1.7.32",
-        logback: "1.2.5",
+            commercetools: "14.5.0",
+            slf4j: "1.7.36",
+            logback: "1.2.10",
     ]
 }
 
@@ -44,9 +44,9 @@ repositories {
 dependencies {
     implementation "com.commercetools.sdk:commercetools-http-client:${versions.commercetools}"
     implementation "com.commercetools.sdk:commercetools-sdk-java-api:${versions.commercetools}"
+    implementation "com.commercetools.sdk:commercetools-graphql-api:${versions.commercetools}"
     implementation "com.commercetools.sdk:commercetools-sdk-java-importapi:${versions.commercetools}"
     implementation "com.commercetools.sdk:commercetools-sdk-java-ml:${versions.commercetools}"
-    implementation 'com.fasterxml.jackson.core:jackson-databind:2.12.4'
     implementation "org.slf4j:slf4j-api:${versions.slf4j}"
     implementation "ch.qos.logback:logback-classic:${versions.logback}"
 
@@ -60,6 +60,4 @@ dependencies {
     implementation group: 'org.json', name: 'json', version: '20200518'
     implementation 'javax.json:javax.json-api:1.1.4'
     implementation 'org.glassfish:javax.json:1.1.4'
-
-    implementation 'io.aexp.nodes.graphql:nodes:0.4.0-atlassian-hosted'
 }

src/main/java/handson/Task03c_SYNC_PROJECTS.java

@@ -45,7 +45,7 @@ public static void main(String[] args) throws IOException, InterruptedException
         //  Modify as wished
         //  RUN the project sync
         //
-        dockerRun.append(" commercetools/commercetools-project-sync:5.0.0 -s all");
+        dockerRun.append(" commercetools/commercetools-project-sync:5.3.1 -s all");
         logger.info(dockerRun.toString());
 
         Process process = Runtime.getRuntime().exec(dockerRun.toString());

src/main/java/handson/Task05a_INSTORE_ME.java

@@ -36,7 +36,7 @@ public static void main(String[] args) throws IOException, ExecutionException, I
         logger.info("Created in-store cart with a global api client: " +
                 " "
         );
-
+        client.close();
 
         // TODO: Create in-store Cart with in-store API client
         //  Update the ApiPrefixHelper with the prefix for Store API Client
@@ -51,6 +51,7 @@ public static void main(String[] args) throws IOException, ExecutionException, I
         logger.info("Created in-store cart with a store api client: "+
                 " "
         );
+//        storeClient.close();
 
         // TODO
         //  Verify on impex that the carts are holding the same information
@@ -122,7 +123,7 @@ public static void main(String[] args) throws IOException, ExecutionException, I
 //        );
 //        storeClient.close();
 
-        client.close();
+
 
     }
 }

src/main/java/handson/Task06c_GRAPHQL.java

@@ -0,0 +1,60 @@
+package handson;
+
+import com.commercetools.api.client.ProjectApiRoot;
+import com.commercetools.api.models.graph_ql.GraphQLRequest;
+import com.commercetools.graphql.api.GraphQL;
+import com.commercetools.graphql.api.GraphQLResponse;
+import com.commercetools.graphql.api.types.ProductQueryResult;
+import handson.impl.ApiPrefixHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.Collections;
+import java.util.concurrent.ExecutionException;
+
+import static handson.impl.ClientService.*;
+
+
+public class Task06c_GRAPHQL {
+
+    public static void main(String[] args) throws IOException, ExecutionException, InterruptedException {
+
+        final String apiClientPrefix = ApiPrefixHelper.API_DEV_CLIENT_PREFIX.getPrefix();
+
+        final ProjectApiRoot client = createApiClient(apiClientPrefix);
+        Logger logger = LoggerFactory.getLogger(Task04b_CHECKOUT.class.getName());
+
+
+        // TODO:
+        //  Use the GraphQL playground to create a graphql query
+        //
+
+        logger.info("GraphQl : " +
+                client
+                        .graphql()
+                        .post(
+                                GraphQLRequest.builder()
+                                        .query("{ products { total }}")
+                                        .build()
+                        )
+                        .execute()
+                        .toCompletableFuture().get()
+                        .getBody()
+                        .getData()
+        );
+
+        GraphQLResponse<ProductQueryResult> responseEntity =
+                client
+                        .graphql()
+                        .query(GraphQL.products(q -> q.limit(3).sort(Collections.singletonList("masterData.current.name.en desc")))
+                                .projection(p -> p.total().results().id().masterData().current().name("en", null)))
+                        .executeBlocking()
+                        .getBody();
+        logger.info("Total products: " + responseEntity.getData().getTotal());
+        responseEntity.getData().getResults().forEach(result ->
+                logger.info("Id: " + result.getId() + "Name: " + result.getMasterData().getCurrent().getName()));
+
+        client.close();
+    }
+}

src/main/java/handson/Task08a_SUBSCRIPTION.java

@@ -2,7 +2,11 @@
 
 
 import com.commercetools.api.client.ProjectApiRoot;
-import com.commercetools.api.models.subscription.*;
+import com.commercetools.api.models.subscription.GoogleCloudPubSubDestinationBuilder;
+import com.commercetools.api.models.subscription.MessageSubscription;
+import com.commercetools.api.models.subscription.MessageSubscriptionBuilder;
+import com.commercetools.api.models.subscription.MessageSubscriptionResourceTypeId;
+import com.commercetools.api.models.subscription.SubscriptionDraftBuilder;
 import handson.impl.ApiPrefixHelper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -47,14 +51,14 @@ public static void main(String[] args) throws IOException, ExecutionException, I
                                         )
                                         .messages(
                                                 MessageSubscriptionBuilder.of()
-                                                        .resourceTypeId(MessageSubscriptionResourceTypeId.ORDER)
-                                                        .types("OrderCreated")
+                                                        .resourceTypeId(MessageSubscriptionResourceTypeId.ORDER) // https://docs.commercetools.com/api/types#referencetype
+                                                        .types("OrderCreated") // https://docs.commercetools.com/api/message-types
                                                         .build()
                                         )
                                         .build()
                         )
                         .execute()
-                        .get()
+                        .toCompletableFuture().get()
                         .getBody()
         );