refactor: convert files regular, name and refs APIs to async/await

package.json

@@ -16,7 +16,6 @@
   "main": "src/core/index.js",
   "browser": {
     "./src/core/runtime/init-assets-nodejs.js": "./src/core/runtime/init-assets-browser.js",
-    "./src/core/runtime/add-from-fs-nodejs.js": "./src/core/runtime/add-from-fs-browser.js",
     "./src/core/runtime/config-nodejs.js": "./src/core/runtime/config-browser.js",
     "./src/core/runtime/dns-nodejs.js": "./src/core/runtime/dns-browser.js",
     "./src/core/runtime/libp2p-nodejs.js": "./src/core/runtime/libp2p-browser.js",
@@ -96,7 +95,6 @@
     "glob": "^7.1.3",
     "hapi-pino": "^6.1.0",
     "hashlru": "^2.3.0",
-    "human-to-milliseconds": "^2.0.0",
     "interface-datastore": "~0.8.0",
     "ipfs-bitswap": "^0.26.0",
     "ipfs-block": "~0.8.1",
@@ -162,6 +160,7 @@
     "node-fetch": "^2.3.0",
     "p-iteration": "^1.1.8",
     "p-queue": "^6.1.0",
+    "parse-duration": "^0.1.2",
     "peer-book": "^0.9.1",
     "peer-id": "~0.12.2",
     "peer-info": "~0.15.1",

src/core/components/add/index.js

@@ -5,7 +5,7 @@ const normaliseAddInput = require('ipfs-utils/src/files/normalise-input')
 const { parseChunkerString } = require('./utils')
 const pipe = require('it-pipe')
 
-module.exports = ({ ipld, dag, gcLock, preload, pin, constructorOptions }) => {
+module.exports = ({ ipld, dag, gcLock, preload, pin, options: constructorOptions }) => {
   const isShardingEnabled = constructorOptions.EXPERIMENTAL && constructorOptions.EXPERIMENTAL.sharding
   return async function * add (source, options) {
     options = options || {}

src/core/components/files-regular/cat-async-iterator.js → src/core/components/cat.js

@@ -1,20 +1,20 @@
 'use strict'
 
 const exporter = require('ipfs-unixfs-exporter')
-const { normalizePath } = require('./utils')
+const { normalizeCidPath } = require('../utils')
 
-module.exports = function (self) {
-  return async function * catAsyncIterator (ipfsPath, options) {
+module.exports = function ({ ipld, preload }) {
+  return async function * cat (ipfsPath, options) {
     options = options || {}
 
-    ipfsPath = normalizePath(ipfsPath)
+    ipfsPath = normalizeCidPath(ipfsPath)
 
     if (options.preload !== false) {
       const pathComponents = ipfsPath.split('/')
-      self._preload(pathComponents[0])
+      preload(pathComponents[0])
     }
 
-    const file = await exporter(ipfsPath, self._ipld, options)
+    const file = await exporter(ipfsPath, ipld, options)
 
     // File may not have unixfs prop if small & imported with rawLeaves true
     if (file.unixfs && file.unixfs.type.includes('dir')) {

src/core/components/dns.js

@@ -2,7 +2,6 @@
 
 // dns-nodejs gets replaced by dns-browser when webpacked/browserified
 const dns = require('../runtime/dns-nodejs')
-const callbackify = require('callbackify')
 
 function fqdnFixups (domain) {
   // Allow resolution of .eth names via .eth.link
@@ -14,7 +13,7 @@ function fqdnFixups (domain) {
 }
 
 module.exports = () => {
-  return callbackify.variadic(async (domain, opts) => { // eslint-disable-line require-await
+  return async (domain, opts) => { // eslint-disable-line require-await
     opts = opts || {}
 
     if (typeof domain !== 'string') {
@@ -24,5 +23,5 @@ module.exports = () => {
     domain = fqdnFixups(domain)
 
     return dns(domain, opts)
-  })
+  }
 }