initial commit

Author: stephenlacy

example.js

@@ -3,5 +3,7 @@ const through = require('through2')
 const stream = require('./')
 
 const req = request.get('http://localhost:8000/file.xlsx')
+  .buffer(false)
   .pipe(stream())
-  .on('data', (d) => console.log(String(d)))
+  .on('data', (d) => console.log(String(d), 'line'))
+  .on('end', console.log)

index.js

@@ -12,17 +12,19 @@ module.exports = () => {
   .then((worksheet) => {
     workbook.eachSheet((sheet, id) => {
       sheet.eachRow((row, id) => {
-        if (id === 1) {
+        if (id === 1 || !headers) {
           headers = row.values
           return
         }
         let item = {}
         row.values.forEach((v, k) => {
+           if (!headers) return
           item[headers[k]] = v
         })
         second.push(JSON.stringify(item))
       })
     })
+    second.emit('end')
   })
   return duplex.obj(input, second)
 }

package.json

@@ -1,14 +1,34 @@
 {
+  "name": "exceljs-transform-stream",
+  "description": "Parse XLSX files as a through stream to exceljs",
+  "main": "index.js",
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/stevelacy/exceljs-transform-stream.git"
+  },
+  "scripts": {
+    "test": "mocha test/"
+  },
+  "author": "Steve Lacy <[email protected]> (http://slacy.me)",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/stevelacy/exceljs-transform-stream/issues"
+  },
+  "homepage": "https://github.com/stevelacy/exceljs-transform-stream#readme",
   "dependencies": {
-    "duplexer": "^0.1.1",
+    "duplexify": "^3.5.0",
     "exceljs": "^0.2.41",
-    "sheetjs": "^1.0.21",
-    "through2": "^2.0.3",
-    "unzip": "^0.1.11",
-    "xlsx": "^0.8.2",
-    "xml-stream": "^0.4.5"
+    "through2": "^2.0.3"
   },
   "devDependencies": {
-    "superagent": "^3.4.1"
-  }
+    "mocha": "^3.2.0",
+    "should": "^11.2.0"
+  },
+  "keywords": [
+    "stream",
+    "xlsx",
+    "exceljs",
+    "transform",
+    "convert"
+  ]
 }

parser.js

@@ -0,0 +1,34 @@
+const fs = require('fs')
+const should = require('should')
+const stream = require('stream')
+const exs = require('..')
+
+describe('exceljs-through-stream', () => {
+  it('should export a function', (done) => {
+    should(typeof exs).equal('function')
+    done()
+  })
+  it('should export a function that returns a stream', (done) => {
+    should(exs() instanceof stream)
+    done()
+  })
+  it('parse xlsx files', (done) => {
+    const file = fs.createReadStream(__dirname + '/file.xlsx')
+    const res = []
+    file.pipe(exs())
+      .on('data', (d) => {
+        res.push(JSON.parse(String(d)))
+      })
+      .on('end', () => {
+        should(res.length).equal(4)
+        should(JSON.stringify(res[0])).equal(
+        JSON.stringify({
+          row: 'row1',
+          date: '2017-02-08T00:00:00.000Z',
+          cost: 100,
+          notes: 111
+        }))
+        done()
+      })
+  })
+})