Proto commits in libp2p/py-libp2p

These 71 commits are when the Protocol Buffers files have changed:

2026-06-28

fix(relay): enforce destination reservation on Circuit Relay v2 CONNECT Fixes #1342. Reject CONNECT when the destination has no active reservation (NO_RESERVATION=204), enforce source per-reservation connection limits separately, add get_reservation() API, regression tests, and regenerate circuit protobuf with 6.x toolchain. Co-authored-by: Cursor <cursoragent@cursor.com>

The documentation is generated from this commit.

2026-06-19

Merge remote-tracking branch 'upstream/main' into webrtc

2026-05-13

feat: Implement Bitswap 1.3.0 with payment gating - Added PaymentGatedDecisionEngine to handle payment-required logic for block serving. - Introduced PaymentTerms, PaymentAuthorization, PaymentReceipt, and PaymentRejection messages in the new bitswap_1_3_0.proto. - Enhanced existing MerkleDag class to store internal nodes with a callback for payment gating. - Created BitswapPaymentClient_1_3 to manage client-side payment authorizations and receipts. - Updated balanced_layout function to support payment gating and internal node storage. - Added necessary protobuf definitions and generated Python files for Bitswap 1.3.0.

2026-05-02

Merge remote-tracking branch 'origin/main' into improvement/bitswap

2026-04-18

feat: enhance DHT record handling with signing and verification for icompatibility with ipfs kubo - Added support for signed records in the DHT by introducing `make_signed_put_record` function. - Updated `ValueStore` to create signed records when storing values. - Enhanced `Envelope` class to handle raw payload types for peer records. - Introduced utility functions for signing and verifying DHT records. - Updated protobuf definitions to include author and signature fields in records. - Improved logging and debug messages for better traceability.

2026-04-11

