Revert "Remove traverse dependency" (#9)

Author: bendrucker

package.json

@@ -8,7 +8,8 @@
     "spawn-error-forwarder": "~1.0.0",
     "split2": "~1.0.0",
     "stream-combiner2": "~1.1.1",
-    "through2": "~2.0.0"
+    "through2": "~2.0.0",
+    "traverse": "~0.6.6"
   },
   "devDependencies": {
     "chai": "~1.10.0",

src/fields.js

@@ -1,5 +1,7 @@
 'use strict';
 
+var traverse = require('traverse');
+
 exports.config = {
   commit: {
     long: 'H',
@@ -30,27 +32,15 @@ exports.config = {
 };
 
 exports.map = function () {
-  var fields = [];
-
-  function crawl(node, path, parent) {
-    if (typeof node === 'object') {
-      for (var childKey in node) {
-        if (!Object.prototype.hasOwnProperty.call(node, childKey)) continue;
-        path.push(childKey);
-        crawl(node[childKey], path, node);
-        path.pop(childKey);
-      }
-    } else if (typeof node === 'string') {
-      var typed = path[path.length - 1] === 'key';
+  return traverse.reduce(exports.config, function (fields, node) {
+    if (this.isLeaf && typeof node === 'string') {
+      var typed = this.key === 'key';
       fields.push({
-        path: typed ? path.slice(0, path.length - 1) : path.slice(0),
+        path: typed ? this.parent.path : this.path,
         key: node,
-        type: parent.type
+        type: this.parent.node.type
       });
     }
-  }
-
-  crawl(exports.config, [], undefined);
-
-  return fields;
+    return fields;
+  }, []);
 };

src/index.js

@@ -3,6 +3,7 @@
 var spawn    = require('child_process').spawn;
 var through  = require('through2');
 var split    = require('split2');
+var traverse = require('traverse');
 var fields   = require('./fields');
 var toArgv   = require('argv-formatter').format;
 var combine  = require('stream-combiner2');
@@ -41,19 +42,6 @@ function args (config, fieldMap) {
   return toArgv(config);
 }
 
-function setByPath(obj, path, value) {
-  var dest = obj;
-  for (var i = 0; i < path.length - 1; i++) {
-    var key = path[i];
-    if (!Object.prototype.hasOwnProperty.call(obj, key)) {
-      obj[key] = {};
-    }
-    dest = dest[key];
-  }
-
-  dest[path[path.length - 1]] = value;
-}
-
 exports.parse = function parseLogStream (config, options) {
   config  = config || {};
   var map = fields.map();
@@ -65,7 +53,7 @@ exports.parse = function parseLogStream (config, options) {
       var fields = chunk.toString('utf8').split(FIELD);
       callback(null, map.reduce(function (parsed, field, index) {
         var value = fields[index];
-        setByPath(parsed, field.path, field.type ? new field.type(value) : value);
+        traverse(parsed).set(field.path, field.type ? new field.type(value) : value);
         return parsed;
       }, {}));
     })