add part_of_batch column to metrics (#91)

clients/database/migrations/20240415111242_add_proxied_request_metrics_partofbatch_column.up.sql

@@ -0,0 +1,4 @@
+ALTER TABLE
+  IF EXISTS proxied_request_metrics
+ADD
+  part_of_batch boolean NOT NULL DEFAULT false;

clients/database/request_metric.go

@@ -30,6 +30,7 @@ type ProxiedRequestMetric struct {
 	ResponseBackend             string
 	ResponseBackendRoute        string
 	CacheHit                    bool
+	PartOfBatch                 bool
 }
 
 // Save saves the current ProxiedRequestMetric to

service/batchmdw/batchmdw.go

@@ -83,3 +83,10 @@ func CreateBatchProcessingMiddleware(
 		batchProcessor.RequestAndServe(w)
 	}
 }
+
+// IsBatchContext returns true when the passed in context is for a batch EVM request
+func IsBatchContext(ctx context.Context, decodedBatchContextKey string) bool {
+	batch := ctx.Value(decodedBatchContextKey)
+	batchReq, ok := (batch).([]*decode.EVMRPCRequestEnvelope)
+	return ok && len(batchReq) > 0
+}

service/middleware.go

@@ -15,6 +15,7 @@ import (
 	"github.com/kava-labs/kava-proxy-service/config"
 	"github.com/kava-labs/kava-proxy-service/decode"
 	"github.com/kava-labs/kava-proxy-service/logging"
+	"github.com/kava-labs/kava-proxy-service/service/batchmdw"
 	"github.com/kava-labs/kava-proxy-service/service/cachemdw"
 )
 
@@ -486,6 +487,8 @@ func createAfterProxyFinalizer(service *ProxyService, config config.Config) http
 			blockNumber = &rawBlockNumber
 		}
 
+		partOfBatch := batchmdw.IsBatchContext(r.Context(), DecodedBatchRequestContextKey)
+
 		isCached := cachemdw.IsRequestCached(r.Context())
 
 		// create a metric for the request
@@ -502,6 +505,7 @@ func createAfterProxyFinalizer(service *ProxyService, config config.Config) http
 			ResponseBackend:             proxyMetadata.BackendName,
 			ResponseBackendRoute:        proxyMetadata.BackendRoute.String(),
 			CacheHit:                    isCached,
+			PartOfBatch:                 partOfBatch,
 		}
 
 		// save metric to database async