Redis handler and heuristic calculator.

client-java/controller/pom.xml

@@ -199,6 +199,11 @@
             <artifactId>mongodb-driver-sync</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>io.lettuce</groupId>
+            <artifactId>lettuce-core</artifactId>
+            <scope>test</scope>
+        </dependency>
 
         <!--gRPC RPC test-->
         <dependency>

client-java/controller/src/main/java/org/evomaster/client/java/controller/SutHandler.java

@@ -181,6 +181,8 @@ default void extractRPCSchema(){}
 
     default Object getOpenSearchConnection() {return null;}
 
+    default Object getRedisConnection() {return null;}
+
     /**
      * <p>
      * register or execute specified SQL script for initializing data in database

client-java/controller/src/main/java/org/evomaster/client/java/controller/internal/db/RedisCommandEvaluation.java

@@ -0,0 +1,13 @@
+package org.evomaster.client.java.controller.internal.db;
+
+import org.evomaster.client.java.instrumentation.RedisCommand;
+
+public class RedisCommandEvaluation {
+    public final RedisCommand redisCommand;
+    public final RedisDistanceWithMetrics redisDistanceWithMetrics;
+
+    public RedisCommandEvaluation(RedisCommand redisCommand, RedisDistanceWithMetrics redisDistanceWithMetrics) {
+        this.redisCommand = redisCommand;
+        this.redisDistanceWithMetrics = redisDistanceWithMetrics;
+    }
+}

client-java/controller/src/main/java/org/evomaster/client/java/controller/internal/db/RedisDistanceWithMetrics.java

@@ -0,0 +1,26 @@
+package org.evomaster.client.java.controller.internal.db;
+
+public class RedisDistanceWithMetrics {
+    public final double redisDistance; // A number between 0 and 1.
+    public final int numberOfEvaluatedKeys;
+
+    public RedisDistanceWithMetrics(double redisDistance, int numberOfEvaluatedKeys) {
+        if(redisDistance < 0){
+            throw new IllegalArgumentException("Distance must be non-negative but value is " + redisDistance);
+        }
+        if(numberOfEvaluatedKeys < 0){
+            throw new IllegalArgumentException("Number of evaluated keys must be non-negative but value is "
+                    + numberOfEvaluatedKeys);
+        }
+        this.redisDistance = redisDistance;
+        this.numberOfEvaluatedKeys = numberOfEvaluatedKeys;
+    }
+
+    public int getNumberOfEvaluatedKeys() {
+        return numberOfEvaluatedKeys;
+    }
+
+    public double getDistance() {
+        return redisDistance;
+    }
+}

client-java/controller/src/main/java/org/evomaster/client/java/controller/internal/db/RedisHandler.java

@@ -0,0 +1,170 @@
+package org.evomaster.client.java.controller.internal.db;
+
+import org.evomaster.client.java.controller.internal.TaintHandlerExecutionTracer;
+import org.evomaster.client.java.controller.redis.RedisClient;
+import org.evomaster.client.java.controller.redis.RedisHeuristicsCalculator;
+import org.evomaster.client.java.controller.redis.RedisInfo;
+import org.evomaster.client.java.instrumentation.RedisCommand;
+import org.evomaster.client.java.utils.SimpleLogger;
+
+import java.util.*;
+
+/**
+ * Class used to act upon Redis commands executed by the SUT
+ */
+public class RedisHandler {
+
+    /**
+     * Info about the executed commands
+     */
+    private final List<RedisCommand> operations;
+
+    /**
+     * The heuristics based on the Redis execution
+     */
+    private final List<RedisCommandEvaluation> evaluatedRedisCommands = new ArrayList<>();
+
+    /**
+     * Whether to calculate heuristics based on execution or not
+     */
+    private volatile boolean calculateHeuristics;
+
+    /**
+     * Whether to use execution's info or not
+     */
+    private volatile boolean extractRedisExecution;
+
+    /**
+     * The client must be created through a connection factory.
+     */
+    private RedisClient redisClient = null;
+
+    private final RedisHeuristicsCalculator calculator = new RedisHeuristicsCalculator(new TaintHandlerExecutionTracer());
+
+
+    public RedisHandler() {
+        operations = new ArrayList<>();
+        extractRedisExecution = true;
+        calculateHeuristics = true;
+    }
+
+    public void reset() {
+        operations.clear();
+        evaluatedRedisCommands.clear();
+    }
+
+    public boolean isCalculateHeuristics() {
+        return calculateHeuristics;
+    }
+
+    public boolean isExtractRedisExecution() {
+        return extractRedisExecution;
+    }
+
+    public void setCalculateHeuristics(boolean calculateHeuristics) {
+        this.calculateHeuristics = calculateHeuristics;
+    }
+
+    public void setExtractRedisExecution(boolean extractRedisExecution) {
+        this.extractRedisExecution = extractRedisExecution;
+    }
+
+    public void handle(RedisCommand info) {
+        if (extractRedisExecution) {
+            operations.add(info);
+        }
+    }
+
+    public List<RedisCommandEvaluation> getEvaluatedRedisCommands() {
+        operations.stream()
+            .filter(command -> command.getType().shouldCalculateHeuristic())
+            .forEach(redisCommand -> {
+                RedisDistanceWithMetrics distanceWithMetrics = computeDistance(redisCommand, redisClient);
+                evaluatedRedisCommands.add(new RedisCommandEvaluation(redisCommand, distanceWithMetrics));
+        });
+        operations.clear();
+
+        return evaluatedRedisCommands;
+    }
+
+    private RedisDistanceWithMetrics computeDistance(RedisCommand redisCommand, RedisClient redisClient) {
+        RedisCommand.RedisCommandType type = redisCommand.getType();
+        try {
+            switch (type) {
+                case KEYS:
+                case EXISTS: {
+                    List<RedisInfo> redisInfo = createRedisInfoForAllKeys(redisClient);
+                    return calculator.computeDistance(redisCommand, redisInfo);
+                }
+
+                case GET: {
+                    List<RedisInfo> redisInfo = createRedisInfoForKeysByType("string", redisClient);
+                    return calculator.computeDistance(redisCommand, redisInfo);
+                }
+
+                case HGET: {
+                    String field = redisCommand.extractArgs().get(1);
+                    List<RedisInfo> redisInfo = createRedisInfoForKeysByField(field, redisClient);
+                    return calculator.computeDistance(redisCommand, redisInfo);
+                }
+
+                case HGETALL: {
+                    List<RedisInfo> redisInfo = createRedisInfoForKeysByType("hash", redisClient);
+                    return calculator.computeDistance(redisCommand, redisInfo);
+                }
+
+                case SMEMBERS: {
+                    List<RedisInfo> redisInfo = createRedisInfoForKeysByType("set", redisClient);
+                    return calculator.computeDistance(redisCommand, redisInfo);
+                }
+
+                case SINTER: {
+                    List<String> keys = redisCommand.extractArgs();
+                    List<RedisInfo> redisInfo = createRedisInfoForIntersection(keys, redisClient);
+                    return calculator.computeDistance(redisCommand, redisInfo);
+                }
+
+                default:
+                    return new RedisDistanceWithMetrics(1d, 0);
+            }
+        } catch (Exception e) {
+            SimpleLogger.warn("Could not compute distance for " + type + ": " + e.getMessage());
+            return new RedisDistanceWithMetrics(1d, 0);
+        }
+    }
+
+    private List<RedisInfo> createRedisInfoForIntersection(List<String> keys, RedisClient redisClient) {
+        List<RedisInfo> redisData = new ArrayList<>();
+        keys.forEach(
+                key -> redisData.add(new RedisInfo(key, redisClient.getType(key), redisClient.getSetMembers(key))
+        ));
+        return redisData;
+    }
+
+    private List<RedisInfo> createRedisInfoForAllKeys(RedisClient redisClient) {
+        Set<String> keys = redisClient.getAllKeys();
+        List<RedisInfo> redisData = new ArrayList<>();
+        keys.forEach(
+                key -> redisData.add(new RedisInfo(key))
+        );
+        return redisData;
+    }
+
+    private List<RedisInfo> createRedisInfoForKeysByType(String type, RedisClient redisClient) {
+        Set<String> keys = redisClient.getKeysByType(type);
+        List<RedisInfo> redisData = new ArrayList<>();
+        keys.forEach(key -> redisData.add(new RedisInfo(key)));
+        return redisData;
+    }
+
+    private List<RedisInfo> createRedisInfoForKeysByField(String field, RedisClient redisClient) {
+        Set<String> keys = redisClient.getKeysByType("hash");
+        List<RedisInfo> redisData = new ArrayList<>();
+        keys.forEach(key -> redisData.add(new RedisInfo(key, redisClient.hashFieldExists(key, field))));
+        return redisData;
+    }
+
+    public void setRedisClient(RedisClient redisClient) {
+        this.redisClient = redisClient;
+    }
+}

