From 7190b146e165fcf1a6ce8402a7224ca7c22337e7 Mon Sep 17 00:00:00 2001 From: Nirmit Jain Date: Wed, 6 Mar 2024 18:34:04 +0530 Subject: [PATCH] DE-1 | Fixed build issue --- server/handlers.go | 22 ++++++++++++---------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/server/handlers.go b/server/handlers.go index bd6c20e..8e0d09c 100644 --- a/server/handlers.go +++ b/server/handlers.go @@ -10,6 +10,7 @@ import ( "io/ioutil" "net/http" "time" + "fmt" ) var ( @@ -39,16 +40,6 @@ 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") - lib.JsonRequestChannel <- &lib.RequestObject{Body: body, Header: r.Header} - var rsp = CustomResponse{Code: 200, Message: "OK"} - json.NewEncoder(w).Encode(rsp) - log.Printf("Dropped blacklisted request") - return - } - } var reader io.Reader // check if body is gzip compressed @@ -74,6 +65,17 @@ func eventsHandlerJson(w http.ResponseWriter, r *http.Request) { metrics.EventHandlerTimeHist.WithLabelValues(JSON, ERROR).Observe(float64(utils.NanosToMillis(time.Now().UnixNano()) - eventHandlerStartTime)) 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}