Skip to content

Commit a68b713

Browse files
authored
chore: Release litep2p 0.7.0 (#240)
## [0.7.0] - 2024-09-05 This release introduces several new features, improvements, and fixes to the litep2p library. Key updates include enhanced error handling, configurable connection limits, and a new API for managing public addresses. ### [Exposing Public Addresses API](#212) A new `PublicAddresses` API has been added, enabling users to manage the node's public addresses. This API allows developers to add, remove, and retrieve public addresses, which are shared with peers through the Identify protocol. ```rust // Public addresses are accessible from the main litep2p instance. let public_addresses = litep2p.public_addresses(); // Add a new public address to the node. if let Err(err) = public_addresses.add_address(multiaddr) { eprintln!("Failed to add public address: {:?}", err); } // Remove a public address from the node. public_addresses.remove_address(&multiaddr); // Retrieve all public addresses of the node. for address in public_addresses.get_addresses() { println!("Public address: {}", address); } ``` **Breaking Change**: The Identify protocol no longer includes public addresses in its configuration. Instead, use the new `PublicAddresses` API. Migration Guide: ```rust // Before: let (identify_config, identify_event_stream) = IdentifyConfig::new( "/substrate/1.0".to_string(), Some(user_agent), config.public_addresses, ); // After: let (identify_config, identify_event_stream) = IdentifyConfig::new("/substrate/1.0".to_string(), Some(user_agent)); // Public addresses must now be added using the `PublicAddresses` API: for address in config.public_addresses { if let Err(err) = public_addresses.add_address(address) { eprintln!("Failed to add public address: {:?}", err); } } ``` ### [Dial Error and List Dial Failures Event](#206) The `DialFailure` event has been enhanced with a new `DialError` enum for more precise error reporting when a dial attempt fails. Additionally, a `ListDialFailures` event has been introduced, listing all dialed addresses and their corresponding errors when multiple addresses are involved. Other litep2p errors, such as `ParseError`, `AddressError`, and `NegotiationError`, have been refactored for improved error propagation. ### [Immediate Dial Error and Request-Response Rejection Reasons](#227) This new feature paves the way for better error handling in the `litep2p` library and moves away from the overarching `litep2p::error::Error` enum. The newly added `ImmediateDialError` enum captures errors occurring before a dial request is sent (e.g., missing peer IDs). It also enhances the `RejectReason` enum for request-response protocols, offering more detailed rejection reasons. ```rust match error { RequestResponseError::Rejected(reason) => { match reason { RejectReason::ConnectionClosed => "connection-closed", RejectReason::DialFailed(Some(ImmediateDialError::AlreadyConnected)) => "already-connected", _ => "other", } } _ => "other", } ``` ### [Connection Limits](#185) Developers can now set limits on the number of inbound and outbound connections to manage resources and optimize performance. ```rust // Configure connection limits for inbound and outbound established connections. let litep2p_config = Config::default() .with_connection_limits(ConnectionLimitsConfig::default() .max_incoming_connections(Some(3)) .max_outgoing_connections(Some(2)) ); ``` ### [Feature Flags for Optional Transports](#192) The library now supports feature flags to selectively enable or disable transport protocols. By default, only the `TCP` transport is enabled. Optional transports include: - `quic` - Enables QUIC transport. - `websocket` - Enables WebSocket transport. - `webrtc` - Enables WebRTC transport. ### [Configurable Keep-Alive Timeout](#155) The keep-alive timeout for connections is now configurable, providing more control over connection lifecycles. ```rust // Set keep alive timeout for connections. let litep2p_config = Config::default() .with_keep_alive_timeout(Duration::from_secs(30)); ``` Thanks for contributing to this @[Ma233](https://github.com/Ma233)! ### Added - errors: Introduce immediate dial error and request-response rejection reasons ([#227](#227)) - Expose API for `PublicAddresses` ([#212](#212)) - transport: Implement `TransportService::local_peer_id()` ([#224](#224)) - find_node: Optimize parallelism factor for slow to respond peers ([#220](#220)) - kad: Handle `ADD_PROVIDER` & `GET_PROVIDERS` network requests ([#213](#213)) - errors: Add `DialError` error and `ListDialFailures` event for better error reporting ([#206](#206)) - kad: Add support for provider records to `MemoryStore` ([#200](#200)) - transport: Add accept_pending/reject_pending for inbound connections and introduce inbound limits ([#194](#194)) - transport/manager: Add connection limits for inbound and outbound established connections ([#185](#185)) - kad: Add query id to log messages ([#174](#174)) ### Changed - transport: Replace trust_dns_resolver with hickory_resolver ([#223](#223)) - crypto/noise: Generate keypair only for Curve25519 ([#214](#214)) - transport: Allow manual setting of keep-alive timeout ([#155](#155)) - kad: Update connection status of an existing bucket entry ([#181](#181)) - Make transports optional ([#192](#192)) ### Fixed - kad: Fix substream opening and dialing race ([#222](#222)) - query-executor: Save the task waker on empty futures ([#219](#219)) - substream: Use write_all instead of manually writing bytes ([#217](#217)) - minor: fix tests without `websocket` feature ([#215](#215)) - Fix TCP, WebSocket, QUIC leaking connection IDs in `reject()` ([#198](#198)) - transport: Fix double lock and state overwrite on disconnected peers ([#179](#179)) - kad: Do not update memory store on incoming `GetRecordSuccess` ([#190](#190)) - transport: Reject secondary connections with different connection IDs ([#176](#176)) ### Testing Done - pulled the latest changes into Substrate - performed warp sync in kusama cc @paritytech/networking --------- Signed-off-by: Alexandru Vasile <[email protected]>
1 parent 69d7ad7 commit a68b713

File tree

4 files changed

+143
-3
lines changed

4 files changed

+143
-3
lines changed

CHANGELOG.md

Lines changed: 140 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,146 @@ All notable changes to this project will be documented in this file.
55
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
66
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
77

8+
## [0.7.0] - 2024-09-05
9+
10+
This release introduces several new features, improvements, and fixes to the litep2p library. Key updates include enhanced error handling, configurable connection limits, and a new API for managing public addresses.
11+
12+
### [Exposing Public Addresses API](https://github.com/paritytech/litep2p/pull/212)
13+
14+
A new `PublicAddresses` API has been added, enabling users to manage the node's public addresses. This API allows developers to add, remove, and retrieve public addresses, which are shared with peers through the Identify protocol.
15+
16+
```rust
17+
// Public addresses are accessible from the main litep2p instance.
18+
let public_addresses = litep2p.public_addresses();
19+
20+
// Add a new public address to the node.
21+
if let Err(err) = public_addresses.add_address(multiaddr) {
22+
eprintln!("Failed to add public address: {:?}", err);
23+
}
24+
25+
// Remove a public address from the node.
26+
public_addresses.remove_address(&multiaddr);
27+
28+
// Retrieve all public addresses of the node.
29+
for address in public_addresses.get_addresses() {
30+
println!("Public address: {}", address);
31+
}
32+
```
33+
34+
**Breaking Change**: The Identify protocol no longer includes public addresses in its configuration. Instead, use the new `PublicAddresses` API.
35+
36+
Migration Guide:
37+
38+
```rust
39+
// Before:
40+
let (identify_config, identify_event_stream) = IdentifyConfig::new(
41+
"/substrate/1.0".to_string(),
42+
Some(user_agent),
43+
config.public_addresses,
44+
);
45+
46+
// After:
47+
let (identify_config, identify_event_stream) =
48+
IdentifyConfig::new("/substrate/1.0".to_string(), Some(user_agent));
49+
// Public addresses must now be added using the `PublicAddresses` API:
50+
for address in config.public_addresses {
51+
if let Err(err) = public_addresses.add_address(address) {
52+
eprintln!("Failed to add public address: {:?}", err);
53+
}
54+
}
55+
```
56+
57+
### [Dial Error and List Dial Failures Event](https://github.com/paritytech/litep2p/pull/206)
58+
59+
The `DialFailure` event has been enhanced with a new `DialError` enum for more precise error reporting when a dial attempt fails. Additionally, a `ListDialFailures` event has been introduced, listing all dialed addresses and their corresponding errors when multiple addresses are involved.
60+
61+
Other litep2p errors, such as `ParseError`, `AddressError`, and `NegotiationError`, have been refactored for improved error propagation.
62+
63+
### [Immediate Dial Error and Request-Response Rejection Reasons](https://github.com/paritytech/litep2p/pull/227)
64+
65+
This new feature paves the way for better error handling in the `litep2p` library and moves away from the overarching `litep2p::error::Error` enum.
66+
67+
The newly added `ImmediateDialError` enum captures errors occurring before a dial request is sent (e.g., missing peer IDs). It also enhances the `RejectReason` enum for request-response protocols, offering more detailed rejection reasons.
68+
69+
70+
```rust
71+
match error {
72+
RequestResponseError::Rejected(reason) => {
73+
match reason {
74+
RejectReason::ConnectionClosed => "connection-closed",
75+
RejectReason::DialFailed(Some(ImmediateDialError::AlreadyConnected)) => "already-connected",
76+
_ => "other",
77+
}
78+
}
79+
_ => "other",
80+
}
81+
```
82+
83+
### [Connection Limits](https://github.com/paritytech/litep2p/pull/185)
84+
85+
Developers can now set limits on the number of inbound and outbound connections to manage resources and optimize performance.
86+
87+
```rust
88+
// Configure connection limits for inbound and outbound established connections.
89+
let litep2p_config = Config::default()
90+
.with_connection_limits(ConnectionLimitsConfig::default()
91+
.max_incoming_connections(Some(3))
92+
.max_outgoing_connections(Some(2))
93+
);
94+
```
95+
96+
### [Feature Flags for Optional Transports](https://github.com/paritytech/litep2p/pull/192)
97+
98+
The library now supports feature flags to selectively enable or disable transport protocols. By default, only the `TCP` transport is enabled. Optional transports include:
99+
100+
- `quic` - Enables QUIC transport.
101+
- `websocket` - Enables WebSocket transport.
102+
- `webrtc` - Enables WebRTC transport.
103+
104+
### [Configurable Keep-Alive Timeout](https://github.com/paritytech/litep2p/pull/155)
105+
106+
The keep-alive timeout for connections is now configurable, providing more control over connection lifecycles.
107+
108+
```rust
109+
// Set keep alive timeout for connections.
110+
let litep2p_config = Config::default()
111+
.with_keep_alive_timeout(Duration::from_secs(30));
112+
```
113+
114+
Thanks for contributing to this @[Ma233](https://github.com/Ma233)!
115+
116+
### Added
117+
118+
- errors: Introduce immediate dial error and request-response rejection reasons ([#227](https://github.com/paritytech/litep2p/pull/227))
119+
- Expose API for `PublicAddresses` ([#212](https://github.com/paritytech/litep2p/pull/212))
120+
- transport: Implement `TransportService::local_peer_id()` ([#224](https://github.com/paritytech/litep2p/pull/224))
121+
- find_node: Optimize parallelism factor for slow to respond peers ([#220](https://github.com/paritytech/litep2p/pull/220))
122+
- kad: Handle `ADD_PROVIDER` & `GET_PROVIDERS` network requests ([#213](https://github.com/paritytech/litep2p/pull/213))
123+
- errors: Add `DialError` error and `ListDialFailures` event for better error reporting ([#206](https://github.com/paritytech/litep2p/pull/206))
124+
- kad: Add support for provider records to `MemoryStore` ([#200](https://github.com/paritytech/litep2p/pull/200))
125+
- transport: Add accept_pending/reject_pending for inbound connections and introduce inbound limits ([#194](https://github.com/paritytech/litep2p/pull/194))
126+
- transport/manager: Add connection limits for inbound and outbound established connections ([#185](https://github.com/paritytech/litep2p/pull/185))
127+
- kad: Add query id to log messages ([#174](https://github.com/paritytech/litep2p/pull/174))
128+
129+
### Changed
130+
131+
- transport: Replace trust_dns_resolver with hickory_resolver ([#223](https://github.com/paritytech/litep2p/pull/223))
132+
- crypto/noise: Generate keypair only for Curve25519 ([#214](https://github.com/paritytech/litep2p/pull/214))
133+
- transport: Allow manual setting of keep-alive timeout ([#155](https://github.com/paritytech/litep2p/pull/155))
134+
- kad: Update connection status of an existing bucket entry ([#181](https://github.com/paritytech/litep2p/pull/181))
135+
- Make transports optional ([#192](https://github.com/paritytech/litep2p/pull/192))
136+
137+
### Fixed
138+
139+
- kad: Fix substream opening and dialing race ([#222](https://github.com/paritytech/litep2p/pull/222))
140+
- query-executor: Save the task waker on empty futures ([#219](https://github.com/paritytech/litep2p/pull/219))
141+
- substream: Use write_all instead of manually writing bytes ([#217](https://github.com/paritytech/litep2p/pull/217))
142+
- minor: fix tests without `websocket` feature ([#215](https://github.com/paritytech/litep2p/pull/215))
143+
- Fix TCP, WebSocket, QUIC leaking connection IDs in `reject()` ([#198](https://github.com/paritytech/litep2p/pull/198))
144+
- transport: Fix double lock and state overwrite on disconnected peers ([#179](https://github.com/paritytech/litep2p/pull/179))
145+
- kad: Do not update memory store on incoming `GetRecordSuccess` ([#190](https://github.com/paritytech/litep2p/pull/190))
146+
- transport: Reject secondary connections with different connection IDs ([#176](https://github.com/paritytech/litep2p/pull/176))
147+
8148
## [0.6.2] - 2024-06-26
9149

10150
This is a bug fixing release. Kademlia now correctly sets and forwards publisher & ttl in the DHT records.

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
name = "litep2p"
33
description = "Peer-to-peer networking library"
44
license = "MIT"
5-
version = "0.6.2"
5+
version = "0.7.0"
66
edition = "2021"
77

88
[build-dependencies]

src/protocol/request_response/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -430,7 +430,7 @@ impl RequestResponseProtocol {
430430
(peer, request_id, fallback_protocol, Err(RequestResponseError::Rejected(error.into())))
431431
},
432432
None => {
433-
tracing::info!(
433+
tracing::debug!(
434434
target: LOG_TARGET,
435435
?peer,
436436
%protocol,

0 commit comments

Comments
 (0)