Initial commit

.gitignore

@@ -0,0 +1,43 @@
+docs
+**/node_modules/
+**/*.log
+test/repo-tests*
+**/bundle.js
+
+# 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

package.json

@@ -0,0 +1,22 @@
+{
+  "name": "js-libp2p-webrtc-star-demo",
+  "version": "1.0.0",
+  "description": "",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "libp2p": "guysv/js-libp2p#pass-node-to-transports",
+    "libp2p-exchange-direct": "0.0.3",
+    "libp2p-exchange-rendezvous": "guysv/libp2p-exchange-rendezvous#no-crypto",
+    "libp2p-webrtc-star": "guysv/js-libp2p-webrtc-star#feat/use-interface-data-exchange",
+    "wrtc": "^0.4.0",
+    "libp2p-mplex": "^0.8.5",
+    "libp2p-tcp": "^0.13.0",
+    "peer-id": "github:mkg20001/js-peer-id",
+    "async": "^2.6.2",
+    "pull-stream": "^3.6.11"
+  }
+}

src/dialer.js

@@ -0,0 +1,69 @@
+'use strict'
+/* eslint-disable no-console */
+
+/*
+ * Listener Node
+ */
+
+const PeerId = require('peer-id')
+const PeerInfo = require('peer-info')
+const Node = require('./bundle')
+const pull = require('pull-stream')
+const series = require('async/series')
+
+let listenerId
+let listenerNode
+
+series([
+  (cb) => {
+    PeerId.createFromJSON(require('./id-d'), (err, id) => {
+      if (err) { return cb(err) }
+      listenerId = id
+      cb()
+    })
+  },
+  (cb) => {
+    const listenerPeerInfo = new PeerInfo(listenerId)
+    listenerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0')
+    listenerPeerInfo.multiaddrs.add('/p2p-webrtc-star')
+    listenerNode = new Node({
+      peerInfo: listenerPeerInfo,
+      config: {
+        relay: {
+          enabled: false
+        }
+      }
+    })
+    listenerNode.start(cb)
+  },
+  (cb) => {
+    listenerNode.dial(`/ip4/0.0.0.0/tcp/10333/ipfs/${require('./id-r').id}`, cb)
+  },
+  (cb) => {
+    setTimeout(cb, 5000)
+  },
+  (cb) => {
+    // console.log("b")
+    listenerNode.dialProtocol(`/p2p-webrtc-star/ipfs/${require('./id-l').id}`, '/echo/1.0.0', cb)
+    // console.log(`/p2p-circuit/ipfs/${require('./id-l').id}`)
+    // cb()
+  }
+], (err, conn) => {
+  if (err) { throw err }
+
+  console.log('Listening on:')
+  listenerNode.peerInfo.multiaddrs.forEach((ma) => {
+    console.log(ma.toString() + '/p2p/' + listenerId.toB58String())
+  })
+
+  console.log(`Sending data to /p2p-webrtc-star/ipfs/${require('./id-l').id}`)
+
+  pull(
+    pull.values(['hey']),
+    conn.conn, // TODO: why conn.conn???
+    pull.collect((err, data) => {
+      if (err) { throw err }
+      console.log('received echo:', data.toString())
+    })
+  )
+})

src/id-d.json

