chore: use fixed gossipsub

fix: stop discoveries (#530 )
* fix: stop discoveries * test: add discovery stop test * chore: fix lint Co-authored-by: Jacob Heun <jacobheun@gmail.com>
2025-07-16 09:01:58 +00:00 · 2020-01-13 16:32:12 +01:00 · 2020-01-07 16:27:32 +01:00 · 2020-01-07 15:31:13 +01:00 · 2020-01-07 15:30:59 +01:00 · 2020-01-07 14:56:05 +01:00
37 changed files with 359 additions and 889 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -3,7 +3,6 @@ docs
 **/*.log
 test/repo-tests*
 **/bundle.js
-.cache

 # Logs
 logs
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,63 +1,3 @@
-<a name="0.27.1"></a>
-## [0.27.1](https://github.com/libp2p/js-libp2p/compare/v0.27.0...v0.27.1) (2020-02-03)
-
-
-### Bug Fixes
-
-* stop stream after first pong received ([#545](https://github.com/libp2p/js-libp2p/issues/545)) ([be8fc9d](https://github.com/libp2p/js-libp2p/commit/be8fc9d))
-
-
-
-<a name="0.27.0"></a>
-# [0.27.0](https://github.com/libp2p/js-libp2p/compare/v0.26.2...v0.27.0) (2020-01-28)
-
-
-### Bug Fixes
-
-* clean up peer discovery flow ([#494](https://github.com/libp2p/js-libp2p/issues/494)) ([12fc069](https://github.com/libp2p/js-libp2p/commit/12fc069))
-* clean up pending dials abort per feedback ([633b0c2](https://github.com/libp2p/js-libp2p/commit/633b0c2))
-* conn mngr min/max connection values ([#528](https://github.com/libp2p/js-libp2p/issues/528)) ([ba4681b](https://github.com/libp2p/js-libp2p/commit/ba4681b))
-* correct release readme ([ce8e60b](https://github.com/libp2p/js-libp2p/commit/ce8e60b))
-* examples readme typos ([#481](https://github.com/libp2p/js-libp2p/issues/481)) ([35ac02d](https://github.com/libp2p/js-libp2p/commit/35ac02d))
-* make dialer configurable ([#521](https://github.com/libp2p/js-libp2p/issues/521)) ([4ca481b](https://github.com/libp2p/js-libp2p/commit/4ca481b))
-* performance bottleneck in stat.js ([#463](https://github.com/libp2p/js-libp2p/issues/463)) ([93a1e42](https://github.com/libp2p/js-libp2p/commit/93a1e42))
-* registrar should filter the disconnected conn ([#532](https://github.com/libp2p/js-libp2p/issues/532)) ([bb2e56e](https://github.com/libp2p/js-libp2p/commit/bb2e56e))
-* release tokens as soon as they are available ([2570a1b](https://github.com/libp2p/js-libp2p/commit/2570a1b))
-* replace peerInfo addresses with listen addresses ([#485](https://github.com/libp2p/js-libp2p/issues/485)) ([1999606](https://github.com/libp2p/js-libp2p/commit/1999606))
-* stop discoveries ([#530](https://github.com/libp2p/js-libp2p/issues/530)) ([4222c49](https://github.com/libp2p/js-libp2p/commit/4222c49))
-* token release logic ([90ecc57](https://github.com/libp2p/js-libp2p/commit/90ecc57))
-* upgrader should not need muxers ([#517](https://github.com/libp2p/js-libp2p/issues/517)) ([5d7ee50](https://github.com/libp2p/js-libp2p/commit/5d7ee50))
-* use toB58String everywhere to be consistent ([#537](https://github.com/libp2p/js-libp2p/issues/537)) ([c1038be](https://github.com/libp2p/js-libp2p/commit/c1038be))
-
-
-### Features
-
-* abort all pending dials on stop ([ba02764](https://github.com/libp2p/js-libp2p/commit/ba02764))
-* add early token recycling in ([a5b54a7](https://github.com/libp2p/js-libp2p/commit/a5b54a7))
-* add libp2p.connections getter ([#522](https://github.com/libp2p/js-libp2p/issues/522)) ([6445fda](https://github.com/libp2p/js-libp2p/commit/6445fda))
-* add token based dialer ([e445a17](https://github.com/libp2p/js-libp2p/commit/e445a17))
-* allow transport options to be passed on creation ([#524](https://github.com/libp2p/js-libp2p/issues/524)) ([c339be1](https://github.com/libp2p/js-libp2p/commit/c339be1))
-* coalescing dial support ([#518](https://github.com/libp2p/js-libp2p/issues/518)) ([15f7c2a](https://github.com/libp2p/js-libp2p/commit/15f7c2a))
-* discovery modules ([#486](https://github.com/libp2p/js-libp2p/issues/486)) ([18a062e](https://github.com/libp2p/js-libp2p/commit/18a062e))
-* discovery modules from transports should be added ([#510](https://github.com/libp2p/js-libp2p/issues/510)) ([f1eb373](https://github.com/libp2p/js-libp2p/commit/f1eb373))
-* peer store ([#470](https://github.com/libp2p/js-libp2p/issues/470)) ([582094a](https://github.com/libp2p/js-libp2p/commit/582094a))
-* registrar ([#471](https://github.com/libp2p/js-libp2p/issues/471)) ([9d52b80](https://github.com/libp2p/js-libp2p/commit/9d52b80))
-* support peer-id instances in peer store operations ([#491](https://github.com/libp2p/js-libp2p/issues/491)) ([8da9fc9](https://github.com/libp2p/js-libp2p/commit/8da9fc9))
-
-
-
-<a name="0.27.0-rc.0"></a>
-# [0.27.0-rc.0](https://github.com/libp2p/js-libp2p/compare/v0.27.0-pre.2...v0.27.0-rc.0) (2020-01-24)
-
-
-### Bug Fixes
-
-* registrar should filter the disconnected conn ([#532](https://github.com/libp2p/js-libp2p/issues/532)) ([83409de](https://github.com/libp2p/js-libp2p/commit/83409de))
-* stop discoveries ([#530](https://github.com/libp2p/js-libp2p/issues/530)) ([c44e6e3](https://github.com/libp2p/js-libp2p/commit/c44e6e3))
-* use toB58String everywhere to be consistent ([#537](https://github.com/libp2p/js-libp2p/issues/537)) ([31d1b23](https://github.com/libp2p/js-libp2p/commit/31d1b23))
-
-
-
 <a name="0.27.0-pre.2"></a>
 # [0.27.0-pre.2](https://github.com/libp2p/js-libp2p/compare/v0.27.0-pre.1...v0.27.0-pre.2) (2020-01-07)

--- a/README.md
+++ b/README.md
@@ -30,9 +30,6 @@

 We've come a long way, but this project is still in Alpha, lots of development is happening, API might change, beware of the Dragons 🐉..

-The documentation in the master branch may contain changes from a pre-release.
-If you are looking for the documentation of the latest release, you can view the latest release on [**npm**](https://www.npmjs.com/package/libp2p), or select the tag in github that matches the version you are looking for.
-
 **Want to get started?** Check our [examples folder](/examples).

 [**`Weekly Core Dev Calls`**](https://github.com/ipfs/pm/issues/650)
@@ -52,7 +49,6 @@ If you are looking for the documentation of the latest release, you can view the
 - [Usage](#usage)
  - [Configuration](#configuration)
  - [API](#api)
-  - [Getting Started](#getting-started)
  - [Tutorials and Examples](#tutorials-and-examples)
 - [Development](#development)
  - [Tests](#tests)
@@ -93,10 +89,6 @@ For all the information on how you can configure libp2p see [CONFIGURATION.md](.

 The specification is available on [API.md](./doc/API.md).

-### Getting started
-
-If you are starting your journey with `js-libp2p`, read the [GETTING_STARTED.md](./doc/GETTING_STARTED.md) guide.
-
 ### Tutorials and Examples

 You can find multiple examples on the [examples folder](./examples) that will guide you through using libp2p for several scenarios.
--- a/doc/API.md
+++ b/doc/API.md
@@ -28,7 +28,6 @@
  * [`metrics.protocols`](#metricsprotocols)
  * [`metrics.forPeer`](#metricsforpeer)
  * [`metrics.forProtocol`](#metricsforprotocol)
-* [Events](#events)
 * [Types](#types)
  * [`Stats`](#stats)

@@ -51,7 +50,7 @@ Creates an instance of Libp2p.
 | [options.datastore] | `Object` | must implement [ipfs/interface-datastore](https://github.com/ipfs/interface-datastore) (in memory datastore will be used if not provided) |
 | [options.dialer] | `Object` | libp2p Dialer configuration
 | [options.metrics] | `Object` | libp2p Metrics configuration
-| [options.peerInfo] | [`PeerInfo`][peer-info] | peerInfo instance (it will be created if not provided) |
+| [options.peerInfo] | [PeerInfo](https://github.com/libp2p/js-peer-info) | peerInfo instance (it will be created if not provided) |

 For Libp2p configurations and modules details read the [Configuration Document](./CONFIGURATION.md).

@@ -73,7 +72,7 @@ const options = {}
 const libp2p = await Libp2p.create(options)
 ```

-Note: The [`PeerInfo`][peer-info] option is not required and will be generated if it is not provided.
+Note: The `PeerInfo` option is not required and will be generated if it is not provided.

 <details><summary>Alternative</summary>
 As an alternative, it is possible to create a Libp2p instance with the constructor:
@@ -92,11 +91,44 @@ const libp2p = new Libp2p(options)

 Required keys in the `options` object:

- `peerInfo`: instance of [`PeerInfo`][peer-info] that contains the [`PeerId`][peer-id], Keys and [multiaddrs][multiaddr] of the libp2p Node (optional when using `.create`).
+- `peerInfo`: instance of [PeerInfo][] that contains the [PeerId][], Keys and [multiaddrs][multiaddr] of the libp2p Node (optional when using `.create`).
 - `modules.transport`: An array that must include at least 1 compliant transport. See [modules that implement the transport interface](https://github.com/libp2p/js-interfaces/tree/master/src/transport#modules-that-implement-the-interface).

 </details>

+Once you have a libp2p instance, you are able to listen to several events it emits, so that you can be noticed of relevant network events.
+
+<details><summary>Events</summary>
+
+#### An error has occurred
+
+`libp2p.on('error', (err) => {})`
+
+- `err`: instance of `Error`
+
+#### A peer has been discovered
+
+`libp2p.on('peer:discovery', (peer) => {})`
+
+If `autoDial` option is `true`, applications should **not** attempt to connect to the peer
+unless they are performing a specific action. See [peer discovery and auto dial](./PEER_DISCOVERY.md) for more information.
+
+- `peer`: instance of [PeerInfo][https://github.com/libp2p/js-peer-info]
+
+#### We have a new connection to a peer
+
+`libp2p.on('peer:connect', (peer) => {})`
+
+- `peer`: instance of [PeerInfo][https://github.com/libp2p/js-peer-info]
+
+#### We have closed a connection to a peer
+
+`libp2p.on('peer:disconnect', (peer) => {})`
+
+- `peer`: instance of [PeerInfo][https://github.com/libp2p/js-peer-info]
+
+</details>
+
 ## Libp2p Instance Methods

 ### start
@@ -182,7 +214,7 @@ Dials to another peer in the network and establishes the connection.

 | Name | Type | Description |
 |------|------|-------------|
-| peer | [`PeerInfo`][peer-info]\|[`PeerId`][peer-id]\|[`Multiaddr`][multiaddr]\|`string` | peer to dial |
+| peer | [PeerInfo](https://github.com/libp2p/js-peer-info), [PeerId][peer-id], [multiaddr](https://github.com/multiformats/js-multiaddr), `string` | peer to dial |
 | [options] | `Object` | dial options |
 | [options.signal] | [`AbortSignal`](https://developer.mozilla.org/en-US/docs/Web/API/AbortSignal) | An `AbortSignal` instance obtained from an [`AbortController`](https://developer.mozilla.org/en-US/docs/Web/API/AbortController) that can be used to abort the connection before it completes |

@@ -217,7 +249,7 @@ Dials to another peer in the network and selects a protocol to communicate with

 | Name | Type | Description |
 |------|------|-------------|
-| peer | [`PeerInfo`][peer-info]\|[`PeerId`][peer-id]\|[`Multiaddr`][multiaddr]\|`string` | peer to dial |
+| peer | [PeerInfo](https://github.com/libp2p/js-peer-info), [PeerId][peer-id], [multiaddr](https://github.com/multiformats/js-multiaddr), `string` | peer to dial |
 | protocols | `String|Array<String>` |  A list of protocols (or single protocol) to negotiate with. Protocols are attempted in order until a match is made. (e.g '/ipfs/bitswap/1.1.0') |
 | [options] | `Object` | dial options |
 | [options.signal] | [`AbortSignal`](https://developer.mozilla.org/en-US/docs/Web/API/AbortSignal) | An `AbortSignal` instance obtained from an [`AbortController`](https://developer.mozilla.org/en-US/docs/Web/API/AbortController) that can be used to abort the connection before it completes |
@@ -250,7 +282,7 @@ Attempts to gracefully close an open connection to the given peer. If the connec

 | Name | Type | Description |
 |------|------|-------------|
-| peer | [`PeerInfo`][peer-info]\|[`PeerId`][peer-id]\|[`Multiaddr`][multiaddr]\|`string` | peer to hang up |
+| peer | [PeerInfo](https://github.com/libp2p/js-peer-info), [PeerId][peer-id], [multiaddr](https://github.com/multiformats/js-multiaddr), `string` | peer to hang up |

 #### Returns

@@ -321,7 +353,7 @@ Pings a given peer and get the operation's latency.

 | Name | Type | Description |
 |------|------|-------------|
-| peer | [`PeerInfo`][peer-info]\|[`PeerId`][peer-id]\|[`Multiaddr`][multiaddr]\|`string` | peer to ping |
+| peer | `PeerInfo|PeerId|Multiaddr|string` | peer to ping |

 #### Returns

@@ -374,7 +406,7 @@ Once a content router succeeds, the iteration will stop. If the DHT is enabled,

 | Name | Type | Description |
 |------|------|-------------|
-| cid | [`CID`][cid] | cid to find |
+| cid | [`CID`](https://github.com/multiformats/js-cid) | cid to find |
 | options | `Object` | operation options |
 | options.timeout | `number` | maximum time the query should run |
 | options.maxNumProviders | `number` | maximum number of providers to find |
@@ -383,7 +415,7 @@ Once a content router succeeds, the iteration will stop. If the DHT is enabled,

 | Type | Description |
 |------|-------------|
-| `AsyncIterator<PeerInfo>` |  Async iterator for [`PeerInfo`][peer-info] |
+| `AsyncIterator<PeerInfo>` |  Async iterator for [`PeerInfo`](https://github.com/libp2p/js-peer-info) |

 #### Example

@@ -404,7 +436,7 @@ Iterates over all content routers in parallel, in order to notify it is a provid

 | Name | Type | Description |
 |------|------|-------------|
-| cid | [`CID`][cid] | cid to provide |
+| cid | [`CID`](https://github.com/multiformats/js-cid) | cid to provide |

 #### Returns

@@ -649,7 +681,7 @@ Enables users to change the value of certain peers in a range of 0 to 1. Peers w

 | Name | Type | Description |
 |------|------|-------------|
-| peerId | [`PeerId`][peer-id] | The peer to set the value for |
+| peerId | `PeerId` | The peer to set the value for |
 | value | `number` | The value of the peer from 0 to 1 |

 #### Returns
@@ -677,7 +709,7 @@ const peerIdStrings = libp2p.metrics.peers

 ### metrics.peers

-An array of [`PeerId`][peer-id] strings of each peer currently being tracked.
+An array of `PeerId` strings of each peer currently being tracked.

 #### Example

@@ -697,7 +729,7 @@ const protocols = libp2p.metrics.protocols

 ### metrics.forPeer

-Returns the [`Stats`](#stats) object for a given [`PeerId`][peer-id] if it is being tracked.
+Returns the [`Stats`](#stats) object for a given `PeerId` if it is being tracked.

 `libp2p.metrics.forPeer(peerId)`

@@ -705,7 +737,7 @@ Returns the [`Stats`](#stats) object for a given [`PeerId`][peer-id] if it is be

 | Name | Type | Description |
 |------|------|-------------|
-| peerId | [`PeerId`][peer-id] | The peer to get stats for |
+| peerId | `PeerId` | The peer to get stats for |

 #### Returns

@@ -745,41 +777,6 @@ const peerStats = libp2p.metrics.forProtocol('/meshsub/1.0.0')
 console.log(peerStats.toJSON())
 ```

-## Events
-
-Once you have a libp2p instance, you can listen to several events it emits, so that you can be notified of relevant network events.
-
-#### An error has occurred
-
-`libp2p.on('error', (err) => {})`
-
- `err`: instance of `Error`
-
-#### A peer has been discovered
-
-`libp2p.on('peer:discovery', (peer) => {})`
-
-If `autoDial` option is `true`, applications should **not** attempt to connect to the peer
-unless they are performing a specific action. See [peer discovery and auto dial](./PEER_DISCOVERY.md) for more information.
-
- `peer`: instance of [`PeerInfo`][peer-info]
-
-#### A new connection to a peer has been opened
-
-This event will be triggered anytime a new Connection is established to another peer.
-
-`libp2p.on('peer:connect', (peer) => {})`
-
- `peer`: instance of [`PeerInfo`][peer-info]
-
-#### An existing connection to a peer has been closed
-
-This event will be triggered anytime we are disconnected from another peer, regardless of the circumstances of that disconnection. If we happen to have multiple connections to a peer, this event will **only** be triggered when the last connection is closed.
-
-`libp2p.on('peer:disconnect', (peer) => {})`
-
- `peer`: instance of [`PeerInfo`][peer-info]
-
 ## Types

 ### Stats
@@ -800,8 +797,5 @@ This event will be triggered anytime we are disconnected from another peer, rega
    - `['300000']<MovingAverage>`: The [MovingAverage](https://www.npmjs.com/package/moving-averages) at a 5 minute interval.
    - `['900000']<MovingAverage>`: The [MovingAverage](https://www.npmjs.com/package/moving-averages) at a 15 minute interval.

-[cid]: https://github.com/multiformats/js-cid
 [connection]: https://github.com/libp2p/js-interfaces/tree/master/src/connection
-[multiaddr]: https://github.com/multiformats/js-multiaddr
 [peer-id]: https://github.com/libp2p/js-peer-id
-[peer-info]: https://github.com/libp2p/js-peer-info
--- a/doc/CONFIGURATION.md
+++ b/doc/CONFIGURATION.md
@@ -129,7 +129,7 @@ If you want to know more about libp2p peer discovery, you should read the follow
 Some available content routing modules are:

 - [js-libp2p-kad-dht](https://github.com/libp2p/js-libp2p-kad-dht)
- [js-libp2p-delegated-content-routing](https://github.com/libp2p/js-libp2p-delegated-content-routing)
+- [js-libp2p-delegated-peer-routing](https://github.com/libp2p/js-libp2p-delegated-peer-routing)

 If none of the available content routing protocols fulfills your needs, you can create a libp2p compatible one. A libp2p content routing protocol just needs to be compliant with the [Content Routing Interface](https://github.com/libp2p/js-interfaces/tree/master/src/content-routing). **(WIP: This module is not yet implemented)**

--- a/doc/GETTING_STARTED.md
+++ b/doc/GETTING_STARTED.md
@@ -1,247 +0,0 @@
-# Getting Started
-
-Welcome to libp2p! This guide will walk you through setting up a fully functional libp2p node 🚀
-
- [Getting Started](#getting-started)
-  - [Install](#install)
-  - [Configuring libp2p](#configuring-libp2p)
-    - [Basic setup](#basic-setup)
-      - [Transports](#transports)
-      - [Connection Encryption](#connection-encryption)
-      - [Multiplexing](#multiplexing)
-      - [Running Libp2p](#running-libp2p)
-    - [Custom setup](#custom-setup)
-      - [Peer Discovery](#peer-discovery)
-      - [Pubsub](#pubsub)
-  - [What is next](#what-is-next)
-
-## Install
-
-The first step is to install libp2p in your project:
-
-```sh
-npm install libp2p
-```
-
-## Configuring libp2p
-
-If you're new to libp2p, we recommend configuring your node in stages, as this can make troubleshooting configuration issues much easier. In this guide, we'll do just that. If you're more experienced with libp2p, you may wish to jump to the [Configuration readme](./CONFIGURATION.md).
-
-### Basic setup
-
-Now that we have libp2p installed, let's configure the minimum needed to get your node running. The only modules libp2p requires are a [**Transport**][transport] and [**Crypto**][crypto] module. However, we recommend that a basic setup should also have a [**Stream Multiplexer**](streamMuxer) configured, which we will explain shortly. Let's start by setting up a Transport.
-
-#### Transports
-
-Libp2p uses Transports to establish connections between peers over the network. Transports are the components responsible for performing the actual exchange of data between libp2p nodes. You can configure any number of Transports, but you only need 1 to start with. Supporting more Transports will improve the ability of your node to speak to a larger number of nodes on the network, as matching Transports are required for two nodes to communicate with one another.
-
-You should select Transports according to the runtime of your application; Node.js or the browser. You can see a list of some of the available Transports in the [configuration readme](./CONFIGURATION.md#transport). For this guide let's install `libp2p-websockets`, as it can be used in both Node.js and the browser.
-
-Start by installing `libp2p-websockets`:
-
-```sh
-npm install libp2p-websockets
-```
-
-Now that we have the module installed, let's configure libp2p to use the Transport. We'll use the [`Libp2p.create`](./API.md#create) method, which takes a single configuration object as its only parameter. We can add the Transport by passing it into the `modules.transport` array:
-
-```js
-const Libp2p = require('libp2p')
-const WebSockets = require('libp2p-websockets')
-
-const node = await Libp2p.create({
-  modules: {
-    transport: [WebSockets]
-  }
-})
-```
-
-There are multiple libp2p transports available, you should evaluate the needs of your application and select the Transport(s) that best suit your requirements. You can add as many transports as you like to `modules.transport` in order to establish connections with as many peers as possible.
-
-<details><summary>Read More</summary>
-If you want to know more about libp2p transports, you should read the following content:
-
- https://docs.libp2p.io/concepts/transport
- https://github.com/libp2p/specs/tree/master/connections
-</details>
-
-#### Connection Encryption
-
-Encryption is an important part of communicating on the libp2p network. Every connection must be encrypted to help ensure security for everyone. As such, Connection Encryption (Crypto) is a required component of libp2p.
-
-There are a growing number of Crypto modules being developed for libp2p. As those are released they will be tracked in the [Connection Encryption section of the configuration readme](./CONFIGURATION.md#connection-encryption). For now, we are going to configure our node to use the `libp2p-secio` module, which is widely supported across the various libp2p implementations.
-
-```sh
-npm install libp2p-secio
-```
-
-With `libp2p-secio` installed, we can add it to our existing configuration by importing it and adding it to the `modules.connEncryption` array:
-
-```js
-const Libp2p = require('libp2p')
-const WebSockets = require('libp2p-websockets')
-const SECIO = require('libp2p-secio')
-
-const node = await Libp2p.create({
-  modules: {
-    transport: [WebSockets],
-    connEncryption: [SECIO]
-  }
-})
-```
-
-<details><summary>Read More</summary>
-If you want to know more about libp2p connection encryption, you should read the following content:
-
- https://docs.libp2p.io/concepts/secure-comms
- https://github.com/libp2p/specs/tree/master/connections
-</details>
-
-#### Multiplexing
-
-While multiplexers are not strictly required, they are highly recommended as they improve the effectiveness and efficiency of connections for the various protocols libp2p runs. Adding a multiplexer to your configuration will allow libp2p to run several of its internal protocols, like Identify, as well as allow your application to easily run any number of protocols over a single connection.
-
-Looking at the [available stream multiplexing](./CONFIGURATION.md#stream-multiplexing) modules, js-libp2p currently only supports `libp2p-mplex`, so we will use that here. Bear in mind that future libp2p Transports might have `multiplexing` capabilities already built-in (such as `QUIC`).
-
-You can install `libp2p-mplex` and add it to your libp2p node as follows in the next example.
-
-```sh
-npm install libp2p-mplex
-```
-
-```js
-const Libp2p = require('libp2p')
-const WebSockets = require('libp2p-websockets')
-const SECIO = require('libp2p-secio')
-const MPLEX = require('libp2p-mplex')
-
-const node = await Libp2p.create({
-  modules: {
-    transport: [WebSockets],
-    connEncryption: [SECIO],
-    streamMuxer: [MPLEX]
-  }
-})
-```
-
-<details><summary>Read More</summary>
-If you want to know more about libp2p stream multiplexing, you should read the following content:
-
- https://docs.libp2p.io/concepts/stream-multiplexing
- https://github.com/libp2p/specs/tree/master/connections
- https://github.com/libp2p/specs/tree/master/mplex
-</details>
-
-#### Running Libp2p
-
-Now that you have configured a [**Transport**][transport], [**Crypto**][crypto] and [**Stream Multiplexer**](streamMuxer) module, you can start your libp2p node. We can start and stop libp2p using the [`libp2p.start()`](./API.md#start) and [`libp2p.stop()`](./API.md#stop) methods.
-
-```js
-const Libp2p = require('libp2p')
-const WebSockets = require('libp2p-websockets')
-const SECIO = require('libp2p-secio')
-const MPLEX = require('libp2p-mplex')
-
-const node = await Libp2p.create({
-  modules: {
-    transport: [WebSockets],
-    connEncryption: [SECIO],
-    streamMuxer: [MPLEX]
-  }
-})
-
-// start libp2p
-await node.start()
-console.log('libp2p has started')
-
-// stop libp2p
-await node.stop()
-console.log('libp2p has stopped')
-```
-
-### Custom setup
-
-Once your libp2p node is running, it is time to get it connected to the public network. We can do this via peer discovery.
-
-#### Peer Discovery
-
-Peer discovery is an important part of creating a well connected libp2p node. A static list of peers will often be used to join the network, but it's useful to couple other discovery mechanisms to ensure you're able to discover other peers that are important to your application.
-
-For each discovered peer libp2p will emit a `peer:discovery` event which includes metadata about that peer. You can read the [Events](./API.md#events) in the API doc to learn more.
-
-Looking at the [available peer discovery](./CONFIGURATION.md#peer-discovery) protocols, there are several options to be considered:
- If you already know the addresses of some other network peers, you should consider using `libp2p-bootstrap` as this is the easiest way of getting your peer into the network.
- If it is likely that you will have other peers on your local network, `libp2p-mdns` is a must if you're node is not running in the browser. It allows peers to discover each other when on the same local network.
- If your application is browser based you can use the `libp2p-webrtc-star` Transport, which includes a rendezvous based peer sharing service.
- A random walk approach can be used via `libp2p-kad-dht`, to crawl the network and find new peers along the way.
-
-For this guide we will configure `libp2p-bootstrap` as this is useful for joining the public network.
-
-Let's install `libp2p-bootstrap`.
-
-```sh
-npm install libp2p-bootstrap
-```
-
-We can provide specific configurations for each protocol within a `config.peerDiscovery` property in the options as shown below.
-
-```js
-const Libp2p = require('libp2p')
-const WebSockets = require('libp2p-websockets')
-const SECIO = require('libp2p-secio')
-const MPLEX = require('libp2p-mplex')
-
-const Bootstrap = require('libp2p-bootstrap')
-
-// Known peers addresses
-const bootstrapMultiaddrs = [
-  '/dns4/ams-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd',
-  '/dns4/lon-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLMeWqB7YGVLJN3pNLQpmmEk35v6wYtsMGLzSr5QBU3'
-]
-
-const node = await Libp2p.create({
-  modules: {
-    transport: [WebSockets],
-    connEncryption: [SECIO],
-    streamMuxer: [MPLEX],
-    peerDiscovery: [Bootstrap]
-  },
-  config: {
-    peerDiscovery: {
-      autoDial: true, // Auto connect to discovered peers (limited by ConnectionManager minPeers)
-      // The `tag` property will be searched when creating the instance of your Peer Discovery service.
-      // The associated object, will be passed to the service when it is instantiated.
-      [Bootstrap.tag]: {
-        enabled: true,
-        list: bootstrapMultiaddrs // provide array of multiaddrs
-      }
-    }
-  }
-})
-
-node.on('peer:discovery', (peer) => {
-  console.log('Discovered %s', peer.id.toB58String()) // Log discovered peer
-})
-
-node.on('peer:connect', (peer) => {
-    console.log('Connected to %s', peer.id.toB58String()) // Log connected peer
-  })
-
-// start libp2p
-await node.start()
-```
-
-<details><summary>Read More</summary>
-If you want to know more about libp2p peer discovery, you should read the following content:
-
- https://github.com/libp2p/specs/blob/master/discovery/mdns.md
-</details>
-
-## What is next
-
-There are a lot of other concepts within `libp2p`, that are not covered in this guide. For additional configuration options we recommend checking out the [Configuration Readme](./CONFIGURATION.md) and the [examples folder](../examples). If you have any problems getting started, or if anything isn't clear, please let us know by submitting an issue!
-
-
-[transport]: https://github.com/libp2p/js-interfaces/tree/master/src/transport
-[crypto]: https://github.com/libp2p/js-interfaces/tree/master/src/crypto
-[streamMuxer]: https://github.com/libp2p/js-interfaces/tree/master/src/stream-muxer
--- a/doc/migrations/v0.26-v0.27.md
+++ b/doc/migrations/v0.26-v0.27.md
@@ -1,178 +0,0 @@
-# Migrating to the new API
-
-A migration guide for refactoring your application code from libp2p v0.26.x to v0.27.0.
-
-## Table of Contents
-
- [Migrating from callbacks](#migrating-from-callbacks)
- [Pull Streams to Streaming Iterables](#pull-streams-to-streaming-iterables)
- [Sample API Migrations](#sample-api-migrations)
-  - [Registering Protocol Handlers](#registering-protocol-handlers)
-  - [Dialing and Sending Data](#dialing-and-sending-data)
-  - [Checking if a peer is connected](#checking-if-a-peer-is-connected)
-  - [Pinging another peer](#pinging-another-peer)
-  - [Pubsub](#pubsub)
-    - [Getting subscribers](#getting-subscribers)
-    - [Getting subscribed topics](#getting-subscribed-topics)
-
-## Migrating from callbacks
-
-Callbacks are no longer supported in the libp2p API, as the API has now fully moved to async / await. You can see a full list of the available methods in the [API readme][api]
-
-**Before**
-```js
-libp2p.start((err) => {
-  if (err) throw err
-  console.log('libp2p started')
-})
-```
-
-**After**
-```js
-await libp2p.start()
-console.log('libp2p started')
-```
-
-## Pull Streams to Streaming Iterables
-
-The libp2p API no longer supports Pull Streams and has migrated to [Streaming Iterables][streaming_iterable]. If you would like to continue using Pull Streams in your application code, or need additional time to migrate your code base, you can leverage the conversion modules [async-iterator-to-pull-stream](https://github.com/alanshaw/async-iterator-to-pull-stream) and [pull-stream-to-async-iterator](https://github.com/alanshaw/pull-stream-to-async-iterator).
-
-For a growing list of async iterator modules, you should follow the [it-awesome repo][it_awesome].
-
-## Sample API Migrations
-
-### Registering Protocol Handlers
-
-Protocol registration is very similar to how it previously was, however, the handler now takes a single parameter containing the incoming stream and its protocol. Additionally, you can now pass an array of protocols to `.handle`, but a single string is still supported.
-
-**Before**
-```js
-const pull = require('pull-stream')
-libp2p.handle('/echo/1.0.0', (protocol, conn) => pull(conn, conn))
-```
-
-**After**
-```js
-const pipe = require('it-pipe')
-libp2p.handle(['/echo/1.0.0'], ({ protocol, stream }) => pipe(stream, stream))
-```
-
-### Dialing and Sending Data
-
-`dialProtocol` no longer takes a callback, and will now return a [Streaming Iterable][streaming_iterable] and the protocol that was successfully negotiated. The new stream can be used with async iterator modules, see [it-awesome][it_awesome], instead of pull streams.
-
-**Before**
-```js
-const pull = require('pull-stream')
-libp2p.dialProtocol(peerInfo, '/echo/1.0.0', (err, conn) => {
-  if (err) { throw err }
-  pull(
-    pull.values(['hey']),
-    conn,
-    pull.drain((data) => {
-      console.log('received echo:', data.toString())
-    }, (err) => {
-      if (err) { throw err }
-    })
-  )
-})
-```
-
-**After**
-```js
-const pipe = require('it-pipe')
-const { protocol, stream } = await libp2p.dialProtocol(peerInfo, '/echo/1.0.0')
-await pipe(
-  ['hey'],
-  stream,
-  async function (source) {
-    for await (const data of source) {
-      console.log('received echo:', data.toString())
-    }
-  }
-)
-```
-
-### Checking if a peer is connected
-
-`peerInfo.isConnected` has been deprecated. libp2p now tracks all connections centrally and will no longer update the state of `peerInfo.isConnected`. Consumers should switch to using `libp2p.registrar.getConnection(peerInfo)`, which will return an open connection to that peer if one exists.
-
-**Before**
-```js
-if (peerInfo.isConnected()) {
-  // ...do something if connected
-}
-```
-
-**After**
-```js
-const connection = libp2p.registrar.getConnection(peerInfo)
-if (connection) {
-  // ...do something if connected
-}
-```
-
-### Pinging another peer
-
-`libp2p.ping` will no longer callback with a `Ping` event emitter. The internal logic has been simplified to give more flexibility to the API. `libp2p.ping` will now execute a single ping and return the latency.
-
-**Before**
-```js
-libp2p.ping(peerInfo, (err, ping) => {
-  if (err) throw err
-  ping.once('ping', (latency) => {
-    console.log('Latency is %s ms', latency)
-    ping.stop()
-  })
-
-  ping.start()
-})
-```
-
-**After**
-```js
-const latency = await libp2p.ping(peerInfo)
-console.log('Latency is %s ms', latency)
-```
-
-### Pubsub
-
-#### Getting subscribers
-
-`libp2p.pubsub.peers()` is now `libp2p.pubsub.getSubscribers()` and is no longer an asynchronous action.
-
-**Before**
-```js
-libp2p.pubsub.peers(topic, (err, subscribers) => {
-  if (err) throw err
-  console.log('Subscribers:', subscribers)
-})
-```
-
-**After**
-```js
-const subscribers = libp2p.pubsub.getSubscribers(topic)
-console.log('Subscribers:', subscribers)
-```
-
-#### Getting subscribed topics
-
-`libp2p.pubsub.ls()` is now `libp2p.pubsub.getTopics()` and is no longer an asynchronous action.
-
-**Before**
-```js
-libp2p.pubsub.ls((err, topics) => {
-  if (err) throw err
-  console.log('Topics:', topics)
-})
-```
-
-**After**
-```js
-const topics = libp2p.pubsub.getTopics()
-console.log('Topics:', topics)
-```
-
-[api]: ../API.md
-[it_awesome]: https://github.com/alanshaw/it-awesome
-[streaming_iterable]: ../STREAMING_ITERABLES.md
--- a/examples/libp2p-in-the-browser/.babelrc
+++ b/examples/libp2p-in-the-browser/.babelrc
@@ -1,4 +0,0 @@
-{
-  "presets": ["@babel/preset-env"],
-  "plugins": ["syntax-async-functions","transform-regenerator"]
-}
--- a/examples/libp2p-in-the-browser/1/.gitignore
+++ b/examples/libp2p-in-the-browser/1/.gitignore
@@ -0,0 +1 @@
+bundle.js
--- a/examples/libp2p-in-the-browser/1/package.json
+++ b/examples/libp2p-in-the-browser/1/package.json
@@ -0,0 +1,32 @@
+{
+  "name": "libp2p-in-the-browser",
+  "version": "0.1.0",
+  "description": "See other nodes in the network using WebRTC Star discovery mechanism",
+  "main": "src/index.js",
+  "scripts": {
+    "bundle": "browserify src/index.js > public/bundle.js",
+    "serve": "static public -p 9090 -H '{\"Cache-Control\": \"no-cache, must-revalidate\"}'",
+    "start": "npm run bundle && npm run serve"
+  },
+  "license": "MIT",
+  "devDependencies": {
+    "browserify": "^14.5.0",
+    "concat-stream": "^1.6.0",
+    "detect-dom-ready": "^1.0.2",
+    "node-static": "~0.7.10"
+  },
+  "dependencies": {
+    "detect-dom-ready": "^1.0.2",
+    "libp2p": "../../../",
+    "libp2p-bootstrap": "~0.9.7",
+    "libp2p-gossipsub": "~0.0.4",
+    "libp2p-kad-dht": "^0.15.3",
+    "libp2p-mplex": "~0.8.5",
+    "libp2p-secio": "~0.11.1",
+    "libp2p-spdy": "~0.13.3",
+    "libp2p-webrtc-star": "~0.15.8",
+    "libp2p-websocket-star": "~0.10.2",
+    "libp2p-websockets": "~0.12.2",
+    "peer-info": "~0.15.1"
+  }
+}
--- a/examples/libp2p-in-the-browser/1/public/index.html
+++ b/examples/libp2p-in-the-browser/1/public/index.html
@@ -0,0 +1,14 @@
+<!doctype html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8"/>
+    <title>libp2p in the browser</title>
+  </head>
+  <body>
+    <h1>libp2p node running \o/</h1>
+    <div id="my-peer"></div>
+    <div id="swarm"></div>
+
+    <script src="bundle.js"></script>
+  </body>
+</html>
--- a/examples/libp2p-in-the-browser/1/src/browser-bundle.js
+++ b/examples/libp2p-in-the-browser/1/src/browser-bundle.js
@@ -0,0 +1,94 @@
+'use strict'
+
+const WebRTCStar = require('libp2p-webrtc-star')
+const WebSockets = require('libp2p-websockets')
+const WebSocketStar = require('libp2p-websocket-star')
+const Mplex = require('libp2p-mplex')
+const SPDY = require('libp2p-spdy')
+const SECIO = require('libp2p-secio')
+const Bootstrap = require('libp2p-bootstrap')
+const DHT = require('libp2p-kad-dht')
+const Gossipsub = require('libp2p-gossipsub')
+const libp2p = require('libp2p')
+
+// Find this list at: https://github.com/ipfs/js-ipfs/blob/master/src/core/runtime/config-browser.json
+const bootstrapList = [
+  '/dns4/ams-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd',
+  '/dns4/sfo-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLju6m7xTh3DuokvT3886QRYqxAzb1kShaanJgW36yx',
+  '/dns4/lon-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLMeWqB7YGVLJN3pNLQpmmEk35v6wYtsMGLzSr5QBU3',
+  '/dns4/sfo-2.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLnSGccFuZQJzRadHn95W2CrSFmZuTdDWP8HXaHca9z',
+  '/dns4/sfo-3.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM',
+  '/dns4/sgp-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu',
+  '/dns4/nyc-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLueR4xBeUbY9WZ9xGUUxunbKWcrNFTDAadQJmocnWm',
+  '/dns4/nyc-2.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64',
+  '/dns4/node0.preload.ipfs.io/tcp/443/wss/p2p/QmZMxNdpMkewiVZLMRxaNxUeZpDUb34pWjZ1kZvsd16Zic',
+  '/dns4/node0.preload.ipfs.io/tcp/443/wss/p2p/Qmbut9Ywz9YEDrz8ySBSgWyJk41Uvm2QJPhwDJzJyGFsD6'
+]
+
+class Node extends libp2p {
+  constructor ({ peerInfo }) {
+    const wrtcStar = new WebRTCStar({ id: peerInfo.id })
+    const wsstar = new WebSocketStar({ id: peerInfo.id })
+
+    const defaults = {
+      modules: {
+        transport: [
+          wrtcStar,
+          WebSockets,
+          wsstar
+        ],
+        streamMuxer: [
+          Mplex,
+          SPDY
+        ],
+        connEncryption: [
+          SECIO
+        ],
+        peerDiscovery: [
+          wrtcStar.discovery,
+          wsstar.discovery,
+          Bootstrap
+        ],
+        dht: DHT,
+        pubsub: Gossipsub
+      },
+      config: {
+        peerDiscovery: {
+          autoDial: true,
+          webRTCStar: {
+            enabled: true
+          },
+          websocketStar: {
+            enabled: true
+          },
+          bootstrap: {
+            interval: 20e3,
+            enabled: true,
+            list: bootstrapList
+          }
+        },
+        relay: {
+          enabled: true,
+          hop: {
+            enabled: false,
+            active: false
+          }
+        },
+        dht: {
+          enabled: false
+        },
+        pubsub: {
+          enabled: false
+        }
+      },
+      connectionManager: {
+        minPeers: 10,
+        maxPeers: 50
+      }
+    }
+
+    super({ ...defaults, peerInfo })
+  }
+}
+
+module.exports = Node
--- a/examples/libp2p-in-the-browser/1/src/create-node.js
+++ b/examples/libp2p-in-the-browser/1/src/create-node.js
@@ -0,0 +1,28 @@
+'use strict'
+
+const PeerInfo = require('peer-info')
+const Node = require('./browser-bundle')
+
+function createNode (callback) {
+  PeerInfo.create((err, peerInfo) => {
+    if (err) {
+      return callback(err)
+    }
+
+    const peerIdStr = peerInfo.id.toB58String()
+    const webrtcAddr = `/dns4/star-signal.cloud.ipfs.team/tcp/443/wss/p2p-webrtc-star/p2p/${peerIdStr}`
+    const wsAddr = `/dns4/ws-star.discovery.libp2p.io/tcp/443/wss/p2p-websocket-star`
+
+    peerInfo.multiaddrs.add(webrtcAddr)
+    peerInfo.multiaddrs.add(wsAddr)
+
+    const node = new Node({
+      peerInfo
+    })
+
+    node.idStr = peerIdStr
+    callback(null, node)
+  })
+}
+
+module.exports = createNode
--- a/examples/libp2p-in-the-browser/1/src/index.js
+++ b/examples/libp2p-in-the-browser/1/src/index.js
@@ -0,0 +1,57 @@
+/* eslint no-console: ["error", { allow: ["log"] }] */
+/* eslint max-nested-callbacks: ["error", 5] */
+'use strict'
+
+const domReady = require('detect-dom-ready')
+const createNode = require('./create-node')
+
+domReady(() => {
+  const myPeerDiv = document.getElementById('my-peer')
+  const swarmDiv = document.getElementById('swarm')
+
+  createNode((err, node) => {
+    if (err) {
+      return console.log('Could not create the Node, check if your browser has WebRTC Support', err)
+    }
+
+    node.on('peer:discovery', (peerInfo) => {
+      console.log('Discovered a peer:', peerInfo.id.toB58String())
+    })
+
+    node.on('peer:connect', (peerInfo) => {
+      const idStr = peerInfo.id.toB58String()
+      console.log('Got connection to: ' + idStr)
+      const connDiv = document.createElement('div')
+      connDiv.innerHTML = 'Connected to: ' + idStr
+      connDiv.id = idStr
+      swarmDiv.append(connDiv)
+    })
+
+    node.on('peer:disconnect', (peerInfo) => {
+      const idStr = peerInfo.id.toB58String()
+      const el = document.getElementById(idStr)
+      el && el.remove()
+    })
+
+    node.start((err) => {
+      if (err) {
+        return console.log(err)
+      }
+
+      const idStr = node.peerInfo.id.toB58String()
+
+      const idDiv = document
+        .createTextNode('Node is ready. ID: ' + idStr)
+
+      myPeerDiv.append(idDiv)
+
+      console.log('Node is listening o/')
+      node.peerInfo.multiaddrs.toArray().forEach(ma => {
+        console.log(ma.toString())
+      })
+
+      // NOTE: to stop the node
+      // node.stop((err) => {})
+    })
+  })
+})
--- a/examples/libp2p-in-the-browser/README.md
+++ b/examples/libp2p-in-the-browser/README.md
@@ -1,55 +1,22 @@
-# libp2p in the browser
+# libp2p running in the Browser

-This example leverages the [Parcel.js bundler](https://parceljs.org/) to compile and serve the libp2p code in the browser. Parcel uses [Babel](https://babeljs.io/) to handle transpilation of the code. You can use other bundlers such as Webpack or Browserify, but we will not be covering them here.
+One of the primary goals with libp2p P2P was to get it fully working in the browser and interopable with the versions running in Go and in Node.js.

-## Setup
+# 1. Setting up a simple app that lists connections to other nodes

-In order to run the example, first install the dependencies from same directory as this README:
+Start by installing libp2p's dependencies.

-```
-cd ./examples/libp2p-in-the-browser
-npm install
+```bash
+> cd ../../
+> npm install
+> cd examples/libp2p-in-the-browser
 ```

-## Signaling Server
+Then simply go into the folder [1](./1) and execute the following

-This example uses the `libp2p-webrtc-star` module, which enables libp2p browser nodes to establish direct connections to one another via a central signaling server. For this example, we are using the signaling server that ships with `libp2p-webrtc-star`.
-
-You can start the server by running `npm run server`. This will start a signaling server locally on port `9090`. If you'd like to run a signaling server outside of this example, you can see instructions on how to do so in the [`libp2p-webrtc-star` README](https://github.com/libp2p/js-libp2p-webrtc-star).
-
-When you run the server, you should see output that looks something like this:
-
-```log
-$ npm run server
-
-> libp2p-in-browser@1.0.0 server
-> star-signal
-
-Listening on: http://0.0.0.0:9090
+```bash
+> cd 1
+> npm install
+> npm start
+# open your browser in port :9090
 ```
-
-## Running the examples
-
-Once you have started the signaling server, you can run the Parcel server.
-
-```
-npm start
-```
-
-The output should look something like this:
-
-```log
-$ npm start
-
-> libp2p-in-browser@1.0.0 start
-> parcel index.html
-
-Server running at http://localhost:1234
-✨  Built in 1000ms.
-```
-
-This will compile the code and start a server listening on port [http://localhost:1234](http://localhost:1234). Now open your browser to `http://localhost:1234`. You should see a log of your node's Peer ID, the discovered peers from the Bootstrap module, and connections to those peers as they are created.
-
-Now, if you open a second browser tab to `http://localhost:1234`, you should discover your node from the previous tab. This is due to the fact that the `libp2p-webrtc-star` transport also acts as a Peer Discovery interface. Your node will be notified of any peer that connects to the same signaling server you are connected to. Once libp2p discovers this new peer, it will attempt to establish a direct WebRTC connection.
-
-**Note**: In the example we assign libp2p to `window.libp2p`, in case you would like to play around with the API directly in the browser. You can of course make changes to `index.js` and Parcel will automatically rebuild and reload the browser tabs.
--- a/examples/libp2p-in-the-browser/index.html
+++ b/examples/libp2p-in-the-browser/index.html
@@ -1,23 +0,0 @@
-<!DOCTYPE html>
-
-<html lang="en">
-
-  <head>
-    <meta charset="utf-8">
-    <title>js-libp2p parcel.js browser example</title>
-  </head>
-
-  <body>
-    <header>
-      <h1 id="status">Starting libp2p...</h1>
-    </header>
-
-    <main>
-      <pre id="output"></pre>
-    </main>
-
-    <script src="./index.js"></script>
-
-  </body>
-
-</html>
--- a/examples/libp2p-in-the-browser/index.js
+++ b/examples/libp2p-in-the-browser/index.js
@@ -1,73 +0,0 @@
-import 'babel-polyfill'
-import Libp2p from 'libp2p'
-import Websockets from 'libp2p-websockets'
-import WebRTCStar from 'libp2p-webrtc-star'
-import Secio from 'libp2p-secio'
-import Mplex from 'libp2p-mplex'
-import Boostrap from 'libp2p-bootstrap'
-
-document.addEventListener('DOMContentLoaded', async () => {
-  // Create our libp2p node
-  const libp2p = await Libp2p.create({
-    modules: {
-      transport: [Websockets, WebRTCStar],
-      connEncryption: [Secio],
-      streamMuxer: [Mplex],
-      peerDiscovery: [Boostrap]
-    },
-    config: {
-      peerDiscovery: {
-        bootstrap: {
-          enabled: true,
-          list: [
-            '/dns4/ams-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd',
-            '/dns4/lon-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLMeWqB7YGVLJN3pNLQpmmEk35v6wYtsMGLzSr5QBU3',
-            '/dns4/sfo-3.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM',
-            '/dns4/sgp-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu',
-            '/dns4/nyc-1.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLueR4xBeUbY9WZ9xGUUxunbKWcrNFTDAadQJmocnWm',
-            '/dns4/nyc-2.bootstrap.libp2p.io/tcp/443/wss/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64'
-          ]
-        }
-      }
-    }
-  })
-
-  // UI elements
-  const status = document.getElementById('status')
-  const output = document.getElementById('output')
-
-  output.textContent = ''
-
-  function log (txt) {
-    console.info(txt)
-    output.textContent += `${txt.trim()}\n`
-  }
-
-  // Add the signaling server address, along with our PeerId to our multiaddrs list
-  // libp2p will automatically attempt to dial to the signaling server so that it can
-  // receive inbound connections from other peers
-  const webrtcAddr = '/ip4/0.0.0.0/tcp/9090/wss/p2p-webrtc-star'
-  libp2p.peerInfo.multiaddrs.add(webrtcAddr)
-
-  // Listen for new peers
-  libp2p.on('peer:discovery', (peerInfo) => {
-    log(`Found peer ${peerInfo.id.toB58String()}`)
-  })
-
-  // Listen for new connections to peers
-  libp2p.on('peer:connect', (peerInfo) => {
-    log(`Connected to ${peerInfo.id.toB58String()}`)
-  })
-
-  // Listen for peers disconnecting
-  libp2p.on('peer:disconnect', (peerInfo) => {
-    log(`Disconnected from ${peerInfo.id.toB58String()}`)
-  })
-
-  await libp2p.start()
-  status.innerText = 'libp2p started!'
-  log(`libp2p id is ${libp2p.peerInfo.id.toB58String()}`)
-
-  // Export libp2p to the window so you can play with the API
-  window.libp2p = libp2p
-})
--- a/examples/libp2p-in-the-browser/package.json
+++ b/examples/libp2p-in-the-browser/package.json
@@ -1,34 +0,0 @@
-{
-  "name": "libp2p-in-browser",
-  "version": "1.0.0",
-  "description": "A libp2p node running in the browser",
-  "main": "index.js",
-  "browserslist": [
-    "last 2 Chrome versions"
-  ],
-  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1",
-    "start": "parcel index.html",
-    "server": "star-signal"
-  },
-  "keywords": [],
-  "author": "",
-  "license": "ISC",
-  "dependencies": {
-    "@babel/preset-env": "^7.8.3",
-    "libp2p": "../../",
-    "libp2p-bootstrap": "^0.10.3",
-    "libp2p-mplex": "^0.9.3",
-    "libp2p-secio": "^0.12.2",
-    "libp2p-webrtc-star": "^0.17.3",
-    "libp2p-websockets": "^0.13.2"
-  },
-  "devDependencies": {
-    "@babel/cli": "^7.8.3",
-    "@babel/core": "^7.8.3",
-    "babel-plugin-syntax-async-functions": "^6.13.0",
-    "babel-plugin-transform-regenerator": "^6.26.0",
-    "babel-polyfill": "^6.26.0",
-    "parcel-bundler": "^1.12.4"
-  }
-}
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
  "name": "libp2p",
-  "version": "0.27.1",
+  "version": "0.27.0-pre.2",
  "description": "JavaScript implementation of libp2p, a modular peer to peer network stack",
  "leadMaintainer": "Jacob Heun <jacobheun@gmail.com>",
  "main": "src/index.js",
@@ -57,7 +57,7 @@
    "it-protocol-buffers": "^0.2.0",
    "latency-monitor": "~0.2.1",
    "libp2p-crypto": "^0.17.1",
-    "libp2p-interfaces": "^0.2.3",
+    "libp2p-interfaces": "^0.1.5",
    "mafmt": "^7.0.0",
    "merge-options": "^2.0.0",
    "moving-average": "^1.0.0",
@@ -77,7 +77,7 @@
  "devDependencies": {
    "@nodeutils/defaults-deep": "^1.1.0",
    "abortable-iterator": "^2.1.0",
-    "aegir": "^20.5.1",
+    "aegir": "^20.4.1",
    "chai": "^4.2.0",
    "chai-as-promised": "^7.1.1",
    "cids": "^0.7.1",
@@ -90,7 +90,7 @@
    "libp2p-delegated-content-routing": "^0.4.1",
    "libp2p-delegated-peer-routing": "^0.4.0",
    "libp2p-floodsub": "^0.20.0",
-    "libp2p-gossipsub": "^0.2.0",
+    "libp2p-gossipsub": "ChainSafe/gossipsub-js#fix/bind-is-not-needed",
    "libp2p-kad-dht": "^0.18.2",
    "libp2p-mdns": "^0.13.0",
    "libp2p-mplex": "^0.9.1",
@@ -102,7 +102,7 @@
    "p-defer": "^3.0.0",
    "p-times": "^2.1.0",
    "p-wait-for": "^3.1.0",
-    "sinon": "^8.1.0",
+    "sinon": "^7.2.7",
    "streaming-iterables": "^4.1.0",
    "wrtc": "^0.4.1"
  },
@@ -112,7 +112,6 @@
    "Alan Shaw <alan@tableflip.io>",
    "Alex Potsides <alex@achingbrain.net>",
    "Andrew Nesbitt <andrewnez@gmail.com>",
-    "Cayman <caymannava@gmail.com>",
    "Chris Bratlien <chrisbratlien@gmail.com>",
    "Chris Dostert <chrisdostert@users.noreply.github.com>",
    "Daijiro Wachi <daijiro.wachi@gmail.com>",
@@ -160,7 +159,6 @@
    "isan_rivkin <isanrivkin@gmail.com>",
    "mayerwin <mayerwin@users.noreply.github.com>",
    "phillmac <phillmac@users.noreply.github.com>",
-    "shresthagrawal <34920931+shresthagrawal@users.noreply.github.com>",
    "swedneck <40505480+swedneck@users.noreply.github.com>",
    "ᴠɪᴄᴛᴏʀ ʙᴊᴇʟᴋʜᴏʟᴍ <victorbjelkholm@gmail.com>"
  ]
--- a/src/connection-manager/index.js
+++ b/src/connection-manager/index.js
@@ -36,7 +36,7 @@ class ConnectionManager {
  constructor (libp2p, options) {
    this._libp2p = libp2p
    this._registrar = libp2p.registrar
-    this._peerId = libp2p.peerInfo.id.toB58String()
+    this._peerId = libp2p.peerInfo.id.toString()
    this._options = mergeOptions.call({ ignoreUndefined: true }, defaultOptions, options)
    assert(
      this._options.maxConnections > this._options.minConnections,
@@ -91,8 +91,8 @@ class ConnectionManager {
    if (value < 0 || value > 1) {
      throw new Error('value should be a number between 0 and 1')
    }
-    if (peerId.toB58String) {
-      peerId = peerId.toB58String()
+    if (peerId.toString) {
+      peerId = peerId.toString()
    }
    this._peerValues.set(peerId, value)
  }
@@ -119,7 +119,7 @@ class ConnectionManager {
   * @param {Connection} connection
   */
  onConnect (connection) {
-    const peerId = connection.remotePeer.toB58String()
+    const peerId = connection.remotePeer.toString()
    this._connections.set(connection.id, connection)
    if (!this._peerValues.has(peerId)) {
      this._peerValues.set(peerId, this._options.defaultPeerValue)
@@ -133,7 +133,7 @@ class ConnectionManager {
   */
  onDisconnect (connection) {
    this._connections.delete(connection.id)
-    this._peerValues.delete(connection.remotePeer.toB58String())
+    this._peerValues.delete(connection.remotePeer.toString())
  }

  /**
@@ -175,7 +175,7 @@ class ConnectionManager {
        debug('%s: lowest value peer is %s', this._peerId, peerId)
        debug('%s: closing a connection to %j', this._peerId, peerId)
        for (const connection of this._connections.values()) {
-          if (connection.remotePeer.toB58String() === peerId) {
+          if (connection.remotePeer.toString() === peerId) {
            connection.close()
            break
          }
--- a/src/dialer/index.js
+++ b/src/dialer/index.js
@@ -113,7 +113,7 @@ class Dialer {
    }
    const addrs = this.peerStore.multiaddrsForPeer(dialable)
    return {
-      id: dialable.id.toB58String(),
+      id: dialable.id.toString(),
      addrs
    }
  }
--- a/src/identify/index.js
+++ b/src/identify/index.js
@@ -180,7 +180,7 @@ class IdentifyService {

    const id = await PeerId.createFromPubKey(publicKey)
    const peerInfo = new PeerInfo(id)
-    if (connection.remotePeer.toB58String() !== id.toB58String()) {
+    if (connection.remotePeer.toString() !== id.toString()) {
      throw errCode(new Error('identified peer does not match the expected peer'), codes.ERR_INVALID_PEER)
    }

--- a/src/index.js
+++ b/src/index.js
@@ -314,7 +314,7 @@ class Libp2p extends EventEmitter {
  hangUp (peer) {
    const peerInfo = getPeerInfo(peer, this.peerStore)
    return Promise.all(
-      this.registrar.connections.get(peerInfo.id.toB58String()).map(connection => {
+      this.registrar.connections.get(peerInfo.id.toString()).map(connection => {
        return connection.close()
      })
    )
@@ -426,7 +426,7 @@ class Libp2p extends EventEmitter {
   * @param {PeerInfo} peerInfo
   */
  _onDiscoveryPeer (peerInfo) {
-    if (peerInfo.id.toB58String() === this.peerInfo.id.toB58String()) {
+    if (peerInfo.id.toString() === this.peerInfo.id.toString()) {
      log.error(new Error(codes.ERR_DISCOVERED_SELF))
      return
    }
@@ -445,7 +445,7 @@ class Libp2p extends EventEmitter {
    if (this._config.peerDiscovery.autoDial === true && !this.registrar.getConnection(peerInfo)) {
      const minPeers = this._options.connectionManager.minPeers || 0
      if (minPeers > this.connectionManager._connections.size) {
-        log('connecting to discovered peer %s', peerInfo.id.toB58String())
+        log('connecting to discovered peer %s', peerInfo.id.toString())
        try {
          await this.dialer.connectToPeer(peerInfo)
        } catch (err) {
--- a/src/metrics/index.js
+++ b/src/metrics/index.js
@@ -82,7 +82,7 @@ class Metrics {
   * @returns {Stats}
   */
  forPeer (peerId) {
-    const idString = peerId.toB58String()
+    const idString = peerId.toString()
    return this._peerStats.get(idString) || this._oldPeers.get(idString)
  }

@@ -110,7 +110,7 @@ class Metrics {
   * @param {PeerId} peerId
   */
  onPeerDisconnected (peerId) {
-    const idString = peerId.toB58String()
+    const idString = peerId.toString()
    const peerStats = this._peerStats.get(idString)
    if (peerStats) {
      peerStats.stop()
@@ -140,7 +140,7 @@ class Metrics {
    let peerStats = this.forPeer(remotePeer)
    if (!peerStats) {
      peerStats = new Stats(initialCounters, this._options)
-      this._peerStats.set(remotePeer.toB58String(), peerStats)
+      this._peerStats.set(remotePeer.toString(), peerStats)
    }

    // Peer and global stats
@@ -162,13 +162,13 @@ class Metrics {
   * Replaces the `PeerId` string with the given `peerId`.
   * If stats are already being tracked for the given `peerId`, the
   * placeholder stats will be merged with the existing stats.
-   * @param {PeerId} placeholder A peerId string
+   * @param {string} placeholder A peerId string
   * @param {PeerId} peerId
   */
  updatePlaceholder (placeholder, peerId) {
    if (!this._running) return
    const placeholderStats = this.forPeer(placeholder)
-    const peerIdString = peerId.toB58String()
+    const peerIdString = peerId.toString()
    const existingStats = this.forPeer(peerId)
    let mergedStats = placeholderStats

@@ -180,7 +180,7 @@ class Metrics {
      this._oldPeers.delete(peerIdString)
    }

-    this._peerStats.delete(placeholder.toB58String())
+    this._peerStats.delete(placeholder.toString())
    this._peerStats.set(peerIdString, mergedStats)
    mergedStats.start()
  }
--- a/src/ping/index.js
+++ b/src/ping/index.js
@@ -8,7 +8,7 @@ const errCode = require('err-code')
 const crypto = require('libp2p-crypto')
 const pipe = require('it-pipe')
 const { toBuffer } = require('it-buffer')
-const { collect, take } = require('streaming-iterables')
+const { collect } = require('streaming-iterables')

 const { PROTOCOL, PING_LENGTH } = require('./constants')

@@ -29,7 +29,6 @@ async function ping (node, peer) {
  const [result] = await pipe(
    [data],
    stream,
-    stream => take(1, stream),
    toBuffer,
    collect
  )
--- a/src/registrar.js
+++ b/src/registrar.js
@@ -74,7 +74,7 @@ class Registrar {
    assert(PeerInfo.isPeerInfo(peerInfo), 'peerInfo must be an instance of peer-info')
    assert(Connection.isConnection(conn), 'conn must be an instance of interface-connection')

-    const id = peerInfo.id.toB58String()
+    const id = peerInfo.id.toString()
    const storedConn = this.connections.get(id)

    if (storedConn) {
@@ -95,18 +95,18 @@ class Registrar {
  onDisconnect (peerInfo, connection, error) {
    assert(PeerInfo.isPeerInfo(peerInfo), 'peerInfo must be an instance of peer-info')

-    const id = peerInfo.id.toB58String()
+    const id = peerInfo.id.toString()
    let storedConn = this.connections.get(id)

    if (storedConn && storedConn.length > 1) {
-      storedConn = storedConn.filter((conn) => conn.id !== connection.id)
+      storedConn = storedConn.filter((conn) => conn.id === connection.id)
      this.connections.set(id, storedConn)
    } else if (storedConn) {
      for (const [, topology] of this.topologies) {
        topology.disconnect(peerInfo, error)
      }

-      this.connections.delete(peerInfo.id.toB58String())
+      this.connections.delete(peerInfo.id.toString())
    }
  }

@@ -118,7 +118,7 @@ class Registrar {
  getConnection (peerInfo) {
    assert(PeerInfo.isPeerInfo(peerInfo), 'peerInfo must be an instance of peer-info')

-    const connections = this.connections.get(peerInfo.id.toB58String())
+    const connections = this.connections.get(peerInfo.id.toString())
    // Return the first, open connection
    if (connections) {
      return connections.find(connection => connection.stat.status === 'open')
--- a/src/transport-manager.js
+++ b/src/transport-manager.js
@@ -86,8 +86,8 @@ class TransportManager {
    try {
      return await transport.dial(ma, options)
    } catch (err) {
-      if (!err.code) err.code = codes.ERR_TRANSPORT_DIAL_FAILED
-      throw err
+      if (err.code) throw err
+      throw errCode(err, codes.ERR_TRANSPORT_DIAL_FAILED)
    }
  }

--- a/src/upgrader.js
+++ b/src/upgrader.js
@@ -73,7 +73,7 @@ class Upgrader {
    if (this.metrics) {
      ({ setTarget: setPeer, proxy: proxyPeer } = mutableProxy())
      const idString = (parseInt(Math.random() * 1e9)).toString(36) + Date.now()
-      setPeer({ toB58String: () => idString })
+      setPeer({ toString: () => idString })
      maConn = this.metrics.trackStream({ stream: maConn, remotePeer: proxyPeer })
    }

@@ -147,7 +147,7 @@ class Upgrader {
    if (this.metrics) {
      ({ setTarget: setPeer, proxy: proxyPeer } = mutableProxy())
      const idString = (parseInt(Math.random() * 1e9)).toString(36) + Date.now()
-      setPeer({ toB58String: () => idString })
+      setPeer({ toString: () => idString })
      maConn = this.metrics.trackStream({ stream: maConn, remotePeer: proxyPeer })
    }

@@ -216,10 +216,7 @@ class Upgrader {
    Muxer,
    remotePeer
  }) {
-    let muxer
-    let newStream
-    // eslint-disable-next-line prefer-const
-    let connection
+    let muxer, newStream

    if (Muxer) {
      // Create the muxer
@@ -264,7 +261,7 @@ class Upgrader {
    const _timeline = maConn.timeline
    maConn.timeline = new Proxy(_timeline, {
      set: (...args) => {
-        if (connection && args[1] === 'close' && args[2] && !_timeline.close) {
+        if (args[1] === 'close' && args[2] && !_timeline.close) {
          connection.stat.status = 'closed'
          this.onConnectionEnd(connection)
        }
@@ -279,7 +276,7 @@ class Upgrader {
    }

    // Create the connection
-    connection = new Connection({
+    const connection = new Connection({
      localAddr: maConn.localAddr,
      remoteAddr: maConn.remoteAddr,
      localPeer: this.localPeer,
--- a/test/connection-manager/index.spec.js
+++ b/test/connection-manager/index.spec.js
@@ -75,7 +75,7 @@ describe('Connection Manager', () => {
      const spy = sinon.spy(connection, 'close')
      // The connections have the same remote id, give them random ones
      // so that we can verify the correct connection was closed
-      sinon.stub(connection.remotePeer, 'toB58String').returns(index)
+      sinon.stub(connection.remotePeer, 'toString').returns(index)
      const value = Math.random()
      spies.set(value, spy)
      libp2p.connectionManager.setPeerValue(connection.remotePeer, value)
--- a/test/core/listening.node.js
+++ b/test/core/listening.node.js
@@ -41,13 +41,16 @@ describe('Listening', () => {
    // Should get something like:
    //   /ip4/127.0.0.1/tcp/50866
    //   /ip4/192.168.1.2/tcp/50866
-    expect(addrs.length).to.be.at.least(2)
-    for (const addr of addrs) {
-      const opts = addr.toOptions()
-      expect(opts.family).to.equal('ipv4')
-      expect(opts.transport).to.equal('tcp')
-      expect(opts.host).to.match(/[0-9]+\.[0-9]+\.[0-9]+\.[0-9]+/)
-      expect(opts.port).to.be.gt(0)
-    }
+    expect(addrs.length).to.equal(2)
+
+    const opts = [addrs[0].toOptions(), addrs[1].toOptions()]
+    expect(opts[0].family).to.equal('ipv4')
+    expect(opts[1].family).to.equal('ipv4')
+    expect(opts[0].transport).to.equal('tcp')
+    expect(opts[1].transport).to.equal('tcp')
+    expect(opts[0].host).to.match(/[0-9]+\.[0-9]+\.[0-9]+\.[0-9]+/)
+    expect(opts[1].host).to.match(/[0-9]+\.[0-9]+\.[0-9]+\.[0-9]+/)
+    expect(opts[0].port).to.be.gt(0)
+    expect(opts[1].port).to.be.gt(0)
  })
 })
--- a/test/core/ping.node.js
+++ b/test/core/ping.node.js
@@ -6,11 +6,9 @@ chai.use(require('dirty-chai'))
 const { expect } = chai

 const pTimes = require('p-times')
-const pipe = require('it-pipe')

 const peerUtils = require('../utils/creators/peer')
 const baseOptions = require('../utils/base-options')
-const { PROTOCOL } = require('../../src/ping/constants')

 describe('ping', () => {
  let nodes
@@ -34,40 +32,4 @@ describe('ping', () => {
    const averageLatency = latencies.reduce((p, c) => p + c, 0) / latencies.length
    expect(averageLatency).to.be.a('Number')
  })
-
-  it('only waits for the first response to arrive', async () => {
-    nodes[1].handle(PROTOCOL, async ({ connection, stream }) => {
-      let firstInvocation = true
-
-      await pipe(
-        stream,
-        function (stream) {
-          const output = {
-            [Symbol.asyncIterator]: () => output,
-            next: async () => {
-              if (firstInvocation) {
-                firstInvocation = false
-
-                for await (const data of stream) {
-                  return {
-                    value: data,
-                    done: false
-                  }
-                }
-              } else {
-                return new Promise() // never resolve
-              }
-            }
-          }
-
-          return output
-        },
-        stream
-      )
-    })
-
-    const latency = await nodes[0].ping(nodes[1].peerInfo)
-
-    expect(latency).to.be.a('Number')
-  })
 })
--- a/test/dialing/direct.node.js
+++ b/test/dialing/direct.node.js
@@ -306,7 +306,7 @@ describe('Dialing (direct, TCP)', () => {
        }
      })

-      const connection = await libp2p.dial(`${remoteAddr.toString()}/p2p/${remotePeerInfo.id.toB58String()}`)
+      const connection = await libp2p.dial(`${remoteAddr.toString()}/p2p/${remotePeerInfo.id.toString()}`)
      expect(connection).to.exist()
      expect(connection.stat.timeline.close).to.not.exist()
      await libp2p.hangUp(connection.remotePeer)
@@ -375,7 +375,7 @@ describe('Dialing (direct, TCP)', () => {
      })
      const dials = 10

-      const fullAddress = remoteAddr.encapsulate(`/p2p/${remoteLibp2p.peerInfo.id.toB58String()}`)
+      const fullAddress = remoteAddr.encapsulate(`/p2p/${remoteLibp2p.peerInfo.id.toString()}`)
      const dialResults = await Promise.all([...new Array(dials)].map((_, index) => {
        if (index % 2 === 0) return libp2p.dial(remoteLibp2p.peerInfo)
        return libp2p.dial(fullAddress)
@@ -405,7 +405,7 @@ describe('Dialing (direct, TCP)', () => {
      const error = new Error('Boom')
      sinon.stub(libp2p.transportManager, 'dial').callsFake(() => Promise.reject(error))

-      const fullAddress = remoteAddr.encapsulate(`/p2p/${remoteLibp2p.peerInfo.id.toB58String()}`)
+      const fullAddress = remoteAddr.encapsulate(`/p2p/${remoteLibp2p.peerInfo.id.toString()}`)
      const dialResults = await pSettle([...new Array(dials)].map((_, index) => {
        if (index % 2 === 0) return libp2p.dial(remoteLibp2p.peerInfo)
        return libp2p.dial(fullAddress)
--- a/test/dialing/relay.node.js
+++ b/test/dialing/relay.node.js
@@ -59,11 +59,11 @@ describe('Dialing (via relay, TCP)', () => {

  it('should be able to connect to a peer over a relay with active connections', async () => {
    const relayAddr = relayLibp2p.transportManager.getAddrs()[0]
-    const relayIdString = relayLibp2p.peerInfo.id.toB58String()
+    const relayIdString = relayLibp2p.peerInfo.id.toString()

    const dialAddr = relayAddr
      .encapsulate(`/p2p/${relayIdString}`)
-      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toB58String()}`)
+      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toString()}`)

    const tcpAddrs = dstLibp2p.transportManager.getAddrs()
    await dstLibp2p.transportManager.listen([multiaddr(`/p2p-circuit${relayAddr}/p2p/${relayIdString}`)])
@@ -94,11 +94,11 @@ describe('Dialing (via relay, TCP)', () => {

  it('should fail to connect to a peer over a relay with inactive connections', async () => {
    const relayAddr = relayLibp2p.transportManager.getAddrs()[0]
-    const relayIdString = relayLibp2p.peerInfo.id.toB58String()
+    const relayIdString = relayLibp2p.peerInfo.id.toString()

    const dialAddr = relayAddr
      .encapsulate(`/p2p/${relayIdString}`)
-      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toB58String()}`)
+      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toString()}`)

    await expect(srcLibp2p.dial(dialAddr))
      .to.eventually.be.rejectedWith(AggregateError)
@@ -107,11 +107,11 @@ describe('Dialing (via relay, TCP)', () => {

  it('should not stay connected to a relay when not already connected and HOP fails', async () => {
    const relayAddr = relayLibp2p.transportManager.getAddrs()[0]
-    const relayIdString = relayLibp2p.peerInfo.id.toB58String()
+    const relayIdString = relayLibp2p.peerInfo.id.toString()

    const dialAddr = relayAddr
      .encapsulate(`/p2p/${relayIdString}`)
-      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toB58String()}`)
+      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toString()}`)

    await expect(srcLibp2p.dial(dialAddr))
      .to.eventually.be.rejectedWith(AggregateError)
@@ -124,11 +124,11 @@ describe('Dialing (via relay, TCP)', () => {

  it('dialer should stay connected to an already connected relay on hop failure', async () => {
    const relayAddr = relayLibp2p.transportManager.getAddrs()[0]
-    const relayIdString = relayLibp2p.peerInfo.id.toB58String()
+    const relayIdString = relayLibp2p.peerInfo.id.toString()

    const dialAddr = relayAddr
      .encapsulate(`/p2p/${relayIdString}`)
-      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toB58String()}`)
+      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toString()}`)

    await srcLibp2p.dial(relayAddr)

@@ -143,11 +143,11 @@ describe('Dialing (via relay, TCP)', () => {

  it('destination peer should stay connected to an already connected relay on hop failure', async () => {
    const relayAddr = relayLibp2p.transportManager.getAddrs()[0]
-    const relayIdString = relayLibp2p.peerInfo.id.toB58String()
+    const relayIdString = relayLibp2p.peerInfo.id.toString()

    const dialAddr = relayAddr
      .encapsulate(`/p2p/${relayIdString}`)
-      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toB58String()}`)
+      .encapsulate(`/p2p-circuit/p2p/${dstLibp2p.peerInfo.id.toString()}`)

    // Connect the destination peer and the relay
    const tcpAddrs = dstLibp2p.transportManager.getAddrs()
--- a/test/identify/index.spec.js
+++ b/test/identify/index.spec.js
@@ -84,12 +84,7 @@ describe('Identify', () => {
  it('should throw if identified peer is the wrong peer', async () => {
    const localIdentify = new IdentifyService({
      peerInfo: localPeer,
-      protocols,
-      registrar: {
-        peerStore: {
-          replace: () => {}
-        }
-      }
+      protocols
    })
    const remoteIdentify = new IdentifyService({
      peerInfo: remotePeer,
@@ -97,7 +92,7 @@ describe('Identify', () => {
    })

    const observedAddr = multiaddr('/ip4/127.0.0.1/tcp/1234')
-    const localConnectionMock = { newStream: () => {}, remotePeer: localPeer.id }
+    const localConnectionMock = { newStream: () => {}, remotePeer }
    const remoteConnectionMock = { remoteAddr: observedAddr }

    const [local, remote] = duplexPair()
--- a/test/metrics/index.spec.js
+++ b/test/metrics/index.spec.js
@@ -104,7 +104,7 @@ describe('Metrics', () => {
    expect(results.length).to.eql(bytes.length * 10)

    const stats = metrics.forPeer(peerId)
-    expect(metrics.peers).to.eql([peerId.toB58String()])
+    expect(metrics.peers).to.eql([peerId.toString()])
    expect(stats.snapshot.dataReceived.toNumber()).to.equal(results.length)
    expect(stats.snapshot.dataSent.toNumber()).to.equal(results.length)

@@ -148,7 +148,7 @@ describe('Metrics', () => {
    // Flush the call stack
    await delay(0)

-    expect(metrics.peers).to.eql([peerId.toB58String(), peerId2.toB58String()])
+    expect(metrics.peers).to.eql([peerId.toString(), peerId2.toString()])
    // Verify global metrics
    const globalStats = metrics.global
    expect(globalStats.snapshot.dataReceived.toNumber()).to.equal(bytes.length * 2)
@@ -181,7 +181,7 @@ describe('Metrics', () => {
    pipe(remote, remote)

    const mockPeer = {
-      toB58String: () => 'a temporary id'
+      toString: () => 'a temporary id'
    }
    metrics.trackStream({
      stream: local,
@@ -197,8 +197,8 @@ describe('Metrics', () => {

    await delay(0)

-    metrics.updatePlaceholder(mockPeer, peerId)
-    mockPeer.toB58String = peerId.toB58String.bind(peerId)
+    metrics.updatePlaceholder(mockPeer.toString(), peerId)
+    mockPeer.toString = peerId.toString.bind(peerId)

    input.push(bytes)
    input.end()
@@ -206,7 +206,7 @@ describe('Metrics', () => {
    await deferredPromise
    await delay(0)

-    expect(metrics.peers).to.eql([peerId.toB58String()])
+    expect(metrics.peers).to.eql([peerId.toString()])
    // Verify global metrics
    const globalStats = metrics.global
    expect(globalStats.snapshot.dataReceived.toNumber()).to.equal(bytes.length * 2)
@@ -237,7 +237,7 @@ describe('Metrics', () => {
    // Disconnect every peer
    for (const id of trackedPeers.keys()) {
      metrics.onPeerDisconnected({
-        toB58String: () => id
+        toString: () => id
      })
    }

@@ -245,9 +245,7 @@ describe('Metrics', () => {
    expect(metrics.peers).to.have.length(0)
    const retainedPeers = []
    for (const id of trackedPeers.keys()) {
-      const stat = metrics.forPeer({
-        toB58String: () => id
-      })
+      const stat = metrics.forPeer(id)
      if (stat) retainedPeers.push(id)
    }
    expect(retainedPeers).to.eql(['45', '46', '47', '48', '49'])
--- a/test/registrar/registrar.spec.js
+++ b/test/registrar/registrar.spec.js
@@ -11,7 +11,6 @@ const Topology = require('libp2p-interfaces/src/topology/multicodec-topology')
 const PeerStore = require('../../src/peer-store')
 const Registrar = require('../../src/registrar')
 const { createMockConnection } = require('./utils')
-const peerUtils = require('../utils/creators/peer')

 const multicodec = '/test/1.0.0'

@@ -171,44 +170,5 @@ describe('registrar', () => {

      await onDisconnectDefer.promise
    })
-
-    it('should filter connections on disconnect, removing the closed one', async () => {
-      const onDisconnectDefer = pDefer()
-
-      const topologyProps = new Topology({
-        multicodecs: multicodec,
-        handlers: {
-          onConnect: () => {},
-          onDisconnect: () => {
-            onDisconnectDefer.resolve()
-          }
-        }
-      })
-
-      // Register protocol
-      registrar.register(topologyProps)
-
-      // Setup connections before registrar
-      const [localPeer, remotePeer] = await peerUtils.createPeerInfo({ number: 2 })
-
-      const conn1 = await createMockConnection({ localPeer: localPeer.id, remotePeer: remotePeer.id })
-      const conn2 = await createMockConnection({ localPeer: localPeer.id, remotePeer: remotePeer.id })
-      const peerInfo = await PeerInfo.create(remotePeer.id)
-      const id = peerInfo.id.toB58String()
-
-      // Add connection to registrar
-      peerStore.put(peerInfo)
-      registrar.onConnect(peerInfo, conn1)
-      registrar.onConnect(peerInfo, conn2)
-
-      expect(registrar.connections.get(id).length).to.eql(2)
-
-      conn2._stat.status = 'closed'
-      registrar.onDisconnect(peerInfo, conn2)
-
-      const peerConnections = registrar.connections.get(id)
-      expect(peerConnections.length).to.eql(1)
-      expect(peerConnections[0]._stat.status).to.eql('open')
-    })
  })
 })
--- a/test/registrar/utils.js
+++ b/test/registrar/utils.js
@@ -27,8 +27,7 @@ module.exports.createMockConnection = async (properties = {}) => {
      },
      direction: 'outbound',
      encryption: '/secio/1.0.0',
-      multiplexer: '/mplex/6.7.0',
-      status: 'open'
+      multiplexer: '/mplex/6.7.0'
    },
    newStream: (protocols) => {
      const id = streamId++
Author	SHA1	Message	Date
Vasco Santos	4dbc6a4dd8	chore: use fixed gossipsub	2020-01-13 16:32:12 +01:00
Alan Shaw	c44e6e33ed	fix: stop discoveries (#530 ) * fix: stop discoveries * test: add discovery stop test * chore: fix lint Co-authored-by: Jacob Heun <jacobheun@gmail.com>	2020-01-07 16:27:32 +01:00
Jacob Heun	999d086278	chore: release version v0.27.0-pre.2	2020-01-07 15:31:13 +01:00
Jacob Heun	122a114d96	chore: update contributors	2020-01-07 15:30:59 +01:00
Vasco Santos	21362b5cbe	refactor: examples transports (#503 ) * refactor: examples-transports * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * chore: address review Co-authored-by: Jacob Heun <jacobheun@gmail.com>	2020-01-07 14:56:05 +01:00
Vasco Santos	0840739a00	refactor: examples/pnet (#523 ) * refactor: examples/pnet * chore: rename pnet-ipfs to pnet * chore: address review	2020-01-07 14:53:27 +01:00
Vasco Santos	f182f5bcd9	refactor: examples/discovery-mechanisms (#498 ) * refactor: examples-discovery-mechanisms * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: suggestion interval Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: add peer connected event Co-authored-by: Jacob Heun <jacobheun@gmail.com>	2020-01-06 10:01:28 -07:00
Alan Shaw	a1717dac6a	fix: conn mngr min/max connection values (#528 ) Fixes the case when options are passed with `maxConnections` and/or `minConnections` set to `undefined`: ```console { defaultOptions: { maxConnections: Infinity, minConnections: 0, maxData: Infinity, maxSentData: Infinity, maxReceivedData: Infinity, maxEventLoopDelay: Infinity, pollInterval: 2000, movingAverageInterval: 60000, defaultPeerValue: 1 }, options: { minPeers: 25, maxConnections: undefined, minConnections: undefined } } { maxConnections: undefined, minConnections: undefined } 1) "before all" hook in "custom config" (node:67176) UnhandledPromiseRejectionWarning: AssertionError [ERR_ASSERTION]: Connection Manager maxConnections must be greater than minConnections at new ConnectionManager (node_modules/libp2p/src/connection-manager/index.js:43:5) at new Libp2p (node_modules/libp2p/src/index.js:92:30) at Object.module.exports [as libp2p] (src/core/components/libp2p.js:27:10) at Proxy.start (src/core/components/start.js:48:31) at async Daemon.start (src/cli/daemon.js:63:31) at async startHttpAPI (test/http-api/routes.js:29:5) at async Context.<anonymous> (test/http-api/routes.js:48:7) ```	2020-01-06 07:03:07 -07:00
Vasco Santos	dec8dc450f	refactor: examples/protocol-and-stream-muxing (#502 )	2020-01-02 21:51:02 +01:00
Jacob Heun	0d4b2bd23d	feat: allow transport options to be passed on creation (#524 ) * feat: allow transport options to be passed on creation * fix: only add circuit transport if enabled * chore: fix lint	2019-12-20 08:32:46 -08:00
Vasco Santos	fdb48c8df5	refactor: examples/peer-and-content-routing (#500 ) * refactor: examples-peer-and-content-routing * chore: address review * chore: review suggestions Co-Authored-By: Jacob Heun <jacobheun@gmail.com>	2019-12-18 03:37:36 +01:00
Vasco Santos	506af15b6b	refactor: examples/encrypted-communications (#499 ) * refactor: examples/encrypted-communications * chore: address review	2019-12-18 03:35:49 +01:00
Vasco Santos	9f0f08f586	refactor: examples-pubsub (#504 )	2019-12-16 23:28:35 +01:00
Jacob Heun	6ca19c5ef4	feat: add libp2p.connections getter (#522 ) * fix: make hangup accept what the API says it does * feat: add libp2p.connections getter * chore: fix typo	2019-12-16 19:24:35 +01:00
Jacob Heun	24c3ce6f8d	fix: make dialer configurable (#521 ) docs: update configuration and api docs	2019-12-16 16:49:29 +01:00
Vasco Santos	56a1825639	fix: upgrader should not need muxers (#517 ) * fix: upgrader should not need muxers * chore: address review * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com>	2019-12-16 12:26:38 +01:00
Jacob Heun	92ed56657c	chore: release version v0.27.0-pre.1	2019-12-15 17:36:47 +01:00
Jacob Heun	9900beb243	chore: update contributors	2019-12-15 17:36:46 +01:00
Jacob Heun	4a871bbf8b	feat: coalescing dial support (#518 ) * docs: fix spelling in api * fix: dont create peerstore twice * feat: add support for dial coalescing * doc(fix): add setPeerValue to API TOC * docs: add more jsdocs to dialer * chore: remove old comment * fix: ensure connections are closed * fix: registrar.getConnections returns first open conn * fix: directly set the closed status * chore: remove unneeded log * refactor: peerStore.put takes an options object	2019-12-15 17:33:16 +01:00
Alan Shaw	a39889c4ea	docs: add ToC link to pubsub.unsubscribe	2019-12-13 10:50:06 +01:00
Alan Shaw	9bbe93c772	docs: fix the ToC links (#515 )	2019-12-12 18:40:40 +01:00
Vasco Santos	cc65a4b06f	chore: update readme (#513 )	2019-12-12 13:08:06 +01:00
Jacob Heun	9c884a72b0	chore: release version v0.27.0-pre.0	2019-12-12 10:43:18 +01:00
Jacob Heun	3ee1e22242	chore: update contributors	2019-12-12 10:43:17 +01:00
Jacob Heun	45f47023d2	refactor: connection manager (#511 ) * refactor: initial refactor of the connection manager * fix: start/stop issues * fix: add tests and resolve pruning issues * chore: fix lint * test: move conn manager tests to node only for now * chore: apply suggestions from code review Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio> * fix: assert min max connection options * test: fix assertion check for browser * docs: add api and config docs for conn manager	2019-12-12 10:29:10 +01:00
Vasco Santos	af96dcc499	feat: discovery modules from transports should be added (#510 ) * feat: discovery modules from transports should be added * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com>	2019-12-12 10:29:10 +01:00
Jacob Heun	f540112835	refactor: stats (#501 ) * docs: add initial notes on stats * feat: initial refactor of stats to metrics * feat: add support for placeholder metrics This is helpful for tracking metrics prior to knowing the remote peers id * fix: add metrics tests and fix issues * fix: always clear the dial timeout timer * docs: add metrics to api doc * chore: apply suggestions from code review Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio> * docs: update metrics docs * fix: call metrics.onDisconnect * docs(config): add example headers so they appear in the TOC * docs(config): add metrics configuration * docs(relay): fix relay configuration docs	2019-12-12 10:29:10 +01:00
Vasco Santos	3d30cb18cd	docs: config (#495 ) * docs: new api * chore: new iteration * chore: apply suggestions from code review Co-Authored-By: Alan Shaw <alan.shaw@protocol.ai> * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * docs: add events * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * docs: configuration * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: update peer routing description Co-Authored-By: Yusef Napora <yusef@protocol.ai> * chore: decouple examples * chore: address pr comment * fix: connection encryption is required * chore: apply review suggestion Co-Authored-By: Jacob Heun <jacobheun@gmail.com>	2019-12-12 10:29:10 +01:00
Vasco Santos	64cbf90e02	refactor: ping (#505 ) * refactor: ping * chore: ping is now a function * chore: address review	2019-12-12 10:29:10 +01:00
Jacob Heun	7fc1900343	chore: it-all over async-iterator-all	2019-12-12 10:29:09 +01:00
Jacob Heun	ad15d4ed09	chore: add bundlesize check back to ci	2019-12-12 10:29:09 +01:00
Jacob Heun	600f761009	chore: remove uneeded dep check exclusions	2019-12-12 10:29:09 +01:00
Jacob Heun	a2f31d99d2	chore: disable pull dep check until ping is refactored	2019-12-12 10:29:09 +01:00
Jacob Heun	edaa67dfd0	chore: remove unused packages	2019-12-12 10:29:09 +01:00
Jacob Heun	9b10e09cc0	chore: move stats folder and delete old switch code	2019-12-12 10:29:09 +01:00
Vasco Santos	8c6ad79630	docs: new api (#472 ) * docs: new api * chore: new iteration * chore: apply suggestions from code review Co-Authored-By: Alan Shaw <alan.shaw@protocol.ai> * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * docs: add events * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com>	2019-12-12 10:29:08 +01:00
Jacob Heun	1838a641d9	fix: token release logic	2019-12-12 10:29:08 +01:00
Jacob Heun	3cadeb39cb	test: bump delay for ci	2019-12-12 10:29:08 +01:00
Jacob Heun	43440aa8a6	fix: release tokens as soon as they are available	2019-12-12 10:29:08 +01:00
Jacob Heun	7c3371bf17	fix: clean up pending dials abort per feedback	2019-12-12 10:29:08 +01:00
Jacob Heun	43b98e64b6	docs: add DialRequest description	2019-12-12 10:29:07 +01:00
Jacob Heun	962081f448	test: remove timeout	2019-12-12 10:29:07 +01:00
Jacob Heun	754fbc2d0b	feat: abort all pending dials on stop	2019-12-12 10:29:07 +01:00
Jacob Heun	0a8f9f3238	test: reduce randomwalk timeout	2019-12-12 10:29:07 +01:00
Jacob Heun	3b52236dee	chore: fix lint test: reduce interval of randomwalk in test chore(test): glob fix	2019-12-12 10:29:07 +01:00
Jacob Heun	c7dcfe5e48	test: add tests for DialRequest	2019-12-12 10:29:06 +01:00
Jacob Heun	3b06283ad8	test(fix): fix support for it.only, it.skip, etc	2019-12-12 10:29:06 +01:00
Jacob Heun	74bfe6bea5	docs(release): point to libp2p weekly sync	2019-12-12 10:29:06 +01:00
Jacob Heun	53ce404260	chore: update per feedback	2019-12-12 10:29:06 +01:00
Jacob Heun	43a3b85f1a	refactor: cleanup and reorganize	2019-12-12 10:29:06 +01:00
Jacob Heun	e8bf12b68a	chore: update docs fix: protect against duplicate token releases	2019-12-12 10:29:05 +01:00
Jacob Heun	7d1cb5423f	chore: fix linting	2019-12-12 10:29:05 +01:00
Jacob Heun	c4be5f4aaf	refactor: consolidation multiaddr dial methods	2019-12-12 10:29:05 +01:00
Jacob Heun	a37c5c0144	refactor: clean up dial timeout abort	2019-12-12 10:29:05 +01:00
Jacob Heun	24c603741f	feat: add early token recycling in	2019-12-12 10:29:05 +01:00
Jacob Heun	ea62c52701	refactor: simplify DialRequest logic per feedback	2019-12-12 10:29:04 +01:00
Jacob Heun	f9fe44f6b7	chore: use any-signal module	2019-12-12 10:29:04 +01:00
Jacob Heun	d5405dbb08	refactor: PER_PEER_LIMIT is now MAX_PER_PEER_DIALS	2019-12-12 10:29:04 +01:00
Jacob Heun	571fd3b7d1	chore: apply suggestions from code review Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio> Co-Authored-By: Alan Shaw <alan.shaw@protocol.ai>	2019-12-12 10:29:04 +01:00
Jacob Heun	cba2c6d8b2	chore: remove commented code	2019-12-12 10:29:04 +01:00
Jacob Heun	f8540fa3ed	feat: add token based dialer	2019-12-12 10:29:03 +01:00
Jacob Heun	0cacfe29a5	doc: add initial dialer readme	2019-12-12 10:29:03 +01:00
Jacob Heun	c4bc00be9c	fix: correct release readme	2019-12-12 10:29:03 +01:00
Jacob Heun	f3eb1f1201	fix: clean up peer discovery flow (#494 ) * fix: clean up peer discovery flow * test(fix): let libp2p start after connecting * test(fix): dont auto dial in disco tests	2019-12-12 10:29:03 +01:00
Vasco Santos	dbb9e57311	chore: update pubsub implementations (#493 )	2019-12-12 10:29:03 +01:00
Vasco Santos	11ed6bd14c	feat: support peer-id instances in peer store operations (#491 )	2019-12-12 10:29:02 +01:00
Vasco Santos	fc22c36ba7	refactor: async routing (#489 ) * feat: async routing * chore: put dht extra api commands under content routing * chore: add default option to createPeerInfo Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * chore: rm dlv	2019-12-12 10:29:02 +01:00
Jacob Heun	b518391a47	refactor: circuit relay to async (#477 ) * refactor: add dialing over relay support * chore: fix lint * fix: dont clear listeners on close * fix: if dial errors already have codes, just rethrow them * fix: clear the registrar when libp2p stops * fix: improve connection maintenance with circuit * chore: correct feedback * test: use chai as promised * test(fix): reset multiaddrs on dial test	2019-12-12 10:29:02 +01:00
Vasco Santos	997ee166b0	feat: discovery modules (#486 ) * feat: discovery modules * chore: address review	2019-12-12 10:29:02 +01:00
dirkmc	acbbc0f84e	fix: replace peerInfo addresses with listen addresses (#485 ) * feat: replace peer info addresses with listen addresses * test: add listening test * chore: fix linting	2019-12-12 10:29:02 +01:00
dirkmc	995640ee2f	refactor(docs): async await version of examples/chat (#482 ) * fix: performance bottleneck in stat.js (#463) Array.shift seems to be very slow, perhaps linear, on some engines, resulting in _update consuming a lot of CPU. * docs(fix): correct docs and example for pnet (#464) * docs(fix): correct docs and example for pnet * docs(fix): correct pnet docs * docs(fix): update README.md language (#468) * docs: reciprocate (#474) * docs(example): fix ipfs cat (#475) `ipfs.files.cat` is incorrect. the correct function is `ipfs.cat` * fix: async-await example chat * fix: move handler before start * fix: examples readme typos (#481) * fix: simplify libp2p bundle for echo example * chore: remove unused vars	2019-12-12 10:29:01 +01:00
dirkmc	b316cdd19b	refactor(docs): async await version of examples/echo (#483 ) * fix: performance bottleneck in stat.js (#463) Array.shift seems to be very slow, perhaps linear, on some engines, resulting in _update consuming a lot of CPU. * docs(fix): correct docs and example for pnet (#464) * docs(fix): correct docs and example for pnet * docs(fix): correct pnet docs * docs(fix): update README.md language (#468) * docs: reciprocate (#474) * docs(example): fix ipfs cat (#475) `ipfs.files.cat` is incorrect. the correct function is `ipfs.cat` * fix: async await examples/echo * fix: examples readme typos (#481) * fix: simplify libp2p bundle for echo example	2019-12-12 10:29:01 +01:00
Vasco Santos	1ea945ad24	refactor: dht async/await (#480 ) * refactor: core async (#478) * refactor: cleanup core test: auto dial on startup * fix: make hangup work properly * chore: fix lint * chore: apply suggestions from code review Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio> * fix: provide libp2p dialer to the dht * chore: use dht release	2019-12-12 10:29:01 +01:00
Jacob Heun	c37703dc17	refactor: update secio and tests to use it (#484 ) * refactor: use async secio * test: add secio to most test suites * chore: update secio version	2019-12-12 10:29:01 +01:00
Jacob Heun	86b275a0d3	refactor: core async (#478 ) * refactor: cleanup core test: auto dial on startup * fix: make hangup work properly * chore: fix lint * chore: apply suggestions from code review Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio>	2019-12-12 10:29:01 +01:00
Vasco Santos	3c79d33db9	chore: use gossipsub release (#479 )	2019-12-12 10:29:00 +01:00
Vasco Santos	34d57f8989	refactor: pubsub (#467 ) * feat: peer-store v0 * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * refactor: pubsub subsystem * chore: address review * chore: use topology interface * chore: address review * chore: address review * chore: simplify tests	2019-12-12 10:29:00 +01:00
Jacob Heun	ced2dbf318	chore: update it-length-prefixed (#476 ) fix: decode.fromReader usage	2019-12-12 10:29:00 +01:00
Jacob Heun	44d47087d1	refactor: async identify and identify push (#473 ) * chore: add missing dep * feat: import from identify push branch https://github.com/libp2p/js-libp2p-identify/tree/feat/identify-push * feat: add the connection to stream handlers * refactor: identify to async/await * chore: fix lint * test: add identify tests * refactor: add identify to the dialer flow * feat: connect identify to the registrar * fix: resolve review feedback * fix: perform identify push when our protocols change	2019-12-12 10:29:00 +01:00
Vasco Santos	797d8f0cf1	feat: registrar (#471 ) * feat: peer-store v0 * feat: registrar * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * chore: support multiple conns * chore: address review * fix: no remote peer from topology on disconnect	2019-12-12 10:29:00 +01:00
Vasco Santos	f3e276eb79	feat: peer store (#470 ) * feat: peer-store v0 * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com>	2019-12-12 10:28:59 +01:00
Jacob Heun	138bb0bbae	refactor: crypto and pnet (#469 ) * feat: add initial plaintext 2 module * refactor: initial refactor of pnet * chore: fix lint * fix: update plaintext api usage * test: use plaintext for test crypto * chore: update deps test: update dialer suite scope * feat: add connection protection to the upgrader * refactor: cleanup and lint fix * chore: remove unncessary transforms * chore: temporarily disable bundlesize * chore: add missing dep * fix: use it-handshake to prevent overreading * chore(fix): PR feedback updates * chore: apply suggestions from code review Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio>	2019-12-12 10:28:59 +01:00
Jacob Heun	af364b070b	refactor(async): add dialer and upgrader (#462 ) * chore(deps): update connection and multistream * feat: add basic dial support for addresses and peers * test: automatically require all node test files * fix: dont catch and log in the wrong place * test: add direct spec test fix: improve dial error consistency * feat: add dial timeouts and concurrency Queue timeouts will result in aborts of the dials * chore: fix linting * test: verify dialer defaults * feat: add initial upgrader * fix: add more test coverage and fix bugs * feat: libp2p creates the upgrader * feat: hook up handle to the upgrader * feat: hook up the dialer to libp2p test: add node dialer libp2p tests * feat: add connection listeners to upgrader * feat: emit connect and disconnect events * chore: use libp2p-interfaces * fix: address review feedback * fix: correct import * refactor: dedupe connection creation code	2019-12-12 10:28:59 +01:00
Jacob Heun	10c8553c58	docs: add stream wrapping example (#466 ) * docs: add duplex wrapping example docs: add iterable types from @alanshaw's gist * docs(fix): add feedback fix Co-Authored-By: Vasco Santos <vasco.santos@moxy.studio> * docs: clean up based on feedback	2019-12-12 10:28:59 +01:00
Jacob Heun	a7d5e67e06	refactor(async): update transports subsystem (#461 ) * test: remove all tests for a clean slate The refactor will require a large number of updates to the tests. In order to ensure we have done a decent deduplication, and have a cleaner suite of tests we've removed all tests. This will also allow us to more easily see tests for the refactored systems. We have a record of the latest test suites in master, so we are not losing any history. * chore: update tcp and websockets * chore: remove other transports until they are converted * chore: use mafmt and multiaddr async versions * chore: add and fix dependencies * chore: clean up travis file * feat: add new transport manager * docs: add constructor jsdocs * refactor(config): check that transports exist This also removes the other logic, it can be added when those subsystems are refactored * chore(deps): use async peer-id and peer-info * feat: wire up the transport manager with libp2p * chore: remove superstruct dep	2019-12-12 10:28:59 +01:00
Jacob Heun	4f8043d259	Add streaming iterables guide (#459 ) * docs: add streaming iterables guide placeholder * chore: move peer discovery readme to doc fold:wqer * docs: add link to async refactor issue	2019-12-12 10:28:58 +01:00