Fix decode bug with http_request

Author: RainingComputers

pkg/platforms/postgres/postgres.go

@@ -835,7 +835,7 @@ func requests(
 				e.elem->>'method' AS method,
 				e.elem->>'url' AS url,
 				e.elem->'headers' AS headers,
-				e.elem->'data' AS data
+				decode(e.elem->>'data', 'base64') AS data
 			FROM jsonb_array_elements(locked.events)
 				WITH ORDINALITY AS e(elem, idx)
 			WHERE e.elem->>'type' = 'HttpRequestEvent'

pkg/runtimes/dupher/testutil_test.go

@@ -572,6 +572,7 @@ import (
 	"encoding/gob"
 	"encoding/json"
 	"fmt"
+	"io"
 	"net/http"
 	"os"
 	"os/signal"
@@ -751,6 +752,15 @@ func spawnCtrl(
 		},
 	)
 
+	mux.HandleFunc(
+		"POST /echo",
+		func(w http.ResponseWriter, r *http.Request) {
+			body, _ := io.ReadAll(r.Body)
+			w.Header().Set("Content-Type", "application/json")
+			w.Write(body)
+		},
+	)
+
 	server := &http.Server{Addr: controlAddr, Handler: mux}
 	go func() {
 		if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {

pkg/runtimes/dupher/worker_test.go

@@ -255,6 +255,39 @@ func ImpureHttpRequestTestSpec() {
 				},
 			},
 		},
+		{
+			name:     "http_request_body",
+			flowName: "EchoRequestTest",
+			source: map[string]string{
+				"echorequestflow.ds.go": `package main
+
+import "github.com/RainingComputers/deepslate/prelude"
+
+func EchoRequestTestSpec() {
+	var body []byte
+	var err error
+	body, err = prelude.JsonMarshal(42)
+	_ = err
+
+	url := "http://localhost:18766/echo"
+	var responseData []byte
+	responseData, err = prelude.HttpRequest("POST", url, map[string]string{}, body)
+
+	value, err := prelude.JsonUnmarshal[int](responseData)
+	_ = err
+	_ = value
+}
+`,
+			},
+			steps: []workerTestStep{
+				{
+					sleep: 500 * time.Millisecond,
+					wantVars: map[string]any{
+						"value": 42,
+					},
+				},
+			},
+		},
 		{
 			name:     "flow_with_args",
 			flowName: "Add",

pkg/runtimes/dython/deepslate/tests/test_utils.py

@@ -434,6 +434,19 @@ def do_GET(self) -> None:
             self.end_headers()
             self.wfile.write(json.dumps({"Status": "healthy", "Code": 200}).encode())
 
+        def do_POST(self) -> None:
+            if self.path != "/echo":
+                self.send_response(404)
+                self.end_headers()
+                return
+
+            length = int(self.headers.get("Content-Length", 0))
+            body = self.rfile.read(length)
+            self.send_response(200)
+            self.send_header("Content-Type", "application/json")
+            self.end_headers()
+            self.wfile.write(body)
+
     server = HTTPServer(("localhost", port), HTTPHandler)
     thread = threading.Thread(target=server.serve_forever, daemon=True)
     thread.start()

pkg/runtimes/dython/deepslate/tests/test_worker.py

@@ -195,6 +195,40 @@ async def impure_http_request_test():
                 ),
             ],
         ),
+        WorkerTestCase(
+            name="http_request_body",
+            flow_name="echo_request_test",
+            source={
+                "echo_request_test.py": """\
+from deepslate import flow, http_request, json_marshal, json_unmarshal, DSError
+
+
+@flow
+async def echo_request_test():
+    body: bytes | DSError
+    response_data: bytes | DSError
+    value: int = 0
+    url: str = "http://localhost:18769/echo"
+
+    body = json_marshal(42)
+    if not isinstance(body, bytes):
+        return body
+
+    response_data = http_request("POST", url, {}, body)
+    if not isinstance(response_data, bytes):
+        return response_data
+
+    value = json_unmarshal[int](response_data)
+""",
+            },
+            steps=[
+                WorkerTestStep(
+                    sleep=0.5,
+                    want_vars={"value": 42},
+                ),
+            ],
+            want_traces=[],
+        ),
         WorkerTestCase(
             name="flow_with_args",
             flow_name="add",