feat: add the stat commands (#639)

* Add Stat Commands

* add submodules spec

* Add Stats commands

README.md

@@ -250,6 +250,10 @@ $ ipfs config --json API.HTTPHeaders.Access-Control-Allow-Methods "[\"PUT\", \"P
   - [`ipfs.config.get([key, callback])`](https://github.com/ipfs/interface-ipfs-core/tree/master/SPEC/CONFIG.md#configget)
   - [`ipfs.config.set(key, value, [callback])`](https://github.com/ipfs/interface-ipfs-core/tree/master/SPEC/CONFIG.md#configset)
   - [`ipfs.config.replace(config, [callback])`](https://github.com/ipfs/interface-ipfs-core/tree/master/SPEC/CONFIG.md#configreplace)
+- stats:
+  - `ipfs.stats.bitswap([callback])`
+  - `ipfs.stats.bw([options, callback])`
+  - `ipfs.stats.repo([options, callback])`
 - log:
   - `ipfs.log.ls([callback])`
   - `ipfs.log.tail([callback])`

src/stats/bitswap.js

@@ -0,0 +1,17 @@
+'use strict'
+
+const promisify = require('promisify-es6')
+
+module.exports = (send) => {
+  return promisify((opts, callback) => {
+    if (typeof (opts) === 'function') {
+      callback = opts
+      opts = {}
+    }
+
+    send({
+      path: 'stats/bitswap',
+      qs: opts
+    }, callback)
+  })
+}

src/stats/bw.js

@@ -0,0 +1,17 @@
+'use strict'
+
+const promisify = require('promisify-es6')
+
+module.exports = (send) => {
+  return promisify((opts, callback) => {
+    if (typeof (opts) === 'function') {
+      callback = opts
+      opts = {}
+    }
+
+    send({
+      path: 'stats/bw',
+      qs: opts
+    }, callback)
+  })
+}

src/stats/index.js

@@ -0,0 +1,13 @@
+'use strict'
+
+const moduleConfig = require('../utils/module-config')
+
+module.exports = (arg) => {
+  const send = moduleConfig(arg)
+
+  return {
+    bitswap: require('./bitswap')(send),
+    bw: require('./bw')(send),
+    repo: require('./repo')(send)
+  }
+}

src/stats/repo.js

@@ -0,0 +1,18 @@
+
+'use strict'
+
+const promisify = require('promisify-es6')
+
+module.exports = (send) => {
+  return promisify((opts, callback) => {
+    if (typeof (opts) === 'function') {
+      callback = opts
+      opts = {}
+    }
+
+    send({
+      path: 'stats/repo',
+      qs: opts
+    }, callback)
+  })
+}

src/utils/load-commands.js

@@ -33,6 +33,7 @@ function requireCommands () {
     ping: require('../ping'),
     refs: require('../refs'),
     repo: require('../repo'),
+    stats: require('../stats'),
     swarm: require('../swarm'),
     pubsub: require('../pubsub'),
     update: require('../update'),

test/sub-modules.spec.js

@@ -110,6 +110,14 @@ describe('submodules', () => {
     expect(repo.stat).to.be.a('function')
   })
 
+  it('stats', () => {
+    const stats = require('../src/stats')(config)
+
+    expect(stats.bitswap).to.be.a('function')
+    expect(stats.bw).to.be.a('function')
+    expect(stats.repo).to.be.a('function')
+  })
+
   it('swarm', () => {
     const swarm = require('../src/swarm')(config)