Finish challenge redislabs-training#6

quinluong · Feb 7, 2023 · f0187cf · f0187cf
1 parent f1f6292
commit f0187cf
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/src/main/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImpl.java b/src/main/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImpl.java
@@ -23,6 +23,18 @@ public FeedDaoRedisImpl(JedisPool jedisPool) {
     public void insert(MeterReading meterReading) {
         // START Challenge #6
         // END Challenge #6
+
+        String globalFeedKey = RedisSchema.getGlobalFeedKey();
+        String feedKey = RedisSchema.getFeedKey(meterReading.getSiteId());
+
+        try (Jedis jedis = jedisPool.getResource()) {
+            Pipeline pipelined = jedis.pipelined();
+
+            pipelined.xadd(globalFeedKey, StreamEntryID.NEW_ENTRY, meterReading.toMap());
+            pipelined.xadd(feedKey, StreamEntryID.NEW_ENTRY, meterReading.toMap());
+
+            pipelined.sync();
+        }
     }
 
     @Override

diff --git a/src/test/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImplTest.java b/src/test/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImplTest.java
@@ -53,7 +53,7 @@ public void flush() {
     }
 
     // Challenge #6
-    @Ignore
+//    @Ignore
     @Test
     public void testBasicInsertReturnsRecent() {
         FeedDao dao = new FeedDaoRedisImpl(jedisPool);