@@ -0,0 +1,5 @@
+{
+  "id": "QmYd8Sv6Y7BgjwoBAPwoRzPufQEJZV6iGxwQmiUxCdDSFj",
+  "privKey": "CAASqAkwggSkAgEAAoIBAQC8JW40COLQ/6S4O0kwPU9eSaBdH6eRnyf14f0KsYxMw9+386syhfi7vJ6ZaPRQkwE81WQPK7v20R9rZoDaDYqoX7FxnBKqATmGYfZLY7GWqjdHBgk9+rOa7wXw+8cf4K6prtms1U3JDIxNiP0ORxiuYUC9Kol4i32nqc5YGW8QgiNhxTGd6XfuKzbOBK25TiJyl1x62nwyFUlLotXQxBFXE79AxNw+oh9fPcUSo/+eDWOjYwbsv95saVa+dI7AtoSp48QVKElJt/g5ARM/bDBz/QQpICK4MtITWNtckHn+3V1o+vL/0McOQp4oSNLdYWNzuYqUOkytZmI39GbnXFxJAgMBAAECggEBAIlyesiuuSxfpfEk9nm0QHgsJ2gAiQUcFTBOsPIP9OPbsGMNMsMNFkHoMKD4CIuYaS4M4jUnCQDtkxt93aHuhJ4ukk3h68ygamrew/QdV44uuYU8RqIttOn5tghvlu+Vz2OMpd7aUSIP9atq6Rt2GvTBfW70VUtn9Br5NRItOnL+rEcmkEnb5eQG8VBhU0BgxfapNzDiA9Xw5mCG6Nu8DNF9uRuO2SNln4W6CWrX++tFqo5JglYv1hO/B7myigYn7pSepEVnbIVtQRqKYQpJfON+tL9MjkzOQKsGQMkuS06g6sgDwXEVoUyOS3FG0nP4bHUEnumZUDa16eXKFJliIWUCgYEA+FotDoix/mGmLZXZoqeUlR9LagkOYhXgQ8G2Zr6RMRnNOVx+Fw0pUR+S74eksZFT71QFjTwQcx/aET0fBiUYNLrOiPsr/x98r35j1JqefajoShnlZbh1qtyCxJ7vdc/9bI2/b+dgr/+uL4h5hXBIMBCynOc0Rp1N4q+mqKlxSscCgYEAwfCijPvnIFFnW69cXyGuI8BOQ1r23nxSTOBqac5gn0k5JDthQBwNjiWFzh81qKSliD532VQw+JYEQxm6gi6wWAbAySUvD2mcdrAVVgR26OUJosBx0fqTdxTVvKgrv3ai2Ul5imUf6MLmabJTPJQqHy7w8RjH940HSyNv9OxrkG8CgYEAuiHrrv7oWD0bbQLoUC3FAFaqENikvQKkSGQArtSYwPITi7A0mFY25yQA3iENYEAJZk/UsVuZAI+Ywl7Kx7I5iBuR+7wz50vUCTty2r7fllJndlIeSbSMC/ik0XRFCElQKHG8TsRdBMtd4yYn3cifcdax50KpPVtcKk93WuVTkbUCgYBlvqaorCcPL2W4FgGx7ut62hK1B23oPvS2XC23oIvURQfzWCunBJCf+FOAVaNC/E3TcmJR4/dlEt7djQvp7DCbnb9aR2WvAksRgUNQQztW54HsnmWYMYtXt9iCBwAcjFLXB9L5ph/dbxKOdP1yFJEclvXUppmR56zh4I+FwNqVhQKBgFv0TS9B1rXTZK4gabf/I2QjuPPwx4B24pCqoLlBtBGIuHrHqWb0upMIFw6ZZB4FCqg4usJaeWPWBZcpfHBEEAExGZ86JdtB3PBVDTrGJISbMpjVMa/KY0TrEyXkIYzzN++4f29ShTeQL3wBXCXInxdrWgfbq2j4AdAA1lzf0abU",
+  "pubKey": "CAASpgIwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC8JW40COLQ/6S4O0kwPU9eSaBdH6eRnyf14f0KsYxMw9+386syhfi7vJ6ZaPRQkwE81WQPK7v20R9rZoDaDYqoX7FxnBKqATmGYfZLY7GWqjdHBgk9+rOa7wXw+8cf4K6prtms1U3JDIxNiP0ORxiuYUC9Kol4i32nqc5YGW8QgiNhxTGd6XfuKzbOBK25TiJyl1x62nwyFUlLotXQxBFXE79AxNw+oh9fPcUSo/+eDWOjYwbsv95saVa+dI7AtoSp48QVKElJt/g5ARM/bDBz/QQpICK4MtITWNtckHn+3V1o+vL/0McOQp4oSNLdYWNzuYqUOkytZmI39GbnXFxJAgMBAAE="
+}

src/id-l.json

