rrequest now adapts body size accordinly to Content-Length

internal/pkg/parser/parser.go

@@ -4,9 +4,11 @@ import (
 	"bufio"
 	"bytes"
 	"fmt"
+	"io"
 	"io/ioutil"
 	"net/http"
 	"net/http/httputil"
+	"strconv"
 
 	"github.com/sirupsen/logrus"
 
@@ -34,12 +36,17 @@ func (parser *Parser) Init() error {
 
 	body, err := ioutil.ReadAll(buf)
 	if err != nil {
-		logrus.Warn("Failed to read body: '%s'", err)
+		logrus.Warn("Failed to read body: '", err)
 		return err
 	}
 
 	req.Body = ioutil.NopCloser(bytes.NewBuffer(body))
 
+	// Fix Body Size
+	bodySize := getBodySize(req, body)
+	req.Header.Set("Content-Length", strconv.FormatInt(bodySize, 10)) //len(dec)
+	req.ContentLength = bodySize
+
 	parser.Body = body
 	req.RequestURI = ""
 	req.URL.Scheme = "http"
@@ -62,6 +69,19 @@ func (parser *Parser) Init() error {
 	return nil
 }
 
+func getBodySize(request *http.Request, body []byte) int64 {
+	buf := &bytes.Buffer{}
+	nRead, err := io.Copy(buf, request.Body)
+	if err != nil {
+		logrus.Warn("Failed to copy body buffer: ", err)
+		return 0
+	}
+
+	request.Body = ioutil.NopCloser(bytes.NewBuffer(body))
+
+	return nRead
+}
+
 // Do sends the request via the parser HTTP Client and return the response
 func (parser *Parser) Do(request *http.Request) (*http.Response, error) {
 	resp, err := parser.Client.Do(request)

internal/pkg/reducer/reducer.go

@@ -39,17 +39,20 @@ func reduceHeaders(request *http.Request, parser *parser.Parser) http.Request {
 	headers := request.Header
 	for key, values := range headers {
 
-		request.Header.Del(key)
-
-		status, _ := validateResponse(parser.InitialResponse, request, parser)
-		if status == true {
-			logrus.Info(fmt.Sprintf("Ok, header %s hasn't impact on response", key))
-		} else {
-
-			logrus.Info(fmt.Sprintf("Ok, header %s has impact on response", key))
-			for _, value := range values {
-				request.Header.Add(key, value)
+		if key != "Content-Length" {
+			request.Header.Del(key)
+
+			status, _ := validateResponse(parser.InitialResponse, request, parser)
+			if status == true {
+				logrus.Info(fmt.Sprintf("Ok, header %s hasn't impact on response", key))
+			} else {
+
+				logrus.Info(fmt.Sprintf("Ok, header %s has impact on response", key))
+				for _, value := range values {
+					request.Header.Add(key, value)
+				}
 			}
+
 		}
 
 	}