tmp

Alexander Mills · Alexander Mills · commit 737f1ddee4a2 · 2019-09-09T23:23:59.000-07:00
diff --git a/.r2g/tests/smoke-test.3.js b/.r2g/tests/smoke-test.3.js
@@ -23,6 +23,7 @@ const {JSONParser} = require('@oresoftware/json-stream-parser');
 
 console.log('Running test', __filename);
 
+
 const k = cp.spawn('bash');
 const foo = 'medicine';
 
@@ -35,8 +36,7 @@ k.stdin.end(`
   {"foo":"$foo"}    ∆∆
   {"foo":"$foo"} ∆
   ∆{"foo":"$foo"}∆
-  
-  EOF
+EOF
 
 `);
 
@@ -48,8 +48,14 @@ const to = setTimeout(() => {
 
 let count = 0;
 
+k.stdout.on('data', d => {
+  console.log('XOKOEE',String(d));
+});
+
 k.stdout.pipe(new JSONParser({delimiter:'∆'})).on('data', d => {
 
+  console.log("HERE IS ONE:", d);
+  
   count++;
 
   if(count > 3){
diff --git a/src/main.ts b/src/main.ts
@@ -105,17 +105,22 @@ export class JSONParser<T = any> extends stream.Transform {
 
   handleJSON(o: string) {
 
-    if (this.cleanFront) {
-      // sometimes there is some noise in the beginning of a line before the JSON starts
-      const ib = o.indexOf('["');
-      if (ib !== 0) {
-        const iz = o.indexOf('{"');
-        if (ib >= 0 || iz >= 0) {
-          let i = Math.min(ib, iz);
-          o = o.slice(i);
-        }
-      }
-    }
+    // if (this.cleanFront) {
+    //   // sometimes there is some noise in the beginning of a line before the JSON starts
+    //   if (!((o[0] === '[' || o[0] === '{') && o[1] === '"')) {
+    //     const ib = o.indexOf('["');
+    //     const iz = o.indexOf('{"');
+    //     if (ib >= 0 || iz >= 0) {
+    //       let i = Math.min(ib, iz);
+    //       if (!o.slice(0, i).match(this.delimiter)) {
+    //         o = o.slice(i);
+    //       }
+    //
+    //     }
+    //   }
+    // }
+
+    // console.log('ooooo:', o);
 
     let json = null;
 
