test(interop): node.js basics

Author: dignifiedquire

package.json

@@ -26,8 +26,8 @@
     "test:unit:node:http": "TEST=http npm run test:node",
     "test:unit:node:cli": "TEST=cli npm run test:node",
     "test:unit:browser": "gulp test:browser",
-    "test:interop": "mocha test/interop",
-    "test:interop:node": "mocha test/interop/node.js",
+    "test:interop": "mocha -t 60000 test/interop",
+    "test:interop:node": "mocha -t 60000 test/interop/node.js",
     "test:interop:browser": "mocha test/interop/browser.js",
     "test:benchmark": "echo \"Error: no benchmarks yet\" && exit 1",
     "test:benchmark:node": "echo \"Error: no benchmarks yet\" && exit 1",

test/interop/daemons/go.js

@@ -0,0 +1,32 @@
+'use strict'
+
+const ctl = require('ipfsd-ctl')
+const waterfall = require('async/waterfall')
+
+class GoDaemon {
+  constructor () {
+    this.node = null
+    this.api = null
+  }
+
+  start (callback) {
+    console.log('starting go')
+    waterfall([
+      (cb) => ctl.disposable(cb),
+      (node, cb) => {
+        this.node = node
+        this.node.startDaemon(cb)
+      },
+      (api, cb) => {
+        this.api = api
+        cb()
+      }
+    ], callback)
+  }
+
+  stop (callback) {
+    this.node.stopDaemon(callback)
+  }
+}
+
+module.exports = GoDaemon

test/interop/daemons/js.js

@@ -0,0 +1,42 @@
+'use strict'
+
+const os = require('os')
+const IPFSAPI = require('ipfs-api')
+const series = require('async/series')
+const rimraf = require('rimraf')
+
+const IPFS = require('../../../src/core')
+const HTTPAPI = require('../../../src/http-api')
+
+class JsDaemon {
+  constructor () {
+    this.repoPath = os.tmpdir() + `${Math.ceil(Math.random() * 100)}`
+    this.ipfs = new IPFS(this.repoPath)
+    this.node = null
+    this.api = null
+  }
+
+  start (callback) {
+    console.log('starting js', this.repoPath)
+    series([
+      (cb) => this.ipfs.init(cb),
+      (cb) => {
+        this.node = new HTTPAPI(this.ipfs._repo)
+        this.node.start(cb)
+      },
+      (cb) => {
+        this.api = new IPFSAPI(this.node.apiMultiaddr)
+        cb()
+      }
+    ], callback)
+  }
+
+  stop (callback) {
+    series([
+      (cb) => this.node.stop(cb),
+      (cb) => rimraf(this.repoPath, cb)
+    ], callback)
+  }
+}
+
+module.exports = JsDaemon

test/interop/index.js

@@ -0,0 +1,88 @@
+/* eslint-env mocha */
+'use strict'
+
+const expect = require('chai').expect
+const series = require('async/series')
+const parallel = require('async/parallel')
+const waterfall = require('async/waterfall')
+const bl = require('bl')
+const crypto = require('crypto')
+
+const GoDaemon = require('./daemons/go')
+const JsDaemon = require('./daemons/js')
+
+describe('interop', () => {
+  let goDaemon
+  let jsDaemon
+
+  before((done) => {
+    goDaemon = new GoDaemon()
+    jsDaemon = new JsDaemon()
+
+    parallel([
+      (cb) => goDaemon.start(cb),
+      (cb) => jsDaemon.start(cb)
+    ], done)
+  })
+
+  after((done) => {
+    parallel([
+      (cb) => goDaemon.stop(cb),
+      (cb) => jsDaemon.stop(cb)
+    ], done)
+  })
+
+  it('connect go <-> js', (done) => {
+    let jsId
+    let goId
+
+    series([
+      (cb) => parallel([
+        (cb) => jsDaemon.api.id(cb),
+        (cb) => goDaemon.api.id(cb)
+      ], (err, ids) => {
+        expect(err).to.not.exist
+        jsId = ids[0]
+        goId = ids[1]
+        cb()
+      }),
+      (cb) => goDaemon.api.swarm.connect(jsId.addresses[0], cb),
+      (cb) => jsDaemon.api.swarm.connect(goId.addresses[0], cb),
+      (cb) => parallel([
+        (cb) => goDaemon.api.swarm.peers(cb),
+        (cb) => jsDaemon.api.swarm.peers(cb)
+      ], (err, peers) => {
+        expect(err).to.not.exist
+        expect(peers[0].map((p) => p.peer.toB58String())).to.include(jsId.id)
+        expect(peers[1].map((p) => p.peer.toB58String())).to.include(goId.id)
+        cb()
+      })
+    ], done)
+  })
+
+  it('cat file: go -> js', (done) => {
+    const data = crypto.randomBytes(1024 * 5)
+    waterfall([
+      (cb) => goDaemon.api.add(data, cb),
+      (res, cb) => jsDaemon.api.cat(res[0].hash, cb),
+      (stream, cb) => stream.pipe(bl(cb))
+    ], (err, file) => {
+      expect(err).to.not.exist
+      expect(file).to.be.eql(data)
+      done()
+    })
+  })
+
+  it('cat file: js -> go', (done) => {
+    const data = crypto.randomBytes(1024 * 5)
+    waterfall([
+      (cb) => jsDaemon.api.add(data, cb),
+      (res, cb) => goDaemon.api.cat(res[0].hash, cb),
+      (stream, cb) => stream.pipe(bl(cb))
+    ], (err, file) => {
+      expect(err).to.not.exist
+      expect(file).to.be.eql(data)
+      done()
+    })
+  })
+})

test/interop/node.js

@@ -0,0 +1,3 @@
+'use strict'
+
+require('./index')