Merge objects if necessary when traversing stores on get()

lib/nconf/provider.js

@@ -218,7 +218,8 @@ Provider.prototype.get = function (key, callback) {
   var current = 0,
       names = Object.keys(this.stores),
       self = this,
-      response;
+      response,
+      mergeObjs = [];
 
   async.whilst(function () {
     return typeof response === 'undefined' && current < names.length;
@@ -233,13 +234,30 @@ Provider.prototype.get = function (key, callback) {
         }
 
         response = value;
+
+        // Merge objects if necessary
+        if (typeof response === 'object' && !Array.isArray(response)) {
+          mergeObjs.push(response);
+          response = undefined;
+        }
+
         next();
       });
     }
 
     response = store.get(key);
+
+    // Merge objects if necessary
+    if (typeof response === 'object' && !Array.isArray(response)) {
+      mergeObjs.push(response);
+      response = undefined;
+    }
+
     next();
   }, function (err) {
+    if (!err && mergeObjs.length) {
+      response = common.merge(mergeObjs.reverse());
+    }
     return err ? callback(err) : callback(null, response);
   });
 };
@@ -475,7 +493,8 @@ Provider.prototype._execute = function (action, syncLength /* [arguments] */) {
       callback = typeof args[args.length - 1] === 'function' && args.pop(),
       destructive = ['set', 'clear', 'merge'].indexOf(action) !== -1,
       self = this,
-      response;
+      response,
+      mergeObjs = [];
 
   function runAction (name, next) {
     var store = self.stores[name];
@@ -505,9 +524,19 @@ Provider.prototype._execute = function (action, syncLength /* [arguments] */) {
       }
 
       response = store[action].apply(store, args);
+
+      // Merge objects if necessary
+      if (action === 'get' && typeof response === 'object' && !Array.isArray(response)) {
+        mergeObjs.push(response);
+        response = undefined;
+      }
     }
   });
 
+  if (mergeObjs.length) {
+    response = common.merge(mergeObjs.reverse());
+  }
+
   return response;
 }
 

test/complete-test.js

@@ -50,7 +50,7 @@ vows.describe('nconf').addBatch({
     "literal vars": {
       "are present": function () {
         Object.keys(data).forEach(function (key) {
-          assert.equal(nconf.get(key), data[key]);
+          assert.deepEqual(nconf.get(key), data[key]);
         });
       }
     },

test/fixtures/merge/file1.json

@@ -7,6 +7,10 @@
   "candy": {
   	"something": "file1",
     "something1": true,
-    "something2": true
+    "something2": true,
+    "something5": {
+      "first": 1,
+      "second": 2
+    }
   }
-}
+}

test/fixtures/scripts/nconf-hierarchical-load-merge.js

@@ -0,0 +1,18 @@
+/*
+ * nconf-hierarchical-load-merge.js: Test fixture for loading and merging nested objects across stores.
+ *
+ * (C) 2012, Nodejitsu Inc.
+ * (C) 2012, Michael Hart
+ *
+ */
+
+var path = require('path'),
+    nconf = require('../../../lib/nconf');
+
+nconf.argv()
+     .file(path.join(__dirname, '..', 'merge', 'file1.json'));
+
+process.stdout.write(JSON.stringify({
+  apples: nconf.get('apples'),
+  candy: nconf.get('candy')
+}));

test/hierarchy-test.js

@@ -75,6 +75,39 @@ vows.describe('nconf/hierarchy').addBatch({
           }
         });
       }
+    },
+    "configured with .argv(), .file() and invoked with nested command line options": {
+      topic: function () {
+        var script = path.join(__dirname, 'fixtures', 'scripts', 'nconf-hierarchical-load-merge.js'),
+            argv = ['--candy:something', 'foo', '--candy:something5:second', 'bar'],
+            that = this,
+            data = '',
+            child;
+
+        child = spawn('node', [script].concat(argv));
+
+        child.stdout.on('data', function (d) {
+          data += d;
+        });
+
+        child.on('exit', function() {
+          that.callback(null, data);
+        });
+      },
+      "should merge nested objects ": function (err, data) {
+        assert.deepEqual(JSON.parse(data), {
+          apples: true,
+          candy: {
+            something: 'foo',
+            something1: true,
+            something2: true,
+            something5: {
+              first: 1,
+              second: 'bar'
+            }
+          }
+        });
+      }
     }
   }
-}).export(module);
+}).export(module);