ORESoftware
diff --git a/‎.r2g/tests/smoke-test.3.js
Lines changed: 79 additions & 0 deletions b/‎.r2g/tests/smoke-test.3.js
Lines changed: 79 additions & 0 deletions
diff --git a/‎readme.md
Lines changed: 5 additions & 4 deletions b/‎readme.md
Lines changed: 5 additions & 4 deletions
diff --git a/‎src/index.ts
Lines changed: 17 additions & 3 deletions b/‎src/index.ts
Lines changed: 17 additions & 3 deletions
@@ -0,0 +1,79 @@
+#!/usr/bin/env node
+'use strict';
+
+const assert = require('assert');
+const path = require('path');
+const cp = require('child_process');
+const os = require('os');
+const fs = require('fs');
+const EE = require('events');
+
+process.on('uncaughtException', err => {
+  console.error('uncaughtException:', {err});
+  process.exit(1);
+});
+
+process.on('unhandledRejection', (reason, p) => {
+  // note: unless we force process to exit with 1, process may exit with 0 upon an unhandledRejection
+  console.error(reason);
+  process.exit(1);
+});
+
+const {JSONParser} = require('@oresoftware/json-stream-parser');
+
+console.log('Running test', __filename);
+
+const k = cp.spawn('bash');
+const foo = 'medicine';
+
+k.stdin.end(`
+
+  foo="${foo}"
+  
+  cat <<EOF
+  
+  {"foo":"$foo"}    ∆∆
+  {"foo":"$foo"} ∆
+  ∆{"foo":"$foo"}∆
+  
+  EOF
+
+`);
+
+const to = setTimeout(() => {
+  console.error('did not receive parsed JSON object within alloted time.');
+  process.exit(1);
+}, 2000);
+
+
+let count = 0;
+
+k.stdout.pipe(new JSONParser({delimiter:'∆'})).on('data', d => {
+
+  count++;
+
+  if(count > 3){
+    throw new Error('too many json blobs.');
+  }
+
+  if(count === 3){
+
+    setTimeout(() => {
+
+      clearTimeout(to);
+      try {
+        assert.deepStrictEqual(d, {foo: foo});
+        process.exit(0);
+      }
+      catch (err) {
+        console.error(err.message);
+        process.exit(1);
+      }
+
+    },1000);
+
+  }
+
+
+});
+
@@ -75,7 +75,7 @@ const k = cp.spawn('bash');
 k.stdin.end(`echo '{"foo":"bar"}\n'`);  // make sure to include the newline char when you write
 
 k.stdout.pipe(new JSONParser()).on('data', d => {
-  // => {foo:'bar'}
+  // => {foo: 'bar'}
 });
 
 ```
@@ -94,9 +94,7 @@ k.stdin.end(`
 `);
 
 k.stdout.pipe(new JSONParser()).on('data', d => {
-  
-    assert.deepStrictEqual(d, {foo: 'medicine'});
-  
+    assert.deepStrictEqual(d, {foo: 'medicine'});  // should pass
 });
 
 
@@ -111,4 +109,7 @@ new JSONParser({delimiter: '∆∆∆'});  // use 3 alt-j's to separate json chu
 
 ```
 
+For other solutions to parsing JSON from CLIs, see:
+https://stackoverflow.com/questions/56014438/get-single-line-json-from-aws-cli
+
 
@@ -51,17 +51,22 @@ export class JSONParser extends stream.Transform {
         continue;
       }
 
+      let json = null;
+
       try {
         l = String(l).trim();
         // l might be an empty string; ignore if so
-        l && this.push(JSON.parse(String(l).trim()));
+        l && (json = JSON.parse(String(l).trim()));
       } catch (err) {
         if (this.debug) {
           console.error('json-parser:', 'error parsing line:', l);
           console.error('json-parser:', err.message);
         }
+        continue;
         // noop
       }
+
+      json && this.push(json);
     }
 
     cb();
@@ -70,11 +75,20 @@ export class JSONParser extends stream.Transform {
 
   _flush(cb: Function) {
     if (this.lastLineData) {
+
+      let json = null, l = String(this.lastLineData).trim();
+
       try {
-        this.push(JSON.parse(this.lastLineData));
+        json = JSON.parse(l);
       } catch (err) {
-        // noop
+        if (this.debug) {
+          console.error('json-parser:', 'error parsing line:', l);
+          console.error('json-parser:', err.message);
+        }
       }
+
+      json && this.push(json);
+
     }
     this.lastLineData = '';
     cb();