Node / JS: Convert CSV string to JSON with series by columns

csv2json.js

/*
Convert using terminal STDIN & Pipe
Example:
  cat files.csv | node csv2json.js
*/
var lines="";
process.stdin.setEncoding('utf8');
process.stdin.on('readable', () => {
  var chunk = process.stdin.read();
  if (chunk !== null) {
		lines += chunk;
  }
});
process.stdin.on('end', () => {
  console.log(JSON.stringify(csvJSONCols(lines)));
});

function csvJSONCols(csv) {
  var d={}, header=true, n=0, labels=[], cn=0;
  csv.split(/\r?\n/).forEach((line)=>{
    var columns=line.split(",");
    if (header) {
      columns.forEach((col)=>{
        labels.push(col);
        d[col]=[];
      });
      header=false;
    } else {
      cn=0;
      if (columns.length==labels.length) {
      //console.log(columns.length,labels.length);
        columns.forEach((val)=>{
          d[labels[cn]].push(val);
          cn++;
        });
      }
    }
    n++;
  });
  return d
}

csvJSONCols.js

/*
csv=`one,two,thre
1,2,3
4,5,6`;
Return result of csv:
{ one: [ '1', '4' ], two: [ '2', '5' ], thre: [ '3', '6' ] }
*/
function csvJSONCols(csv) {
 var d = {},
  header = true,
  n = 0,
  labels = [],
  cn = 0;
 csv.split(/\r?\n/).forEach((line) => {
  var columns = line.split(",");
  if (header) {
   columns.forEach((col) => {
    labels.push(col);
    d[col] = [];
   });
   header = false;
  } else {
   cn = 0;
   if (columns.length == labels.length) {
    //console.log(columns.length,labels.length);
    columns.forEach((val) => {
     d[labels[cn]].push(val);
     cn++;
    });
   }
  }
  n++;
 });
 return d
}