Fix chunk (#44)

Author: Sylvestre

lib/mssql.js

@@ -101,17 +101,21 @@ export async function queryStream(req, res, pool) {
           new Transform({
             objectMode: true,
             transform(chunk, encoding, cb) {
-              const row = chunk.reduce((acc, r, idx) => {
-                const key = columnNameMap.get(idx);
-                return {...acc, [key]: r};
-              }, {});
-
-              cb(null, row);
+              if (Array.isArray(chunk)) {
+                const row = chunk.reduce((acc, r, idx) => {
+                  const key = columnNameMap.get(idx);
+                  return {...acc, [key]: r};
+                }, {});
+                cb(null, row);
+              } else {
+                cb(new Error("row has unexpected format"), chunk);
+              }
             },
           })
         )
         .pipe(JSONStream.stringify("", "\n", "\n"))
         .pipe(res);
+
       stream.on("done", () => {
         resolve();
       });