redismap with tests

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

@@ -0,0 +1,138 @@
+package org.redis;
+
+import redis.clients.jedis.JedisPool;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class RedisMap implements Map<String, String> {
+    private final JedisPool jedisPool;
+    private final String namespace;
+
+    public RedisMap(JedisPool jedisPool, String namespace) {
+        this.jedisPool = jedisPool;
+        this.namespace = namespace;
+    }
+
+    @Override
+    public int size() {
+        try (var jedis = jedisPool.getResource()) {
+            return jedis.keys(builtRedisKey("*")).size();
+        }
+    }
+
+    @Override
+    public boolean isEmpty() {
+        return size() == 0;
+    }
+
+    @Override
+    public boolean containsKey(Object key) {
+        try (var jedis = jedisPool.getResource()) {
+            return jedis.get(builtRedisKey(key)) != null;
+        }
+    }
+
+    @Override
+    public boolean containsValue(Object value) {
+        try (var jedis = jedisPool.getResource()) {
+            for (var key : jedis.keys(builtRedisKey("*"))) {
+                if (Objects.equals(jedis.get(key), value)) {
+                    return true;
+                }
+            }
+            return false;
+        }
+    }
+
+    @Override
+    public String get(Object key) {
+        try (var jedis = jedisPool.getResource()) {
+            return jedis.get(builtRedisKey(key));
+        }
+    }
+
+    @Override
+    public String put(String key, String value) {
+        try (var jedis = jedisPool.getResource()) {
+            var rKey = builtRedisKey(key);
+            var oldValue = jedis.get(rKey);
+            jedis.set(rKey, value);
+            return oldValue;
+        }
+    }
+
+    @Override
+    public String remove(Object key) {
+        try (var jedis = jedisPool.getResource()) {
+            var rKey = builtRedisKey(key);
+            var oldValue = jedis.get(rKey);
+            jedis.del(rKey);
+            return oldValue;
+        }
+    }
+
+    @Override
+    public void putAll(Map<? extends String, ? extends String> m) {
+        try (var jedis = jedisPool.getResource()) {
+            for (var entry : m.entrySet()) {
+                jedis.set(builtRedisKey(entry.getKey()), entry.getValue());
+            }
+        }
+    }
+
+    @Override
+    public void clear() {
+        try (var jedis = jedisPool.getResource()) {
+            var keySet = jedis.keys(builtRedisKey("*"));
+            if (keySet.isEmpty()) return;
+            String[] keys = keySet.toArray(new String[0]);
+            jedis.del(keys);
+        }
+    }
+
+    @Override
+    public Set<String> keySet() {
+        try (var jedis = jedisPool.getResource()) {
+            var keysWithNamespace = jedis.keys(builtRedisKey("*"));
+            return keysWithNamespace.stream()
+                    .map(rKey -> extractKey(rKey))
+                    .collect(Collectors.toSet());
+        }
+    }
+
+    @Override
+    public Collection<String> values() {
+        try (var jedis = jedisPool.getResource()) {
+            List<String> valiesList = new ArrayList<>();
+            for (var key : jedis.keys(builtRedisKey("*"))) {
+                valiesList.add(jedis.get(key));
+            }
+            return valiesList;
+        }
+    }
+
+    @Override
+    public Set<Entry<String, String>> entrySet() {
+        try (var jedis = jedisPool.getResource()) {
+            var entrySet = new HashSet<Entry<String, String>>();
+
+            var keySet = jedis.keys(builtRedisKey("*"));
+            for (var rKey : keySet) {
+                var value = jedis.get(rKey);
+
+                var key = extractKey(rKey);
+                entrySet.add(new AbstractMap.SimpleEntry<>(key, value));
+            }
+            return entrySet;
+        }
+    }
+
+    private String builtRedisKey(Object key) {
+        return namespace + ":" + key;
+    }
+
+    private String extractKey(String rKey) {
+        return rKey.substring(namespace.length() + 1);
+    }
+}