#170: Fixed looping recursion issue with single-item list

backend/app_sdk/app_base.py

@@ -127,7 +127,10 @@ class AppBase:
                 print("%s is not a list: " % value)
 
         print("Listlengths: %s" % listlengths)
-        if len(listlengths) <= 1:
+        if len(listlengths) == 0:
+            print("NO multiplier. Running a single iteration.")
+            paramlist.append(baseparams)
+        elif len(listlengths) == 1:
             print("NO MULTIPLIER NECESSARY. Length is %d" % len(listitems))
             for item in listitems:
                 # This loops should always be length 1
@@ -189,6 +192,17 @@ class AppBase:
 
         newparams = {}
         for key, value in baseparams.items():
+            if isinstance(value, list) and len(value) > 0:
+                print("In list check")
+                try:
+                    value[0] = json.loads(value[0])
+                except json.decoder.JSONDecodeError as e:
+                    print("JSON casting error: %s" % e)
+                except TypeError as e:
+                    print("TypeError: %s" % e)
+
+                print("POST list check")
+
             if isinstance(value, list) and len(value) == 1 and isinstance(value[0], list):
                 try:
                     loop_wrapper[key] += 1
@@ -202,6 +216,7 @@ class AppBase:
                 has_loop = True 
             else:
                 print("Key %s is NOT a list within a list: %s" % (key, value))
+
                 newparams[key] = value
         
         results = []
@@ -216,6 +231,7 @@ class AppBase:
             # If here: check for multipliers within this scope.
             ret = []
             param_multiplier = await self.get_param_multipliers(newparams)
+
             print("Multiplier length: %d" % len(param_multiplier))
             for subparams in param_multiplier:
                 tmp = await func(**subparams)
@@ -248,7 +264,7 @@ class AppBase:
             results.append(ret)
             json_object = True
         elif isinstance(ret, list):
-            results.append(ret)
+            results = ret
             json_object = True
         else:
             ret = ret.replace("\"", "\\\"", -1)
@@ -1324,7 +1340,7 @@ class AppBase:
                                 print("Before first part in multiexec!")
                                 handled = False
                                 if len(actualitem[0]) > 2 and actualitem[0][1] == "SHUFFLE_NO_SPLITTER":
-                                    print("Pre replacement: %s" % actualitem[0][2])
+                                    print("(1) Pre replacement: %s" % actualitem[0][2])
                                     tmpitem = value
 
                                     replacement = actualitem[0][2]
@@ -1379,6 +1395,7 @@ class AppBase:
                                     multi_execution_lists.append(json_replacement)
                                     print("MULTI finished: %s" % json_replacement)
                                 else:
+                                    print("(2) Pre replacement: %s" % actualitem)
                                     # This is here to handle for loops within variables.. kindof
                                     # 1. Find the length of the longest array
                                     # 2. Build an array with the base values based on parameter["value"] 

backend/app_sdk/build.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 NAME=shuffle-app_sdk
-VERSION=0.8.31
+VERSION=0.8.32
 
 docker rmi docker.pkg.github.com/frikky/shuffle/$NAME:$VERSION --force
 docker build . -t frikky/shuffle:app_sdk -t frikky/$NAME:$VERSION -t docker.pkg.github.com/frikky/shuffle/$NAME:$VERSION -t ghcr.io/frikky/$NAME:$VERSION

backend/go-app/walkoff.go

@@ -5910,7 +5910,7 @@ func getWorkflowExecutions(resp http.ResponseWriter, request *http.Request) {
 	ctx := context.Background()
 	workflow, err := getWorkflow(ctx, fileId)
 	if err != nil {
-		log.Printf("Failed getting the workflow locally (get executions): %s", err)
+		log.Printf("Failed getting the workflow %s locally (get executions): %s", fileId, err)
 		resp.WriteHeader(401)
 		resp.Write([]byte(`{"success": false}`))
 		return
@@ -5987,7 +5987,7 @@ func getAllWorkflowApps(ctx context.Context) ([]WorkflowApp, error) {
 	_, err := dbclient.GetAll(ctx, q, &allworkflowapps)
 	if err != nil {
 		if strings.Contains(fmt.Sprintf("%s", err), "ResourceExhausted") {
-			q := datastore.NewQuery("workflowapp").Limit(30).Order("-edited")
+			q := datastore.NewQuery("workflowapp").Limit(40).Order("-edited")
 			_, err := dbclient.GetAll(ctx, q, &allworkflowapps)
 			if err != nil {
 				return []WorkflowApp{}, err