@@ -0,0 +1,5 @@
+{
+  "id": "QmdoPFts9fNq1UxP6xWe14XPN6MeL4QJyE2ALd4h2sq9Sw",
+  "privKey": "CAASpgkwggSiAgEAAoIBAQDCIRPUXo8u+OcJkKV7a5foj3iXbC9d+kPNEKdWYEs/F/pv/hLpyEn6uHN/sFe7VEOzZlO7LwRHHylipVONYOeekXwVXpol5JCFZi9/JlDISYzyQgTxmtnx8WU58u+1CWTk/qdohQrrRzW409ob45TlUEcqDT70r8lsxAFrPGE+f7FcfAeG8kgqF2ytGyq+e/n46ByFWn/VMTwBsolKqzbw8yw9iQn0R5+ZuGk1RWGnYWTYGlARhHpOJENI9SjKwnFSmnMjkBfI04ulnmUwNmp/sNAEfiUwAZ5JcCdGlNd5QJQWVWbdKmAGNHi0h1mDryDBuHoI0RAyufCASGciPGEXAgMBAAECggEAV98jG7EFvOxbn//CeCBWraUrn9cPhcl/oTYVmMqTpOaUrNbj9sB7hCqz1SucOqZE0tLRudvpYswfLpDJRiiED0mpUf71ZYuVQ1ziyPot/MsWKp5poHdIifSLrnRhvp+W9PS0EGKQc7lS/uueQZt9TWNOIyHFyno7gakjP0ggeGoHLZTivo9gBcL5Ol3d8FChXl9WBp8v1T2pBhB28R1Z64c8vDP/btvKS36u7VBJ/BOz+q26Rv1x8SvM8lzVCkazMvDBX1F76/nyMqli06AvaJ0vP2B50oqNoSHkQKdX6sEBeMvN5U5BWmv3b45chRHUhGOdjtXtMFn30KCpccYDqQKBgQD7wJ3DuXaXXh8boJUd6y4NUeBbdmkk8IA6QP0O/tyrAEM1du+Fnq6KGiqTNTpj1gtCp1HNklWRuFG8t2j6blM5QnEUUUhZSr/yIiAcXv4rw+GGuKH0xcYyL4xRvpJyyOCtpARM2h53QMqrIxq4vbYuVFwBfpzN5RcqFaFFC3oGhQKBgQDFZ5Ja7173SG+oIwvcDH0Nzsf+lqbOy4yCcyiAvwLBik/YF+k3IC2gKpp99/jo4QCGxmhQnGfh5FQ2NRdFZsQ1c5FHJBCtCg0pED0Xa7eTccmkyJZoXHS0aX6UGtapZdT6M56iK5rUIba6t17wz2A0c3y2PQHettJmo5rRZcBh6wKBgCZ0vuS2AOqQYxoaRo0Cbs90EVyHUvpkjoHXiZBv2A97A8k3+NClc63+30ALYnb7rE6rNnC7iLywtjOopK2Uirv1bUaYP//7ziRTmCodTKAs1Nd6fqrgRy1FXB7kiIRmMQP1SP7gVsUKrarEuwE7YYfkNQW5bIR7GTXBhhgA78vtAoGAJscjvu1K0HTQSk0oJT/myPGX4/EgL3tYzL9mc3QSTIapDKAV1hhiHhaAZsJxiP26Jr+O+lbfKUa7LDLdsWpwnLdpEHqLNBLHZwujlJg6ZaJypAYrVbDj1BTtIpbrGDfC0KuXO/Ao6Ab/aEphQhjaozMUipANb/yl9DerT/sXAaUCgYBiKZL0KxqVzqKGpUjBJfhZivxsjsCfGIcfx2qKknQg4nuh5Ho6j4vWYoaVZt6012GuihX/foRY68X+PamBOk3qYKnkiK1zNsVyMh7WHiQ2835eNOgr2Dy5PdYHtmmL6NSaZdn+T+WskQYZ1DOaYPRI3PpualqGjFUNN4QhB4BOJA==",
+  "pubKey": "CAASpgIwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDCIRPUXo8u+OcJkKV7a5foj3iXbC9d+kPNEKdWYEs/F/pv/hLpyEn6uHN/sFe7VEOzZlO7LwRHHylipVONYOeekXwVXpol5JCFZi9/JlDISYzyQgTxmtnx8WU58u+1CWTk/qdohQrrRzW409ob45TlUEcqDT70r8lsxAFrPGE+f7FcfAeG8kgqF2ytGyq+e/n46ByFWn/VMTwBsolKqzbw8yw9iQn0R5+ZuGk1RWGnYWTYGlARhHpOJENI9SjKwnFSmnMjkBfI04ulnmUwNmp/sNAEfiUwAZ5JcCdGlNd5QJQWVWbdKmAGNHi0h1mDryDBuHoI0RAyufCASGciPGEXAgMBAAE="
+}

