refactor: use async-await

This is part of the Awesome Endeavour: Async Iterators:
ipfs/js-ipfs#1670

Author: niinpatel

package.json

@@ -44,15 +44,14 @@
   "devDependencies": {
     "abstract-blob-store": "^3.3.4",
     "aegir": "^17.0.1",
-    "ipfs": "~0.33.0",
+    "ipfs": "~0.34.4",
     "ipfsd-ctl": "~0.40.0",
     "tape": "^4.9.1",
     "which": "^1.3.1"
   },
   "dependencies": {
     "debug": "^4.1.0",
-    "ipfs": "~0.33.0",
-    "ipfs-api": "^26.1.2",
-    "promisify-es6": "^1.0.3"
+    "ipfs": "~0.34.4",
+    "ipfs-http-client": "^30.1.0"
   }
 }

src/create.js

@@ -1,8 +1,7 @@
 'use strict'
 
-const promisify = require('promisify-es6')
 const IPFS = require('ipfs')
-const remote = require('ipfs-api')
+const remote = require('ipfs-http-client')
 const mfs = require('./mfs')
 const log = require('debug')('ipfs:blob-store:create')
 const defaultOptions = {
@@ -11,43 +10,31 @@ const defaultOptions = {
   baseDir: '/'
 }
 
-module.exports = promisify((opts, callback) => {
-  if (typeof opts === 'function') {
-    callback = opts
-    opts = defaultOptions
-  }
-
+module.exports = async (opts) => {
   const options = Object.assign({}, defaultOptions, opts)
 
   if (options.ipfs) {
     log('Using pre-configured IPFS instance')
-    return setImmediate(() => callback(null, mfs(options)))
+    return mfs(options)
   }
 
   if (options.host && options.port) {
     log(`Connecting to remote IPFS at ${options.host}:${options.port}`)
     options.ipfs = remote(options.host, options.port)
 
-    return setImmediate(() => callback(null, mfs(options)))
+    return mfs(options)
   }
 
   log(`Starting an IPFS instance`)
-  callback = once(callback)
-
-  options.ipfs = new IPFS()
-  options.ipfs.once('ready', () => callback(null, mfs(options)))
-  options.ipfs.once('error', (error) => callback(error))
-})
 
-function once (cb) {
-  let called = false
-
-  return function () {
-    if (called) {
-      return
-    }
+  options.ipfs = await getIPFSReadyNode()
+  return mfs(options)
+}
 
-    called = true
-    cb.apply(null, arguments)
-  }
+function getIPFSReadyNode () {
+  return new Promise((resolve, reject) => {
+    const ipfs = new IPFS()
+    ipfs.once('ready', () => resolve(ipfs))
+    ipfs.once('error', reject)
+  })
 }