Tests: incr and fix output

src/commands/incr.rs

@@ -16,7 +16,7 @@ impl Executable for Incr {
     fn exec(self, store: Store) -> Result<Frame, Error> {
         let res = store.incr_by(&self.key, 1);
         match res {
-            Ok(_) => Ok(Frame::Simple("OK".to_string())),
+            Ok(val) => Ok(Frame::Integer(val)),
             Err(msg) => Ok(Frame::Error(msg.to_string())),
         }
     }
@@ -60,7 +60,7 @@ mod tests {
 
         let result = cmd.exec(store.clone()).unwrap();
 
-        assert_eq!(result, Frame::Simple("OK".to_string()));
+        assert_eq!(result, Frame::Integer(2));
         assert_eq!(store.lock().get("key1"), Some(Bytes::from("2")));
     }
 
@@ -83,7 +83,7 @@ mod tests {
 
         let result = cmd.exec(store.clone()).unwrap();
 
-        assert_eq!(result, Frame::Simple("OK".to_string()));
+        assert_eq!(result, Frame::Integer(1));
         assert_eq!(store.lock().get("key1"), Some(Bytes::from("1")));
     }
 

tests/integration.rs

@@ -36,6 +36,14 @@ where
         .await
         .unwrap();
 
+    // Since we use the same Redis instance for all tests, we flush it to start fresh.
+    // NOTE: our implementation doesn't yet persist data between runs.
+    let _: Value = redis::pipe()
+        .cmd("FLUSHDB")
+        .query_async(&mut their_connection)
+        .await
+        .unwrap();
+
     let their_response: Res = pipeline
         .clone()
         .query_async(&mut their_connection)
@@ -114,3 +122,20 @@ async fn test_exists() {
     })
     .await;
 }
+
+#[tokio::test]
+async fn test_incr() {
+    type Response = (Value, Value, Value, Value, Value, Value, Value);
+
+    test_compare::<Response>(|p| {
+        p.cmd("SET").arg("incr_key_1").arg(1);
+        p.cmd("SET").arg("incr_key_2").arg(1);
+        p.cmd("SET").arg("incr_key_3").arg("1");
+
+        p.cmd("INCR").arg("incr_key_1");
+        p.cmd("INCR").arg("incr_key_2");
+        p.cmd("INCR").arg("incr_key_3");
+        p.cmd("INCR").arg("incr_key_4");
+    })
+    .await;
+}