feat: initial implementation

.gitignore

@@ -0,0 +1,42 @@
+**/node_modules/
+**/*.log
+test/repo-tests*
+**/bundle.js
+docs
+# Logs
+logs
+*.log
+
+coverage
+
+# Runtime data
+pids
+*.pid
+*.seed
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# node-waf configuration
+.lock-wscript
+
+build
+
+# Dependency directory
+# https://www.npmjs.org/doc/misc/npm-faq.html#should-i-check-my-node_modules-folder-into-git
+node_modules
+
+lib
+dist
+test/test-data/go-ipfs-repo/LOCK
+test/test-data/go-ipfs-repo/LOG
+test/test-data/go-ipfs-repo/LOG.old
+
+# while testing npm5
+package-lock.json

README.md

@@ -1,33 +1,36 @@
-# Interoperability Compliance Test Stories for libp2p
+# Interoperability Tests for libp2p
 
-<a href="http://protocol.ai"><img src="https://img.shields.io/badge/made%20by-Protocol%20Labs-blue.svg?style=flat-square" /></a>
-<a href="http://libp2p.io/"><img src="https://img.shields.io/badge/project-libp2p-yellow.svg?style=flat-square" /></a>
-<a href="http://webchat.freenode.net/?channels=%23libp2p"><img src="https://img.shields.io/badge/freenode-%23libp2p-yellow.svg?style=flat-square" /></a>
-<a href="https://waffle.io/libp2p/libp2p"><img src="https://img.shields.io/badge/pm-waffle-yellow.svg?style=flat-square" /></a>
+[![](https://img.shields.io/badge/made%20by-Protocol%20Labs-blue.svg?style=flat-square)](https://protocol.ai/)
+[![](https://img.shields.io/badge/project-libp2p-yellow.svg?style=flat-square)](http://libp2p.io/)
+[![](https://img.shields.io/badge/freenode-%23ipfs-blue.svg?style=flat-square)](http://webchat.freenode.net/?channels=%23libp2p)
 
-> In this repo you will find the [PDD (Protocol Driven Development)](https://github.com/ipfs/pdd) stories that enable you to test a libp2p implementation against other implementations.
+> Interoperability tests for libp2p Implementations
 
-## ❗️ Important
+This repository will be used for interop tests.
 
-**The setup for these tests is still in flux, please make sure to read the latest update at: https://github.com/libp2p/interop/issues/1**
+## Usage
 
-## PDD Compliance Test Stories
+### Install
 
-Each Test Story has actors and a dramatization.
+```
+> git clone git@github.com:libp2p/interop.git
+> cd interop
+> npm install
+```
 
-- **Qualitative** - Test Stories that check feature interoperability and compliance.
-  - [Transports](./PDD-TRANSPORTS.md)
-  - [Protocol and Stream Multiplexing](./PDD-PROTOCOL-AND-STREAM-MULTIPLEXING.md)
-  - [Identify](./PDD-IDENTIFY.md)
-  - [Encrypted Communications](./PDD-ENCRYPTED-COMMUNICATIONS.md)
-  - [Peer Routing](./PDD-PEER-ROUTING.md)
-  - [Content Routing](./PDD-CONTENT-ROUTING.md)
-  - [PubSub](./PDD-PUBSUB.md)
-  - [Circuit Relay](./PDD-CIRCUIT-RELAY.md)
-  - [The IPFS bundle](./PDD-THE-IPFS-BUNDLE.md)
-- **Quantitative** - Test Stories focused on stress testing the implementations against each other.
-  - [Thousands of Muxed Streams](./PDD-THOUSANDS-OF-MUXED-STREAMS.md)
-  - [Hundreds of Peer Connections](./PDD-HUNDREDS-OF-PEER-CONNECTIONS.md)
+### Run the tests
+
+```
+> npm test
+```
+
+### Test with a non yet released version of js-ipfs
+
+TODO
+
+### Test with a non yet released version of go-ipfs
+
+TODO
 
 ## Contribute
 

ci/Jenkinsfile

@@ -0,0 +1,2 @@
+// Warning: This file is automatically synced from https://github.com/ipfs/ci-sync so if you want to change it, please change it there and ask someone to sync all repositories.
+javascript()

package.json

@@ -1,19 +1,44 @@
 {
-  "name": "libp2p-interop",
+  "name": "interop-libp2p",
   "version": "0.0.0",
-  "description": "",
-  "main": " ",
+  "description": "Interoperability Tests for libp2p",
+  "leadMaintainer": "Vasco Santos <santos.vasco10@gmail.com>",
+  "main": "",
+  "engines": {
+    "node": ">=10.0.0",
+    "npm": ">6.0.0"
+  },
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "lint": "aegir lint",
+    "test": "cross-env IPFS_REUSEPORT=false aegir test",
+    "test:node": "cross-env IPFS_REUSEPORT=false aegir test -t node -f test/node.js",
+    "test:browser": "cross-env IPFS_REUSEPORT=false aegir test -t browser --no-cors -f test/browser.js"
   },
   "repository": {
     "type": "git",
     "url": "git+https://github.com/libp2p/interop.git"
   },
-  "author": "David Dias <daviddias@ipfs.io>",
+  "keywords": [
+    "libp2p"
+  ],
   "license": "MIT",
   "bugs": {
     "url": "https://github.com/libp2p/interop/issues"
   },
-  "homepage": "https://github.com/libp2p/interop#readme"
+  "homepage": "https://github.com/libp2p/interop#readme",
+  "devDependencies": {
+    "aegir": "^17.0.1",
+    "chai": "^4.2.0",
+    "chai-checkmark": "^1.0.1",
+    "cross-env": "^5.2.0",
+    "dirty-chai": "^2.0.1",
+    "go-libp2p-dep": "libp2p/npm-go-libp2p-dep#feat/initial-implementation",
+    "libp2p-daemon": "~0.1.0",
+    "libp2p-daemon-client": "~0.0.2",
+    "rimraf": "^2.6.3"
+  },
+  "contributors": [],
+  "dependencies": {
+    "execa": "^1.0.0"
+  }
 }

src/daemon.js

@@ -0,0 +1,111 @@
+'use strict'
+
+const assert = require('assert')
+const execa = require('execa')
+const rimraf = require('rimraf')
+
+const Client = require('libp2p-daemon-client')
+
+// go-libp2p defaults
+const goDaemon = {
+  defaultSock: '/tmp/p2pd-go.sock',
+  bin: './node_modules/go-libp2p-dep/go-libp2p/p2pd'
+}
+
+// js-libp2p defaults
+const jsDaemon = {
+  defaultSock: '/tmp/p2pd-js.sock',
+  bin: './node_modules/libp2p-daemon/src/cli/bin.js'
+}
+
+class Daemon {
+  /**
+   * @constructor
+   * @param {String} type daemon implementation type ("go" or "js")
+   * @param {String} sock unix socket path
+   */
+  constructor (type, sock) {
+    assert(type === 'go' || type === 'js', 'invalid type received. Should be "go" or "js"')
+
+    this._client = undefined
+    this._type = type
+    this._binPath = type === 'go' ? goDaemon.bin : jsDaemon.bin
+    this._sock = sock
+
+    if (!this._sock) {
+      this._sock = type === 'go' ? goDaemon.defaultSock : jsDaemon.defaultSock
+    }
+  }
+
+  /**
+   * @async
+   * Starts a daemon and a client associated with it.
+   * @returns {void}
+   */
+  async start () {
+    if (this._client) {
+      throw new Error('Daemon has already started')
+    }
+
+    // start daemon
+    await this._startDaemon()
+
+    // start client
+    this._client = new Client(this._sock)
+
+    await this._client.attach()
+  }
+
+  /**
+   * Starts the specifiec daemon and wait for its start.
+   * @returns {Promise}
+   */
+  _startDaemon () {
+    return new Promise((resolve, reject) => {
+      const options = this._type === 'go' ? ['-sock', this._sock] : ['--sock', this._sock]
+      const daemon = execa(this._binPath, options)
+
+      daemon.stdout.once('data', () => {
+        return resolve()
+      })
+      daemon.stderr.once('data', (data) => {
+        return reject(data.toString())
+      })
+    })
+  }
+
+  /**
+   * @async
+   * Stops the daemon client and cleans the unix socket.
+   * @returns {void}
+   */
+  async stop () {
+    await this._client && this._client.close()
+    await this._cleanUnixSocket()
+  }
+
+  /**
+   * Cleans the unix socket.
+   * @returns {Promise}
+   */
+  _cleanUnixSocket () {
+    return new Promise((resolve, reject) => {
+      rimraf(this._sock, (err) => {
+        if (err) {
+          return reject(err)
+        }
+        resolve()
+      })
+    })
+  }
+
+  /**
+   * libp2p client instance
+   * @type {Client}
+   */
+  get client () {
+    return this._client
+  }
+}
+
+exports = module.exports = Daemon

test/connect.js

@@ -0,0 +1,61 @@
+/* eslint-env mocha */
+'use strict'
+
+const chai = require('chai')
+chai.use(require('dirty-chai'))
+chai.use(require('chai-checkmark'))
+const expect = chai.expect
+
+const Daemon = require('../src/daemon')
+
+describe('connect', () => {
+  let goDaemon
+  let jsDaemon
+
+  // Start Daemons
+  beforeEach(async function () {
+    goDaemon = new Daemon('go')
+    jsDaemon = new Daemon('js')
+
+    await goDaemon.start()
+    await jsDaemon.start()
+  })
+
+  // Stop daemons
+  afterEach(async function () {
+    await goDaemon.stop()
+    await jsDaemon.stop()
+  })
+
+  it('a js peer should be able to connect with a go peer', async function () {
+    this.timeout(10 * 1000)
+
+    const identifyGo = await goDaemon.client.identify()
+
+    const knownPeersBeforeConnect = await jsDaemon.client.listPeers()
+    expect(knownPeersBeforeConnect).to.have.lengthOf(0)
+
+    // connect peers
+    await jsDaemon.client.connect(identifyGo.peerId, identifyGo.addrs)
+
+    const knownPeersAfterConnect = await jsDaemon.client.listPeers()
+    expect(knownPeersAfterConnect).to.have.lengthOf(1)
+    expect(knownPeersAfterConnect[0].toB58String()).to.equal(identifyGo.peerId.toB58String())
+  })
+
+  it.skip('a go peer should be able to connect with a js peer', async function () {
+    this.timeout(10 * 1000)
+
+    const identifyJs = await jsDaemon.client.identify()
+
+    const knownPeersBeforeConnect = await goDaemon.client.listPeers()
+    expect(knownPeersBeforeConnect).to.have.lengthOf(0)
+
+    // connect peers
+    await goDaemon.client.connect(identifyJs.peerId, identifyJs.addrs)
+
+    const knownPeersAfterConnect = await goDaemon.client.listPeers()
+    expect(knownPeersAfterConnect).to.have.lengthOf(1)
+    expect(knownPeersAfterConnect[0].toB58String()).to.equal(identifyJs.peerId.toB58String())
+  })
+})

test/node.js

@@ -0,0 +1,4 @@
+/* eslint-env mocha */
+'use strict'
+
+require('./connect')