Added bearer auth

Author: RijulTP

cmdexec/cmdexec.go

@@ -13,6 +13,7 @@ import (
 
 	"github.com/HexmosTech/httpie-go"
 	"github.com/HexmosTech/lama2/utils"
+	"fmt"
 )
 
 // ExecCommand changes directory to the given `apiDir`
@@ -22,6 +23,8 @@ import (
 // Once execution finishes, previous CWD is restored,
 // and the command output is returned as a string
 func ExecCommand(cmdSlice []string, stdinBody string, apiDir string) (httpie.ExResponse, int64, error) {
+	fmt.Println("Command Slice:", cmdSlice)
+    fmt.Println("Standard Input Body:", stdinBody)
 	oldDir, _ := os.Getwd()
 	utils.ChangeWorkingDir(apiDir)
 	start := time.Now()

cmdgen/cmdgen.go

@@ -12,6 +12,7 @@ import (
 
 	"github.com/HexmosTech/gabs/v2"
 	"github.com/HexmosTech/lama2/lama2cmd"
+	"syscall/js"
 )
 
 // The assembleCmdString function constructs a httpie
@@ -38,13 +39,6 @@ func assembleCmdString(httpv string, url string, jsonObj *gabs.Container, header
 		jsonStr = dst.String()
 	}
 
-	/*
-		if !multipart && jsonStr != "" {
-			command = append(command, "echo '")
-			command = append(command, jsonStr)
-			command = append(command, "' |")
-		}*/
-
 	command = append(command, "ht ")
 	if o != nil && o.Nocolor {
 		command = append(command, "--pretty=none ")
@@ -78,6 +72,30 @@ func assembleCmdString(httpv string, url string, jsonObj *gabs.Container, header
 			command = append(command, key+":"+val.Data().(*gabs.Container).Data().(string))
 		}
 	}
+
+	// Add the Authorization header
+	// LaBearerAuthToken := js.Global().Get("LaBearerAuthToken").String()
+	// command = append(command, "Authorization: Bearer " + LaBearerAuthToken)
+
+	LaBearerAuthToken := js.Global().Get("LaBearerAuthToken").String()
+
+	// Check if Authorization header is already present
+	authHeaderExists := false
+	for _, header := range command {
+		if len(header) >= len("Authorization:") && header[:len("Authorization:")] == "Authorization:" {
+			authHeaderExists = true
+			break
+		}
+	}
+
+	// Append the Authorization header only if it doesn't already exist
+	if !authHeaderExists {
+		command = append(command, "Authorization: Bearer "+LaBearerAuthToken)
+	}
+
+
+
+	
 	cleanCommand := make([]string, 0)
 	for _, c := range command {
 		cleanC := strings.TrimSpace(c)

cmdgen/cmdgen.wasm.go

@@ -5,8 +5,18 @@ package cmdgen
 import (
 	"github.com/HexmosTech/gabs/v2"
 	"github.com/HexmosTech/lama2/lama2cmd"
+	"fmt"
+    "syscall/js"
 )
 
+
+var myPassedValue string
+func setMyValue(this js.Value, p []js.Value) interface{} {
+    myPassedValue = p[0].String() // Get the first parameter
+    fmt.Println("DBGX: Received value from JS in Go:", myPassedValue)
+    return nil
+}
+
 func ConstructCommand(parsedInput *gabs.Container, o *lama2cmd.Opts) ([]string, string) {
 	httpv, url, jsonObj, headers, multipartBool, formBool := ConstructCommandHelper(parsedInput)
 	res, stdinBody := assembleCmdString(httpv, url, jsonObj, headers, multipartBool, formBool, nil)

l2.wasm.go

@@ -11,7 +11,7 @@ import (
 )
 
 var version string
-
+var LaBearerAuthToken string // Exported global variable
 func init() {
 	// Initialize version if not set
 	if len(version) == 0 {
@@ -30,6 +30,8 @@ func main() {
 
 func wasmLamaPromise() js.Func {
 	return js.FuncOf(func(this js.Value, args []js.Value) interface{} {
+		LaBearerAuthToken = args[2].String()
+		js.Global().Set("LaBearerAuthToken", LaBearerAuthToken)
 		inputdata := args[0].String()
 		handler := js.FuncOf(func(this js.Value, args []js.Value) interface{} {
 			resolve := args[0]

localwasmbuild.sh

@@ -0,0 +1,2 @@
+GOOS=js GOARCH=wasm go build -a -gcflags=all="-l -B -wb=false" -ldflags="-w -s" -o static/main.wasm
+cp /home/rtp/Projects/Lama2/static/main.wasm /home/rtp/Projects/liveapi/dist/main.wasm

preprocess/webworker.wasm.go

@@ -106,3 +106,35 @@ func GetFromWorker(variableName string) string {
 	fmt.Println("WW: getfromworker webworker.go", variableName, result.Get("value").String())
 	return result.Get("value").String()
 }
+
+func GetFromLocalStorage(key string) string {
+    worker := InitWebWorker() // Initialize the Web Worker
+    responseChannel := make(chan js.Value, 1) // Single-buffered channel for one response
+
+    // Send the request to the Web Worker
+    worker.Call("postMessage", map[string]interface{}{
+        "action": "get",
+        "key":    key,
+    })
+
+    // Set up an event listener to handle the Web Worker's response
+    worker.Call("addEventListener", "message", js.FuncOf(func(this js.Value, args []js.Value) interface{} {
+        data := args[0].Get("data")
+        if data.Get("result").IsUndefined() {
+            log.Error().Msg("WW: LocalStorage value is undefined")
+            return nil
+        }
+
+        select {
+        case responseChannel <- data:
+            log.Debug().Msg("WW: Value received from Web Worker")
+        default:
+            log.Error().Msg("WW: responseChannel is full, cannot write data")
+        }
+        return nil
+    }))
+
+    // Wait for the response and retrieve the result
+    result := <-responseChannel
+    return result.Get("result").String()
+}