From ba353dea2a8621d39b9f65b210c640d92a91b955 Mon Sep 17 00:00:00 2001 From: Nirmit Jain Date: Wed, 6 Mar 2024 20:11:34 +0530 Subject: [PATCH] DE-1 | Removed msg generation for blacklisted event --- server/handlers.go | 20 +++++++++----------- 1 file changed, 9 insertions(+), 11 deletions(-) diff --git a/server/handlers.go b/server/handlers.go index 71f05f4..79f3098 100644 --- a/server/handlers.go +++ b/server/handlers.go @@ -41,6 +41,15 @@ func eventsHandlerJson(w http.ResponseWriter, r *http.Request) { headerName := "X-Correlation-Id" substring := "abcdabcd-1234" headerValue, ok := r.Header[headerName] + if ok { + if strings.HasPrefix(headerValue[0], substring) { + w.Header().Set("Content-Type", "application/json") + var rsp = CustomResponse{Code: 200, Message: "OK"} + json.NewEncoder(w).Encode(rsp) + fmt.Println("Dropped blacklisted request") + return + } + } var reader io.Reader // check if body is gzip compressed @@ -67,17 +76,6 @@ func eventsHandlerJson(w http.ResponseWriter, r *http.Request) { return } - if ok { - if strings.HasPrefix(headerValue[0], substring) { - w.Header().Set("Content-Type", "application/json") - lib.JsonRequestChannel <- &lib.RequestObject{Body: body, Header: r.Header} - var rsp = CustomResponse{Code: 200, Message: "OK"} - json.NewEncoder(w).Encode(rsp) - fmt.Println("Dropped blacklisted request") - return - } - } - w.Header().Set("Content-Type", "application/json") lib.JsonRequestChannel <- &lib.RequestObject{Body: body, Header: r.Header} var rsp = CustomResponse{Code: 200, Message: "OK"}