fix: Add missing lock

keboola · Sep 27, 2024 · 4b4fb5a · 4b4fb5a
1 parent 7f76d80
commit 4b4fb5a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/internal/pkg/service/stream/mapping/recordctx/fasthttp.go b/internal/pkg/service/stream/mapping/recordctx/fasthttp.go
@@ -94,6 +94,8 @@ func (c *fastHTTPContext) BodyBytes() ([]byte, error) {
 }
 
 func (c *fastHTTPContext) BodyLength() int {
+	c.lock.Lock()
+	defer c.lock.Unlock()
 	return len(c.req.Request.Body())
 }
 

diff --git a/internal/pkg/service/stream/source/type/httpsource/httpsource_test.go b/internal/pkg/service/stream/source/type/httpsource/httpsource_test.go
@@ -542,7 +542,7 @@ func testCases(t *testing.T, ts *testState) []TestCase {
 		//  "statusCode": 413,
 		//  "error": "stream.in.bodyTooLarge",
 		//  "message": "Request body size is over the maximum \"8000B\"."
-		//}`,
+		// }`,
 		//		},
 		{
 			Name: "stream input - POST - disable sink",