jsipfs swarm

libp2p start and stop

not fail on browser tests. separate browser and node.js swarm tests

src/cli/commands/swarm/addrs.js

@@ -0,0 +1,21 @@
+const Command = require('ronin').Command
+const utils = require('../../utils')
+const bs58 = require('bs58')
+const debug = require('debug')
+const log = debug('cli:object')
+log.error = debug('cli:object:error')
+
+module.exports = Command.extend({
+  desc: '',
+
+  options: {},
+
+  run: () => {
+    utils.getIPFS((err, ipfs) => {
+      if (err) {
+        throw err
+      }
+      // TODO
+    })
+  }
+})

src/cli/commands/swarm/addrs/local.js

@@ -0,0 +1,21 @@
+const Command = require('ronin').Command
+const utils = require('../../../utils')
+const bs58 = require('bs58')
+const debug = require('debug')
+const log = debug('cli:object')
+log.error = debug('cli:object:error')
+
+module.exports = Command.extend({
+  desc: '',
+
+  options: {},
+
+  run: () => {
+    utils.getIPFS((err, ipfs) => {
+      if (err) {
+        throw err
+      }
+      // TODO
+    })
+  }
+})

src/cli/commands/swarm/connect.js

@@ -0,0 +1,21 @@
+const Command = require('ronin').Command
+const utils = require('../../utils')
+const bs58 = require('bs58')
+const debug = require('debug')
+const log = debug('cli:object')
+log.error = debug('cli:object:error')
+
+module.exports = Command.extend({
+  desc: '',
+
+  options: {},
+
+  run: () => {
+    utils.getIPFS((err, ipfs) => {
+      if (err) {
+        throw err
+      }
+      // TODO
+    })
+  }
+})

src/cli/commands/swarm/disconnect.js

@@ -0,0 +1,21 @@
+const Command = require('ronin').Command
+const utils = require('../../utils')
+const bs58 = require('bs58')
+const debug = require('debug')
+const log = debug('cli:object')
+log.error = debug('cli:object:error')
+
+module.exports = Command.extend({
+  desc: '',
+
+  options: {},
+
+  run: () => {
+    utils.getIPFS((err, ipfs) => {
+      if (err) {
+        throw err
+      }
+      // TODO
+    })
+  }
+})

src/cli/commands/swarm/peers.js

@@ -0,0 +1,21 @@
+const Command = require('ronin').Command
+const utils = require('../../utils')
+const bs58 = require('bs58')
+const debug = require('debug')
+const log = debug('cli:object')
+log.error = debug('cli:object:error')
+
+module.exports = Command.extend({
+  desc: '',
+
+  options: {},
+
+  run: () => {
+    utils.getIPFS((err, ipfs) => {
+      if (err) {
+        throw err
+      }
+      // TODO
+    })
+  }
+})

src/core/index.js

@@ -323,11 +323,15 @@ function IPFS (repo) {
       libp2pNode.swarm.close(callback)
     },
     swarm: {
-      peers: () => {},
+      peers: (callback) => {
+        callback(null, [])
+      },
+      // all the addrs we know
       addrs: notImpl,
+      localAddrs: notImpl,
       connect: notImpl,
       disconnect: notImpl,
-      filters: notImpl
+      filters: notImpl // TODO
     },
     routing: {},
     records: {},

src/http-api/routes/swarm.js

@@ -0,0 +1,46 @@
+const resources = require('./../resources')
+
+module.exports = (server) => {
+  const api = server.select('API')
+
+  api.route({
+    method: 'GET',
+    path: '/api/v0/swarm/addrs',
+    config: {
+      handler: resources.swarm.addrs.handler
+    }
+  })
+
+  api.route({
+    method: 'GET',
+    path: '/api/v0/swarm/addrs/local',
+    config: {
+      handler: resources.swarm.localAddrs.handler
+    }
+  })
+
+  api.route({
+    method: 'GET',
+    path: '/api/v0/swarm/connect',
+    config: {
+      handler: resources.swarm.connect
+    }
+  })
+
+  api.route({
+    method: 'GET',
+    path: '/api/v0/swarm/disconnect',
+    config: {
+      handler: resources.swarm.disconnect
+    }
+  })
+
+  // TODO
+  // api.route({
+  //  method: 'GET',
+  //  path: '/api/v0/swarm/filters',
+  //  config: {
+  //    handler: resources.swarm.disconnect
+  //  }
+  // })
+}

test/cli-tests/test-commands.js

@@ -9,7 +9,7 @@ describe('commands', () => {
       .run((err, stdout, exitcode) => {
         expect(err).to.not.exist
         expect(exitcode).to.equal(0)
-        expect(stdout.length).to.equal(40)
+        expect(stdout.length).to.equal(45)
         done()
       })
   })

test/core-tests/test-bootstrap.js

@@ -2,7 +2,6 @@
 
 const expect = require('chai').expect
 
-process.env.IPFS_PATH = process.cwd() + '/tests/repo-example'
 const IPFS = require('../../src/core')
 
 describe('bootstrap', () => {

test/core-tests/test-id.js

@@ -2,7 +2,6 @@
 
 const expect = require('chai').expect
 
-process.env.IPFS_PATH = process.cwd() + '/tests/repo-example'
 const IPFS = require('../../src/core')
 
 describe('id', () => {

test/core-tests/test-swarm-node.js

@@ -2,7 +2,6 @@
 
 const expect = require('chai').expect
 
-process.env.IPFS_PATH = process.cwd() + '/tests/repo-example'
 const IPFS = require('../../src/core')
 
 describe('swarm', () => {

test/core-tests/test-version.js

@@ -2,7 +2,6 @@
 
 const expect = require('chai').expect
 
-process.env.IPFS_PATH = process.cwd() + '/tests/repo-example'
 const IPFS = require('../../src/core')
 
 describe('version', () => {