Merge branch 'dev-43' of github.com:ksankeerth/core into ksankeerth-dev-43

Author: dstpierre

function/helpers.go

@@ -0,0 +1,39 @@
+package function
+
+type JSFetchOptionsArg struct {
+	Method         string
+	Headers        map[string]string
+	Body           string
+	Mode           string
+	Credentials    string
+	Cache          string
+	Redirect       string
+	Referrer       string
+	ReferrerPolicy string
+	Integrity      string
+	Keepalive      string
+	Signal         string
+}
+
+type HTTPResponse struct {
+	Status int    `json:"status"`
+	Body   string `json:"body"`
+}
+
+func NewJSFetcthOptionArg() JSFetchOptionsArg {
+	defaultOptions := JSFetchOptionsArg{
+		Method:         "GET",
+		Headers:        make(map[string]string, 0),
+		Body:           "",
+		Mode:           "no-cors",
+		Credentials:    "omit",
+		Cache:          "no-cache",
+		Redirect:       "error",
+		Referrer:       "",
+		ReferrerPolicy: "",
+		Integrity:      "",
+		Keepalive:      "",
+		Signal:         "",
+	}
+	return defaultOptions
+}

function/runtime.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io"
 	"net/http"
 	"strings"
 	"time"
@@ -121,6 +122,69 @@ func (env *ExecutionEnvironment) addHelpers(vm *goja.Runtime) {
 		env.CurrentRun.Output = append(env.CurrentRun.Output, fmt.Sprint(params...))
 		return goja.Undefined()
 	})
+	vm.Set("fetch", func(call goja.FunctionCall) goja.Value {
+		url := ""
+		fetchOptions := NewJSFetcthOptionArg()
+		if len(call.Arguments) == 0 {
+			return goja.Undefined()
+		} else if len(call.Arguments) == 1 {
+			url = call.Argument(0).Export().(string)
+		} else {
+			url = call.Argument(0).Export().(string)
+			if err := vm.ExportTo(call.Argument(1), &fetchOptions); err != nil {
+				return vm.ToValue(Result{Content: "the second argument should be an object"})
+			}
+		}
+		if len(url) == 0 {
+			return vm.ToValue(Result{Content: "the url should not be blank"})
+		}
+
+		responseChan := make(chan interface{})
+		go func() {
+			client := http.Client{Timeout: time.Duration(30) * time.Second}
+			var request *http.Request
+			var err error
+			bodyReader := strings.NewReader(fetchOptions.Body)
+			switch fetchOptions.Method {
+			case "GET":
+				request, err = http.NewRequest(http.MethodGet, url, nil)
+			case "POST":
+				request, err = http.NewRequest(http.MethodPost, url, bodyReader)
+			case "PUT":
+				request, err = http.NewRequest(http.MethodPut, url, bodyReader)
+			case "DELETE":
+				request, err = http.NewRequest(http.MethodDelete, url, bodyReader)
+			case "PATCH":
+				request, err = http.NewRequest(http.MethodPatch, url, bodyReader)
+			}
+			if err != nil {
+				responseChan <- err
+			}
+			for headerKey, headerValue := range fetchOptions.Headers {
+				if len(headerKey) > 0 && len(headerValue) > 0 {
+					request.Header.Set(headerKey, headerValue)
+				}
+			}
+			res, err := client.Do(request)
+			if err != nil {
+				responseChan <- err
+			}
+			responseChan <- res
+		}()
+
+		output := <-responseChan
+
+		if err, ok := output.(error); ok {
+			return vm.ToValue(Result{OK: false, Content: fmt.Sprintf("error calling fetch(): %s", err.Error())})
+		} else if response, ok := output.(*http.Response); ok {
+			bodyBytes, err := io.ReadAll(response.Body)
+			if err != nil {
+				return vm.ToValue(Result{OK: false, Content: fmt.Sprintf("error calling fetch(): %s", err.Error())})
+			}
+			return vm.ToValue(Result{OK: true, Content: HTTPResponse{Status: response.StatusCode, Body: string(bodyBytes)}})
+		}
+		return goja.Undefined()
+	})
 }
 
 func (env *ExecutionEnvironment) addDatabaseFunctions(vm *goja.Runtime) {

functions_test.go

@@ -72,7 +72,71 @@ func TestFunctionsExecuteDBOperations(t *testing.T) {
 			log("query doc id: " + qres.content.results[0].id);
 			return;
 		}
-		
+
+		var getRes = fetch("https://run.mocky.io/v3/427873c5-4baa-4f68-b880-b6e3e45b3d4d");
+		if (!getRes.ok) {
+			log("ERROR: sending GET request");
+			log(getRes.content);
+			return;
+		}
+
+		var postRes = fetch("https://run.mocky.io/v3/427873c5-4baa-4f68-b880-b6e3e45b3d4d", {
+			method: "POST",
+			headers: {
+				"Content-Type" : "application/json"
+			}, 
+			body: {
+				"test": "test msg"
+			}
+		});
+		if (!postRes.ok) {
+			log("ERROR: sending POST request");
+			log(postRes.content);
+			return;
+		}
+
+		var putRes = fetch("https://run.mocky.io/v3/427873c5-4baa-4f68-b880-b6e3e45b3d4d", {
+			method: "PUT",
+			headers: {
+				"Content-Type" : "application/json"
+			}, 
+			body: {
+				"test": "test msg"
+			}
+		});
+		if (!putRes.ok) {
+			log("ERROR: sending PUT request");
+			log(putRes.content);
+			return;
+		}
+		var patchRes = fetch("https://run.mocky.io/v3/427873c5-4baa-4f68-b880-b6e3e45b3d4d", {
+			method: "PATCH",
+			headers: {
+				"Content-Type" : "application/json"
+			}, 
+			body: {
+				"test": "test msg"
+			}
+		});
+		if (!patchRes.ok) {
+			log("ERROR: sending PATCH request");
+			log(patchRes.content);
+			return;
+		}
+		var delRes = fetch("https://run.mocky.io/v3/427873c5-4baa-4f68-b880-b6e3e45b3d4d", {
+			method: "DELETE",
+			headers: {
+				"Content-Type" : "application/json"
+			}, 
+			body: {
+				"test": "test msg"
+			}
+		});
+		if (!delRes.ok) {
+			log("ERROR: sending DELETE request");
+			log(delRes.content);
+			return;
+		}
 	}`
 	data := internal.ExecData{
 		FunctionName: "unittest",