Merge branch 'Shuffle:main' into support-llm

Author: satti-hari-krishna-reddy

README.md

@@ -1,7 +1,8 @@
 # Shuffle-shared
 A repository containing structures and commonly used functions between different deployments on Shuffle. Here to ensure consistency and not re-making the same functions multiple places.
 
-[![Shuffle repositories](https://github.com/user-attachments/assets/856f5faa-991c-47f5-9dd5-44e711b7d437)](https://www.figma.com/board/V6Kg7KxbmuhIUyTImb20t1/Shuffle-AI-Agent-system?node-id=0-1&p=f&t=ywpMQJ555sxggEpj-0)
+[![Shuffle repositories](https://github.com/user-attachments/assets/df117c01-f2fc-4000-8b5e-ffad33f5779e)](https://www.figma.com/board/V6Kg7KxbmuhIUyTImb20t1/Shuffle-AI-Agent-system?node-id=0-1&p=f&t=ywpMQJ555sxggEpj-0)
+
 
 ### Sample areas
 - [Shuffle backend (APIs)](https://github.com/Shuffle/Shuffle/tree/main/backend/go-app) (open source)

ai.go

@@ -8,7 +8,6 @@ import (
 	"github.com/shuffle/shuffle-shared"
 
 	"archive/zip"
-	"runtime"
 	"bytes"
 	"context"
 	"crypto/md5"
@@ -23,6 +22,7 @@ import (
 	"os"
 	"os/user"
 	"path/filepath"
+	"runtime"
 	"strings"
 	"time"
 
@@ -323,7 +323,6 @@ func stitcher(appname string, appversion string) string {
 		return ""
 	}
 
-
 	err = ioutil.WriteFile(fmt.Sprintf("%s/main.py", foldername), stitched, os.ModePerm)
 	if err != nil {
 		log.Println("Failed writing to stitched: %s", err)
@@ -464,7 +463,7 @@ func deployFunction(appname, localization, applocation string, environmentVariab
 		log.Println("[WARNING] Failed creating new function. Attempting patch, as it might exist already")
 
 		// Get the function
-		// Then replicate environment variables, maxinstance & memory 
+		// Then replicate environment variables, maxinstance & memory
 		getcall := projectsLocationsFunctionsService.Get(fmt.Sprintf("%s/functions/%s", location, appname))
 		existingFunction, err := getcall.Do()
 		if err != nil {
@@ -488,7 +487,6 @@ func deployFunction(appname, localization, applocation string, environmentVariab
 			}
 		}
 
-
 		patchCall := projectsLocationsFunctionsService.Patch(fmt.Sprintf("%s/functions/%s", location, appname), cloudFunction)
 		_, err = patchCall.Do()
 		if err != nil {
@@ -599,7 +597,6 @@ func loadYaml(fileLocation string) (shuffle.WorkflowApp, error) {
 	return action, nil
 }
 
-
 // Deploys to backend (YAML config)
 func deployConfigToBackend(basefolder, appname, appversion string) error {
 	location := fmt.Sprintf("%s/%s/%s/api.yaml", basefolder, appname, appversion)
@@ -664,7 +661,7 @@ func deployConfigToBackend(basefolder, appname, appversion string) error {
 		storageclient, err := storage.NewClient(ctx)
 		if err != nil {
 			log.Printf("[ERROR] Failed to create client: %v", err)
-			return nil 
+			return nil
 		}
 
 		bucket := storageclient.Bucket(bucketName)
@@ -940,8 +937,8 @@ func sendRebuildRequest(imageName string) {
 
 	client := &http.Client{}
 	req, err := http.NewRequest(
-		http.MethodPost, 
-		url, 
+		http.MethodPost,
+		url,
 		nil,
 	)
 
@@ -964,7 +961,7 @@ func sendRebuildRequest(imageName string) {
 func main() {
 	//addRequirements("generated_apps/shuffle-tools_1.0.0/requirements.txt")
 	if len(os.Args) < 3 {
-		log.Printf("[WARNING] Missing arguments. <> are NOT required. Input: go run stitcher.go APIKEY URL <GCEPROJECT> <GCE_REGION> <BUCKETNAME>\n\n\nSample: go run stitcher.go APIKEY https://ca.shuffler.io shuffle-na-northeast1 northamerica-northeast1 shuffle_org_files_na_northeast1") 
+		log.Printf("[WARNING] Missing arguments. <> are NOT required. Input: go run stitcher.go APIKEY URL <GCEPROJECT> <GCE_REGION> <BUCKETNAME>\n\n\nSample: go run stitcher.go APIKEY https://ca.shuffler.io shuffle-na-northeast1 northamerica-northeast1 shuffle_org_files_na_northeast1")
 		return
 	}
 
@@ -986,7 +983,7 @@ func main() {
 		appbasefile = strings.Replace(appbasefile, "/home/", "/Users/", -1)
 		appfolder = strings.Replace(appfolder, "/home/", "/Users/", -1)
 	}
-	
+
 	if strings.Contains(appbasefile, "$USER") || strings.Contains(appfolder, "$USER") {
 		log.Printf("[INFO] Replacing $USER with current user in paths")
 		currentUser, err := user.Current()