fix: incoming stream conn (#30)

Author: vasco-santos

src/index.js

@@ -146,10 +146,10 @@ class PubsubBaseProtocol extends EventEmitter {
    * @param {Object} props
    * @param {string} props.protocol
    * @param {DuplexStream} props.strean
-   * @param {PeerId} props.remotePeer remote peer-id
+   * @param {Connection} props.connection connection
    */
-  async _onIncomingStream ({ protocol, stream, remotePeer }) {
-    const peerInfo = await PeerInfo.create(remotePeer)
+  async _onIncomingStream ({ protocol, stream, connection }) {
+    const peerInfo = await PeerInfo.create(connection.remotePeer)
     peerInfo.protocols.add(protocol)
 
     const idB58Str = peerInfo.id.toB58String()

test/pubsub.spec.js

@@ -180,7 +180,9 @@ describe('pubsub base protocol', () => {
       await handlerB({
         protocol,
         stream: c1.stream,
-        remotePeer: peerInfoA.id
+        connection: {
+          remotePeer: peerInfoA.id
+        }
       })
 
       expect(pubsubA.peers.size).to.be.eql(1)
@@ -200,7 +202,9 @@ describe('pubsub base protocol', () => {
       await handlerB({
         protocol,
         stream: c1.stream,
-        remotePeer: peerInfoA.id
+        connection: {
+          remotePeer: peerInfoA.id
+        }
       })
 
       // Notice peers of disconnect