Add json input/output support

Author: caleeli

Dockerfile

@@ -5,6 +5,7 @@ MAINTAINER ProcessMaker Inc.
 COPY /src /opt/executor
 
 WORKDIR /opt/executor/spark-sdk-java
-RUN ls
-RUN mvn package mvn -DmyProperty=3.9.1
-RUN cp target/openapi-java-client-1.0.0.jar ../openapi-java-client-1.0.0.jar
+
+RUN mvn package -DmyProperty=3.9.1
+
+WORKDIR /opt/executor

Script.java

@@ -12,5 +12,3 @@ pushd src
 popd
 
 docker build -t processmaker/spark-docker-executor-java:${TAG} .
-
-docker run -it --rm --name java1 -v "$(pwd)/Script.java":/opt/executor/Script.java -w /opt/executor processmaker/spark-docker-executor-java:${TAG} ls

build.sh

@@ -0,0 +1,13 @@
+import org.openapitools.client.api.UsersApi;
+import ProcessMaker_Client.ApiClient;
+import com.google.gson.Gson;
+import java.io.*;
+import java.lang.reflect.Type;
+import com.google.gson.reflect.TypeToken;
+import java.util.Map;
+import java.util.HashMap;
+
+public interface BaseScript {
+
+    public void execute(Map<String, Object> data, Map<String, Object> config, Map<String, Object> output);
+}

src/BaseScript.java

@@ -0,0 +1,20 @@
+import org.openapitools.client.api.UsersApi;
+import ProcessMaker_Client.ApiClient;
+import com.google.gson.Gson;
+import java.io.*;
+import java.lang.reflect.Type;
+import com.google.gson.reflect.TypeToken;
+import java.util.Map;
+import java.util.HashMap;
+
+public class Main {
+
+    public static void main(String args[]) throws FileNotFoundException {
+        Script script = new Script();
+        Map<String, Object> data = Spark.data();
+        Map<String, Object> config = Spark.config();
+        Map<String, Object> output = new HashMap<String, Object>();
+        script.execute(data, config, output);
+        Spark.printOutput(output);
+    }
+}

src/Main.java

@@ -0,0 +1,45 @@
+import org.openapitools.client.api.UsersApi;
+import ProcessMaker_Client.ApiClient;
+import com.google.gson.Gson;
+import java.io.*;
+import java.lang.reflect.Type;
+import com.google.gson.reflect.TypeToken;
+import java.util.Map;
+import java.util.HashMap;
+
+public class Spark {
+
+    public static ApiClient api() {
+        String baseApiUrl = System.getenv("API_HOST");
+        String v3Token = System.getenv("API_TOKEN");
+        int connectTimeout = 60000;
+        int readTimeout = 120000;
+
+        ApiClient client = new ApiClient();
+
+        client.setBasePath(baseApiUrl);
+        client.setApiKey("Bearer " + v3Token);
+        client.setConnectTimeout(connectTimeout);
+        client.setDebugging(false);
+        return client;
+    }
+
+    public static Map<String, Object> data() throws FileNotFoundException {
+        Type typeOfHashMap = new TypeToken<Map<String, Object>>() { }.getType();
+        BufferedReader bufferedReader = new BufferedReader(new FileReader("data.json"));
+        Gson gson = new Gson();
+        return gson.fromJson(bufferedReader, typeOfHashMap);
+    }
+
+    public static Map<String, Object> config() throws FileNotFoundException {
+        Type typeOfHashMap = new TypeToken<Map<String, Object>>() { }.getType();
+        BufferedReader bufferedReader = new BufferedReader(new FileReader("config.json"));
+        Gson gson = new Gson();
+        return gson.fromJson(bufferedReader, typeOfHashMap);
+    }
+
+    public static void printOutput(Map<String, Object> data) {
+        String jsonString = new Gson().toJson(data);
+        System.out.println(jsonString);
+    }
+}

src/Spark.java

@@ -1,3 +1,3 @@
 #!/bin/bash
-javac -cp spark-sdk-java/target/lib/*:spark-sdk-java/target/openapi-java-client-1.0.0.jar Script.java
-java -cp spark-sdk-java/target/lib/*:spark-sdk-java/target/openapi-java-client-1.0.0.jar:. Script
+javac -cp spark-sdk-java/target/lib/*:spark-sdk-java/target/openapi-java-client-1.0.0.jar -Xlint:unchecked Script.java Spark.java Main.java BaseScript.java
+java -cp spark-sdk-java/target/lib/*:spark-sdk-java/target/openapi-java-client-1.0.0.jar:. Main