refactor: Split api definitions into separate files

Author: dignifiedquire

package.json

@@ -9,6 +9,7 @@
     "multipart-stream": "^2.0.0",
     "ndjson": "^1.4.3",
     "qs": "^6.0.0",
+    "require-dir": "^0.3.0",
     "vinyl": "^1.1.0",
     "vinyl-fs-browser": "^2.1.1-1",
     "vinyl-multipart-stream": "^1.2.6",
@@ -50,7 +51,6 @@
     "mocha": "^2.3.3",
     "pre-commit": "^1.0.6",
     "raw-loader": "^0.5.1",
-    "require-dir": "^0.3.0",
     "rimraf": "^2.4.3",
     "run-sequence": "^1.1.4",
     "stream-equal": "^0.1.7",

src/api/add.js

@@ -0,0 +1,22 @@
+const Wreck = require('wreck')
+
+module.exports = send => {
+  return function add (files, opts, cb) {
+    if (typeof (opts) === 'function' && cb === undefined) {
+      cb = opts
+      opts = {}
+    }
+
+    if (typeof files === 'string' && files.startsWith('http')) {
+      Wreck.request('GET', files, null, (err, res) => {
+        if (err) return cb(err)
+
+        send('add', null, opts, res, cb)
+      })
+
+      return
+    }
+
+    send('add', null, opts, files, cb)
+  }
+}

src/api/block.js

@@ -0,0 +1,15 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return {
+    get: argCommand(send, 'block/get'),
+    put (file, cb) {
+      if (Array.isArray(file)) {
+        return cb(null, new Error('block.put() only accepts 1 file'))
+      }
+      return send('block/put', null, null, file, cb)
+    }
+  }
+}

src/api/cat.js

@@ -0,0 +1,7 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return argCommand(send, 'cat')
+}

src/api/commands.js

@@ -0,0 +1,7 @@
+'use strict'
+
+const command = require('../cmd-helpers').command
+
+module.exports = send => {
+  return command(send, 'commands')
+}

src/api/config.js

@@ -0,0 +1,22 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return {
+    get: argCommand(send, 'config'),
+    set (key, value, opts, cb) {
+      if (typeof (opts) === 'function') {
+        cb = opts
+        opts = {}
+      }
+      return send('config', [key, value], opts, null, cb)
+    },
+    show (cb) {
+      return send('config/show', null, null, null, true, cb)
+    },
+    replace (file, cb) {
+      return send('config/replace', null, null, file, cb)
+    }
+  }
+}

src/api/dht.js

@@ -0,0 +1,40 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return {
+    findprovs: argCommand(send, 'dht/findprovs'),
+    get (key, opts, cb) {
+      if (typeof (opts) === 'function' && !cb) {
+        cb = opts
+        opts = null
+      }
+
+      return send('dht/get', key, opts, null, (err, res) => {
+        if (err) return cb(err)
+        if (!res) return cb(new Error('empty response'))
+        if (res.length === 0) return cb(new Error('no value returned for key'))
+
+        // Inconsistent return values in the browser vs node
+        if (Array.isArray(res)) {
+          res = res[0]
+        }
+
+        if (res.Type === 5) {
+          cb(null, res.Extra)
+        } else {
+          cb(res)
+        }
+      })
+    },
+    put (key, value, opts, cb) {
+      if (typeof (opts) === 'function' && !cb) {
+        cb = opts
+        opts = null
+      }
+
+      return send('dht/put', [key, value], opts, null, cb)
+    }
+  }
+}

src/api/diag.js

@@ -0,0 +1,10 @@
+'use strict'
+
+const command = require('../cmd-helpers').command
+
+module.exports = send => {
+  return {
+    net: command(send, 'diag/net'),
+    sys: command(send, 'diag/sys')
+  }
+}

src/api/id.js

@@ -0,0 +1,11 @@
+'use strict'
+
+module.exports = send => {
+  return function id (id, cb) {
+    if (typeof id === 'function') {
+      cb = id
+      id = null
+    }
+    return send('id', id, null, null, cb)
+  }
+}

src/api/log.js

@@ -0,0 +1,14 @@
+'use strict'
+
+const ndjson = require('ndjson')
+
+module.exports = send => {
+  return {
+    tail (cb) {
+      send('log/tail', null, {}, null, false, (err, res) => {
+        if (err) return cb(err)
+        cb(null, res.pipe(ndjson.parse()))
+      })
+    }
+  }
+}

