FIX: Use assert not assert-diff

src/http.js

@@ -1,85 +1,85 @@
-/* eslint-disable new-cap */
+/* eslint-disable new-cap */
-'use strict';
+'use strict';
-
+
-const assert = require('assert-diff');
+const assert = require('assert');
-const _ = require('lodash');
+const _ = require('lodash');
-const jayson = require('jayson');
+const jayson = require('jayson');
-
+
-const RippleAPI = require('./api').RippleAPI;
+const RippleAPI = require('./api').RippleAPI;
-
+
-
+
-function createHTTPServer(options, httpPort) {
+function createHTTPServer(options, httpPort) {
-  const rippleAPI = new RippleAPI(options);
+  const rippleAPI = new RippleAPI(options);
-
+
-  const methodNames = _.filter(_.keys(RippleAPI.prototype), k => {
+  const methodNames = _.filter(_.keys(RippleAPI.prototype), k => {
-    return typeof RippleAPI.prototype[k] === 'function'
+    return typeof RippleAPI.prototype[k] === 'function'
-    && k !== 'connect'
+    && k !== 'connect'
-    && k !== 'disconnect'
+    && k !== 'disconnect'
-    && k !== 'constructor'
+    && k !== 'constructor'
-    && k !== 'RippleAPI';
+    && k !== 'RippleAPI';
-  });
+  });
-
+
-  function applyPromiseWithCallback(fnName, callback, args_) {
+  function applyPromiseWithCallback(fnName, callback, args_) {
-    try {
+    try {
-      let args = args_;
+      let args = args_;
-      if (!_.isArray(args_)) {
+      if (!_.isArray(args_)) {
-        const fnParameters = jayson.Utils.getParameterNames(rippleAPI[fnName]);
+        const fnParameters = jayson.Utils.getParameterNames(rippleAPI[fnName]);
-        args = fnParameters.map(name => args_[name]);
+        args = fnParameters.map(name => args_[name]);
-        const defaultArgs = _.omit(args_, fnParameters);
+        const defaultArgs = _.omit(args_, fnParameters);
-        assert(_.size(defaultArgs) <= 1,
+        assert(_.size(defaultArgs) <= 1,
-          'Function must have no more than one default argument');
+          'Function must have no more than one default argument');
-        if (_.size(defaultArgs) > 0) {
+        if (_.size(defaultArgs) > 0) {
-          args.push(defaultArgs[_.keys(defaultArgs)[0]]);
+          args.push(defaultArgs[_.keys(defaultArgs)[0]]);
-        }
+        }
-      }
+      }
-      Promise.resolve(rippleAPI[fnName].apply(rippleAPI, args))
+      Promise.resolve(rippleAPI[fnName].apply(rippleAPI, args))
-        .then(res => callback(null, res))
+        .then(res => callback(null, res))
-        .catch(err => {
+        .catch(err => {
-          callback({code: 99, message: err.message, data: {name: err.name}});
+          callback({code: 99, message: err.message, data: {name: err.name}});
-        });
+        });
-    } catch (err) {
+    } catch (err) {
-      callback({code: 99, message: err.message, data: {name: err.name}});
+      callback({code: 99, message: err.message, data: {name: err.name}});
-    }
+    }
-  }
+  }
-
+
-  const methods = {};
+  const methods = {};
-  _.forEach(methodNames, fn => {
+  _.forEach(methodNames, fn => {
-    methods[fn] = jayson.Method((args, cb) => {
+    methods[fn] = jayson.Method((args, cb) => {
-      applyPromiseWithCallback(fn, cb, args);
+      applyPromiseWithCallback(fn, cb, args);
-    }, {collect: true});
+    }, {collect: true});
-  });
+  });
-
+
-  const server = jayson.server(methods);
+  const server = jayson.server(methods);
-  let httpServer = null;
+  let httpServer = null;
-
+
-  return {
+  return {
-    server: server,
+    server: server,
-    start: function() {
+    start: function() {
-      if (httpServer !== null) {
+      if (httpServer !== null) {
-        return Promise.reject('Already started');
+        return Promise.reject('Already started');
-      }
+      }
-      return new Promise((resolve) => {
+      return new Promise((resolve) => {
-        rippleAPI.connect().then(() => {
+        rippleAPI.connect().then(() => {
-          httpServer = server.http();
+          httpServer = server.http();
-          httpServer.listen(httpPort, resolve);
+          httpServer.listen(httpPort, resolve);
-        });
+        });
-      });
+      });
-    },
+    },
-    stop: function() {
+    stop: function() {
-      if (httpServer === null) {
+      if (httpServer === null) {
-        return Promise.reject('Not started');
+        return Promise.reject('Not started');
-      }
+      }
-      return new Promise((resolve) => {
+      return new Promise((resolve) => {
-        rippleAPI.disconnect();
+        rippleAPI.disconnect();
-        httpServer.close(() => {
+        httpServer.close(() => {
-          httpServer = null;
+          httpServer = null;
-          resolve();
+          resolve();
-        });
+        });
-      });
+      });
-    }
+    }
-  };
+  };
-}
+}
-
+
-module.exports = {
+module.exports = {
-  createHTTPServer
+  createHTTPServer
-};
+};