* initial
* first iteration, lots of lifetime and trait issues, does not compile
* Daniel/sampling service (#706)
* Implement sampling service
* Implement libp2p adapter listen_to_sampling_messages
* temporary empty backend mod; implement start_sampling
* addressed PR comments; moved random sampling subnet list generation to backend (todo impl)
* addressed PR nitpicks
* remove empty mod which was failing CI due to cargo fmt
* removed unused code
---------
Co-authored-by: holisticode <holistic.computing@gmail.com>
Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com>
* Nomos cli executor swarm
* Executor swarm and backend in nomos-cli
* Libp2p executor adapter in nomos cli
* Update nomos-cli/src/da/network/backend.rs
Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com>
* Use FillFromNodeList with executor backend
* Integrate Executor backend into the cli
* Use subnetwork id where appropriate
* Common clone_deserialize_error
* Use thiserror
* Minimal dialing in cli swarm
* Send dispersal messages async
* Remove unused connection id
---------
Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com>
* Build up validator behaviour and swarm
* Refactor modules
* More barebones structure on validator swarm
* Refactor protocols into submodule
* Pipe up events stream into swarm impl
* Clippy happy on tests
* Fix reading messages state machine
* Improve waker on behaviour
* Rename test
* First sketch
* Implement replication
* Refactor protocols names
* Clippy happy
* expose behaviour
* Return dummy on outbound for validator behaviour
* Implement behaviour, lacks streams handling
* Cleanup
* Implement stream handling
* Add some documentation and comments
* Clippy fixes after rebase
* Move all neighbours to test_utils module
* Executor only outgoing streams
* First assault at testing behaviours
* Add debug instead of traces
* Added more logs
* Bullshitting tests
* Fix outstream handling, offers hook to send new peer streams
* Fix blob dispersal handling
* Refactor test, use new api
* Imports cleanup
* Working test
* Add docs
* Non overlapping test port
* Fix attempt 1 - nonworking
* Added missing open stream request
* Expand outbound lifecycle to openstream state
* Fix reading messages state machine
* Use tracing
* Remove unnecessary loop
* Use stream style for test
* Send 10 messages
* Use quic in test
* Sends and receives
* cargo update fixed the panic
* Refactor test
* reschedule polls
* Clippy cleanup
* Remove leftover features
* Cargo fmt
* Improve waker on behaviour
* Rename test
* Split message definitions for broadcast, dispersal and sampling
* Expose dispersal messages via crate
* Create nomos-da-messages crate
* From trait implementations for messages
* Rename broadcast to replication
* Prost crate integration for DA
* Packing and unpacking for protobuf messages
* Minimal helper macro for dispersal message
* Use protoc in gh actions
* Move dispersal related protocol to nomos-da-dispersal
Roman
holisticode
gusto
Daniel Sanchez