Add zookeeper sync api call

Author: zimski

lib/client.js

@@ -602,7 +602,25 @@ ZKClient.prototype.unlink = function unlink(p, options, callback) {
         });
 };
 
+ZKClient.prototype.sync = function get(p, callback) {
+        assertString('path', p);
+        assertFunction('callback', callback);
+
+        var log = this.log;
+        var zk = this.zk;
+
+        log.trace({path: p}, 'sync: entered');
+        zk.a_sync(path.normalize(p), function (rc, msg) {
+                if (rc !== 0) {
+                        var err = new ZKError(rc, msg);
+                        log.trace({path: p, err: err}, 'sync: error');
+                        return (callback(err));
+                }
 
+                log.trace({path: p}, 'sync: done');
+                return (callback(err));
+        });
+};
 ZKClient.prototype.update = function update(p, object, options, callback) {
         assertString('path', p);
         assertObject('object', object);

package.json

@@ -9,7 +9,7 @@
                 "bunyan": "0.11.0",
                 "node-uuid": "1.3.3",
                 "vasync": "1.3.1",
-                "zookeeper": "git://github.com/mcavage/node-zookeeper.git#8a28f8c"
+                "zookeeper": "git://github.com/fasterize/node-zookeeper.git#9cd98a4217d0e8386d08a465c7818af9935e1d03"
         },
         "devDependencies": {
                 "cover": "0.2.8",

test/client.test.js

@@ -174,6 +174,21 @@ test('update', function (t) {
         });
 });
 
+test('sync', function (t) {
+        ZK.create(FILE, function (err) {
+                t.ifError(err);
+                var obj = {
+                        hello: 'world'
+                };
+                ZK.sync(FILE, function (err2) {
+                        t.ifError(err2);
+                        ZK.get(FILE, function (err3, obj2) {
+                                t.ifError(err3);
+                                t.end();
+                        });
+                });
+        });
+});
 
 test('unlink', function (t) {
         ZK.create(FILE, function (err) {