Bugfixes found Shuffle blog part 2

backend/app_sdk/app_base.py

@@ -588,6 +588,7 @@ class AppBase:
         logging.basicConfig(format="{asctime} - {name} - {levelname}:{message}", style='{')
         logger = logging.getLogger(f"{cls.__name__}")
         logger.setLevel(logging.DEBUG)
+        print("Started execution!!")
 
         app = cls(redis=None, logger=logger, console_logger=logger)
 

backend/go-app/codegen.go

@@ -637,6 +637,7 @@ func getRunner(classname string) string {
 	return fmt.Sprintf(`
 # Run the actual thing after we've checked params
 def run(request):
+    print("Started execution!")
     action = request.get_json() 
     print(action)
     print(type(action))

backend/go-app/main.go

@@ -5748,10 +5748,10 @@ func runInit(ctx context.Context) {
 				}
 			}
 
+			//log.Printf("Schedule time: every %d seconds", schedule.Seconds)
 			jobret, err := newscheduler.Every(schedule.Seconds).Seconds().NotImmediately().Run(job)
 			if err != nil {
 				log.Printf("Failed to schedule workflow: %s", err)
-				// FIXME: what now? lol:w
 			}
 
 			scheduledJobs[schedule.Id] = jobret

backend/go-app/walkoff.go

@@ -2340,7 +2340,16 @@ func scheduleWorkflow(resp http.ResponseWriter, request *http.Request) {
 		return
 	}
 
-	log.Printf("Schedulearg: %s", string(scheduleArg))
+	// Clean up garbage. This might be wrong in some very specific use-cases
+	parsedBody := string(scheduleArg)
+	parsedBody = strings.Replace(parsedBody, "\\\"", "\"", -1)
+	if len(parsedBody) > 0 {
+		if string(parsedBody[0]) == `"` && string(parsedBody[len(parsedBody)-1]) == "\"" {
+			parsedBody = parsedBody[1 : len(parsedBody)-1]
+		}
+	}
+
+	log.Printf("Schedulearg: %s", parsedBody)
 
 	err = createSchedule(
 		ctx,
@@ -2348,7 +2357,7 @@ func scheduleWorkflow(resp http.ResponseWriter, request *http.Request) {
 		workflow.ID,
 		schedule.Name,
 		schedule.Frequency,
-		scheduleArg,
+		[]byte(parsedBody),
 	)
 
 	// FIXME - real error message lol
@@ -3325,7 +3334,6 @@ func iterateOpenApiGithub(fs billy.Filesystem, dir []os.FileInfo, extra string,
 			// Check the file
 			filename := file.Name()
 			if strings.Contains(filename, "yaml") || strings.Contains(filename, "yml") {
-				appCounter += 1
 				//log.Printf("File: %s", filename)
 				//log.Printf("Found file: %s", filename)
 				tmpExtra := fmt.Sprintf("%s%s/", extra, file.Name())
@@ -3395,6 +3403,7 @@ func iterateOpenApiGithub(fs billy.Filesystem, dir []os.FileInfo, extra string,
 						log.Printf("Failed setting workflowapp in loop: %s", err)
 						continue
 					} else {
+						appCounter += 1
 						log.Printf("Added %s:%s to the database from OpenAPI repo", api.Name, api.AppVersion)
 
 						// Set OpenAPI datastore