First working version

.gitignore

@@ -31,3 +31,6 @@ node_modules
 
 # Optional REPL history
 .node_repl_history
+
+lib
+dist

.npmignore

@@ -0,0 +1,35 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+
+# 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
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directory
+node_modules
+
+# Optional npm cache directory
+.npm
+
+# Optional REPL history
+.node_repl_history
+
+test

.travis.yml

@@ -0,0 +1,24 @@
+sudo: false
+language: node_js
+node_js:
+  - 4
+  - 5
+
+# Make sure we have new NPM.
+before_install:
+  - npm install -g npm
+
+script:
+  - npm run lint
+  - npm test
+  - npm run coverage
+
+addons:
+  firefox: 'latest'
+
+before_script:
+  - export DISPLAY=:99.0
+  - sh -e /etc/init.d/xvfb start
+
+after_success:
+  - npm run coverage-publish

circle.yml

@@ -0,0 +1,12 @@
+machine:
+  node:
+    version: stable
+
+dependencies:
+  pre:
+    - google-chrome --version
+    - wget -q -O - https://dl-ssl.google.com/linux/linux_signing_key.pub | sudo apt-key add -
+    - sudo sh -c 'echo "deb [arch=amd64] http://dl.google.com/linux/chrome/deb/ stable main" >> /etc/apt/sources.list.d/google.list'
+    - sudo apt-get update
+    - sudo apt-get --only-upgrade install google-chrome-stable
+    - google-chrome --version

gulpfile.js

@@ -0,0 +1,36 @@
+'use strict'
+
+const gulp = require('gulp')
+const multiaddr = require('multiaddr')
+const Node = require('libp2p-ipfs').Node
+const Peer = require('peer-info')
+const Id = require('peer-id')
+
+let node
+const rawPeer = require('./test/peer.json')
+const id = new Id(rawPeer.id, rawPeer.privKey, rawPeer.pubKey)
+
+gulp.task('libnode:start', (done) => {
+  const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/websockets')
+  const peer = new Peer(id)
+  peer.multiaddr.add(mh)
+
+  node = new Node(peer)
+  node.start(() => {
+    node.swarm.handle('/echo/1.0.0', (conn) => {
+      conn.pipe(conn)
+    })
+    done()
+  })
+})
+
+gulp.task('libnode:stop', (done) => {
+  node.swarm.close(done)
+})
+
+gulp.task('test:browser:before', ['libnode:start'])
+gulp.task('test:node:before', ['libnode:start'])
+gulp.task('test:browser:after', ['libnode:stop'])
+gulp.task('test:node:after', ['libnode:stop'])
+
+require('aegir/gulp')(gulp)

package.json

@@ -0,0 +1,56 @@
+{
+  "name": "js-libp2p-ipfs-browser",
+  "version": "1.0.0",
+  "description": "libp2p build (module) used in js-ipfs when running it on the browser",
+  "main": "lib/index.js",
+  "jsnext:main": "src/index.js",
+  "pre-commit": [
+    "lint",
+    "test"
+  ],
+  "scripts": {
+    "test": "gulp test",
+    "lint": "aegir-lint",
+    "test:node": "gulp test:node",
+    "test:browser": "gulp test:browser",
+    "build": "gulp build",
+    "release": "gulp release",
+    "coverage": "gulp coverage",
+    "coverage-publish": "aegir-coverage publish"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/ipfs/js-libp2p-ipfs-browser.git"
+  },
+  "author": "Friedel Ziegelmayer <dignifiedquire@gmail.com>",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/ipfs/js-libp2p-ipfs-browser/issues"
+  },
+  "homepage": "https://github.com/ipfs/js-libp2p-ipfs-browser#readme",
+  "devDependencies": {
+    "aegir": "^2.1.1",
+    "chai": "^3.5.0",
+    "gulp": "^3.9.1",
+    "libp2p-ipfs": "^0.3.1",
+    "peer-id": "^0.6.6",
+    "pre-commit": "^1.1.2"
+  },
+  "dependencies": {
+    "babel-runtime": "^6.6.1",
+    "libp2p-spdy": "^0.3.1",
+    "libp2p-swarm": "^0.10.5",
+    "libp2p-websockets": "^0.3.2",
+    "multiaddr": "^1.4.0",
+    "peer-info": "^0.6.1"
+  },
+  "aegir": {
+    "webpack": {
+      "resolve": {
+        "alias": {
+          "node-forge": "../vendor/forge.bundle.js"
+        }
+      }
+    }
+  }
+}

src/index.js

