'remove'

@@ -3,6 +3,16 @@
 const _ = require('lodash');
 const zookeeper = require('node-zookeeper-client');
 
+const _createClient = (server) => new Promise((resolve, reject) => {
+    const client = zookeeper.createClient(server);
+
+    client.once('connected', function () {
+        resolve(client);
+    });
+
+    client.connect();
+});
+
 const _exists = (client, path) => new Promise((resolve, reject) => {
     client.exists(path, (err, stat) => {
         if (err) {
@@ -15,22 +25,18 @@ const _exists = (client, path) => new Promise((resolve, reject) => {
 });
 
 const exists = (server, path) => new Promise((resolve, reject) => {
-    const client = zookeeper.createClient(server);
-
-    client.once('connected', function () {
+    return _createClient(server).then(client => {
         _exists(client, path).then(stat => {
             client.close();
             resolve(stat);
         });
+    }).catch(state => {
+        reject(state);
     });
-
-    client.connect();
 });
 
 const creator = (server, path, value, iscover) => new Promise((resolve, reject) => {
-    const client = zookeeper.createClient(server);
-
-    client.once('connected', function () {
+    return _createClient(server).then(client => {
         _exists(client, path).then(stat => {
             if (stat && iscover) {
                 client.setData(path, new Buffer(value.toString()), function(err, data, stat) {
@@ -59,22 +65,20 @@ const creator = (server, path, value, iscover) => new Promise((resolve, reject)
                 });
             }
         });
+    }).catch(state => {
+        reject(state);
     });
-
-    client.connect();
 });
 
 const getter = (server, path) => new Promise((resolve, reject) => {
-    const client = zookeeper.createClient(server);
-
-    client.once('connected', function () {
+    return _createClient(server).then(client => {
         _exists(client, path).then(stat => {
             if (stat) {
                 client.getData(
                     path,
                     (err, data, statData) => {
                         if (err) {
-                            console.log('Got path %s data error', path, err.stack);
+                            console.log('Get path %s data error', path, err.stack);
                         }
 
                         client.close();
@@ -87,16 +91,14 @@ const getter = (server, path) => new Promise((resolve, reject) => {
                 client.close();
                 resolve();
             }
-        })
+        });
+    }).catch(state => {
+        reject(state);
     });
-
-    client.connect();
 });
 
 const setter = (server, path, value) => new Promise((resolve, reject) => {
-    const client = zookeeper.createClient(server);
-
-    client.once('connected', function () {
+    return _createClient(server).then(client => {
         _exists(client, path).then(stat => {
             if (stat) {
                 client.setData(path, new Buffer(val.toString()), function(err, data, stat) {
@@ -105,7 +107,6 @@ const setter = (server, path, value) => new Promise((resolve, reject) => {
                         console.log('update path %s data error');
                         resolve(false);
                     } else {
-                        console.log('path %s data change to', path, value);
                         resolve(true);
                     }
                 });
@@ -114,9 +115,28 @@ const setter = (server, path, value) => new Promise((resolve, reject) => {
                 resolve(false);
             }
         });
+    }).catch(state => {
+        reject(state);
     });
+});
 
-    client.connect();
+
+const remove = (server, path) => new Promise((resolve, reject) => {
+    return _createClient(server).then(client => {
+        _exists(client, path).then(stat => {
+            if (stat) {
+                client.remove(path, function(err) {
+                    client.close();
+                    err ? resolve(false) : resolve(true);
+                });
+            } else {
+                client.close();
+                resolve(false);
+            }
+        });
+    }).catch(state => {
+        reject(state);
+    });
 });
 
 
@@ -124,5 +144,6 @@ module.exports = {
     exists,
     creator,
     setter,
-    getter
+    getter,
+    remove
 };