add del and set by path

Author: gkorland

Cargo.lock

@@ -10,5 +10,5 @@ crate-type = ["cdylib"]
 [dependencies]
 serde_json = "1.0"
 libc = "0.2"
-jsonpath_lib = "0.2.0"
-redismodule = { path = "redismodule-rs", version = "0.1.0" }
+jsonpath_lib = "0.2.3"
+redismodule = { path = "redismodule-rs", version = "0.1.0" }

Cargo.toml

@@ -16,11 +16,25 @@ pub enum SetOptions {
     AlreadyExists,
 }
 
+fn json_del(ctx: &Context, args: Vec<String>) -> RedisResult {
+    let mut args = args.into_iter().skip(1);
+
+    let key = args.next_string()?;
+    let path = args.next_string()?;
+
+    let key = ctx.open_key_writable(&key);
+    let deleted : usize = match key.get_value::<RedisJSON>(&REDIS_JSON_TYPE)? {
+        Some(doc) => doc.delete_path(&path)?,
+        None => 0
+    };
+    Ok(deleted.into())
+}
+
 fn json_set(ctx: &Context, args: Vec<String>) -> RedisResult {
     let mut args = args.into_iter().skip(1);
 
     let key = args.next_string()?;
-    let _path = args.next_string()?; // TODO handle this path
+    let path = args.next_string()?;
     let value = args.next_string()?;
 
     let set_option = args.next()
@@ -39,7 +53,7 @@ fn json_set(ctx: &Context, args: Vec<String>) -> RedisResult {
     match (current, set_option) {
         (Some(_), Some(SetOptions::NotExists)) => Ok(().into()),
         (Some(ref mut doc), _) => {
-            doc.set_value(&value)?;
+            doc.set_value(&value, &path)?;
             REDIS_OK
         }
         (None, Some(SetOptions::AlreadyExists)) => Ok(().into()),
@@ -117,8 +131,6 @@ fn json_mget(ctx: &Context, args: Vec<String>) -> RedisResult {
     } else {
         Err(RedisError::WrongArity)
     }
-
-
 }
 
 
@@ -162,6 +174,7 @@ redis_module! {
     ],
     commands: [
         ["json.set", json_set, "write"],
+        ["json.del", json_del, "write"],
         ["json.get", json_get, ""],
         ["json.mget", json_mget, ""],
         ["json.strlen", json_strlen, ""],

src/lib.rs

@@ -43,28 +43,35 @@ pub struct RedisJSON {
 
 impl RedisJSON {
     pub fn from_str(data: &str) -> Result<Self, Error> {
-        eprintln!("Parsing JSON from input '{}'", data);
-
         // Parse the string of data into serde_json::Value.
         let v: Value = serde_json::from_str(data)?;
 
         Ok(Self { data: v })
     }
 
-    pub fn set_value(&mut self, data: &str) -> Result<(), Error> {
-        eprintln!("Parsing JSON from input '{}'", data);
-
+    pub fn set_value(&mut self, data: &str, path: &str) -> Result<(), Error> {
         // Parse the string of data into serde_json::Value.
-        let v: Value = serde_json::from_str(data)?;
+        let json: Value = serde_json::from_str(data)?;
 
+        let v = jsonpath_lib::replace_with(self.data.clone(), path, &mut |_v| {
+            json.clone()
+        })?;
         self.data = v;
 
         Ok(())
     }
 
-    pub fn to_string(&self, path: &str) -> Result<String, Error> {
-        eprintln!("Serializing back to JSON");
+    pub fn delete_path(&mut self, path: &str) -> Result<usize, Error> {
+        self.data = jsonpath_lib::delete(self.data.clone(), path)?;
 
+        let res : usize = match self.data {
+            Value::Null => 0,
+            _ => 1
+        };
+        Ok(res)
+    }
+
+    pub fn to_string(&self, path: &str) -> Result<String, Error> {
         let results = self.get_doc(path)?;
         Ok(serde_json::to_string(&results)?)
     }