feat: adding circuit relaying

Author: dryajov

src/index.js

@@ -14,6 +14,7 @@ const PeerInfo = require('peer-info')
 const PeerBook = require('peer-book')
 const mafmt = require('mafmt')
 const multiaddr = require('multiaddr')
+const Circuit = require('libp2p-circuit')
 
 exports = module.exports
 
@@ -29,6 +30,7 @@ class Node extends EventEmitter {
     this.peerInfo = _peerInfo
     this.peerBook = _peerBook || new PeerBook()
     this.isOnline = false
+    this.relayCircuit = null
 
     this.swarm = new Swarm(this.peerInfo, this.peerBook)
 
@@ -41,6 +43,24 @@ class Node extends EventEmitter {
       // If muxer exists, we can use Identify
       this.swarm.connection.reuse()
 
+      // enable circuit relaying
+      // TODO: move defaults elsewhere
+      _options.Relay = Object.assign({
+        Circuit: {
+          Enabled: false,
+          Active: false
+        },
+        DialMode: 'onion'
+      }, _options.Relay)
+
+      if (_options.Relay.Circuit.Enabled) {
+        this.relayCircuit = new Circuit.Relay(_options.Relay.Circuit)
+        this.relayCircuit.mount(this.swarm)
+      }
+
+      // If muxer exists, we can use Relay for listening/dialing
+      this.swarm.connection.relay(_options.Relay)
+
       // Received incommind dial and muxer upgrade happened,
       // reuse this muxed connection
       this.swarm.on('peer-mux-established', (peerInfo) => {
@@ -152,7 +172,7 @@ class Node extends EventEmitter {
         this.swarm.transport.add(
           transport.tag || transport.constructor.name, transport)
       } else if (transport.constructor &&
-                 transport.constructor.name === 'WebSockets') {
+        transport.constructor.name === 'WebSockets') {
         // TODO find a cleaner way to signal that a transport is always
         // used for dialing, even if no listener
         ws = transport
@@ -274,7 +294,7 @@ class Node extends EventEmitter {
     // PeerInfo
     if (PeerInfo.isPeerInfo(peer)) {
       p = peer
-    // Multiaddr instance (not string)
+      // Multiaddr instance (not string)
     } else if (multiaddr.isMultiaddr(peer)) {
       const peerIdB58Str = peer.getPeerId()
       try {
@@ -283,7 +303,7 @@ class Node extends EventEmitter {
         p = new PeerInfo(PeerId.createFromB58String(peerIdB58Str))
       }
       p.multiaddrs.add(peer)
-    // PeerId
+      // PeerId
     } else if (PeerId.isPeerId(peer)) {
       const peerIdB58Str = peer.toB58String()
       try {