src/id-r.json

@@ -0,0 +1,5 @@
+{
+  "id": "QmWNFVgnkgqbh5rMMRjBX9ye1K8wNtTjmYGtAXUkRG4ESe",
+  "privKey": "CAASpwkwggSjAgEAAoIBAQDwLfOE+0NBkdZheQ2Ct/r7qZHKPcvUevW1bOE1eQ1XOGNocnfvuJ8jgRR5pubTQxKZlZXm4kMaXFxumgsLTNgocRQRt28qzlNuDV++SQAl3Y1EhAMmr9KpLcnu0hDZRnSJ9/fRW3JEmH7smEjqo/+EQKy6SEhoKledgqmflAWVHacBFF6IWm6OyYmx78+DDG3fYiyWtmbacq/t5+HoFRUrbGp9+il/dcLEgUa5Rxg8v5K/rzBHpc/BMZ3eh12EG7sr6gfMPUNoxe6XgtlbR0bMQkVSDbWBTvWqbVHzDwwxXvorXUIVVLAcpVEaikf8iKHcaHzv4QkormfQIGcbN0lFAgMBAAECggEAEw2iJueD41y9ZAglYTxVJcfC8AdM9zM18MmNaB+NRmELycpi51p/DWL9C9WItDO68wIh3SoP5rRzBLclryTOdQ7bZ7hkkkHB7pYTBVZnM5nKziem1FfYX2Fpho+VlJb5QcSxHSOjAfwS/ZPrHOobqBM1YKXBULojLzShXi5w7u4+7Egq9ziv2AXOIh+Ou1WxMPtFjffO4geyCMw002o35nMDKoSMIcCkmJq/QYabxQoaPvjm80fU6EhA3bjOdst76hOQJsr5BUdBMxpP02+pAvZ/vJAyIh38O8XUbTKWBDSlFjiqi3IEtWc36/dS1AELxnGU+3NRO1p53CA7GqXhYQKBgQD6d+lsm3xzrdWGrJtGtRH2/Xf4vU+jJD1MQgsiPTu/WQ7Y2gOrsLGpXrE/J2fQuVGTyop1T/pXPUXgIq8JzrRSX7Z3P9Yob5JC6X0LM/INKPA8QeK9nsA6zhLOWPjxi5fCPaOLms1LAx84iIwhchg8oMIX7AIdTv/5hOUgwBr9LQKBgQD1e95QpPG43KMm0m5X6hLclGNOn8XBmjYsjBcqiY91mRp5MPOnGwBA7OkyvXTbTPnsMYE1EwJFpQCcmKeFUCsnVGz3sHDEALjXiQSghTXJrymGhjM01DkI3oRbw+QEJ7DMvTxobWc7xDGupTvPOMF0q5rNWoTTyb3uVo1lbrV7eQKBgQDtDc68PxDzv0QHmZfAvSFKna0Nm8cixerKIPu+pSvGN3jo3rZ4qdwMTBX/isEj+DFwalLPIynxpYlb0BfQdXWPPQ1KIf4D+Uz5zVjO4JQnxmZQ8Z6zDuwq+90qtWSv4Al7CrGeMJ46b7L946aVBRJRV2k8EOATczCrrQ7bB1bD5QKBgEFCEpGBp7iq/rw9SJQaZ7U3xUaLdrjG1Av3mdj3BKoQb1c0SjFsHh8kW8HfV4dM6Ut+xYhka0A0Yvs+IZpw+2fTK7yUrQWN45V4mUBK6UeaRwG5/zbWC+ttq+XxJ1Zrbraev8ZK/xyGRWbWChZGUjc/v0FEBPeAM/t+CsyiJ6CRAoGAF0dZ8mpO1KSBY9VsxSudpEUuLu00v2azImLvTqE1ksWWNxqeUeGKWYSUg41/U3PERSUp9KztHitIFFGiwh+mQxB5OsT6loTsIbcIhpBR1gzZL7yjXnaS92XHyzFMaU6egN2ihNtRpKDnJE2OXN8WGXwZZRPSo9iTwWVyOuBG+zE=",
+  "pubKey": "CAASpgIwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDwLfOE+0NBkdZheQ2Ct/r7qZHKPcvUevW1bOE1eQ1XOGNocnfvuJ8jgRR5pubTQxKZlZXm4kMaXFxumgsLTNgocRQRt28qzlNuDV++SQAl3Y1EhAMmr9KpLcnu0hDZRnSJ9/fRW3JEmH7smEjqo/+EQKy6SEhoKledgqmflAWVHacBFF6IWm6OyYmx78+DDG3fYiyWtmbacq/t5+HoFRUrbGp9+il/dcLEgUa5Rxg8v5K/rzBHpc/BMZ3eh12EG7sr6gfMPUNoxe6XgtlbR0bMQkVSDbWBTvWqbVHzDwwxXvorXUIVVLAcpVEaikf8iKHcaHzv4QkormfQIGcbN0lFAgMBAAE="
+}

