remove sync call and properly handle directory entries

datproject · Jan 5, 2016 · e25c4e2d60d60fad1204364ccd1dd6da06ae2ea9 · e25c4e2
1 parent ec4a359
commit e25c4e2d60d60fad1204364ccd1dd6da06ae2ea9
Unified Split

Showing with 8 additions and 5 deletions.

+8 −5 fs.js
diff --git a/fs.js b/fs.js
@@ -38,11 +38,14 @@ module.exports.listEach = function (opts, onEach, cb) {
 module.exports.createDownloadStream = function (drive, dir) {
  return through.obj(function (entry, enc, next) {
    var entryPath = path.join(dir, entry.value.name)
-    mkdirp.sync(path.dirname(entryPath))
-    var content = drive.get(entry)
-    var writeStream = fs.createWriteStream(entryPath, {mode: entry.value.mode})
-    pump(content.createStream(), writeStream, function (err) {
-      next(err)
+    if (entry.type === 'directory') return mkdirp(entryPath, next)
+    mkdirp(path.dirname(entryPath), function (err) {
+      if (err) return next(err)
+      var content = drive.get(entry)
+      var writeStream = fs.createWriteStream(entryPath, {mode: entry.value.mode})
+      pump(content.createStream(), writeStream, function (err) {
+        next(err)
+      })
    })
  })
 }