From bdfcf0a2bfdb58f465f19c27971b9381298f146b Mon Sep 17 00:00:00 2001
From: Yann Stepienik <azukaar@gmail.com>
Date: Wed, 1 Nov 2023 21:17:16 +0000
Subject: [PATCH] [release] v0.12.0-unstable31

---
 package.json              |  2 +-
 src/metrics/middleware.go | 82 +++++++++++++++++++--------------------
 2 files changed, 42 insertions(+), 42 deletions(-)

diff --git a/package.json b/package.json
index fa64c40..58a5fd4 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "cosmos-server",
-  "version": "0.12.0-unstable30",
+  "version": "0.12.0-unstable31",
   "description": "",
   "main": "test-server.js",
   "bugs": {
diff --git a/src/metrics/middleware.go b/src/metrics/middleware.go
index 7ea3179..edb3105 100644
--- a/src/metrics/middleware.go
+++ b/src/metrics/middleware.go
@@ -9,15 +9,15 @@ import (
 )
 
 // responseWriter wraps the original http.ResponseWriter to capture the status code.
-type responseWriter struct {
-	http.ResponseWriter
-	status int
-}
+// type responseWriter struct {
+// 	http.ResponseWriter
+// 	status int
+// }
 
-func (rw *responseWriter) WriteHeader(status int) {
-	rw.status = status
-	rw.ResponseWriter.WriteHeader(status)
-}
+// func (rw *responseWriter) WriteHeader(status int) {
+// 	rw.status = status
+// 	rw.ResponseWriter.WriteHeader(status)
+// }
 
 func MetricsMiddleware(route utils.ProxyRouteConfig) func(next http.Handler) http.Handler {
 	return func(next http.Handler) http.Handler {
@@ -25,9 +25,9 @@ func MetricsMiddleware(route utils.ProxyRouteConfig) func(next http.Handler) htt
 		startTime := time.Now()
 
 		// Call the next handler (which can be another middleware or the final handler).
-		wrappedWriter := &responseWriter{ResponseWriter: w}
+		// wrappedWriter := &responseWriter{ResponseWriter: w}
 
-		next.ServeHTTP(wrappedWriter, r)
+		next.ServeHTTP(w, r)
 
 		// Calculate and log the response time.
 		responseTime := time.Since(startTime)
@@ -36,37 +36,37 @@ func MetricsMiddleware(route utils.ProxyRouteConfig) func(next http.Handler) htt
 
 		if !utils.GetMainConfig().MonitoringDisabled {
 			go func() {
-				if wrappedWriter.status >= 400 {
-					PushSetMetric("proxy.all.error", 1, DataDef{
-						Max: 0,
-						Period: time.Second * 30,
-						Label: "Global Request Errors",
-						AggloType: "sum",
-						SetOperation: "sum",
-					})
-					PushSetMetric("proxy.route.error."+route.Name, 1, DataDef{
-						Max: 0,
-						Period: time.Second * 30,
-						Label: "Request Errors " + route.Name,
-						AggloType: "sum",
-						SetOperation: "sum",
-					})
-				} else {
-					PushSetMetric("proxy.all.success", 1, DataDef{
-						Max: 0,
-						Period: time.Second * 30,
-						Label: "Global Request Success",
-						AggloType: "sum",
-						SetOperation: "sum",
-					})
-					PushSetMetric("proxy.route.success."+route.Name, 1, DataDef{
-						Max: 0,
-						Period: time.Second * 30,
-						Label: "Request Success " + route.Name,
-						AggloType: "sum",
-						SetOperation: "sum",
-					})
-				}
+				// if wrappedWriter.status >= 400 {
+				// 	PushSetMetric("proxy.all.error", 1, DataDef{
+				// 		Max: 0,
+				// 		Period: time.Second * 30,
+				// 		Label: "Global Request Errors",
+				// 		AggloType: "sum",
+				// 		SetOperation: "sum",
+				// 	})
+				// 	PushSetMetric("proxy.route.error."+route.Name, 1, DataDef{
+				// 		Max: 0,
+				// 		Period: time.Second * 30,
+				// 		Label: "Request Errors " + route.Name,
+				// 		AggloType: "sum",
+				// 		SetOperation: "sum",
+				// 	})
+				// } else {
+				// 	PushSetMetric("proxy.all.success", 1, DataDef{
+				// 		Max: 0,
+				// 		Period: time.Second * 30,
+				// 		Label: "Global Request Success",
+				// 		AggloType: "sum",
+				// 		SetOperation: "sum",
+				// 	})
+				// 	PushSetMetric("proxy.route.success."+route.Name, 1, DataDef{
+				// 		Max: 0,
+				// 		Period: time.Second * 30,
+				// 		Label: "Request Success " + route.Name,
+				// 		AggloType: "sum",
+				// 		SetOperation: "sum",
+				// 	})
+				// }
 
 				PushSetMetric("proxy.all.time", int(responseTime.Milliseconds()), DataDef{
 					Max: 0,