update

Author: Keyang

dist/csvtojson.js

@@ -628,8 +628,10 @@ module.exports = function (params) {
     maxRowLength: 0, //the max character a csv row could have. 0 means infinite. If max number exceeded, parser will emit "error" of "row_exceed". if a possibly corrupted csv data provided, give it a number like 65535 so the parser wont consume memory. default: 0
     checkColumn: false, //whether check column number of a row is the same as headers. If column number mismatched headers number, an error of "mismatched_column" will be emitted.. default: false
     escape: '"', //escape char for quoted column
+    colParser:{}, //flags on columns to alter field processing.
 
     /**below are internal params */
+    _columnConv:[],
     _headerType: [],
     _headerTitle: [],
     _headerFlag: [],
@@ -1004,19 +1006,27 @@ function convertRowToJson(row, headRow, param) {
     if (!head || head === "") {
       head = headRow[i] = "field" + (i + 1);
     }
-    var flag = getFlag(head, i, param);
-    if (flag === 'omit') {
-      continue;
-    }
-    if (param.checkType) {
-      convertFunc = checkType(item, head, i, param);
-      item = convertFunc(item);
-    }
-    var title = getTitle(head, i, param);
-    if (flag === 'flat' || param.flatKeys) {
-      resultRow[title] = item;
+    var convFunc = getConvFunc(head, i, param);
+    if (convFunc) {
+      var convRes = convFunc(item, head, resultRow,row,i);
+      if (convRes !== undefined) {
+        setPath(resultRow, head, convRes);
+      }
     } else {
-      setPath(resultRow, title, item);
+      var flag = getFlag(head, i, param);
+      if (flag === 'omit') {
+        continue;
+      }
+      if (param.checkType) {
+        convertFunc = checkType(item, head, i, param);
+        item = convertFunc(item);
+      }
+      var title = getTitle(head, i, param);
+      if (flag === 'flat' || param.flatKeys) {
+        resultRow[title] = item;
+      } else {
+        setPath(resultRow, title, item);
+      }
     }
   }
   if (hasValue) {
@@ -1026,6 +1036,34 @@ function convertRowToJson(row, headRow, param) {
   }
 }
 
+var builtInConv={
+  "string":stringType,
+  "number":numberType,
+  "omit":function(){}
+}
+function getConvFunc(head,i,param){
+  if (param._columnConv[i] !== undefined){
+    return param._columnConv[i];
+  }else{
+    var flag=param.colParser[head];
+    if (flag === undefined){
+      return param._columnConv[i]=false;
+    }
+    if (typeof flag ==="string"){
+      flag=flag.trim().toLowerCase();
+      var builtInFunc=builtInConv[flag];
+      if (builtInFunc){
+        return param._columnConv[i]=builtInFunc;
+      }else{
+        return param._columnConv[i]=false;  
+      }
+    }else if (typeof flag ==="function"){
+      return param._columnConv[i]=flag;
+    }else{
+      return param._columnConv[i]=false;
+    }
+  }
+}
 function setPath(json, path, value) {
   var _set = require('lodash/set');
   var pathArr = path.split('.');
@@ -1054,8 +1092,7 @@ function getTitle(head, i, param) {
   }
 
   var flag = getFlag(head, i, param);
-  var str = head.replace(flag, '');
-  str = str.replace('string#!', '').replace('number#!', '');
+  var str = head.replace('*flat*', '').replace('string#!', '').replace('number#!', '');
   return param._headerTitle[i] = str;
 }
 
@@ -28173,7 +28210,7 @@ module.exports={
       "hireable": true
     }
   ],
-  "version": "1.1.6",
+  "version": "1.1.7",
   "keywords": [
     "csv",
     "csv parser",