From e75fb0792e692f6e32be0a064c7fd6b8d30790e5 Mon Sep 17 00:00:00 2001
From: Lorenzo Venerandi <lollo.venerandi@gmail.com>
Date: Mon, 10 Mar 2025 22:58:51 +0100
Subject: [PATCH] updated http provider

---
 src/code_generator/template_compiler.py         |  2 +-
 .../templates/producer_nats/main.go             | 17 +++++++++++------
 2 files changed, 12 insertions(+), 7 deletions(-)

diff --git a/src/code_generator/template_compiler.py b/src/code_generator/template_compiler.py
index e539ba5..cbfb693 100644
--- a/src/code_generator/template_compiler.py
+++ b/src/code_generator/template_compiler.py
@@ -8,7 +8,7 @@ def handle_task(task, output_dir):
     try:
     
         match task['type']:
-            case 'producer_nats':
+            case 'http_producer_nats':
                 __generate_producer(task, output_dir)
             case 'processor_nats':
                 __generate_processor(task, output_dir)
diff --git a/src/code_generator/templates/producer_nats/main.go b/src/code_generator/templates/producer_nats/main.go
index 99f9647..76ecba5 100644
--- a/src/code_generator/templates/producer_nats/main.go
+++ b/src/code_generator/templates/producer_nats/main.go
@@ -4,6 +4,7 @@ package main
 import (
 	"fmt"
 	"net/http"
+	"io"
 
 	logger "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/logging/logging"
 	"gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasmcloud/messaging/consumer"
@@ -30,14 +31,18 @@ func init() {
 
 func handleHttp(w http.ResponseWriter, r *http.Request) {
 
-	// get body as string
-	if handleRequest(r.FormValue("data")) {
-		fmt.Fprintf(w, "Message sent!\n")
-	} else {
-		fmt.Fprintf(w, "Error\n") 
+	value, err := io.ReadAll(r.Body)
+
+	if err != nil {
+		fmt.Fprintf(w, "Error, invalid request body\n") 
+		return
 	}
 
-	// send response
+	if handleRequest(string(value)) {
+		fmt.Fprintf(w, "Message sent!\n")
+	} else {
+		fmt.Fprintf(w, "Error, coudln't send message\n")
+	}
 }
 
 func handleMessage(msg types.BrokerMessage) cm.Result[string, struct{}, string]{