All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
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.
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.
// 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:
// 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);
}
}
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.
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.
match error {
RequestResponseError::Rejected(reason) => {
match reason {
RejectReason::ConnectionClosed => "connection-closed",
RejectReason::DialFailed(Some(ImmediateDialError::AlreadyConnected)) => "already-connected",
_ => "other",
}
}
_ => "other",
}
Developers can now set limits on the number of inbound and outbound connections to manage resources and optimize performance.
// 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))
);
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.
The keep-alive timeout for connections is now configurable, providing more control over connection lifecycles.
// 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!
- errors: Introduce immediate dial error and request-response rejection reasons (#227)
- Expose API for
PublicAddresses
(#212) - transport: Implement
TransportService::local_peer_id()
(#224) - find_node: Optimize parallelism factor for slow to respond peers (#220)
- kad: Handle
ADD_PROVIDER
&GET_PROVIDERS
network requests (#213) - errors: Add
DialError
error andListDialFailures
event for better error reporting (#206) - kad: Add support for provider records to
MemoryStore
(#200) - transport: Add accept_pending/reject_pending for inbound connections and introduce inbound limits (#194)
- transport/manager: Add connection limits for inbound and outbound established connections (#185)
- kad: Add query id to log messages (#174)
- transport: Replace trust_dns_resolver with hickory_resolver (#223)
- crypto/noise: Generate keypair only for Curve25519 (#214)
- transport: Allow manual setting of keep-alive timeout (#155)
- kad: Update connection status of an existing bucket entry (#181)
- Make transports optional (#192)
- kad: Fix substream opening and dialing race (#222)
- query-executor: Save the task waker on empty futures (#219)
- substream: Use write_all instead of manually writing bytes (#217)
- minor: fix tests without
websocket
feature (#215) - Fix TCP, WebSocket, QUIC leaking connection IDs in
reject()
(#198) - transport: Fix double lock and state overwrite on disconnected peers (#179)
- kad: Do not update memory store on incoming
GetRecordSuccess
(#190) - transport: Reject secondary connections with different connection IDs (#176)
This is a bug fixing release. Kademlia now correctly sets and forwards publisher & ttl in the DHT records.
- kademlia: Preserve publisher & expiration time in DHT records (#162)
This is a bug fixing and security release. curve255190-dalek has been upgraded to v4.1.3, see dalek-cryptography/curve25519-dalek#659 for details.
- kad: Set default ttl 36h for kad records (#154)
- chore: update ed25519-dalek to v2.1.1 (#122)
- Bump curve255190-dalek 4.1.2 -> 4.1.3 (#159)
This release introduces breaking changes into kad
module. The API has been extended as following:
- An event
KademliaEvent::IncomingRecord
has been added. - New methods
KademliaHandle::store_record()
/KademliaHandle::try_store_record()
have been introduced.
This allows implementing manual incoming DHT record validation by configuring Kademlia
with IncomingRecordValidationMode::Manual
.
Also, it is now possible to enable TCP_NODELAY
on sockets.
Multiple refactorings to remove the code duplications and improve the implementation robustness have been done.
- transport: Introduce common listener for tcp and websocket (#147)
- transport/common: Share DNS lookups between TCP and WebSocket (#151)
- ping: Make ping fault tolerant wrt outbound substreams races (#133)
- crypto/noise: Make noise fault tolerant (#142)
- protocol/notif: Fix panic on missing peer state (#143)
- transport: Fix erroneous handling of secondary connections (#149)
This is a small release that makes the FindNode
command a bit more robust:
- The
FindNode
command now retains the K (replication factor) best results. - The
FindNode
command has been updated to handle errors and unexpected states without panicking.
- Add release checklist (#115)
- kad: Refactor FindNode query, keep K best results and add tests (#114)
This release introduces breaking changes to the litep2p crate, primarily affecting the kad
module. Key updates include:
- The
GetRecord
command now exposes all peer records, not just the latest one. - A new
RecordType
has been introduced to clearly distinguish between locally stored records and those discovered from the network.
Significant refactoring has been done to enhance the efficiency and accuracy of the kad
module. The updates are as follows:
- The
GetRecord
command now exposes all peer records. - The
GetRecord
command has been updated to handle errors and unexpected states without panicking.
Additionally, we've improved code coverage in the kad
module by adding more tests.
- multistream_select: Remove unneeded changelog.md (#116)
- kad: Refactor
GetRecord
query and add tests (#97) - kad/store: Set memory-store on an incoming record for PutRecordTo (#88)
- multistream: Dialer deny multiple /multistream/1.0.0 headers (#61)
- kad: Limit MemoryStore entries (#78)
- Refactor WebRTC code (#51)
- Revert "Bring
rustfmt.toml
in sync with polkadot-sdk (#71)" (#74) - cargo: Update str0m from 0.4.1 to 0.5.1 (#95)
- Expose
reuse_port
option for TCP and WebSocket transports (#69) - protocol/mdns: Use
SO_REUSEPORT
for the mDNS socket (#68) - Add support for protocol/agent version (#64)
This is the second release of litep2p, v0.2.0. The quality of the first release was so bad that this release is a complete rewrite of the library.
Support is added for the following features:
-
Transport protocols:
- TCP
- QUIC
- WebRTC
- WebSocket
-
Protocols:
/ipfs/identify/1.0.0
/ipfs/ping/1.0.0
/ipfs/kad/1.0.0
/ipfs/bitswap/1.2.0
- Request-response protocol
- Notification protocol
- Multicast DNS
- API for creating custom protocols
This time the architecture has been designed to be extensible and integrating new transport and/or user-level protocols should be easier. Additionally, the test coverage is higher both in terms of unit and integration tests. The project also contains conformance tests which test the behavior of litep2p
against, rust-libp2p
, go-libp2p
and Substrate's sc-network
. Currently the Substrate conformance tests are not enabled by default as they require unpublished/unaccepted changes to Substrate.
This is the first release of litep2p
, v0.1.0.
Support is added for the following:
- TCP + Noise + Yamux (compatibility with
libp2p
) /ipfs/identify/1.0.0
/ipfs/ping/1.0.0
- Request-response protocol
- Notification protocol
The code quality is atrocious but it works and the second release focuses on providing high test coverage for the library. After that is done and most of the functionality is covered (unit, integration and conformance tests, benchmarks), the focus can be turned to refactoring the code into something clean and efficient.