Added RedisMap class to use with jeids and tests

pom.xml

@@ -9,8 +9,8 @@
     <version>1.0-SNAPSHOT</version>
 
     <properties>
-        <maven.compiler.source>17</maven.compiler.source>
-        <maven.compiler.target>17</maven.compiler.target>
+        <maven.compiler.source>21</maven.compiler.source>
+        <maven.compiler.target>21</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
@@ -20,6 +20,18 @@
             <artifactId>jedis</artifactId>
             <version>5.1.5</version>
         </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.36</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>testcontainers</artifactId>
+            <version>1.20.0</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter</artifactId>

src/main/java/org/redis/Main.java

@@ -1,7 +1,8 @@
 package org.redis;
 
+import org.redis.model.RedisMap;
+
 public class Main {
     public static void main(String[] args) {
-        System.out.println("Hello world!");
     }
 }

src/main/java/org/redis/model/RedisMap.java

@@ -0,0 +1,146 @@
+package org.redis.model;
+
+import com.google.gson.Gson;
+import java.util.Collection;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+import redis.clients.jedis.Jedis;
+
+public class RedisMap<K, V> implements Map<K, V> {
+
+  final Gson gson = new Gson();
+  final Jedis jedis;
+  final String redisKey;
+  private final Class<V> valueClass;
+  private final Class<K> keyClass;
+
+  public RedisMap(Jedis jedis, String redisKey, Class<K> keyClass, Class<V> valueClass) {
+    this.jedis = jedis;
+    this.redisKey = redisKey;
+    this.keyClass = keyClass;
+    if (!jedis.isConnected()) {
+      jedis.connect();
+    }
+    this.valueClass = valueClass;
+  }
+
+  public RedisMap(String address, int port, String password, String redisKey,
+      Class<K> keyClass, Class<V> valueClass) {
+    this.redisKey = redisKey;
+    this.valueClass = valueClass;
+    this.keyClass = keyClass;
+    jedis = new Jedis(address, port);
+    jedis.auth(password);
+    jedis.connect();
+  }
+
+  public RedisMap(String address, int port, String redisKey, Class<K> keyClass,
+      Class<V> valueClass) {
+    this.redisKey = redisKey;
+    this.valueClass = valueClass;
+    this.keyClass = keyClass;
+    jedis = new Jedis(address, port);
+    jedis.connect();
+  }
+
+  @Override
+  public int size() {
+    return Math.toIntExact(jedis.hlen(redisKey));
+  }
+
+  @Override
+  public boolean isEmpty() {
+    return jedis.hlen(redisKey) == 0;
+  }
+
+  @Override
+  public boolean containsKey(Object key) {
+    return jedis.hexists(redisKey, serialize(key));
+  }
+
+  private String serialize(Object obj) {
+    if (obj instanceof String) {
+      return obj.toString();
+    }
+
+    return gson.toJson(obj);
+  }
+
+  private <R> R deserialize(String v, Class<R> clazz) {
+    if (clazz.equals(String.class)){
+      return (R) v;
+    }
+
+    return gson.fromJson(v, clazz);
+  }
+
+  @Override
+  public boolean containsValue(Object value) {
+    if (value == null) {
+      return false;
+    }
+
+    return jedis.hgetAll(redisKey).containsValue(serialize(value));
+  }
+
+  @Override
+  public V get(Object key) {
+    String jsonValue = jedis.hget(redisKey, serialize(key));
+    return deserialize(jsonValue, valueClass);
+  }
+
+  @Override
+  public V put(K key, V value) {
+    V previousVal = get(key);
+    jedis.hset(redisKey, serialize(key), serialize(value));
+    return previousVal;
+  }
+
+  @Override
+  public V remove(Object key) {
+    V value = get(key);
+    jedis.hdel(redisKey, serialize(key));
+    return value;
+  }
+
+  @Override
+  public void putAll(Map<? extends K, ? extends V> m) {
+    Map<String, String> map = m.entrySet().stream()
+        .collect(Collectors.toMap(entry -> serialize(entry.getKey()),
+            entry -> serialize(entry.getValue())));
+    jedis.hset(redisKey, map);
+  }
+
+  @Override
+  public void clear() {
+    jedis.del(redisKey);
+  }
+
+  @Override
+  public Set<K> keySet() {
+    return jedis.hgetAll(redisKey)
+        .keySet().stream()
+        .map(elem -> deserialize(elem, keyClass))
+        .collect(Collectors.toSet());
+  }
+
+  @Override
+  public Collection<V> values() {
+    return jedis.hgetAll(redisKey)
+        .values().stream()
+        .map(value -> deserialize(value, valueClass))
+        .toList();
+  }
+
+  @Override
+  public Set<Entry<K, V>> entrySet() {
+    return jedis.hgetAll(redisKey)
+        .entrySet().stream()
+        .collect(
+            Collectors.toMap(
+                entry -> deserialize(entry.getKey(), keyClass),
+                entry -> deserialize(entry.getValue(), valueClass)))
+        .entrySet();
+  }
+}