refactor: convert object API to async/await

Author: Alan Shaw

src/core/components/index.js

@@ -9,6 +9,7 @@ exports.bitswap = {
 exports.config = require('./config')
 exports.id = require('./id')
 exports.init = require('./init')
+exports.object = require('./object')
 exports.ping = require('./ping')
 exports.start = require('./start')
 exports.stop = require('./stop')
@@ -17,6 +18,5 @@ exports.version = require('./version')
 exports.legacy = { // TODO: these will be removed as the new API is completed
   dag: require('./dag'),
   libp2p: require('./libp2p'),
-  object: require('./object'),
   pin: require('./pin')
 }

src/core/components/init.js

@@ -102,7 +102,20 @@ module.exports = ({
     })
 
     const dag = Commands.legacy.dag({ _ipld: ipld, _preload: preload })
-    const object = Commands.legacy.object({ _ipld: ipld, _preload: preload, dag, _gcLock: gcLock })
+    const object = {
+      data: Commands.object.data({ ipld, preload }),
+      get: Commands.object.get({ ipld, preload }),
+      links: Commands.object.links({ dag }),
+      new: Commands.object.new({ ipld, preload }),
+      patch: {
+        addLink: Commands.object.patch.addLink({ ipld, gcLock, preload }),
+        appendData: Commands.object.patch.appendData({ ipld, gcLock, preload }),
+        rmLink: Commands.object.patch.rmLink({ ipld, gcLock, preload }),
+        setData: Commands.object.patch.setData({ ipld, gcLock, preload })
+      },
+      put: Commands.object.put({ ipld, gcLock, preload }),
+      stat: Commands.object.stat({ ipld, preload })
+    }
 
     const pinManager = new PinManager(repo, dag)
     await pinManager.load()
@@ -134,6 +147,7 @@ module.exports = ({
       initOptions: options,
       ipld,
       keychain,
+      object,
       peerInfo,
       pinManager,
       preload,
@@ -276,6 +290,7 @@ function createApi ({
   initOptions,
   ipld,
   keychain,
+  object,
   peerInfo,
   pinManager,
   preload,
@@ -302,6 +317,7 @@ function createApi ({
     config: Commands.config({ repo }),
     id: Commands.id({ peerInfo }),
     init: () => { throw new AlreadyInitializedError() },
+    object,
     start,
     version: Commands.version({ repo })
   }

src/core/components/object.js

@@ -0,0 +1,9 @@
+'use strict'
+
+module.exports = ({ ipld, preload }) => {
+  const get = require('./get')({ ipld, preload })
+  return async function data (multihash, options) {
+    const node = await get(multihash, options)
+    return node.Data
+  }
+}