jsonexport - npm Package Compare versions

Comparing version 2.0.7 to 2.0.8

bin/jsonexport.js

 #! /usr/bin/env node
+const jsonexport = require('../lib/index.js');
+const fs = require('fs');
 
-var jsonexport = require('../lib/index.js');
+const stdin = process.stdin;
+const stdout = process.stdout;
+const inputFile = process.argv[2];
+const outputFile = process.argv[3];
 
-var stdin = process.stdin,
-    inputChunks = [];
+if (inputFile)
+  return fs.createReadStream(inputFile)
+    .pipe(jsonexport())
+    .pipe(outputFile ? fs.createWriteStream(outputFile) : stdout);
 
 stdin.setEncoding('utf8');
-
-stdin.on('data', function (chunk) {
-    inputChunks.push(chunk);
-});
-
-stdin.on('end', function () {
-    var input = inputChunks.join(''),
-        parsedData = JSON.parse(input);
-
-    jsonexport(parsedData, function (err, csv) {
-        if (err) {
-            console.error(err);
-            process.exit(1);
-        }
-
-        console.log(csv);
-    });
-});
+stdin
+  .pipe(jsonexport())
+  .pipe(stdout);

CHANGELOG.md

 ## Change log
 ----------------------
+- v2.0.8 - cli improvements
 - v2.0.7 - removed underscore as a dependency (dydx)
@@ -4,0 +5,0 @@ - v2.0.4 - rename option

lib/core/helper.js

@@ -6,3 +6,3 @@ 'use strict';
     return fn && getType.toString.call(fn) === '[object Function]';
-}
+};
 
@@ -9,0 +9,0 @@ module.exports.isArray = (arr) => Array.isArray(arr);

lib/index.js

@@ -7,3 +7,3 @@ /* jshint node:true */
 //const _ = require('underscore');
-const Parser = require('./parser/json');
+const Parser = require('./parser/csv');
 const Stream = require('./core/stream');
@@ -26,3 +26,3 @@ const helper = require('./core/helper');
   }
-  userOptions = !callback ? json : userOptions; 
+  userOptions = !callback ? json : userOptions;
   let parser = new Parser(userOptions);
@@ -29,0 +29,0 @@ if (!callback || !helper.isFunction(callback)) return new Stream(parser);

package.json

 {
   "name": "jsonexport",
-  "version": "2.0.7",
+  "version": "2.0.8",
   "description": "Makes easy to convert JSON to CSV",
@@ -5,0 +5,0 @@ "main": "./lib",

README.md

@@ -21,2 +21,3 @@ # jsonexport
 Installation command is `npm install jsonexport`.
+
 Run tests with `npm test`.
@@ -32,2 +33,11 @@
 ```
+
+## CLI
+
+Global installation command is `npm install -g jsonexport`.
+
+Convert JSON to CSV using `cat data.json | jsonexport` or `jsonexport data.json`
+
+Usage: `jsonexport <JSON filename> <CSV filename>`
+
 ## Stream
@@ -34,0 +44,0 @@

tests/stream.js

@@ -10,16 +10,24 @@ /* jshint evil: true */
 
+function getWriteStream(done) {
+  var write = new stream.Writable();
+  var csv = "";
+  write._write = function(chunk, enc, next) {
+    chunk = chunk.toString();
+    csv += chunk;
+    next();
+  };
+  write.on('finish', () => {
+    done(csv);
+  });
+  return write;
+}
+
 describe('Stream', () => {
   it('simple', (done) => {
     var read = new stream.Readable();
-    var write = new stream.Writable();
-    var csv = "";
-    write._write = function(chunk, enc, next) {
-      chunk = chunk.toString();
-      csv += chunk;
-      next();
-    };
-    write.on('finish', () => {
+    var write = getWriteStream((csv) => {
       expect(csv).to.equal(`name,lastname,escaped${os.EOL}Bob,Smith${os.EOL}James,David,I am a ""quoted"" field`);
       done();
     });
+
     read.pipe(jsonexport()).pipe(write);
@@ -39,10 +47,3 @@
     var read = new stream.Readable();
-    var write = new stream.Writable();
-    var csv = "";
-    write._write = function(chunk, enc, next) {
-      chunk = chunk.toString();
-      csv += chunk;
-      next();
-    };
-    write.on('finish', () => {
+    var write = getWriteStream((csv) => {
       expect(csv).to.equal(`name|lastname|escaped${os.EOL}Bob|Smith${os.EOL}James|David|I am a ""quoted"" field`);
@@ -68,10 +69,3 @@ done();
     var read = new stream.Readable();
-    var write = new stream.Writable();
-    var csv = "";
-    write._write = function(chunk, enc, next) {
-      chunk = chunk.toString();
-      csv += chunk;
-      next();
-    };
-    write.on('finish', () => {
+    var write = getWriteStream((csv) => {
       expect(csv).to.equal(`id,name,lastname,family.name,family.type${os.EOL}1,Bob,Smith,Peter,Father${os.EOL}2,James,David,Julie,Mother`);
@@ -78,0 +72,0 @@ done();

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

10570813

Number of package files

24

increased by4.35%

Number of lines in readme file

259

increased by4.02%

Worsened metrics

Lines of code

2419

decreased by-0.17%

Number of low supply chain risk alerts

2

increased by100%

No dependency changes