Made Singul work better onprem. Moving to test.

Author: frikky

app_upload/stitcher.go

@@ -1010,8 +1010,8 @@ func main() {
 		bucketName = os.Args[5]
 	}
 
-	appname := "shuffle-tools"
-	appversion := "1.2.0"
+	appname := "shuffle-ai"
+	appversion := "1.0.0"
 	err := deployConfigToBackend(appfolder, appname, appversion)
 	if err != nil {
 		log.Printf("[WARNING] Failed uploading config: %s", err)

blobs.go

@@ -205,6 +205,7 @@ func GetDefaultWorkflowByType(workflow Workflow, orgId string, categoryAction Ca
 						},
 						WorkflowAppActionParameter{
 							Name:  "standard",
+							Description: "The standard to use from https://github.com/Shuffle/standards/tree/main",
 							Value: "OCSF",
 							Multiline: false,
 						},

db-connector.go

@@ -1169,12 +1169,7 @@ func Fixexecution(ctx context.Context, workflowExecution WorkflowExecution) (Wor
 	dbsave := false
 	workflowExecution.Workflow.Image = ""
 
-	//newExec := cleanupProtectedKeys(*exec)
-	//exec = &newExec
 	workflowExecution = cleanupProtectedKeys(workflowExecution)
-
-	// FIXME: May be a problem here with setting it at all times~
-	//if workflowExecution.Status != "EXECUTING" {
 	validation, err := GetExecutionValidation(ctx, workflowExecution.ExecutionId)
 	if err == nil {
 		if workflowExecution.NotificationsCreated > 0 {
@@ -13561,11 +13556,16 @@ func GetCacheKeyCount(ctx context.Context, orgId string, category string) (int,
 }
 
 func GetAllCacheKeys(ctx context.Context, orgId string, category string, max int, inputcursor string) ([]CacheKeyData, string, error) {
+	if (os.Getenv("SHUFFLE_SWARM_CONFIG") == "run" || project.Environment == "worker") {
+		return []CacheKeyData{}, "", errors.New("Not available in worker mode")
+	}
+
 	nameKey := "org_cache"
 	if strings.ToLower(category) == "default" {
 		category = ""
 	}
 
+
 	category = strings.ReplaceAll(strings.ToLower(category), " ", "_")
 	cacheKey := fmt.Sprintf("%s_%s_%s_%s", nameKey, inputcursor, orgId, category)
 	// Look for

health.go

@@ -2048,9 +2048,15 @@ func GetStaticWorkflowHealth(ctx context.Context, workflow Workflow) (Workflow,
 				startnodeFound = true
 			}
 
+			if strings.ToLower(strings.ReplaceAll(action.Name, " ", "_")) == "translate_standard" {
+				newActions = append(newActions, action)
+				continue
+			}
+
 			for _, field := range action.Parameters {
 				if (field.Name == "app_name" || field.Name == "appname") && (field.Value == "" || field.Value == "noapp") {
-					parsedError := fmt.Sprintf("Singul AI action %s is an app to use", action.Label)
+
+					parsedError := fmt.Sprintf("Singul action %s requires an app to use", action.Label)
 					if !ArrayContains(workflow.Errors, parsedError) {
 						workflow.Errors = append(workflow.Errors, parsedError)
 					}

shared.go

@@ -31003,8 +31003,8 @@ func SanitizeFuzzySubstring(haystack, secret string, maxDistance int) string {
 
 // Basic cleanup.
 func cleanupProtectedKeys(exec WorkflowExecution) WorkflowExecution {
-	isDisabled := os.Getenv("SHUFFLE_PROTECTED_CLEANUP_DISABLED")
-	if isDisabled == "true" {
+	// Basic checks to return 
+	if os.Getenv("SHUFFLE_PROTECTED_CLEANUP_DISABLED") == "true" || project.Environment == "worker" {
 		return exec
 	}