chore: convert all commands return resolvable promises

License: MIT
Signed-off-by: achingbrain <[email protected]>

Author: achingbrain

src/cli/cp.js

@@ -41,10 +41,12 @@ module.exports = {
       hash
     } = argv
 
-    return ipfs.files.cp(source, dest, {
-      parents,
-      format,
-      hashAlg: hash
-    })
+    argv.resolve(
+      ipfs.files.cp(source, dest, {
+        parents,
+        format,
+        hashAlg: hash
+      })
+    )
   }
 }

src/cli/flush.js

@@ -17,6 +17,8 @@ module.exports = {
       ipfs
     } = argv
 
-    return ipfs.files.flush(path || FILE_SEPARATOR, {})
+    argv.resolve(
+      ipfs.files.flush(path || FILE_SEPARATOR, {})
+    )
   }
 }

src/cli/ls.js

@@ -30,45 +30,47 @@ module.exports = {
       long
     } = argv
 
-    return ipfs.files.ls(path || FILE_SEPARATOR)
-      .then(files => {
-        if (long) {
-          const table = []
-          const lengths = {}
-
-          files.forEach(link => {
-            const row = {
-              name: `${link.name}`,
-              hash: `${link.hash}`,
-              size: `${link.size}`
-            }
-
-            Object.keys(row).forEach(key => {
-              const value = row[key]
-
-              lengths[key] = lengths[key] > value.length ? lengths[key] : value.length
+    argv.resolve(
+      ipfs.files.ls(path || FILE_SEPARATOR)
+        .then(files => {
+          if (long) {
+            const table = []
+            const lengths = {}
+
+            files.forEach(link => {
+              const row = {
+                name: `${link.name}`,
+                hash: `${link.hash}`,
+                size: `${link.size}`
+              }
+
+              Object.keys(row).forEach(key => {
+                const value = row[key]
+
+                lengths[key] = lengths[key] > value.length ? lengths[key] : value.length
+              })
+
+              table.push(row)
             })
 
-            table.push(row)
-          })
+            table.forEach(row => {
+              let line = ''
 
-          table.forEach(row => {
-            let line = ''
+              Object.keys(row).forEach(key => {
+                const value = row[key]
 
-            Object.keys(row).forEach(key => {
-              const value = row[key]
+                line += value.padEnd(lengths[key])
+                line += '\t'
+              })
 
-              line += value.padEnd(lengths[key])
-              line += '\t'
+              print(line)
             })
 
-            print(line)
-          })
+            return
+          }
 
-          return
-        }
-
-        files.forEach(link => print(link.name))
-      })
+          files.forEach(link => print(link.name))
+        })
+    )
   }
 }

src/cli/mkdir.js

@@ -44,11 +44,13 @@ module.exports = {
       flush
     } = argv
 
-    return ipfs.files.mkdir(path, {
-      parents,
-      cidVersion,
-      hash,
-      flush
-    })
+    argv.resolve(
+      ipfs.files.mkdir(path, {
+        parents,
+        cidVersion,
+        hash,
+        flush
+      })
+    )
   }
 }

src/cli/mv.js

@@ -35,9 +35,11 @@ module.exports = {
       recursive
     } = argv
 
-    return ipfs.files.mv(source, dest, {
-      parents,
-      recursive
-    })
+    argv.resolve(
+      ipfs.files.mv(source, dest, {
+        parents,
+        recursive
+      })
+    )
   }
 }

src/cli/read.js

@@ -34,28 +34,30 @@ module.exports = {
       length
     } = argv
 
-    return new Promise((resolve, reject) => {
-      waterfall([
-        (cb) => ipfs.files.readPullStream(path, {
-          offset,
-          length
-        }, cb),
-        (stream, cb) => {
-          pull(
-            stream,
-            through(buffer => {
-              print(buffer, false)
-            }),
-            collect(cb)
-          )
-        }
-      ], (error) => {
-        if (error) {
-          return reject(error)
-        }
+    argv.resolve(
+      new Promise((resolve, reject) => {
+        waterfall([
+          (cb) => ipfs.files.readPullStream(path, {
+            offset,
+            length
+          }, cb),
+          (stream, cb) => {
+            pull(
+              stream,
+              through(buffer => {
+                print(buffer, false)
+              }),
+              collect(cb)
+            )
+          }
+        ], (error) => {
+          if (error) {
+            return reject(error)
+          }
 
-        resolve()
+          resolve()
+        })
       })
-    })
+    )
   }
 }

src/cli/rm.js

@@ -26,8 +26,10 @@ module.exports = {
       recursive
     } = argv
 
-    return ipfs.files.rm(path, {
-      recursive
-    })
+    argv.resolve(
+      ipfs.files.rm(path, {
+        recursive
+      })
+    )
   }
 }

src/cli/stat.js

@@ -54,25 +54,27 @@ Type: <type>`,
       withLocal
     } = argv
 
-    return ipfs.files.stat(path, {
-      withLocal
-    })
-      .then((stats) => {
-        if (hash) {
-          return print(stats.hash)
-        }
+    argv.resolve(
+      ipfs.files.stat(path, {
+        withLocal
+      })
+        .then((stats) => {
+          if (hash) {
+            return print(stats.hash)
+          }
 
-        if (size) {
-          return print(stats.size)
-        }
+          if (size) {
+            return print(stats.size)
+          }
 
-        print(format
-          .replace('<hash>', stats.hash)
-          .replace('<size>', stats.size)
-          .replace('<cumulsize>', stats.cumulativeSize)
-          .replace('<childs>', stats.blocks)
-          .replace('<type>', stats.type)
-        )
-      })
+          print(format
+            .replace('<hash>', stats.hash)
+            .replace('<size>', stats.size)
+            .replace('<cumulsize>', stats.cumulativeSize)
+            .replace('<childs>', stats.blocks)
+            .replace('<type>', stats.type)
+          )
+        })
+    )
   }
 }

src/cli/write.js

@@ -85,19 +85,21 @@ module.exports = {
       flush
     } = argv
 
-    return ipfs.files.write(path, process.stdin, {
-      offset,
-      length,
-      create,
-      truncate,
-      rawLeaves,
-      cidVersion,
-      hashAlg,
-      format,
-      parents,
-      progress,
-      strategy,
-      flush
-    })
+    argv.resolve(
+      ipfs.files.write(path, process.stdin, {
+        offset,
+        length,
+        create,
+        truncate,
+        rawLeaves,
+        cidVersion,
+        hashAlg,
+        format,
+        parents,
+        progress,
+        strategy,
+        flush
+      })
+    )
   }
 }