feat: reuse createAddPullStream to avoid code duplication

ipfs · Oct 20, 2017 · 3038452 · 3038452
1 parent 4daa0ad
commit 3038452
Showing 1 changed file with 2 additions and 11 deletions.
diff --git a/src/core/components/files.js b/src/core/components/files.js
@@ -73,18 +73,9 @@ module.exports = function files (self) {
         return callback(new Error('Invalid arguments, data must be an object, Buffer or readable stream'))
       }
 
-      let total = 0
-      let prog = options.progress || (() => {})
-      const progress = (bytes) => {
-        total += bytes
-        prog(total)
-      }
-
-      options.progress = progress
       pull(
-        pull.values(normalizeContent(data)),
-        importer(self._ipldResolver, options),
-        pull.asyncMap(prepareFile.bind(null, self, options)),
+        pull.values([data]),
+        createAddPullStream(options),
         sort((a, b) => {
           if (a.path < b.path) return 1
           if (a.path > b.path) return -1