feat(webrtc): add signaling protocol for private-to-private connections Implements /webrtc-signaling/0.0.1 for SDP and ICE candidate exchange over Circuit Relay v2 streams. Bilateral ICE_DONE mechanism (specs#585) ensures neither side closes the signaling stream before the other has received all candidates. WebRTCPrivateTransport handles /p2p-circuit/webrtc/ multiaddrs. WebRTCPrivateListener registers a stream handler for incoming signaling.

feat(webrtc): add protobuf schema, constants and exception hierarchy Wire format for WebRTC data-channel messages per the libp2p spec: Message { Flag flag, bytes message } with FIN/STOP_SENDING/RESET/FIN_ACK. Constants include protocol codes (0x0118, 0x0119, 0x01D2), message size limits, data-channel ID allocation rules, Noise prologue prefix, and ICE/DTLS defaults matching go-libp2p.

2026-03-16

Merge branch 'main' into enh/1231-add-gossipsub-1.3-support

added newsfragement, replaced string with hex method and protocol version check

2026-03-03

Merge branch 'main' into IPNS

2026-02-21

feat: implement GossipSub v1.3 support with extensions and improved peer scoring

2026-01-25

feat(kad-dht): implement IPNS validator for DHT record validation - Add IPNS protobuf definition (IpnsEntry message) - Implement IPNSValidator class following IPNS spec - Integrate IPNS validator with DHT (apply_fallbacks, validate_config) - Add cbor2 dependency for DAG-CBOR decoding - Add comprehensive tests (19 test cases) Closes #1157 Signed-off-by: asmit27rai <raiasmit10@gmail.com>

2026-01-21

feat: implement GossipSub with extensions, adaptive gossip, enhanced scoring, and rate limiting

2025-11-18

implement persistent peerstore with Protocol Buffer serialization, context managers, and configurable sync

2025-11-07

Fix flaky test: preserve empty bytes in NoiseExtensions early_data - Change proto3 early_data field to optional bytes to enable presence tracking - Update from_protobuf to use HasField() instead of empty check - Regenerate protobuf code - Fix documentation in protocol_buffer.py for create_status function

Merge remote-tracking branch 'origin/main' into feat/protobuf-spec-for-noise # Conflicts: # libp2p/relay/circuit_v2/protocol_buffer.py

2025-11-04

Merge branch 'main' into feature/file_sharing

2025-11-03

Merge origin/main and fix type error in protocol_buffer.py - Resolved merge conflict in circuit_pb2.py by regenerating from proto source - Fixed type error in protocol_buffer.py by using proper ValueType cast for protobuf enum - Updated protobuf files from proto source after merge

2025-11-02

add spr in all hop messages

Add SPR field in relayV2 protobuf

2025-10-23

feat: experimental full spec-compliant Noise protocol implementation 🎯 SPEC COMPLIANCE ACHIEVED: - ✅ Added stream_muxers field to NoiseExtensions (spec requirement) - ✅ Removed legacy data field from NoiseHandshakePayload (cleanup) - ✅ Updated protobuf schema to match official libp2p/specs/noise - ✅ Maintained early_data support as Python extension 🔧 CORE CHANGES: - libp2p/security/noise/messages.py: Added stream_muxers, removed legacy fields - libp2p/security/noise/pb/noise.proto: Updated schema for spec compliance - libp2p/security/noise/patterns.py: Fixed handshake payload creation - libp2p/security/noise/transport.py: Added static key caching support 🧪 TESTING: - ✅ All 1064 tests passing - ✅ Full tox parallel execution successful - ✅ Wheel builds working correctly - ✅ Type checking and linting clean 🚀 INTEROP READY: - Compatible with Go, Rust, JavaScript implementations - Stream muxers support for spec compliance - WebTransport certificate hashes preserved - Early data maintained as Python extension Next phase: Interoperability testing with other libp2p implementations

Implement complete libp2p Noise protocol extensions

2025-10-21

Merge branch 'main' into feature/file_sharing

fixed some type errors

2025-10-13

Merge branch 'main' into enh/806-add-gossipsub-1.2-support

2025-10-12

Init py-peer-record module

added record validators in kad-dht

2025-10-09

Add integration tests for MerkleDag and DAG-PB functionality - Created `test_dag.py` to test the MerkleDag class, including methods for adding bytes and files, fetching files, and verifying file information. - Implemented tests for handling small and large data, progress tracking, and error handling. - Added `test_dag_pb.py` to test the encoding and decoding of DAG-PB structures, including file and directory nodes. - Introduced a verification script `verify_bitswap.py` to ensure the Bitswap implementation's structure and functionality, including imports, configuration, block store operations, message creation, and file structure validation.

2025-10-06

Merge branch 'main' into enh/806-add-gossipsub-1.2-support

Initial commit for bitswap

2025-09-07

Initial commit for rendezvous implementation

2025-09-03

Merge branch 'main' into enh/806-add-gossipsub-1.2-support

2025-08-29

signed-peer-record transfer integrated with pubsub rpc message trasfer

2025-08-28

Merge branch 'main' into enh/806-add-gossipsub-1.2-support

2025-08-26

fix typos

2025-08-09

feat: add GossipSub 1.2 support with IDONTWANT messages

2025-08-08

feat/606-enable-nat-traversal-via-hole-punching (#668) * feat: base implementation of dcutr for hole-punching * chore: removed circuit-relay imports from __init__ * feat: implemented dcutr protocol * added test suite with mock setup * Fix pre-commit hook issues in DCUtR implementation * usages of CONNECT_TYPE and SYNC_TYPE have been replaced with HolePunch.Type.CONNECT and HolePunch.Type.SYNC * added unit tests for dcutr and nat module and * added multiaddr.get_peer_id() with proper DNS address handling and fixed method signature inconsistencies * added assertions to verify DCUtR hole punch result in integration test --------- Co-authored-by: Manu Sheel Gupta <manusheel.edu@gmail.com>

2025-07-26

Integrated Signed-peer-record transfer with identify/identify-push

Implemented: Envelope wrapper class + linter hacks for protobuf checks

PeerRecord class with ProtoBuff implemented

2025-06-21

updated protobuf for prune message

2025-06-18

Feat/587-circuit-relay (#611) * feat: implemented setup of circuit relay and test cases * chore: remove test files to be rewritten * added 1 test suite for protocol * added 1 test suite for discovery * fixed protocol timeouts and message types to handle reservations and stream operations. * Resolved merge conflict in libp2p/tools/utils.py by combining timeout approach with retry mechanism * fix: linting issues * docs: updated documentation with circuit-relay * chore: added enums, improved typing, security and examples * fix: created proper __init__ file to ensure importability * fix: replace transport_opt with listen_addrs in examples, fixed typing and improved code * fix type checking issues across relay module and test suite * regenerated circuit_pb2 file protobuf version 3 * fixed circuit relay example and moved imports to top in test_security_multistream * chore: moved imports to the top * chore: fixed linting of test_circuit_v2_transport.py --------- Co-authored-by: Manu Sheel Gupta <manusheel.edu@gmail.com>

2025-06-16

Kademlia DHT implementation in py-libp2p (#579) * initialise the module * added content routing * added routing module * added peer routing * added value store * added utilities functions * added main kademlia file * fixed create_key_from_binary function * example to test kademlia dht * added protocol ID and enhanced logging for peer store size in provider and consumer nodes * refactor: specify stream type in handle_stream method and add peer in routing table * removed content routing * added default value of count for finding closest peers * added functions to find close peers * refactor: remove content routing and enhance peer discovery * added put value function * added get value function * fix: improve logging and handle key encoding in get_value method * refactor: remove ContentRouting import from __init__.py * refactor: improved basic kademlia example * added protobuf files * replaced json with protobuf * refactor: enhance peer discovery and routing logic in KadDHT * refactor: enhance Kademlia routing table to use PeerInfo objects and improve peer management * refactor: enhance peer addition logic to utilize PeerInfo objects in routing table * feat: implement content provider functionality in Kademlia DHT * refactor: update value store to use datetime for validity management * refactor: update RoutingTable initialization to include host reference * refactor: enhance KBucket and RoutingTable for improved peer management and functionality * refactor: streamline peer discovery and value storage methods in KadDHT * refactor: update KadDHT and related classes for async peer management and enhanced value storage * refactor: enhance ProviderStore initialization and improve peer routing integration * test: add tests for Kademlia DHT functionality * fix linting issues * pydocstyle issues fixed * CICD pipeline issues solved * fix: update docstring format for find_peer method * refactor: improve logging and remove unused code in DHT implementation * refactor: clean up logging and remove unused imports in DHT and test files * Refactor logging setup and improve DHT stream handling with varint length prefixes * Update bootstrap peer handling in basic_dht example and refactor peer routing to accept string addresses * Enhance peer querying in Kademlia DHT by implementing parallel queries using Trio. * Enhance peer querying by adding deduplication checks * Refactor DHT implementation to use varint for length prefixes and enhance logging for better traceability * Add base58 encoding for value storage and enhance logging in basic_dht example * Refactor Kademlia DHT to support server/client modes * Added unit tests * Refactor documentation to fixsome warning * Add unit tests and remove outdated tests * Fixed precommit errora * Refactor error handling test to raise StringParseError for invalid bootstrap addresses * Add libp2p.kad_dht to the list of subpackages in documentation * Fix expiration and republish checks to use inclusive comparison * Add __init__.py file to libp2p.kad_dht.pb package * Refactor get value and put value to run in parallel with query timeout * Refactor provider message handling to use parallel processing with timeout * Add methods for provider store in KadDHT class * Refactor KadDHT and ProviderStore methods to improve type hints and enhance parallel processing * Add documentation for libp2p.kad_dht.pb module. * Update documentation for libp2p.kad_dht package to include subpackages and correct formatting * Fix formatting in documentation for libp2p.kad_dht package by correcting the subpackage reference * Fix header formatting in libp2p.kad_dht.pb documentation * Change log level from info to debug for various logging statements. * fix CICD issues (post revamp) * fixed value store unit test * Refactored kademlia example * Refactor Kademlia example: enhance logging, improve bootstrap node connection, and streamline server address handling * removed bootstrap module * Refactor Kademlia DHT example and core modules: enhance logging, remove unused code, and improve peer handling * Added docs of kad dht example * Update server address log file path to use the script's directory * Refactor: Introduce DHTMode enum for clearer mode management * moved xor_distance function to utils.py * Enhance logging in ValueStore and KadDHT: include decoded value in debug logs and update parameter description for validity * Add handling for closest peers in GET_VALUE response when value is not found * Handled failure scenario for PUT_VALUE * Remove kademlia demo from project scripts and contributing documentation * spelling and logging --------- Co-authored-by: pacrob <5199899+pacrob@users.noreply.github.com>

2025-05-22

Feat: Adding Yamux as default multiplexer, keeping Mplex as fallback (#538) * feat: Replace mplex with yamux as default multiplexer in py-libp2p * Retain Mplex alongside Yamux in new_swarm with messaging that Yamux is preferred * moved !BBHII to a constant YAMUX_HEADER_FORMAT at the top of yamux.py with a comment explaining its structure * renamed the news fragment to 534.feature.rst and updated the description * renamed the news fragment to 534.feature.rst and updated the description * added a docstring to clarify that Yamux does not support deadlines natively * Remove the __main__ block entirely from test_yamux.py * Replaced the print statements in test_yamux.py with logging.debug * Added a comment linking to the spec for clarity * Raise NotImplementedError in YamuxStream.set_deadline per review * Add muxed_conn to YamuxStream and test deadline NotImplementedError * Fix Yamux implementation to meet libp2p spec * Fix None handling in YamuxStream.read and Yamux.read_stream * Fix test_connected_peers.py to correctly handle peer connections * fix: Ensure StreamReset is raised on read after local reset in yamux * fix: Map MuxedStreamError to StreamClosed in NetStream.write for Yamux * fix: Raise MuxedStreamReset in Yamux.read_stream for closed streams * fix: Correct Yamux stream read behavior for NetStream tests Fixed est_net_stream_read_after_remote_closed by updating NetStream.read to raise StreamEOF when the stream is remotely closed and no data is available, aligning with test expectations and Fixed est_net_stream_read_until_eof by modifying YamuxStream.read to block until the stream is closed ( ecv_closed=True) for =-1 reads, ensuring data is only returned after remote closure. * fix: Correct Yamux stream read behavior for NetStream tests Fixed est_net_stream_read_after_remote_closed by updating NetStream.read to raise StreamEOF when the stream is remotely closed and no data is available, aligning with test expectations and Fixed est_net_stream_read_until_eof by modifying YamuxStream.read to block until the stream is closed ( ecv_closed=True) for =-1 reads, ensuring data is only returned after remote closure. * fix: raise StreamEOF when reading from closed stream with empty buffer * fix: prioritize returning buffered data even after stream reset * fix: prioritize returning buffered data even after stream reset * fix: Ensure test_net_stream_read_after_remote_closed_and_reset passes in full suite * fix: Add __init__.py to yamux module to fix documentation build * fix: Add __init__.py to yamux module to fix documentation build * fix: Add libp2p.stream_muxer.yamux to libp2p.stream_muxer.rst toctree * fix: Correct title underline length in libp2p.stream_muxer.yamux.rst * fix: Add a = so that is matches the libp2p.stream\_muxer.yamux length * fix(tests): Resolve race condition in network notification test * fix: fixing failing tests and examples with yamux and noise * refactor: remove debug logging and improve x25519 tests * fix: Add functionality for users to choose between Yamux and Mplex * fix: increased trio sleep to 0.1 sec for slow environment * feat: Add test for switching between Yamux and mplex * refactor: move host fixtures to interop tests * chore: Update __init__.py removing unused import removed unused ```python import os import logging ``` * lint: fix import order * fix: Resolve conftest.py conflict by removing trio test support * fix: Resolve test skipping by keeping trio test support * Fix: add a newline at end of the file --------- Co-authored-by: acul71 <luca.pisani@birdo.net> Co-authored-by: acul71 <34693171+acul71@users.noreply.github.com>

2025-05-09

feat/561-added autonat service

Refactor: changed PeerInfo to Peer_Info in autonat.proto to avoid conflicts

refractored Peer_Info to PeerInfo as imports

2024-04-27

rebuild protobufs adding ECC_P256 to KeyType

2024-02-19

run lint and fix errors, except mypy

2020-02-28

Noise: update pb

2020-02-08

Noise: add `PatternXX`

2019-12-06

Remove kademlia module (#377) * Remove kademlia and routing/kademlia * cleanup * Fix routed_host test * lint mypy * fix doc * remove set_up_nodes_by_transport_and_disc_opt and fix typing

2019-11-06

Add core handler for `identify` protocol

2019-10-24

Fix typo

2019-08-24

Add `secio` protobufs

2019-08-22

Add `plaintext.proto` Update Makefile to handle the import in `plaintext.proto`. Import path is modified to be relative to the project root. And we run `protoc` from where `Makefile` locates, i.e. the project root. Reference: - plaintext.proto: https://github.com/libp2p/go-libp2p-core/blob/62b2c6c482ef265f6b975d59244fd7b2169aaabf/sec/insecure/pb/plaintext.proto

2019-08-14

Add abstraction for a cryptographic key

2019-04-18

Merge branch 'master' into peer_routing

added changes from future commits to last passing bmuller commit

2019-04-03

add pubsub proto

update from to from_id in proto

added rpc.proto from go repo

update from to from_id in proto

add pubsub proto

added rpc.proto from go repo

add source to rpc.proto

remove redundant proto file

2019-03-29

Merge branch 'floodsub-rpc' of https://github.com/libp2p/py-libp2p into floodsub-rpc

2019-03-28

update from to from_id in proto

add pubsub proto

2019-03-24

added rpc.proto from go repo