fix: signing logic and body mismatch

Author: ProgrammingMuffin

jamq-replica/globals/global.go

@@ -0,0 +1,3 @@
+package globals
+
+var Body string = ""

jamq-replica/router/middleware/auth.go

@@ -4,6 +4,7 @@ import (
 	"encoding/base64"
 	"fmt"
 	"jamq-replica/constants"
+	"jamq-replica/globals"
 	"net/http"
 	"os"
 	"strconv"
@@ -14,15 +15,18 @@ import (
 	"crypto/sha256"
 
 	"github.com/labstack/echo/v4"
+	"github.com/valyala/bytebufferpool"
 )
 
 func Authenticate(next echo.HandlerFunc) echo.HandlerFunc {
 	return func(c echo.Context) error {
-		var bodyBytes []byte
+		bodyBytesBuffer := &bytebufferpool.ByteBuffer{}
 		request := c.Request()
 		header := request.Header
-		request.Body.Read(bodyBytes)
-		body := string(bodyBytes)
+		bodyBytesBuffer.ReadFrom(request.Body)
+		body := bodyBytesBuffer.String()
+		globals.Body = body
+		fmt.Println("Body is: " + body)
 		queryString := strings.ToValidUTF8(c.QueryString(), "")
 		nonce := header.Get(constants.GetHeaders().X_AUTH_NONCE)
 		sentTimestamp, err := strconv.Atoi(nonce)

jamq-replica/utils/json.go

@@ -1,15 +1,11 @@
 package utils
 
 import (
-	"bytes"
 	"encoding/json"
-
-	"github.com/labstack/echo/v4"
+	"jamq-replica/globals"
 )
 
-func GetRequestBody(c echo.Context, requestBody interface{}) error {
-	bytesBuff := new(bytes.Buffer)
-	bytesBuff.ReadFrom(c.Request().Body)
-	err := json.Unmarshal(bytesBuff.Bytes(), requestBody)
+func GetRequestBody(requestBody interface{}) error {
+	err := json.Unmarshal([]byte(globals.Body), requestBody)
 	return err
 }

jamq-replica/v1/handler.go

@@ -43,6 +43,10 @@ func HandleSendMessage(c echo.Context) error {
 	if err != nil {
 		return echo.NewHTTPError(400, err.Error())
 	}
+	err = utils.GetRequestBody(request)
+	if err != nil {
+		return echo.NewHTTPError(400, err.Error())
+	}
 	err = queueService.SendMessage(c.Param("queueName"), request.Message, request.Timestamp)
 	if err != nil {
 		return echo.NewHTTPError(400, err.Error())