consul - npm Package Compare versions

Comparing version 0.15.0 to 0.16.0

lib/acl.js

@@ -33,2 +33,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -58,2 +59,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -93,2 +95,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -121,2 +124,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -151,2 +155,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -180,2 +185,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -182,0 +188,0 @@ var req = {

lib/agent.js

@@ -56,2 +56,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -79,2 +80,5 @@ var req = {
 
+  opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
+
   var req = {
@@ -100,2 +104,3 @@ name: 'agent.self',
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -128,2 +133,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -155,2 +161,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -157,0 +164,0 @@ var req = {

lib/agent/check.js

@@ -32,2 +32,5 @@ /**
 
+  opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
+
   var req = {
@@ -49,2 +52,3 @@ name: 'agent.check.list',
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -96,2 +100,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -123,2 +128,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -153,2 +159,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -183,2 +190,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -185,0 +193,0 @@ var req = {

lib/agent/service.js

@@ -32,2 +32,5 @@ /**
 
+  opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
+
   var req = {
@@ -53,2 +56,3 @@ name: 'agent.service.list',
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -108,2 +112,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -131,2 +136,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -133,0 +139,0 @@ var req = {

lib/catalog.js

@@ -38,2 +38,5 @@ /**
 
+  opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
+
   var req = {
@@ -40,0 +43,0 @@ name: 'catalog.datacenters',

lib/catalog/node.js

@@ -35,2 +35,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -57,2 +58,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -59,0 +61,0 @@ var req = {

lib/catalog/service.js

@@ -35,2 +35,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -58,2 +59,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -60,0 +62,0 @@ var req = {

lib/constants.js

@@ -8,2 +8,16 @@ /**
 /**
+ * Default options
+ */
+
+exports.DEFAULT_OPTIONS = [
+  'consistent',
+  'dc',
+  'stale',
+  'timeout',
+  'token',
+  'wait',
+  'wan',
+];
+
+/**
  * Values
@@ -10,0 +24,0 @@ */

lib/consul.js

@@ -24,2 +24,4 @@ /**
 var Watch = require('./watch').Watch;
+var constants = require('./constants');
+var utils = require('./utils');
 
@@ -45,2 +47,16 @@ /**
 
+  if (opts.defaults) {
+    var rawDefaults = utils.normalizeKeys(opts.defaults);
+    var defaults;
+
+    constants.DEFAULT_OPTIONS.forEach(function(key) {
+      if (!rawDefaults.hasOwnProperty(key)) return;
+      if (!defaults) defaults = {};
+      defaults[key] = rawDefaults[key];
+    });
+
+    if (defaults) this._defaults = defaults;
+  }
+  delete opts.defaults;
+
   papi.Client.call(this, opts);
@@ -47,0 +63,0 @@

lib/event.js

@@ -38,2 +38,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -87,2 +88,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -89,0 +91,0 @@ var req = {

lib/health.js

@@ -33,2 +33,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -60,2 +61,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -87,2 +89,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -118,2 +121,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -120,0 +124,0 @@ var req = {

lib/kv.js

@@ -32,2 +32,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -85,2 +86,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -125,2 +127,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -163,2 +166,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -165,0 +169,0 @@ var req = {

lib/lock.js

@@ -160,7 +160,7 @@ /**
   if (!ctx.session.id) {
-    var opts = {
+    var opts = utils.defaults({
       name: ctx.session.name || DEFAULT_LOCK_SESSION_NAME,
       ttl: ctx.session.ttl || DEFAULT_LOCK_SESSION_TTL,
       ctx: ctx,
-    };
+    }, self.consul._defaults);
 
@@ -184,7 +184,7 @@ self.consul.session.create(opts, function(err, data, res) {
       ctx.renewSession = setInterval(function() {
-        var opts = {
+        var opts = utils.defaults({
           id: ctx.session.id,
           timeout: renewTimeout,
           ctx: ctx,
-        };
+        }, self.consul._defaults);
 
@@ -222,3 +222,3 @@ self.consul.session.renew(opts, function(err, data, res) {
 
-  var opts = {
+  var opts = utils.defaults({
     key: ctx.key,
@@ -229,3 +229,3 @@ wait: ctx.lockWaitTime,
     index: ctx.index,
-  };
+  }, self.consul._defaults);
 
@@ -264,3 +264,3 @@ self.consul.kv.get(opts, function(err, data, res) {
 
-  var opts = {
+  var opts = utils.defaults({
     key: ctx.key,
@@ -271,3 +271,3 @@ acquire: ctx.session.id,
     flags: LOCK_FLAG_VALUE_IN,
-  };
+  }, self.consul._defaults);
 
@@ -302,3 +302,3 @@ self.consul.kv.set(opts, function(err, data, res) {
     method: self.consul.kv.get,
-    options: {
+    options: utils.defaults({
       key: ctx.key,
@@ -308,3 +308,3 @@ wait: ctx.lockWaitTime,
       index: ctx.index,
-    },
+    }, self.consul._defaults),
   });
@@ -366,6 +366,6 @@
 
-    var opts = {
+    var opts = utils.defaults({
       id: ctx.session.id,
       timeout: 1000,
-    };
+    }, self.consul._defaults);
 
@@ -398,3 +398,3 @@ self.consul.session.destroy(opts, function() {
   if (ctx.held) {
-    var opts = {
+    var opts = utils.defaults({
       key: ctx.key,
@@ -405,3 +405,3 @@ release: ctx.session.id,
       flags: LOCK_FLAG_VALUE_IN,
-    };
+    }, self.consul._defaults);
 
@@ -408,0 +408,0 @@ self.consul.kv.set(opts, function(err, data) {

lib/session.js

@@ -33,2 +33,3 @@ /**
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -65,2 +66,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -93,2 +95,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -131,2 +134,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -159,2 +163,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -181,2 +186,3 @@ var req = {
   opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
 
@@ -183,0 +189,0 @@ var req = {

lib/status.js

@@ -31,2 +31,5 @@ /**
 
+  opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
+
   var req = {
@@ -52,2 +55,5 @@ name: 'status.leader',
 
+  opts = utils.normalizeKeys(opts);
+  opts = utils.defaults(opts, this.consul._defaults);
+
   var req = {
@@ -54,0 +60,0 @@ name: 'status.peers',

lib/utils.js

@@ -66,2 +66,19 @@ /**
 /**
+ * Defaults
+ */
+
+function defaults(obj, src) {
+  if (!obj) obj = {};
+  if (!src) return obj;
+
+  for (var p in src) {
+    if (src.hasOwnProperty(p) && !obj.hasOwnProperty(p)) {
+      obj[p] = src[p];
+    }
+  }
+
+  return obj;
+}
+
+/**
  * Common options
@@ -193,2 +210,3 @@ */
 exports.normalizeKeys = normalizeKeys;
+exports.defaults = defaults;
 exports.options = options;
@@ -195,0 +213,0 @@ exports.clone = clone;

lib/watch.js

@@ -29,2 +29,3 @@ /**
   var options = utils.normalizeKeys(opts.options || {});
+  options = utils.defaults(options, consul._defaults);
   options.wait = options.wait || '30s';
@@ -31,0 +32,0 @@ options.index = options.index || 0;

package.json

 {
   "name": "consul",
-  "version": "0.15.0",
+  "version": "0.16.0",
   "description": "Consul client",
@@ -5,0 +5,0 @@ "main": "./lib",

README.md

@@ -39,2 +39,3 @@ # Consul [![Build Status](https://travis-ci.org/silas/node-consul.png?branch=master)](https://travis-ci.org/silas/node-consul)
  * ca (String[], optional): array of strings or Buffers of trusted certificates in PEM format
+ * defaults (Object, optional): default options for method calls
 
@@ -41,0 +42,0 @@ Usage

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

99673

increased by3.99%

Lines of code

2059

increased by4.57%

Number of lines in readme file

1589

increased by0.06%

No dependency changes