CR's fixes

clients/cache/cache.go

@@ -12,4 +12,5 @@ type Cache interface {
 	Set(ctx context.Context, key string, data []byte, expiration time.Duration) error
 	Get(ctx context.Context, key string) ([]byte, error)
 	Delete(ctx context.Context, key string) error
+	Healthcheck(ctx context.Context) error
 }

clients/cache/inmemory.go

@@ -95,3 +95,7 @@ func (c *InMemoryCache) Delete(ctx context.Context, key string) error {
 	delete(c.data, key)
 	return nil
 }
+
+func (c *InMemoryCache) Healthcheck(ctx context.Context) error {
+	return nil
+}

clients/cache/redis.go

@@ -2,6 +2,7 @@ package cache
 
 import (
 	"context"
+	"fmt"
 	"time"
 
 	"github.com/kava-labs/kava-proxy-service/logging"
@@ -68,3 +69,13 @@ func (rc *RedisCache) Get(
 func (rc *RedisCache) Delete(ctx context.Context, key string) error {
 	return rc.client.Del(ctx, key).Err()
 }
+
+func (rc *RedisCache) Healthcheck(ctx context.Context) error {
+	// Check if we can connect to Redis
+	_, err := rc.client.Ping(ctx).Result()
+	if err != nil {
+		return fmt.Errorf("error connecting to Redis: %v", err)
+	}
+
+	return nil
+}

service/cachemdw/cache.go

@@ -111,3 +111,7 @@ func (c *ServiceCache) ValidateAndCacheQueryResponse(
 
 	return nil
 }
+
+func (c *ServiceCache) Healthcheck(ctx context.Context) error {
+	return c.cacheClient.Healthcheck(ctx)
+}

service/handlers.go

@@ -1,6 +1,7 @@
 package service
 
 import (
+	"context"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -20,12 +21,17 @@ func createHealthcheckHandler(service *ProxyService) func(http.ResponseWriter, *
 
 		// check that the database is reachable
 		err := service.Database.HealthCheck()
-
 		if err != nil {
 			errMsg := fmt.Errorf("proxy service unable to connect to database")
 			combinedErrors = errors.Join(combinedErrors, errMsg)
 		}
 
+		err = service.Cache.Healthcheck(context.Background())
+		if err != nil {
+			errMsg := fmt.Errorf("proxy service unable to connect to cache")
+			combinedErrors = errors.Join(combinedErrors, errMsg)
+		}
+
 		if combinedErrors != nil {
 			w.WriteHeader(http.StatusInternalServerError)