Added contributor tracking apps, and started tracking revisions the same way as workflows

backend/go-app/walkoff.go

@@ -3183,6 +3183,12 @@ func setNewWorkflowApp(resp http.ResponseWriter, request *http.Request) {
 	workflowapp.Generated = false
 	workflowapp.Activated = true
 
+	if !shuffle.ArrayContains(api.Contributors, user.Id) {
+		api.Contributors = append(api.Contributors, user.Id)
+	}
+
+	shuffle.SetAppRevision(ctx, workflowapp)
+
 	err = shuffle.SetWorkflowAppDatastore(ctx, workflowapp, workflowapp.ID)
 	if err != nil {
 		log.Printf("[WARNING] Failed setting workflowapp: %s", err)

functions/onprem/orborus/orborus.go

@@ -1825,22 +1825,32 @@ func deployPipeline(image, identifier, command string) error {
 
 	// Add volume binds for storage
 	// Want read/write with full access for the container
-	// Should mount 
+	//sourceFolder := "/Users/frikky/git/shuffle/shuffle-database"
-	sourceFolder := "/Users/frikky/git/shuffle/shuffle-database/tenzir"
+	//destinationFolder := "/tmp/storage"
-	destinationFolder := "/var/lib/tenzir"
+	//hostConfig.Mounts = append(hostConfig.Mounts, mount.Mount{
-	hostConfig.Mounts = append(hostConfig.Mounts, mount.Mount{
+	//	Type:   mount.TypeBind,
-		Type:   mount.TypeBind,
+	//	Source: sourceFolder,
-		Source: sourceFolder,
+	//	Target: destinationFolder,
-		Target: destinationFolder,
+	//})
-	})
+
+	// FIXME: Is using sigma "automatically" here good?
+	// Or is it better to run it as a separate workflow?
+	if strings.Contains(command, "sigma") {
+		log.Printf("[DEBUG] Should LOAD sigma from backend in realtime and dump it in a folder inside the container")
+
+		//sourceFolder := "/tmp/tenzir/sigma"
+		//sigmaFolder := "/tmp/tenzir/sigma"
+		//hostConfig.Mounts = append(hostConfig.Mounts, mount.Mount{
+		//	Type:   mount.TypeBind,
+		//	Source: sigmaFolder,
+		//	Target: sigmaFolder,
+		//}
+	}
 
 	config := &container.Config{
 		Image: image,
 		Env:   envVariables,
 		Cmd:   []string{
-			"mkdir", 
-			"-p", 
-			destinationFolder,
 			command,
 		},
 	}
@@ -1922,6 +1932,7 @@ func deployPipeline(image, identifier, command string) error {
 	}
 
 	// Wait for the container to finish
+	/*
 	statusCh, errCh := dockercli.ContainerWait(ctx, cont.ID, container.WaitConditionNotRunning)
 	select {
 	case err := <-errCh:
@@ -1931,7 +1942,7 @@ func deployPipeline(image, identifier, command string) error {
 	case <-statusCh:
 		log.Printf("[INFO] Container finished")
 	}
-
+	*/
 
 	return nil
 }