Add tests

service/cachemdw/middleware_test.go

@@ -15,7 +15,7 @@ import (
 	"github.com/kava-labs/kava-proxy-service/service"
 )
 
-func TestServiceCacheMiddleware(t *testing.T) {
+func TestE2ETestServiceCacheMiddleware(t *testing.T) {
 	logger, err := logging.New("TRACE")
 	require.NoError(t, err)
 
@@ -68,6 +68,33 @@ func TestServiceCacheMiddleware(t *testing.T) {
 	})
 }
 
+func TestE2ETestServiceCacheMiddlewareInvalidRequestBody(t *testing.T) {
+	logger, err := logging.New("TRACE")
+	require.NoError(t, err)
+
+	inMemoryCache := cache.NewInMemoryCache()
+	evmClient := NewMockEVMClient()
+	cacheTTL := time.Duration(0) // TTL: no expiry
+
+	serviceCache := NewServiceCache(inMemoryCache, evmClient, cacheTTL, service.DecodedRequestContextKey, &logger)
+
+	req, err := http.NewRequest(http.MethodPost, "/test", nil)
+	require.NoError(t, err)
+	req = req.WithContext(context.WithValue(req.Context(), service.DecodedRequestContextKey, "invalid"))
+
+	recorder := httptest.NewRecorder()
+	handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.WriteHeader(http.StatusOK)
+		w.Write([]byte("test response"))
+	})
+
+	serviceCache.Middleware(handler).ServeHTTP(recorder, req)
+
+	require.Equal(t, http.StatusOK, recorder.Code)
+	require.Equal(t, "test response", recorder.Body.String())
+	require.Empty(t, recorder.Header().Get(CacheHeaderKey))
+}
+
 func createTestHttpRequest(
 	t *testing.T,
 	url string,