src/listener.js

@@ -0,0 +1,50 @@
+'use strict'
+/* eslint-disable no-console */
+
+/*
+ * Listener Node
+ */
+
+const PeerId = require('peer-id')
+const PeerInfo = require('peer-info')
+const Node = require('./bundle')
+const pull = require('pull-stream')
+const series = require('async/series')
+
+let listenerId
+let listenerNode
+
+series([
+  (cb) => {
+    PeerId.createFromJSON(require('./id-l'), (err, id) => {
+      if (err) { return cb(err) }
+      listenerId = id
+      cb()
+    })
+  },
+  (cb) => {
+    const listenerPeerInfo = new PeerInfo(listenerId)
+    listenerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0')
+    listenerPeerInfo.multiaddrs.add('/p2p-webrtc-star')
+    listenerNode = new Node({
+      peerInfo: listenerPeerInfo,
+      config: {
+        relay: {
+          enabled: false
+        }
+      }
+    })
+    listenerNode.handle('/echo/1.0.0', (protocol, conn) => pull(conn, conn))
+    listenerNode.start(cb)
+  },
+  (cb) => {
+    listenerNode.dial(`/ip4/0.0.0.0/tcp/10333/ipfs/${require('./id-r').id}`, cb)
+  }
+], (err) => {
+  if (err) { throw err }
+
+  console.log('Listening on:')
+  listenerNode.peerInfo.multiaddrs.forEach((ma) => {
+    console.log(ma.toString() + '/p2p/' + listenerId.toB58String())
+  })
+})

src/rendezvous.js

@@ -0,0 +1,46 @@
+'use strict'
+/* eslint-disable no-console */
+
+/*
+ * Listener Node
+ */
+
+const PeerId = require('peer-id')
+const PeerInfo = require('peer-info')
+const Node = require('./bundle')
+// const pull = require('pull-stream')
+const series = require('async/series')
+
+let listenerId
+let listenerNode
+
+series([
+  (cb) => {
+    PeerId.createFromJSON(require('./id-r'), (err, id) => {
+      if (err) { return cb(err) }
+      listenerId = id
+      cb()
+    })
+  },
+  (cb) => {
+    const listenerPeerInfo = new PeerInfo(listenerId)
+    listenerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/10333')
+    listenerPeerInfo.multiaddrs.add('/p2p-webrtc-star')
+    listenerNode = new Node({
+      peerInfo: listenerPeerInfo,
+      config: {
+        relay: {
+          enabled: false
+        }
+      }
+    })
+    listenerNode.start(cb)
+  }
+], (err) => {
+  if (err) { throw err }
+
+  console.log('Listening on:')
+  listenerNode.peerInfo.multiaddrs.forEach((ma) => {
+    console.log(ma.toString() + '/p2p/' + listenerId.toB58String())
+  })
+})