[WIP] feat: adding relay

src/connection.js

@@ -1,6 +1,7 @@
 'use strict'
 
 const identify = require('libp2p-identify')
+const circuit = require('libp2p-circuit').Listener
 const multistream = require('multistream-select')
 const waterfall = require('async/waterfall')
 const debug = require('debug')
@@ -75,6 +76,13 @@ module.exports = function connection (swarm) {
       })
     },
 
+    relay () {
+      swarm.relay = true
+      circuit.listener(swarm).on('connection', (conn) => {
+        protocolMuxer(swarm.protocols, conn)
+      })
+    },
+
     crypto (tag, encrypt) {
       if (!tag && !encrypt) {
         tag = plaintext.tag

src/dial.js

@@ -78,10 +78,17 @@ module.exports = function dial (swarm) {
     }
 
     function attemptDial (pi, cb) {
-      const tKeys = swarm.availableTransports(pi)
+      let tKeys = swarm.availableTransports(pi)
 
       if (tKeys.length === 0) {
-        return cb(new Error('No available transport to dial to'))
+        if (this.relay) {
+          // force relay if it's enabled
+          tKeys = ['Circuit']
+          // create a generic relay addres
+          pi.multiaddrs.addSafe(`/p2p-circuit/ipfs/${pi.peerInfo.id}`)
+        } else {
+          return cb(new Error('No available transport to dial to'))
+        }
       }
 
       nextTransport(tKeys.shift())

src/index.js

@@ -52,6 +52,9 @@ function Swarm (peerInfo) {
   // is the Identify protocol enabled?
   this.identify = false
 
+  // is relay enabled?
+  this.relay = false
+
   // Crypto details
   this.crypto = plaintext
 
@@ -72,7 +75,10 @@ function Swarm (peerInfo) {
 
         if (includes(addr.protoNames(), 'ipfs')) {
           return addr.decapsulate('ipfs')
+        } else if (includes(addr.protoNames(), 'p2p-circuit')) {
+          return addr.decapsulate('p2p-circuit')
         }
+
         return addr
       })
 
@@ -135,11 +141,16 @@ function Swarm (peerInfo) {
           cb()
         })
       }, cb),
+      // (cb) => {
+      //   each(this.transports, (transport, cb) => {
+      //     each(transport.listeners, (listener, cb) => {
+      //       listener.close(cb)
+      //     }, cb)
+      //   }, cb)
+      // },
       (cb) => {
-        each(this.transports, (transport, cb) => {
-          each(transport.listeners, (listener, cb) => {
-            listener.close(cb)
-          }, cb)
+        each(Object.keys(this.transports), (key, cb) => {
+          this.transport.close(key, cb)
         }, cb)
       }
     ], callback)