remove unused actions && propagate inputs to transaction async

Author: NRHelmi

rai-sdk-examples/src/main/java/com/relationalai/examples/ExecuteAsync.java

@@ -19,6 +19,7 @@
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
+
 import com.relationalai.Client;
 import com.relationalai.Config;
 import com.relationalai.HttpError;

rai-sdk/src/main/java/com/relationalai/Client.java

@@ -760,16 +760,15 @@ public HashMap<String, Any> executeAsyncWait(
 
     public Any executeAsync(
             String database, String engine, String source, boolean readonly) throws HttpError, IOException, InterruptedException {
-        return executeAsync(database, engine, source, readonly, null);
+        return executeAsync(database, engine, source, readonly, new HashMap<>());
     }
 
     public Any executeAsync(
             String database, String engine,
             String source, boolean readonly,
             Map<String, String> inputs) throws HttpError, IOException, InterruptedException {
-        var tx = new TransactionAsync(database, engine,  source, readonly);
-        var action = DbAction.makeQueryAction(source, inputs);
-        var body = tx.payload(action);
+        var tx = new TransactionAsync(database, engine,  source, readonly, inputs);
+        var body = tx.payload();
         var rsp = post(PATH_TRANSACTIONS, tx.queryParams(), body);
         return Json.deserialize(rsp);
     }

rai-sdk/src/main/java/com/relationalai/TransactionAsync.java

@@ -50,24 +50,15 @@ public TransactionAsync(String database, String engine, String command, Boolean
     }
 
     // Construct the transaction payload and return serialized JSON string.
-    String payload(DbAction... actions) {
+    String payload() {
         var data = new HashMap<String, Object>();
         data.put("dbname", database);
         data.put("readonly", readonly);
         data.put("engine_name", engine);
         data.put("query", command);
 
         var inputsList = new ArrayList<>();
-        for (Map.Entry<String, String> entry : inputs.entrySet()) {
-            inputsList.add(
-                    DbAction.makeQueryActionInput(
-                            entry.getKey(),
-                            entry.getValue()
-                    )
-            );
-        }
-
-        data.put("inputs", inputsList);
+        inputs.forEach((k, v) -> inputsList.add(DbAction.makeQueryActionInput(k, v)));
 
         var output = new ByteArrayOutputStream();
         JsonStream.setIndentionStep(0);