@@ -0,0 +1,37 @@
+'use strict'
+
+const Swarm = require('libp2p-swarm')
+const Peer = require('peer-info')
+const WS = require('libp2p-websockets')
+const spdy = require('libp2p-spdy')
+
+exports = module.exports
+
+exports.Node = function Node (peerInfo) {
+  if (!(this instanceof Node)) {
+    return new Node(peerInfo)
+  }
+  if (!peerInfo) {
+    peerInfo = new Peer()
+  }
+
+  this.peerInfo = peerInfo
+
+  // Swarm
+  this.swarm = new Swarm(peerInfo)
+  this.swarm.transport.add('ws', new WS())
+  this.swarm.connection.addStreamMuxer(spdy)
+  this.swarm.connection.reuse()
+
+  this.start = (callback) => {
+    // Yeah empty function, we can't actually do anything here, yet.
+    callback()
+  }
+
+  this.routing = null
+  this.records = null
+
+  this.dial = () => {
+    throw new Error('THIS WILL BE EQUIVALENT TO THE ROUTED HOST FEATURE, IT WILL FIGURE OUT EVERYTHING :D')
+  }
+}

test/index.spec.js

@@ -0,0 +1,111 @@
+/* eslint-env mocha */
+'use strict'
+
+const expect = require('chai').expect
+const multiaddr = require('multiaddr')
+const Peer = require('peer-info')
+const Id = require('peer-id')
+
+const Node = require('../src').Node
+const rawPeer = require('./peer.json')
+const id = new Id(rawPeer.id, rawPeer.privKey, rawPeer.pubKey)
+
+describe('libp2p-ipfs-browser', function () {
+  this.timeout(10000)
+  let node
+
+  it('start', (done) => {
+    node = new Node()
+    node.start(done)
+  })
+
+  it('echo', (done) => {
+    const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/websockets')
+    const peer = new Peer(id)
+    peer.multiaddr.add(mh)
+
+    const message = 'Hello World!'
+    node.swarm.dial(peer, '/echo/1.0.0', (err, conn) => {
+      expect(err).to.not.exist
+
+      conn.write(message)
+      conn.on('data', (data) => {
+        expect(data.toString()).to.equal(message)
+
+        conn.end()
+        done()
+      })
+    })
+  })
+
+  describe('stress', () => {
+    it('one big write', (done) => {
+      const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/websockets')
+      const peer = new Peer(id)
+      peer.multiaddr.add(mh)
+
+      const message = new Buffer(1000000).fill('a').toString('hex')
+      node.swarm.dial(peer, '/echo/1.0.0', (err, conn) => {
+        expect(err).to.not.exist
+
+        conn.write(message)
+        conn.write('STOP')
+
+        let result = ''
+        conn.on('data', (data) => {
+          if (data.toString() === 'STOP') {
+            conn.end()
+            return
+          }
+          result += data.toString()
+        })
+
+        conn.on('end', () => {
+          expect(result).to.equal(message)
+          done()
+        })
+      })
+    })
+
+    it('many writes in 2 batches', (done) => {
+      const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/websockets')
+      const peer = new Peer(id)
+      peer.multiaddr.add(mh)
+
+      let expected = ''
+      let counter = 0
+
+      node.swarm.dial(peer, '/echo/1.0.0', (err, conn) => {
+        expect(err).to.not.exist
+
+        while (++counter < 10000) {
+          conn.write(`${counter} `)
+          expected += `${counter} `
+        }
+
+        setTimeout(() => {
+          while (++counter < 20000) {
+            conn.write(`${counter} `)
+            expected += `${counter} `
+          }
+
+          conn.write('STOP')
+        }, 1000)
+
+        let result = ''
+        conn.on('data', (data) => {
+          if (data.toString() === 'STOP') {
+            conn.end()
+            return
+          }
+          result += data.toString()
+        })
+
+        conn.on('end', () => {
+          expect(result).to.equal(expected)
+          done()
+        })
+      })
+    })
+  })
+})

test/peer.json

