- Added a function to find a free port on localhost.
- Updated the run function to use the new port finding logic when a non-positive port is provided.
- Modified address printing to handle multiple listen addresses correctly.
- Improved the get_available_interfaces function to ensure the IPv4 loopback address is included.
* Implementing random walk in py libp2p
* Add documentation for Random Walk module implementation in py-libp2p
* Add Random Walk example for py-libp2p Kademlia DHT
* refactor: peer eviction from routing table stopped
* refactored location of random walk
* add nodesin routing table from peerstore
* random walk working as expected
* removed extra functions
* Removed all manual triggers
* added newsfragments
* fix linting issues
* refacored logs and cleaned example file
* refactor: update RandomWalk and RTRefreshManager to use query function for peer discovery
* docs: added Random Walk example docs
* added optional argument to use random walk in kademlia DHT
* enabled random walk in example file
* Added tests for RandomWalk module
* fixed lint issues
* Update refresh interval and some more tests are added.
* Removed Random Walk module documentation file
* Extra parentheses have been removed from the random walk logs.
Co-authored-by: Paul Robinson <5199899+pacrob@users.noreply.github.com>
---------
Co-authored-by: Manu Sheel Gupta <manusheel.edu@gmail.com>
Co-authored-by: Paul Robinson <5199899+pacrob@users.noreply.github.com>
- Replaced hardcoded listen address with `get_optimal_binding_address` for improved flexibility.
- Imported address validation utilities in `echo.py` and updated `__init__.py` to include new functions.
- Added `network_discover.py` to demonstrate Thin Waist address handling.
- Introduced `address_validation.py` with functions for discovering available network interfaces, expanding wildcard addresses, and determining optimal binding addresses.
- Included fallback mechanisms for environments lacking Thin Waist support.
* 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>
* updated examples to automatically use random port
* Refactor examples to use shared utils for port selection (#1)
---------
Co-authored-by: acul71 <34693171+acul71@users.noreply.github.com>
* 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>
