Challenge redislabs-training#6

Streams for Feeds
Implement `insert()` in `FeedDaoRedisImpl.java`.

src/main/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImpl.java

@@ -3,10 +3,8 @@
 import com.redislabs.university.RU102J.api.MeterReading;
 import redis.clients.jedis.*;
 
-import java.nio.channels.Pipe;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.stream.Collectors;
 
 public class FeedDaoRedisImpl implements FeedDao {
 
@@ -22,9 +20,21 @@ public FeedDaoRedisImpl(JedisPool jedisPool) {
     @Override
     public void insert(MeterReading meterReading) {
         // START Challenge #6
+        try (Jedis jedis = jedisPool.getResource()) {
+            final Pipeline pipelined = jedis.pipelined();
+            pipelined.xadd(RedisSchema.getGlobalFeedKey(), StreamEntryID.NEW_ENTRY, meterReading.toMap(),
+                    globalMaxFeedLength, true);
+            pipelined.xadd(RedisSchema.getFeedKey(meterReading.getSiteId()), StreamEntryID.NEW_ENTRY, meterReading.toMap(),
+                    siteMaxFeedLength, true);
+            pipelined.sync();
+        }
         // END Challenge #6
     }
 
+    private void insertForKey(String globalFeedKey, MeterReading meterReading, Long maxGlobalDays) {
+
+    }
+
     @Override
     public List<MeterReading> getRecentGlobal(int limit) {
         return getRecent(RedisSchema.getGlobalFeedKey(), limit);

src/test/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImplTest.java

@@ -53,7 +53,6 @@ public void flush() {
     }
 
     // Challenge #6
-    @Ignore
     @Test
     public void testBasicInsertReturnsRecent() {
         FeedDao dao = new FeedDaoRedisImpl(jedisPool);