Merge pull request #10 from skodjob/redis-flush

Redis flush
skodjob · May 13, 2024 · e628c81 · e628c81
2 parents fa8361e + 9060075
commit e628c81
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 0 deletions.
diff --git a/database-manipulation-tool/README.md b/database-manipulation-tool/README.md
@@ -118,6 +118,11 @@ You can reset all databases on DMT start with property `onstart.reset.database`.
     <code>Sends a message specified in json body to the redis stream channel 
     specified in as header argument</code>
 </summary>
+<summary>
+    <code>GET</code> 
+    <code><b>/Redis/reset</b></code>
+    <code>Flush whole Redis instance</code>
+</summary>
 
 ## Running the application in dev mode
 

diff --git a/database-manipulation-tool/src/main/java/io/skodjob/dmt/resource/RedisResource.java b/database-manipulation-tool/src/main/java/io/skodjob/dmt/resource/RedisResource.java
@@ -72,4 +72,11 @@ public Response pollMessages(@QueryParam("max") Integer max, List<String> channe
         return Response.ok(res).build();
     }
 
+    @Path("reset")
+    @GET
+    public Response resetRedis() {
+        redisService.resetRedis();
+        return Response.ok().build();
+    }
+
 }
diff --git a/database-manipulation-tool/src/main/java/io/skodjob/dmt/service/RedisService.java b/database-manipulation-tool/src/main/java/io/skodjob/dmt/service/RedisService.java
@@ -51,4 +51,8 @@ public String insert(String channel, Map<String, String> message) {
     public List<Map.Entry<String, List<StreamEntry>>> get(int amount, List<String> channels) {
         return redisDataSource.pollMessages(amount, channels);
     }
+
+    public void resetRedis() {
+        redisDataSource.flushRedis();
+    }
 }
diff --git a/database-manipulation-tool/src/main/java/io/skodjob/dmt/sinkSources/RedisDataSource.java b/database-manipulation-tool/src/main/java/io/skodjob/dmt/sinkSources/RedisDataSource.java
@@ -78,4 +78,9 @@ public List<Map.Entry<String, List<StreamEntry>>> pollMessages(int maxAmount, Li
         return jedis.xread(XReadParams.xReadParams().count(maxAmount), streams);
     }
 
+    public void flushRedis() {
+        Jedis jedis = pool.getResource();
+        jedis.flushAll();
+    }
+
 }