(feat) promisifies DDPClient

Author: sunny-g

README.md

@@ -32,6 +32,7 @@ ddpclient.call("login", [
 
 ```js
 var DDPClient = require("ddp-client");
+// or "ddp-client/promise" for promisified versions of all async functions
 
 var ddpclient = new DDPClient({
   // All properties optional, defaults shown

index.js

@@ -186,55 +186,29 @@ class DDPClient extends EventEmitter{
         }
 
         self.collections[name].upsert(item);
-
-        if (self._observers[name]) {
-          _.each(self._observers[name], function(observer) {
-            observer.added(id, item);
-          })
-        }
       }
 
     // remove document from collection
     } else if (data.msg === "removed") {
       if (self.maintainCollections && data.collection) {
-        var name = data.collection,
-          id = data.id
-          oldFields = self.collections[name].get(id);
-
         self.collections[name].remove({"_id": id});
-
-        if (self._observers[name]) {
-          _.each(self._observers[name], function(observer) {
-            observer.removed(id, oldFields);
-          });
         }
-      }
 
     // change document in collection
     } else if (data.msg === "changed") {
       if (self.maintainCollections && data.collection) {
-        var name = data.collection,
-          id = data.id,
-          oldFields = {},
-          clearedFields = data.cleared || [];
+        var name = data.collection, id = data.id;
         var item = {
           "_id": id
         };
 
         if (data.fields) {
-          oldFields = self.collections[name].get(id);
           _.each(data.fields, function(value, key) {
             item[key] = value;
           });
         }
 
-        var newFields = self.collections[name].upsert(item);
-
-        if (self._observers[name]) {
-          _.each(self._observers[name], function(observer) {
-            observer.changed(id, oldFields, clearedFields, newFields);
-          });
-        }
+        self.collections[name].upsert(item);
       }
 
     // subscriptions ready

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ddp-client",
-  "version": "0.1.2",
+  "version": "0.1.3",
   "description": "DDP Client for browsers and native JS runtimes (no dependencies on document or 3rd party WebSocket libraries)",
   "main": "index.js",
   "keywords": [

promise.js

@@ -0,0 +1,73 @@
+"use strict";
+
+let DDPClient = require('./index.js');
+
+class DDP extends DDPClient {
+  constructor(opts) {
+    super(opts);
+  }
+
+  connect() {
+    return new Promise((resolve, reject) => {
+      super.connect((err, wasReconnect) => {
+        if (err) {
+          console.log('DDP connection error!');
+          return reject(err);
+        }
+
+        if (wasReconnect) {
+          console.log('Reestablishment of a connection.');
+        }
+
+        console.log('connected to Meteor server');
+        resolve(this._isReconnecting);
+      });
+    });
+  }
+
+  call(name, params) {
+    return new Promise((resolve, reject) => {
+      super.call(name, params, (err, res) => {
+        if (err) {
+          reject(err);
+        } else { 
+          resolve(res);
+        }
+      }, () => {
+        // callback which fires when server has finished
+      });
+    });
+  }
+
+  callWithRandomSeed(name, params, randomSeed) {
+    return new Promise((resolve, reject) => {
+      super.callWithRandomSeed(name, params, randomSeed, (err, res) => {
+        if (err) { r
+          reject(err);
+        } else { 
+          resolve(res);
+        }
+      }, () => {
+        // callback which fires when server has finished
+      });
+    });
+  }
+
+  subscribe(...args) {
+    return super.subscribe(...args);
+  }
+
+  unsubscribe(...args) {
+    return super.unsubscribe(...args);
+  }
+
+  close() {
+    return super.close();
+  }
+
+  observe(...args) {
+    return super.observe(...args);
+  }
+}
+
+module.exports = DDP;