11 releases (7 breaking)

new 0.8.0 Nov 4, 2024
0.7.0 Sep 5, 2024
0.6.2 Jun 26, 2024
0.5.0 May 24, 2024
0.1.0 Apr 4, 2023

#93 in Network programming

Download history 29677/week @ 2024-07-22 24017/week @ 2024-07-29 29372/week @ 2024-08-05 41951/week @ 2024-08-12 26213/week @ 2024-08-19 36517/week @ 2024-08-26 42211/week @ 2024-09-02 35897/week @ 2024-09-09 34321/week @ 2024-09-16 35231/week @ 2024-09-23 38340/week @ 2024-09-30 39834/week @ 2024-10-07 40691/week @ 2024-10-14 46311/week @ 2024-10-21 36302/week @ 2024-10-28 50647/week @ 2024-11-04

175,115 downloads per month
Used in 110 crates (3 directly)

MIT license

2MB
36K SLoC

litep2p

License Crates.io docs.rs

litep2p is a libp2p-compatible peer-to-peer (P2P) networking library

Features

  • Supported protocols:
    • /ipfs/ping/1.0.0
    • /ipfs/identify/1.0.0
    • /ipfs/kad/1.0.0
    • /ipfs/bitswap/1.2.0
    • Multicast DNS
    • Notification protocol
    • Request-response protocol
    • API for creating custom protocols
  • Supported transports:
    • TCP
    • QUIC
    • WebRTC
    • WebSocket (WS + WSS)

Usage

litep2p has taken a different approach with API design and as such is not a drop-in replacement for rust-libp2p. Below is a sample usage of the library:

use futures::StreamExt;
use litep2p::{
    config::ConfigBuilder,
    protocol::{libp2p::ping, request_response::ConfigBuilder as RequestResponseConfigBuilder},
    transport::{quic::config::Config as QuicConfig, tcp::config::Config as TcpConfig},
    Litep2p, ProtocolName,
};

// simple example which enables `/ipfs/ping/1.0.0` and `/request/1` protocols
// and TCP and QUIC transports and starts polling events
#[tokio::main]
async fn main() {
    // enable IPFS PING protocol
    let (ping_config, mut ping_event_stream) = ping::Config::default();

    // enable `/request/1` request-response protocol
    let (req_resp_config, mut req_resp_handle) =
        RequestResponseConfigBuilder::new(ProtocolName::Static("/request/1"))
            .with_max_size(1024)
            .build();

    // build `Litep2pConfig` object
    let config = ConfigBuilder::new()
        .with_tcp(TcpConfig {
            listen_addresses: vec![
                "/ip6/::1/tcp/0".parse().expect("valid address"),
                "/ip4/127.0.0.1/tcp/0".parse().expect("valid address"),
            ],
            ..Default::default()
        })
        .with_quic(QuicConfig {
            listen_addresses: vec!["/ip4/127.0.0.1/udp/0/quic-v1"
                .parse()
                .expect("valid address")],
            ..Default::default()
        })
        .with_libp2p_ping(ping_config)
        .with_request_response_protocol(req_resp_config)
        .build();

    // build `Litep2p` object
    let mut litep2p = Litep2p::new(config).unwrap();

    loop {
        tokio::select! {
            _event = litep2p.next_event() => {},
            _event = req_resp_handle.next() => {},
            _event = ping_event_stream.next() => {},
        }
    }
}

Seeexamples for more details on how to use the library

Copying

MIT license

Dependencies

~26–41MB
~759K SLoC