src/api/ls.js

@@ -0,0 +1,7 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return argCommand(send, 'ls')
+}

src/api/mount.js

@@ -0,0 +1,17 @@
+'use strict'
+
+module.exports = send => {
+  return function mount (ipfs, ipns, cb) {
+    if (typeof ipfs === 'function') {
+      cb = ipfs
+      ipfs = null
+    } else if (typeof ipns === 'function') {
+      cb = ipns
+      ipns = null
+    }
+    const opts = {}
+    if (ipfs) opts.f = ipfs
+    if (ipns) opts.n = ipns
+    return send('mount', null, opts, null, cb)
+  }
+}

src/api/name.js

@@ -0,0 +1,10 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return {
+    publish: argCommand(send, 'name/publish'),
+    resolve: argCommand(send, 'name/resolve')
+  }
+}

src/api/object.js

@@ -0,0 +1,21 @@
+'use strict'
+
+const argCommand = require('../cmd-helpers').argCommand
+
+module.exports = send => {
+  return {
+    get: argCommand(send, 'object/get'),
+    put (file, encoding, cb) {
+      if (typeof encoding === 'function') {
+        return cb(null, new Error("Must specify an object encoding ('json' or 'protobuf')"))
+      }
+      return send('object/put', encoding, null, file, cb)
+    },
+    data: argCommand(send, 'object/data'),
+    stat: argCommand(send, 'object/stat'),
+    links: argCommand(send, 'object/links'),
+    patch (file, opts, cb) {
+      return send('object/patch', [file].concat(opts), null, null, cb)
+    }
+  }
+}

src/api/pin.js

@@ -0,0 +1,31 @@
+'use strict'
+
+module.exports = send => {
+  return {
+    add (hash, opts, cb) {
+      if (typeof opts === 'function') {
+        cb = opts
+        opts = null
+      }
+
+      send('pin/add', hash, opts, null, cb)
+    },
+    remove (hash, opts, cb) {
+      if (typeof opts === 'function') {
+        cb = opts
+        opts = null
+      }
+
+      send('pin/rm', hash, opts, null, cb)
+    },
+    list (type, cb) {
+      if (typeof type === 'function') {
+        cb = type
+        type = null
+      }
+      let opts = null
+      if (type) opts = { type: type }
+      return send('pin/ls', null, opts, null, cb)
+    }
+  }
+}

src/api/ping.js

@@ -0,0 +1,10 @@
+'use strict'
+
+module.exports = send => {
+  return function ping (id, cb) {
+    return send('ping', id, { n: 1 }, null, function (err, res) {
+      if (err) return cb(err, null)
+      cb(null, res[1])
+    })
+  }
+}

src/api/refs.js

@@ -0,0 +1,10 @@
+'use strict'
+
+const cmds = require('../cmd-helpers')
+
+module.exports = send => {
+  const refs = cmds.argCommand(send, 'refs')
+  refs.local = cmds.command(send, 'refs/local')
+
+  return refs
+}

src/api/swarm.js

@@ -0,0 +1,10 @@
+'use strict'
+
+const cmds = require('../cmd-helpers')
+
+module.exports = send => {
+  return {
+    peers: cmds.command(send, 'swarm/peers'),
+    connect: cmds.argCommand(send, 'swarm/connect')
+  }
+}

src/api/update.js

@@ -0,0 +1,11 @@
+'use strict'
+
+const command = require('../cmd-helpers').command
+
+module.exports = send => {
+  return {
+    apply: command(send, 'update'),
+    check: command(send, 'update/check'),
+    log: command(send, 'update/log')
+  }
+}

src/api/version.js

@@ -0,0 +1,7 @@
+'use strict'
+
+const command = require('../cmd-helpers').command
+
+module.exports = send => {
+  return command(send, 'version')
+}

src/cmd-helpers.js

@@ -0,0 +1,21 @@
+'use strict'
+
+exports.command = function command (send, name) {
+  return (opts, cb) => {
+    if (typeof (opts) === 'function') {
+      cb = opts
+      opts = {}
+    }
+    return send(name, null, opts, null, cb)
+  }
+}
+
+exports.argCommand = function argCommand (send, name) {
+  return (arg, opts, cb) => {
+    if (typeof (opts) === 'function') {
+      cb = opts
+      opts = {}
+    }
+    return send(name, arg, opts, null, cb)
+  }
+}