examples: custom task for runtime-v2 (walmartlabs#469)

Author: brig

examples/custom_task/pom.xml

@@ -14,7 +14,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 
-        <concord.version>1.12.0</concord.version>
+        <concord.version>1.88.0</concord.version>
         <jackson.version>2.9.8</jackson.version>
         <okhttp.version>3.12.1</okhttp.version>
     </properties>
@@ -27,6 +27,14 @@
             <version>${concord.version}</version>
             <scope>provided</scope>
         </dependency>
+        <!-- for runtime-v2 support -->
+        <dependency>
+            <groupId>com.walmartlabs.concord.runtime.v2</groupId>
+            <artifactId>concord-runtime-sdk-v2</artifactId>
+            <version>${concord.version}</version>
+            <scope>provided</scope>
+        </dependency>
+
         <dependency>
             <groupId>javax.inject</groupId>
             <artifactId>javax.inject</artifactId>
@@ -69,4 +77,23 @@
             <scope>test</scope>
         </dependency>
     </dependencies>
+
+    <build>
+        <plugins>
+            <!-- required for runtime-v2 -->
+            <plugin>
+                <groupId>org.eclipse.sisu</groupId>
+                <artifactId>sisu-maven-plugin</artifactId>
+                <version>0.3.3</version>
+                <executions>
+                    <execution>
+                        <id>index</id>
+                        <goals>
+                            <goal>main-index</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 </project>

examples/custom_task/src/main/java/com/walmartlabs/concord/examples/customtask/CustomTaskV2.java

@@ -0,0 +1,52 @@
+package com.walmartlabs.concord.examples.customtask;
+
+import com.walmartlabs.concord.runtime.v2.sdk.Task;
+
+import javax.inject.Named;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.walmartlabs.concord.runtime.v2.sdk.TaskResult;
+import com.walmartlabs.concord.runtime.v2.sdk.Variables;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+
+/**
+ * A custom task example. All tasks must implement {@link Task} interface and
+ * be marked with {@link Named} annotation.
+ *
+ * The task fetches a specified URL and parses the response as JSON, converting
+ * the data into regular Java objects.
+ */
+@Named("customTask")
+public class CustomTaskV2 implements Task {
+
+    private static final Logger log = LoggerFactory.getLogger(CustomTaskV2.class);
+
+    @Override
+    public TaskResult execute(Variables input) throws Exception {
+        String url = input.assertString("url");
+
+        OkHttpClient client = new OkHttpClient();
+        Request req = new Request.Builder()
+                .url(url)
+                .build();
+
+        try (Response resp = client.newCall(req).execute()) {
+            if (!resp.isSuccessful()) {
+                log.warn("Error while fetching {}: {}", url, resp.code());
+                return TaskResult.error("Error while fetching")
+                        .value("errorCode", resp.code());
+            }
+
+            ObjectMapper om = new ObjectMapper();
+            Object data = om.readValue(resp.body().byteStream(), Object.class);
+
+            return TaskResult.success()
+                    .value("data", data);
+        }
+    }
+}

examples/custom_task/test-v2.yml

@@ -0,0 +1,15 @@
+configuration:
+  runtime: concord-v2
+
+flows:
+  default:
+    - task: customTask
+      in:
+        url: "https://jsonplaceholder.typicode.com/todos/1"
+      out: result
+
+    - if: "${!result.ok}"
+      then:
+        - throw: "The request returned ${result.errorCode}"
+
+    - log: "Data: ${result.data}"

examples/custom_task/test.sh

@@ -3,6 +3,7 @@
 set -e
 
 SERVER_ADDR="$1"
+CONCORD_YAML="$2"
 
 # build the task
 mvn clean package -DskipTests
@@ -11,7 +12,7 @@ mvn clean package -DskipTests
 rm -rf target/test && mkdir -p target/test
 
 # copy the test flow
-cp test.yml target/test/concord.yml
+cp ${CONCORD_YAML:-test.yml} target/test/concord.yml
 
 # copy the task's JAR...
 mkdir -p target/test/lib/