fix exporter event emitter sequence

Author: nginnever

src/exporter.js

@@ -37,20 +37,29 @@ function exporter (hash, dagService, options, callback) {
   return ee
 
   function fileExporter (node, name, dir, callback) {
+    let init
+
     if (typeof dir === 'function') { callback = dir; dir = {} }
     var rs = new Readable()
     if (node.links.length === 0) {
       const unmarshaledData = UnixFS.unmarshal(node.data)
+      init = false
+      rs._read = () => {
+        if (init) {
+          return
+        }
+        init = true
+        rs.push(unmarshaledData.data)
+        rs.push(null)
+      }
       ee.emit('file', { stream: rs, path: name, dir: dir })
-      rs.push(unmarshaledData.data)
-      rs.push(null)
       if (callback) {
         callback()
       }
       return
     } else {
       ee.emit('file', { stream: rs, path: name, dir: dir })
-      var init = false
+      init = false
       rs._read = () => {
         if (init) {
           return
@@ -83,10 +92,19 @@ function exporter (hash, dagService, options, callback) {
   }
 
   function dirExporter (node, name, callback) {
+    let init
+
     var rs = new Readable()
     if (node.links.length === 0) {
-      rs.push(node.data)
-      rs.push(null)
+      init = false
+      rs._read = () => {
+        if (init) {
+          return
+        }
+        init = true
+        rs.push(node.data)
+        rs.push(null)
+      }
       ee.emit('file', {stream: rs, path: name})
       if (callback) {
         callback()

test/test-exporter.js

@@ -7,6 +7,7 @@ const expect = require('chai').expect
 const BlockService = require('ipfs-block-service')
 const DAGService = require('ipfs-merkle-dag').DAGService
 const UnixFS = require('ipfs-unixfs')
+const bl = require('bl')
 
 let ds
 
@@ -27,10 +28,13 @@ module.exports = function (repo) {
       const testExport = exporter(hash, ds)
       testExport.on('file', (data) => {
         ds.get(hash, (err, fetchedNode) => {
-          expect(err).to.not.exist
           const unmarsh = UnixFS.unmarshal(fetchedNode.data)
-          expect(unmarsh.data).to.deep.equal(data.stream._readableState.buffer[0])
-          done()
+          expect(err).to.not.exist
+          data.stream.pipe(bl((err, bldata) => {
+            expect(err).to.not.exist
+            expect(bldata).to.deep.equal(unmarsh.data)
+            done()
+          }))
         })
       })
     })