fix

go/pkg/server/gateway.go

@@ -191,13 +191,11 @@ func (g *Gateway) forwardCheckRequestMiddleware(next http.Handler) http.Handler
 				}
 
 				// Check if the request forward is needed
-				isForwardNeed := false
-				if !dslFound {
-					isForwardNeed = true
-				} else {
+				isForwardNeed := true
+				if dslFound {
 					for _, validation := range dsl.Validations {
 						if validation.ID == id {
-							isForwardNeed = true
+							isForwardNeed = false
 							break
 						}
 					}

go/pkg/slave/manager.go

@@ -1,6 +1,7 @@
 package slave
 
 import (
+	"fmt"
 	"log/slog"
 	"sync"
 
@@ -40,5 +41,5 @@ func (m *SlaveManager) FindSlave(validationId string) (*Slave, error) {
 			}
 		}
 	}
-	return nil, failure.New("slave node that can handle the validation ID is not found")
+	return nil, failure.New(fmt.Sprintf("slave node that can handle the validation ID (%s) is not found", validationId))
 }

go/pkg/store/memory.go

@@ -3,6 +3,7 @@ package store
 import (
 	"bytes"
 	"encoding/json"
+	"strings"
 	"sync"
 
 	"github.com/morikuni/failure/v2"
@@ -23,7 +24,11 @@ func NewMemoryStore(id string) *MemoryStore {
 
 func (s *MemoryStore) Reset() error {
 	s.mu.Lock()
-	s.memory = make(map[string][]byte)
+	for k := range s.memory {
+		if strings.HasPrefix(k, s.id+":") {
+			delete(s.memory, k)
+		}
+	}
 	s.mu.Unlock()
 	return nil
 }

go/pkg/store/redis.go

@@ -20,7 +20,11 @@ func NewRedisStore(id string, redisClient *redis.Client) *RedisStore {
 }
 
 func (s *RedisStore) Reset() error {
-	if err := s.redisClient.FlushDB().Err(); err != nil {
+	keys, _ := s.redisClient.Scan(0, s.id+":*", 0).Val()
+	if len(keys) == 0 {
+		return nil
+	}
+	if err := s.redisClient.Del(keys...).Err(); err != nil {
 		return failure.Translate(err, appError.ErrRedisOperationFailed)
 	}
 	return nil