Label async functions

src/api-addr.js

@@ -22,15 +22,15 @@ module.exports = (store) => {
      * @param {Object} value - the api address to be written
      * @returns {Promise<void>}
      */
-    set (value) {
+    async set (value) {
       return store.put(apiFile, Buffer.from(value.toString()))
     },
     /**
      * Deletes api file
      *
      * @returns {Promise<void>}
      */
-    delete () {
+    async delete () {
       return store.delete(apiFile)
     }
   }

src/config.js

@@ -20,7 +20,7 @@ module.exports = (store) => {
      * @param {String} key - the config key to get
      * @returns {Promise<Object>}
      */
-    get (key) {
+    async get (key) {
       if (!key) {
         key = undefined
       }
@@ -61,7 +61,7 @@ module.exports = (store) => {
      *
      * @returns {Promise<bool>}
      */
-    exists () {
+    async exists () {
       return store.has(configKey)
     }
   }

src/index.js

@@ -147,7 +147,7 @@ class IpfsRepo {
    *
    * @returns {Promise<void>}
    */
-  _closeLock () {
+  async _closeLock () {
     if (this.lockfile) {
       return this.lockfile.close()
     }

src/lock-memory.js

@@ -14,7 +14,7 @@ const LOCKS = {}
  * @param {string} dir
  * @returns {Promise<Object>}
  */
-exports.lock = (dir) => {
+exports.lock = async (dir) => {
   const file = dir + '/' + lockFile
   log('locking %s', file)
   LOCKS[file] = true

src/lock.js

@@ -22,7 +22,7 @@ const STALE_TIME = 20000
  * Lock the repo in the given dir.
  *
  * @param {string} dir
- * @returns {Object}
+ * @returns {Promise<Object>}
  */
 exports.lock = async (dir) => {
   const file = path.join(dir, lockFile)

src/spec.js

@@ -12,25 +12,25 @@ module.exports = (store) => {
      *
      * @returns {Promise<bool>}
      */
-    exists () {
+    async exists () {
       return store.has(specKey)
     },
     /**
      * Get the current datastore spec.
      *
      * @returns {Promise<Buffer>}
      */
-    get () {
-      return store.get()
-        .then(buf => JSON.parse(buf.toString()))
+    async get () {
+      const buf = await store.get()
+      return JSON.parse(buf.toString())
     },
     /**
      * Set the datastore spec of the repo, writing it to the underlying store.
      * TODO unclear on what the type should be or if it's required
      * @param {number} spec
      * @returns {Promise<void>}
      */
-    set (spec) {
+    async set (spec) {
       return store.put(specKey, Buffer.from(JSON.stringify(sortKeys(spec, { deep: true }))))
     }
   }

src/version.js

@@ -13,25 +13,25 @@ module.exports = (store) => {
      *
      * @returns {Promise<bool>}
      */
-    exists () {
+    async exists () {
       return store.has(versionKey)
     },
     /**
      * Get the current version.
      *
      * @returns {Promise<Integer>}
      */
-    get () {
-      return this.get(versionKey)
-        .then(buf => parseInt(buf.toString().trim(), 10))
+    async get () {
+      const buf =await this.get(versionKey)
+      return parseInt(buf.toString().trim(), 10)
     },
     /**
      * Set the version of the repo, writing it to the underlying store.
      *
      * @param {number} version
-     * @returns {void}
+     * @returns {Promise<void>}
      */
-    set (version) {
+    async set (version) {
       return store.put(versionKey, Buffer.from(String(version)))
     },
     /**