add StringBuffer(Vec<u8>) support for RedisValue (#161)

* add StringBuffer(Vec<u8>) support for RedisValue

src/context/mod.rs

@@ -169,6 +169,15 @@ impl Context {
                 raw::RedisModule_ReplyWithString.unwrap()(self.ctx, s.inner).into()
             },
 
+            Ok(RedisValue::StringBuffer(s)) => unsafe {
+                raw::RedisModule_ReplyWithStringBuffer.unwrap()(
+                    self.ctx,
+                    s.as_ptr() as *const i8,
+                    s.len() as usize,
+                )
+                .into()
+            },
+
             Ok(RedisValue::Array(array)) => {
                 unsafe {
                     // According to the Redis source code this always succeeds,

src/redisvalue.rs

@@ -6,6 +6,7 @@ pub enum RedisValue {
     SimpleString(String),
     BulkString(String),
     BulkRedisString(RedisString),
+    StringBuffer(Vec<u8>),
     Integer(i64),
     Float(f64),
     Array(Vec<RedisValue>),
@@ -49,6 +50,12 @@ impl From<RedisString> for RedisValue {
     }
 }
 
+impl From<Vec<u8>> for RedisValue {
+    fn from(s: Vec<u8>) -> Self {
+        RedisValue::StringBuffer(s)
+    }
+}
+
 impl From<&RedisString> for RedisValue {
     fn from(s: &RedisString) -> Self {
         s.to_owned().into()
@@ -120,6 +127,15 @@ mod tests {
         );
     }
 
+    #[test]
+    fn from_vec() {
+        let v : Vec<u8> = vec![0,3,5,21,255];
+        assert_eq!(
+            RedisValue::from(v),
+            RedisValue::StringBuffer(vec![0,3,5,21,255])
+        );
+    }
+
     #[test]
     fn from_option_none() {
         assert_eq!(RedisValue::from(None::<()>), RedisValue::Null,);