fix: broken ndjson implementation

Fixes #17

package.json

@@ -16,7 +16,9 @@
     "node": ">=18"
   },
   "scripts": {
-    "test": "echo '[{\"foo\": 1}]' | ./bin/groq.js --pretty '*[]{ foo }'",
+    "test": "npm run test:json && npm run test:ndjson",
+    "test:json": "echo '[{\"foo\": 1}]' | ./bin/groq.js --pretty '*[]{ foo }'",
+    "test:ndjson": "echo '{\"foo\": 1}\n{\"bar\": 2}' | ./bin/groq.js -n --pretty '*[]'",
     "lint": "eslint . && prettier --check ./src ./bin"
   },
   "files": [

src/cli.js

@@ -105,13 +105,15 @@ async function* outputPrettyJSON(result) {
 }
 
 async function* outputNDJSON(result) {
-  if (result.getType() == 'array') {
-    for await (const value of result) {
-      yield JSON.stringify(await value.get())
+  const value = await result.get()
+
+  if (Array.isArray(value)) {
+    for await (const row of value) {
+      yield JSON.stringify(row)
       yield '\n'
     }
   } else {
-    yield JSON.stringify(await result.get())
+    yield JSON.stringify(value)
     yield '\n'
   }
 }
@@ -129,7 +131,7 @@ async function inputJSON() {
 }
 
 function inputNDJSON() {
-  const dataset = new S2A(process.stdin.pipe(ndjson()))
+  const dataset = new S2A(process.stdin.pipe(ndjson.parse()))
   return {dataset}
 }