@@ -0,0 +1,5 @@
+{
+  "id": "QmZpyYZHbDXhghpm2D5LqWF2otYrr1HhkScAjWCMSc157i",
+  "privKey": "080012a709308204a3020100028201010095404e93fabdd36406d2e9ab6efe8be152f7682d4889b686717dba73eb9453bbdef6ef4a02ecc4dd4a413ac01b5abbb62f362a7c56a4f52fa60c903aa58967442f97fc2d4e1d9566df842d24f0297a889a12d15de11e95b9e826e0c720f531ff6465583b71061dc6b017579e24e139976c3a100b49ed152db23eadac5db16df48288381a621fee64b25fd620458290494bd188941e27840250019d4b08443ce32054be6fd8bd7e3af23dcc49de6899c385f4aa29073f23a2f96ede5400aa7b986812d1d79f81c1d0d0b78765b9c7c56fa585181a6beb78accfc630afe02d8602786540cb26fe5c0e85ffa5b6d121bd607eab98aa7e6e49b39e00b912e5e7d3b9020301000102820100438be3041dcaa34cf5b9a67f2bb08fe5de0292674c18e73e5946a987a4ea702aea719f4243a89c3ffa47232ba6359e1689af5df2ffd390138c76cb1f7fa37bd4e42548bfc846a342f78d7e50e55020608a3a51fec6cf6cbbc251361168dd0f4fa2442b765b64853d529c7dced8aa05c27dfc991e42cac576f4e061014d35eba8b59fdc15e49d569aa5ce8c5678fae1b2cfa1233cdd608019dcdcf1fef3a2cf3f00b296795d74ea4543655f86b2d2b510f2cf4809860243329bc9b2ebf47e3bda4d8c1ea09607b114b78c2e253055cf3c05bac2bba1c7b75c1cdffe137e2065595d7b088b73af4a4f31a6ff795ac41bc9a892357735015e9a088a72e5331274c102818100e798357f07a44e2cc107d8f136025bcea47dbe9bb21e840029c4f40ce4b096b1ded08d405b4a3c1010b8994b673611807812bfcc2a57b40af665160806f41cf32073e652e2a5ac9c1e80a2eb3a5a7ee91af1f86ce617a8ed1bf83c28079b935b76d0c2efc49d67fe2b1b43fcd7016a4d076c4e34f85c38b015a27a25b8e6328d02818100a4fab2b3a719837e81ec266e930ffa1558d19b3dc6d2b6ef155d5da27ce947a5fbef8074552cc2f5c4880a1dc258681f5b5a8deef412689cc02079e960d1899fc73cc3d7f88ce41bbabbf8632c17d4ae9db63b35333732b2a668763e7abbb1510ccc0f0bc92b5a9d751ca5aaf95aa62959efddddf0786f719ac3fea50972f0dd02818054ca3b3bc8d674f099b37fcfc01059006ce4c4b6481e3801bf492678d9f97512a61b00bc01304a912f2e06a1bea5e2fe7ff78d54f863a7bd23bc9ab651a56a3bf133bdadb6e12532fb4fe955e9c55c158811f2fc1bb9a9d5359a4a9bf53d16543449f634c66d42b7a19c97e5a7ea12bb24ee982b788a7b0eacbd11af61e495b902818001c1d1c96c0c2f845769e676e3061689c7aa63d6e29937ed8ff2b09e9c69f7a362ed8816b51986f20b27cfc3c5601fabc5d34f13ae71cbbf6fa468e7fd69fde73fbdfbeffeebb13a4260e2225c43dcb60763fb79739430ec0a2daea4b7b5ec0b8af1596facb2d3823dcf124ca1df3f49cd756a8d849423cbb7f442700b8bb7d90281810085e74f432629b16a9467090fab232c7e40d5d949029539db4e35c91a2dbad7275648f638c3630ef5fea40dd9d930e5dca5851eb4f24c3f93d414717539707353f19be404dc7b180a52980bf76b8b13ad411eb58a88b67b6885485240454e93dea69ab36eec754454ac9843b1adba43eaf9cfe751bf47170ec90d9b71afbf49b9",
+  "pubKey": "080012a60230820122300d06092a864886f70d01010105000382010f003082010a028201010095404e93fabdd36406d2e9ab6efe8be152f7682d4889b686717dba73eb9453bbdef6ef4a02ecc4dd4a413ac01b5abbb62f362a7c56a4f52fa60c903aa58967442f97fc2d4e1d9566df842d24f0297a889a12d15de11e95b9e826e0c720f531ff6465583b71061dc6b017579e24e139976c3a100b49ed152db23eadac5db16df48288381a621fee64b25fd620458290494bd188941e27840250019d4b08443ce32054be6fd8bd7e3af23dcc49de6899c385f4aa29073f23a2f96ede5400aa7b986812d1d79f81c1d0d0b78765b9c7c56fa585181a6beb78accfc630afe02d8602786540cb26fe5c0e85ffa5b6d121bd607eab98aa7e6e49b39e00b912e5e7d3b90203010001"
+}