eric/onix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: req preprocessor

Browse Source
This commit is contained in:
mayur.popli
2025-03-20 09:07:43 +05:30
parent aa10fcceaf
commit 5e3422fb24
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
shared/plugin/implementation/requestPreProcessor/reqpreprocessor_test.go
View File

@@ -24,8 +24,8 @@ func TestNewUUIDSetter(t *testing.T) {
}, },
requestBody: map[string]any{ requestBody: map[string]any{
"context": map[string]any{ "context": map[string]any{
"transaction_id": "", "transaction_id": "",
"message_id": nil, "message_id": nil,
}, },
}, },
expectedCode: http.StatusOK, expectedCode: http.StatusOK,
@@ -38,8 +38,8 @@ func TestNewUUIDSetter(t *testing.T) {
}, },
requestBody: map[string]any{ requestBody: map[string]any{
"context": map[string]any{ "context": map[string]any{
"transaction_id": "existing-transaction", "transaction_id": "existing-transaction",
"message_id": "existing-message", "message_id": "existing-message",
}, },
}, },
expectedCode: http.StatusOK, expectedCode: http.StatusOK,
@@ -107,7 +107,10 @@ func TestNewUUIDSetter(t *testing.T) {
// Define a dummy handler // Define a dummy handler
dummyHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { dummyHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusOK) w.WriteHeader(http.StatusOK)
io.Copy(w, r.Body) if _, err := io.Copy(w, r.Body); err != nil {
http.Error(w, "Failed to copy request body", http.StatusInternalServerError)
return
}
}) })
// Apply middleware // Apply middleware