From c97e50f058648d40f9421dca4704197e366962e3 Mon Sep 17 00:00:00 2001
From: Mehdi Hasan <mhasan@omicronlab.com>
Date: Fri, 4 Oct 2019 15:01:40 +0600
Subject: [PATCH] Cleanup redis after each test-suit

---
 __tests__/01_producer.js         | 1 +
 __tests__/02_consumer_cleanup.js | 2 ++
 __tests__/03_consumer_unit.js    | 1 +
 3 files changed, 4 insertions(+)

diff --git a/__tests__/01_producer.js b/__tests__/01_producer.js
index dce9d68..d7cf542 100644
--- a/__tests__/01_producer.js
+++ b/__tests__/01_producer.js
@@ -15,6 +15,7 @@ describe('Producer', () => {
 
   afterAll(async () => {
     await producer._disconnect();
+    await redis.flushall();
     await redis.disconnect();
   });
 
diff --git a/__tests__/02_consumer_cleanup.js b/__tests__/02_consumer_cleanup.js
index 810aea9..389b681 100644
--- a/__tests__/02_consumer_cleanup.js
+++ b/__tests__/02_consumer_cleanup.js
@@ -24,6 +24,8 @@ describe('Consumer Unit - Cleanup', () => {
     for (const consumer of consumers) {
       await consumer._disconnect();
     }
+
+    await redis.flushall();
     await redis.disconnect();
   });
 
diff --git a/__tests__/03_consumer_unit.js b/__tests__/03_consumer_unit.js
index 0f4bf7d..b87096c 100644
--- a/__tests__/03_consumer_unit.js
+++ b/__tests__/03_consumer_unit.js
@@ -25,6 +25,7 @@ describe('Consumer Unit', () => {
     for (const consumer of consumers) {
       await consumer._disconnect();
     }
+    await redis.flushall();
     await redis.disconnect();
   });