[minor] binary pack buffers

lib/redis.js

@@ -1,6 +1,7 @@
 'use strict';
 
-var fuse = require('fusing');
+var fuse = require('fusing')
+  , binary = require('binarypack');
 
 /**
  * Setup Redis persistence layer via node-redis.
@@ -66,7 +67,10 @@ Redis.readable('api', function api(dynamis) {
    */
   dynamis.api('get', function get(key, done) {
     dynamis.execute(redis.database, redis.database.get, key, function complete(error, value) {
-      try { value = JSON.parse(value); } catch (err) { error = error || err; }
+      try {
+        if (Buffer.isBuffer(value)) value = binary.unpack(value);
+        else value = JSON.parse(value);
+      } catch (err) { error = error || err; }
       done(error, value);
     });
   });
@@ -86,7 +90,11 @@ Redis.readable('api', function api(dynamis) {
       ttl = null;
     }
 
-    try { value = JSON.stringify(value); } catch (error) { return done(error); }
+    try {
+      if (Buffer.isBuffer(value)) value = binary.pack(value);
+      else value = JSON.stringify(value);
+    } catch (error) { return done(error); }
+
     if (!ttl) return dynamis.execute(redis.database, redis.database.set, key, value, done);
     dynamis.execute(redis.database, redis.database.setex, key, ttl, value, done);
   });

test/common.js

@@ -21,7 +21,7 @@ exports.redis = function () {
 
 exports.levelup = function () {
   return require('levelup')('/tmp/test');
-}
+};
 
 exports.cradle = function () {
   return new require('cradle').Connection;

test/lib/redis.test.js

@@ -2,6 +2,7 @@ describe('Redis persistence layer', function () {
   'use strict';
 
   var common = require('../common')
+    , binary = require('binarypack')
     , expect = common.expect
     , sinon = common.sinon
     , Dynamis = common.Dynamis
@@ -132,6 +133,26 @@ describe('Redis persistence layer', function () {
         done();
       });
     });
+
+    it('will binary-pack buffers', function (done) {
+      var data = new Buffer('test');
+
+      redis = require('redis').createClient({ return_buffers: true });
+      dynamis = new Dynamis('redis', redis, { database: 10 });
+      persist = new Persist(dynamis, redis);
+
+      dynamis.set(key, data, function (error, result) {
+        expect(error).to.equal(null);
+        expect(result.toString()).to.equal('OK');
+
+        redis.get(key, function  (error, result) {
+          expect(error).to.equal(null);
+          expect(binary.unpack(result).length).to.equal(data.length);
+          expect(binary.unpack(result).toString()).to.equal(data.toString());
+          done();
+        });
+      });
+    });
   });
 
   describe('#get', function () {