client-java/controller/src/main/java/org/evomaster/client/java/controller/redis/RedisClient.java

@@ -0,0 +1,130 @@
+package org.evomaster.client.java.controller.redis;
+
+import java.lang.reflect.Method;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * RedisClient that uses Lettuce dynamically via reflection, avoiding
+ * compile-time dependency on Spring or Lettuce.
+ */
+public class RedisClient {
+
+    private final Object redisClient;      // io.lettuce.core.RedisClient
+    private final Object connection;       // io.lettuce.core.api.StatefulRedisConnection
+    private final Object syncCommands;     // io.lettuce.core.api.sync.RedisCommands
+
+    public RedisClient(String host, int port) {
+        try {
+            Class<?> redisClientClass = Class.forName("io.lettuce.core.RedisClient");
+            Class<?> redisURIClass = Class.forName("io.lettuce.core.RedisURI");
+
+            Method createUri = redisURIClass.getMethod("create", String.class);
+            Object uri = createUri.invoke(null, "redis://" + host + ":" + port);
+
+            Method createClient = redisClientClass.getMethod("create", redisURIClass);
+            this.redisClient = createClient.invoke(null, uri);
+
+            Method connectMethod = redisClientClass.getMethod("connect");
+            this.connection = connectMethod.invoke(redisClient);
+
+            Class<?> statefulConnClass = Class.forName("io.lettuce.core.api.StatefulRedisConnection");
+            Method syncMethod = statefulConnClass.getMethod("sync");
+            this.syncCommands = syncMethod.invoke(connection);
+
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to initialize Lettuce Redis client via reflection", e);
+        }
+    }
+
+    public void close() {
+        try {
+            if (connection != null) {
+                Method close = connection.getClass().getMethod("close");
+                close.invoke(connection);
+            }
+            if (redisClient != null) {
+                Method shutdown = redisClient.getClass().getMethod("shutdown");
+                shutdown.invoke(redisClient);
+            }
+        } catch (Exception ignored) {}
+    }
+
+    /** Equivalent to SET key value */
+    public void setValue(String key, String value) {
+        invoke("set", key, value);
+    }
+
+    /** Equivalent to GET key */
+    public String getValue(String key) {
+        return (String) invoke("get", key);
+    }
+
+    /** Equivalent to KEYS * */
+    public Set<String> getAllKeys() {
+        Object result = invoke("keys", "*");
+        if (result instanceof Collection)
+            return new HashSet<>((Collection<String>) result);
+        return Collections.emptySet();
+    }
+
+    /** Equivalent to TYPE key */
+    public String getType(String key) {
+        Object result = invoke("type", key);
+        return result != null ? result.toString() : null;
+    }
+
+    /** HSET key field value */
+    public void hashSet(String key, String field, String value) {
+        invoke("hset", key, field, value);
+    }
+
+    /** HEXISTS key field */
+    public boolean hashFieldExists(String key, String field) {
+        Object result = invoke("hexists", key, field);
+        return result instanceof Boolean && (Boolean) result;
+    }
+
+    /** SMEMBERS key */
+    public Set<String> getSetMembers(String key) {
+        Object result = invoke("smembers", key);
+        if (result instanceof Collection)
+            return new HashSet<>((Collection<String>) result);
+        return Collections.emptySet();
+    }
+
+    private Object invoke(String methodName, Object... args) {
+        try {
+            Class<?>[] argTypes = Arrays.stream(args)
+                    .map(Object::getClass)
+                    .toArray(Class<?>[]::new);
+
+            Method method = findMethod(syncCommands.getClass(), methodName, argTypes);
+            if (method == null)
+                throw new RuntimeException("Method not found: " + methodName);
+            return method.invoke(syncCommands, args);
+
+        } catch (Exception e) {
+            throw new RuntimeException("Error invoking Redis command: " + methodName, e);
+        }
+    }
+
+    private Method findMethod(Class<?> clazz, String name, Class<?>[] argTypes) {
+        for (Method m : clazz.getMethods()) {
+            if (!m.getName().equals(name)) continue;
+            if (m.getParameterCount() != argTypes.length) continue;
+            return m;
+        }
+        return null;
+    }
+
+    public Set<String> getKeysByType(String expectedType) {
+        return getAllKeys().stream()
+                .filter(k -> expectedType.equalsIgnoreCase(getType(k)))
+                .collect(Collectors.toSet());
+    }
+
+    public void flushAll() {
+        invoke("flushall");
+    }
+}