move gossipsub into a separate crate

Author: jxs

Cargo.lock

@@ -9,6 +9,7 @@ members = [
     "beacon_node/client",
     "beacon_node/eth1",
     "beacon_node/lighthouse_network",
+    "beacon_node/lighthouse_network/gossipsub",
     "beacon_node/execution_layer",
     "beacon_node/http_api",
     "beacon_node/http_metrics",
@@ -200,6 +201,7 @@ execution_layer = { path = "beacon_node/execution_layer" }
 filesystem = { path = "common/filesystem" }
 fork_choice = { path = "consensus/fork_choice" }
 genesis = { path = "beacon_node/genesis" }
+gossipsub = { path = "beacon_node/lighthouse_network/gossipsub/" }
 http_api = { path = "beacon_node/http_api" }
 int_to_bytes = { path = "consensus/int_to_bytes" }
 kzg = { path = "crypto/kzg" }

Cargo.toml

@@ -0,0 +1,378 @@
+## 0.5 Sigma Prime fork
+
+- Attempt to publish to at least mesh_n peers when publishing a message when flood publish is disabled.
+  See [PR 5357](https://github.com/sigp/lighthouse/pull/5357).
+- Drop `Publish` and `Forward` gossipsub stale messages when polling ConnectionHandler.
+  See [PR 5175](https://github.com/sigp/lighthouse/pull/5175).
+- Apply back pressure by setting a limit in the ConnectionHandler message queue.
+  See [PR 5066](https://github.com/sigp/lighthouse/pull/5066).
+
+## 0.46.1
+
+- Deprecate `Rpc` in preparation for removing it from the public API because it is an internal type.
+  See [PR 4833](https://github.com/libp2p/rust-libp2p/pull/4833).
+
+## 0.46.0
+
+- Remove `fast_message_id_fn` mechanism from `Config`.
+  See [PR 4285](https://github.com/libp2p/rust-libp2p/pull/4285).
+- Remove deprecated `gossipsub::Config::idle_timeout` in favor of `SwarmBuilder::idle_connection_timeout`.
+  See [PR 4642](https://github.com/libp2p/rust-libp2p/pull/4642).
+- Return typed error from config builder.
+  See [PR 4445](https://github.com/libp2p/rust-libp2p/pull/4445).
+- Process outbound stream before inbound stream in `EnabledHandler::poll(..)`.
+  See [PR 4778](https://github.com/libp2p/rust-libp2p/pull/4778).
+
+## 0.45.2
+
+- Deprecate `gossipsub::Config::idle_timeout` in favor of `SwarmBuilder::idle_connection_timeout`.
+  See [PR 4648].
+
+<!-- Interal changes:
+
+- Allow new clippy lint.
+
+-->
+
+[PR 4648]: (https://github.com/libp2p/rust-libp2p/pull/4648)
+
+<!-- Internal changes
+
+- Allow deprecated usage of `KeepAlive::Until`
+
+-->
+
+## 0.45.1
+
+- Add getter function to o  btain `TopicScoreParams`.
+  See [PR 4231].
+
+[PR 4231]: https://github.com/libp2p/rust-libp2p/pull/4231
+
+## 0.45.0
+
+- Raise MSRV to 1.65.
+  See [PR 3715].
+- Remove deprecated items. See [PR 3862].
+
+[PR 3715]: https://github.com/libp2p/rust-libp2p/pull/3715
+[PR 3862]: https://github.com/libp2p/rust-libp2p/pull/3862
+
+## 0.44.4
+
+- Deprecate `metrics`, `protocol`, `subscription_filter`, `time_cache` modules to make them private. See [PR 3777].
+- Honor the `gossipsub::Config::support_floodsub` in all cases.
+  Previously, it was ignored when a custom protocol id was set via `gossipsub::Config::protocol_id`.
+  See [PR 3837].
+
+[PR 3777]: https://github.com/libp2p/rust-libp2p/pull/3777
+[PR 3837]: https://github.com/libp2p/rust-libp2p/pull/3837
+
+## 0.44.3
+
+- Fix erroneously duplicate message IDs. See [PR 3716].
+
+- Gracefully disable handler on stream errors. Deprecate a few variants of `HandlerError`.
+  See [PR 3625].
+
+[PR 3716]: https://github.com/libp2p/rust-libp2p/pull/3716
+[PR 3625]: https://github.com/libp2p/rust-libp2p/pull/3325
+
+## 0.44.2
+
+- Signed messages now use sequential integers in the sequence number field.
+  See [PR 3551].
+
+[PR 3551]: https://github.com/libp2p/rust-libp2p/pull/3551
+
+## 0.44.1
+
+- Migrate from `prost` to `quick-protobuf`. This removes `protoc` dependency. See [PR 3312].
+
+[PR 3312]: https://github.com/libp2p/rust-libp2p/pull/3312
+
+## 0.44.0
+
+- Update to `prometheus-client` `v0.19.0`. See [PR 3207].
+
+- Update to `libp2p-core` `v0.39.0`.
+
+- Update to `libp2p-swarm` `v0.42.0`.
+
+- Initialize `ProtocolConfig` via `GossipsubConfig`. See [PR 3381].
+
+- Rename types as per [discussion 2174].
+  `Gossipsub` has been renamed to `Behaviour`.
+  The `Gossipsub` prefix has been removed from various types like `GossipsubConfig` or `GossipsubMessage`.
+  It is preferred to import the gossipsub protocol as a module (`use libp2p::gossipsub;`), and refer to its types via `gossipsub::`.
+  For example: `gossipsub::Behaviour` or `gossipsub::RawMessage`. See [PR 3303].
+
+[PR 3207]: https://github.com/libp2p/rust-libp2p/pull/3207/
+[PR 3303]: https://github.com/libp2p/rust-libp2p/pull/3303/
+[PR 3381]: https://github.com/libp2p/rust-libp2p/pull/3381/
+[discussion 2174]: https://github.com/libp2p/rust-libp2p/discussions/2174
+
+## 0.43.0
+
+- Update to `libp2p-core` `v0.38.0`.
+
+- Update to `libp2p-swarm` `v0.41.0`.
+
+- Update to `prost-codec` `v0.3.0`.
+
+- Refactoring GossipsubCodec to use common protobuf Codec. See [PR 3070].
+
+- Replace `Gossipsub`'s `NetworkBehaviour` implementation `inject_*` methods with the new `on_*` methods.
+  See [PR 3011].
+
+- Replace `GossipsubHandler`'s `ConnectionHandler` implementation `inject_*` methods with the new `on_*` methods.
+  See [PR 3085].
+
+- Update `rust-version` to reflect the actual MSRV: 1.62.0. See [PR 3090].
+
+[PR 3085]: https://github.com/libp2p/rust-libp2p/pull/3085
+[PR 3070]: https://github.com/libp2p/rust-libp2p/pull/3070
+[PR 3011]: https://github.com/libp2p/rust-libp2p/pull/3011
+[PR 3090]: https://github.com/libp2p/rust-libp2p/pull/3090
+
+## 0.42.0
+
+- Bump rand to 0.8 and quickcheck to 1. See [PR 2857].
+
+- Update to `libp2p-core` `v0.37.0`.
+
+- Update to `libp2p-swarm` `v0.40.0`.
+
+[PR 2857]: https://github.com/libp2p/rust-libp2p/pull/2857
+
+## 0.41.0
+
+- Update to `libp2p-swarm` `v0.39.0`.
+
+- Update to `libp2p-core` `v0.36.0`.
+
+- Allow publishing with any `impl Into<TopicHash>` as a topic. See [PR 2862].
+
+[PR 2862]: https://github.com/libp2p/rust-libp2p/pull/2862
+
+## 0.40.0
+
+- Update prost requirement from 0.10 to 0.11 which no longer installs the protoc Protobuf compiler.
+  Thus you will need protoc installed locally. See [PR 2788].
+
+- Update to `libp2p-swarm` `v0.38.0`.
+
+- Update to `libp2p-core` `v0.35.0`.
+
+- Update to `prometheus-client` `v0.18.0`. See [PR 2822].
+
+[PR 2822]: https://github.com/libp2p/rust-libp2p/pull/2761/
+[PR 2788]: https://github.com/libp2p/rust-libp2p/pull/2788
+
+## 0.39.0
+
+- Update to `libp2p-core` `v0.34.0`.
+
+- Update to `libp2p-swarm` `v0.37.0`.
+
+- Allow for custom protocol ID via `GossipsubConfigBuilder::protocol_id()`. See [PR 2718].
+
+[PR 2718]: https://github.com/libp2p/rust-libp2p/pull/2718/
+
+## 0.38.1
+
+- Fix duplicate connection id. See [PR 2702].
+
+[PR 2702]: https://github.com/libp2p/rust-libp2p/pull/2702
+
+## 0.38.0
+
+- Update to `libp2p-core` `v0.33.0`.
+
+- Update to `libp2p-swarm` `v0.36.0`.
+
+- changed `TimeCache::contains_key` and `DuplicateCache::contains` to immutable methods. See [PR 2620].
+
+- Update to `prometheus-client` `v0.16.0`. See [PR 2631].
+
+[PR 2620]: https://github.com/libp2p/rust-libp2p/pull/2620
+[PR 2631]: https://github.com/libp2p/rust-libp2p/pull/2631
+
+## 0.37.0
+
+- Update to `libp2p-swarm` `v0.35.0`.
+
+- Fix gossipsub metric (see [PR 2558]).
+
+- Allow the user to set the buckets for the score histogram, and to adjust them from the score thresholds. See [PR 2595].
+
+[PR 2558]: https://github.com/libp2p/rust-libp2p/pull/2558
+[PR 2595]: https://github.com/libp2p/rust-libp2p/pull/2595
+
+## 0.36.0 [2022-02-22]
+
+- Update to `libp2p-core` `v0.32.0`.
+
+- Update to `libp2p-swarm` `v0.34.0`.
+
+- Move from `open-metrics-client` to `prometheus-client` (see [PR 2442]).
+
+- Emit gossip of all non empty topics (see [PR 2481]).
+
+- Merge NetworkBehaviour's inject_\* paired methods (see [PR 2445]).
+
+- Revert to wasm-timer (see [PR 2506]).
+
+- Do not overwrite msg's peers if put again into mcache (see [PR 2493]).
+
+[PR 2442]: https://github.com/libp2p/rust-libp2p/pull/2442
+[PR 2481]: https://github.com/libp2p/rust-libp2p/pull/2481
+[PR 2445]: https://github.com/libp2p/rust-libp2p/pull/2445
+[PR 2506]: https://github.com/libp2p/rust-libp2p/pull/2506
+[PR 2493]: https://github.com/libp2p/rust-libp2p/pull/2493
+
+## 0.35.0 [2022-01-27]
+
+- Update dependencies.
+
+- Migrate to Rust edition 2021 (see [PR 2339]).
+
+- Add metrics for network and configuration performance analysis (see [PR 2346]).
+
+- Improve bandwidth performance by tracking IWANTs and reducing duplicate sends
+  (see [PR 2327]).
+
+- Implement `Serialize` and `Deserialize` for `MessageId` and `FastMessageId` (see [PR 2408])
+
+- Fix `GossipsubConfigBuilder::build()` requiring `&self` to live for `'static` (see [PR 2409])
+
+- Implement Unsubscribe backoff as per [libp2p specs PR 383] (see [PR 2403]).
+
+[PR 2346]: https://github.com/libp2p/rust-libp2p/pull/2346
+[PR 2339]: https://github.com/libp2p/rust-libp2p/pull/2339
+[PR 2327]: https://github.com/libp2p/rust-libp2p/pull/2327
+[PR 2408]: https://github.com/libp2p/rust-libp2p/pull/2408
+[PR 2409]: https://github.com/libp2p/rust-libp2p/pull/2409
+[PR 2403]: https://github.com/libp2p/rust-libp2p/pull/2403
+[libp2p specs PR 383]: https://github.com/libp2p/specs/pull/383
+
+## 0.34.0 [2021-11-16]
+
+- Add topic and mesh metrics (see [PR 2316]).
+
+- Fix bug in internal peer's topics tracking (see [PR 2325]).
+
+- Use `instant` and `futures-timer` instead of `wasm-timer` (see [PR 2245]).
+
+- Update dependencies.
+
+[PR 2245]: https://github.com/libp2p/rust-libp2p/pull/2245
+[PR 2325]: https://github.com/libp2p/rust-libp2p/pull/2325
+[PR 2316]: https://github.com/libp2p/rust-libp2p/pull/2316
+
+## 0.33.0 [2021-11-01]
+
+- Add an event to register peers that do not support the gossipsub protocol
+  [PR 2241](https://github.com/libp2p/rust-libp2p/pull/2241)
+
+- Make default features of `libp2p-core` optional.
+  [PR 2181](https://github.com/libp2p/rust-libp2p/pull/2181)
+
+- Improve internal peer tracking.
+  [PR 2175](https://github.com/libp2p/rust-libp2p/pull/2175)
+
+- Update dependencies.
+
+- Allow `message_id_fn`s to accept closures that capture variables.
+  [PR 2103](https://github.com/libp2p/rust-libp2p/pull/2103)
+
+- Implement std::error::Error for error types.
+  [PR 2254](https://github.com/libp2p/rust-libp2p/pull/2254)
+
+## 0.32.0 [2021-07-12]
+
+- Update dependencies.
+
+- Reduce log levels across the crate to lessen noisiness of libp2p-gossipsub (see [PR 2101]).
+
+[PR 2101]: https://github.com/libp2p/rust-libp2p/pull/2101
+
+## 0.31.0 [2021-05-17]
+
+- Keep connections to peers in a mesh alive. Allow closing idle connections to peers not in a mesh
+  [PR-2043].
+
+[PR-2043]: https://github.com/libp2p/rust-libp2p/pull/2043https://github.com/libp2p/rust-libp2p/pull/2043
+
+## 0.30.1 [2021-04-27]
+
+- Remove `regex-filter` feature flag thus always enabling `regex::RegexSubscriptionFilter` [PR
+  2056](https://github.com/libp2p/rust-libp2p/pull/2056).
+
+## 0.30.0 [2021-04-13]
+
+- Update `libp2p-swarm`.
+
+- Update dependencies.
+
+## 0.29.0 [2021-03-17]
+
+- Update `libp2p-swarm`.
+
+- Update dependencies.
+
+## 0.28.0 [2021-02-15]
+
+- Prevent non-published messages being added to caches.
+  [PR 1930](https://github.com/libp2p/rust-libp2p/pull/1930)
+
+- Update dependencies.
+
+## 0.27.0 [2021-01-12]
+
+- Update dependencies.
+
+- Implement Gossipsub v1.1 specification.
+  [PR 1720](https://github.com/libp2p/rust-libp2p/pull/1720)
+
+## 0.26.0 [2020-12-17]
+
+- Update `libp2p-swarm` and `libp2p-core`.
+
+## 0.25.0 [2020-11-25]
+
+- Update `libp2p-swarm` and `libp2p-core`.
+
+## 0.24.0 [2020-11-09]
+
+- Update dependencies.
+
+## 0.23.0 [2020-10-16]
+
+- Update dependencies.
+
+## 0.22.0 [2020-09-09]
+
+- Update `libp2p-swarm` and `libp2p-core`.
+
+## 0.21.0 [2020-08-18]
+
+- Add public API to list topics and peers. [PR 1677](https://github.com/libp2p/rust-libp2p/pull/1677).
+
+- Add message signing and extended privacy/validation configurations. [PR 1583](https://github.com/libp2p/rust-libp2p/pull/1583).
+
+- `Debug` instance for `Gossipsub`. [PR 1673](https://github.com/libp2p/rust-libp2p/pull/1673).
+
+- Bump `libp2p-core` and `libp2p-swarm` dependency.
+
+## 0.20.0 [2020-07-01]
+
+- Updated dependencies.
+
+## 0.19.3 [2020-06-23]
+
+- Maintenance release fixing linter warnings.
+
+## 0.19.2 [2020-06-22]
+
+- Updated dependencies.