Challenge redislabs-training#6

mate0021 · Mar 20, 2022 · 71204ab · 71204ab
1 parent 667ced2
commit 71204ab
Show file tree

Hide file tree

Showing 2 changed files with 12 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
@@ -5,7 +5,9 @@
 
 import java.nio.channels.Pipe;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 public class FeedDaoRedisImpl implements FeedDao {
@@ -22,6 +24,15 @@ public FeedDaoRedisImpl(JedisPool jedisPool) {
     @Override
     public void insert(MeterReading meterReading) {
         // START Challenge #6
+        String globalKey = RedisSchema.getGlobalFeedKey();
+        String localKey = RedisSchema.getFeedKey(meterReading.getSiteId());
+
+        try (Jedis jedis = jedisPool.getResource()) {
+            final Pipeline p = jedis.pipelined();
+            p.xadd(globalKey, StreamEntryID.NEW_ENTRY, meterReading.toMap(), globalMaxFeedLength, true);
+            p.xadd(localKey, StreamEntryID.NEW_ENTRY, meterReading.toMap(), siteMaxFeedLength, true);
+            p.sync();
+        }
         // END Challenge #6
     }
 

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);