fix: also support ipfs.libp2p

src/connection.js

@@ -7,6 +7,7 @@ const Pushable = require('pull-pushable')
 const PROTOCOL = require('./protocol')
 const encoding = require('./encoding')
 const getPeerId = require('./peer-id')
+const libp2p = require('./libp2p')
 
 module.exports = class Connection extends EventEmitter {
   constructor (id, ipfs, room) {
@@ -48,7 +49,7 @@ module.exports = class Connection extends EventEmitter {
         return // early
       }
 
-      this._ipfs._libp2pNode.dialProtocol(peerAddresses[0], PROTOCOL, (err, conn) => {
+      libp2p(this._ipfs).dialProtocol(peerAddresses[0], PROTOCOL, (err, conn) => {
         if (err) {
           this.emit('disconnect')
           return // early

src/index.js

@@ -9,6 +9,7 @@ const PROTOCOL = require('./protocol')
 const Connection = require('./connection')
 const encoding = require('./encoding')
 const directConnection = require('./direct-connection-handler')
+const libp2p = require('./libp2p')
 
 const DEFAULT_OPTIONS = {
   pollInterval: 1000
@@ -130,7 +131,7 @@ class PubSubRoom extends EventEmitter {
       })
     })
 
-    this._ipfs._libp2pNode.handle(PROTOCOL, directConnection.handler)
+    libp2p(this._ipfs).handle(PROTOCOL, directConnection.handler)
 
     directConnection.emitter.on(this._topic, this._handleDirectMessage)
   }

src/libp2p.js

@@ -0,0 +1,5 @@
+'use strict'
+
+module.exports = (ipfs) => {
+  return ipfs._libp2pNode || ipfs.libp2p
+}