logos-co
/
nomos-node
mirror of
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
nomos-node/nomos-services/network/Cargo.toml

39 lines
1.1 KiB
TOML
Raw Permalink Normal View History

Initial network service (#2) * initial network service * [style] unpack inbound relay
2022-11-03 13:28:37 +00:00
[package]
Split services into different crates (#13)
2022-11-23 13:43:22 +00:00
name = "nomos-network"
Initial network service (#2) * initial network service * [style] unpack inbound relay
2022-11-03 13:28:37 +00:00
version = "0.1.0"
edition = "2021"
[dependencies]
async-trait = "0.1"
Storage service (#6) * Added storage main files and trait * Pipe skeleton for StorageService * Implement running StorageService * Add sled module * Refactor error reporting * Missing logging todo * Implement mock storage * Add channel for auto-converting types on channel replies * Simplify StorageBackend trait * Refactor mock backend and use HashMap * Remove sled for now * Refactor serialization scheme * Add storage traits docs * Make transaction a custom trait. This way we can return stuff from the transactions themselves if needed.
2022-11-18 08:46:54 +00:00
bytes = "1.2"
Implement #31: Mock network backend (#41) * relax trait bounds * mock mempool * remove unused generic * add mock network test case * fix some PR comments * simplify match branch * finish mempool adapter example * clippy happy * mock consensus
2023-02-01 13:58:23 +00:00
chrono = { version = "0.4", optional = true }
Mixnet PoC base branch (#316) * Add `mixnode` and `mixnet-client` crate (#302) * Add `mixnode` binary (#317) * Integrate mixnet with libp2p network backend (#318) * Fix #312: proper delays (#321) * proper delays * add missing duration param * tiny fix: compilation error caused by `rand` 0.8 -> 0.7 * use `get_available_port()` for mixnet integration tests (#333) * add missing comments * Overwatch mixnet node (#339) * Add mixnet service and overwatch app * remove #[tokio::main] --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * fix tests for the overwatch mixnode (#342) * fix panic when corner case happen in RandomDelayIter (#335) * Use `log` service for `mixnode` bin (#341) * Use `wire` for MixnetMessage in libp2p (#347) * Prevent tmixnet tests from running forever (#363) * Use random delay when sending msgs to mixnet (#362) * fix a minor compilation error caused by the latest master * Fix run output fd (#343) * add a connection pool * Exp backoff (#332) * move mixnet listening into separate task * add exponential retry for insufficient peers in libp2p * fix logging * Fix MutexGuard across await (#373) * Fix MutexGuard across await Holding a MutexGuard across an await point is not a good idea. Removing that solves the issues we had with the mixnet test * Make mixnode handle bodies coming from the same source concurrently (#372) --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * Move wait at network startup (#338) We now wait after the call to 'subscribe' to give the network the time to register peers in the mesh before starting to publish messages * Remove unused functions from mixnet connpool (#374) * Mixnet benchmark (#375) * merge fixes * add `connection_pool_size` field to `config.yaml` * Simplify mixnet topology (#393) * Simplify bytes and duration range ser/de (#394) * optimize bytes serde and duration serde --------- Co-authored-by: Al Liu <scygliu1@gmail.com> Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com> Co-authored-by: Giacomo Pasini <Zeegomo@users.noreply.github.com>
2023-09-14 08:38:47 +00:00
humantime-serde = { version = "1", optional = true }
Lifecycle update and implementations (#457) * Update deps * Implement base lifecycle handling in network service * Implement base lifecycle handling in storage service * Use methods instead of functions * Pipe lifecycle in metrics service * Pipe lifecycle in mempool service * Pipe lifecycle in log service * Pipe lifecycle in da service * Pipe lifecycle in consensus service * Refactor handling of lifecycle message to should_stop_service * Update overwatch version to fixed run_all one
2023-10-25 10:10:21 +00:00
overwatch-rs = { git = "https://github.com/logos-co/Overwatch", rev = "2f70806" }
Sled backend (#7) * Add sled module * Remove sled for now * Implement sled as a storage backend * Remove manual panic * Refactor sled to adap to latest StorageBackend traits changes * Use option bytes for sled transaction output * Cleanup imports * Add tests * Removed unused scopes
2022-11-21 14:23:45 +00:00
multiaddr = "0.15"
Add derive feature to serde (#380)
2023-09-07 08:46:13 +00:00
serde = { version = "1.0", features = ["derive"] }
Implement #31: Mock network backend (#41) * relax trait bounds * mock mempool * remove unused generic * add mock network test case * fix some PR comments * simplify match branch * finish mempool adapter example * clippy happy * mock consensus
2023-02-01 13:58:23 +00:00
sscanf = { version = "0.4", optional = true }
Sled backend (#7) * Add sled module * Remove sled for now * Implement sled as a storage backend * Remove manual panic * Refactor sled to adap to latest StorageBackend traits changes * Use option bytes for sled transaction output * Cleanup imports * Add tests * Removed unused scopes
2022-11-21 14:23:45 +00:00
sled = { version = "0.34", optional = true }
Initial network service (#2) * initial network service * [style] unpack inbound relay
2022-11-03 13:28:37 +00:00
tokio = { version = "1", features = ["sync"] }
Waku cached streams consensus adapter (#70) * Added waku archive message to waku network backend * Use cached streams in consensus waku adapter * Fix mock test * Add missing import * Join requests tasks * Use waku-bindings beta4 * Get stream from archive query method * Set store protocol active for waku backend * Implement local query stream response * Add missing linking flags for new waku-bindings version * Cleanup unbounded sender fuse/unwrap * Clippy happy
2023-02-15 15:49:49 +00:00
tokio-stream = "0.1"
Storage service (#6) * Added storage main files and trait * Pipe skeleton for StorageService * Implement running StorageService * Add sled module * Refactor error reporting * Missing logging todo * Implement mock storage * Add channel for auto-converting types on channel replies * Simplify StorageBackend trait * Refactor mock backend and use HashMap * Remove sled for now * Refactor serialization scheme * Add storage traits docs * Make transaction a custom trait. This way we can return stuff from the transactions themselves if needed.
2022-11-18 08:46:54 +00:00
thiserror = "1.0"
tracing = "0.1"
Mixnet PoC base branch (#316) * Add `mixnode` and `mixnet-client` crate (#302) * Add `mixnode` binary (#317) * Integrate mixnet with libp2p network backend (#318) * Fix #312: proper delays (#321) * proper delays * add missing duration param * tiny fix: compilation error caused by `rand` 0.8 -> 0.7 * use `get_available_port()` for mixnet integration tests (#333) * add missing comments * Overwatch mixnet node (#339) * Add mixnet service and overwatch app * remove #[tokio::main] --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * fix tests for the overwatch mixnode (#342) * fix panic when corner case happen in RandomDelayIter (#335) * Use `log` service for `mixnode` bin (#341) * Use `wire` for MixnetMessage in libp2p (#347) * Prevent tmixnet tests from running forever (#363) * Use random delay when sending msgs to mixnet (#362) * fix a minor compilation error caused by the latest master * Fix run output fd (#343) * add a connection pool * Exp backoff (#332) * move mixnet listening into separate task * add exponential retry for insufficient peers in libp2p * fix logging * Fix MutexGuard across await (#373) * Fix MutexGuard across await Holding a MutexGuard across an await point is not a good idea. Removing that solves the issues we had with the mixnet test * Make mixnode handle bodies coming from the same source concurrently (#372) --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * Move wait at network startup (#338) We now wait after the call to 'subscribe' to give the network the time to register peers in the mesh before starting to publish messages * Remove unused functions from mixnet connpool (#374) * Mixnet benchmark (#375) * merge fixes * add `connection_pool_size` field to `config.yaml` * Simplify mixnet topology (#393) * Simplify bytes and duration range ser/de (#394) * optimize bytes serde and duration serde --------- Co-authored-by: Al Liu <scygliu1@gmail.com> Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com> Co-authored-by: Giacomo Pasini <Zeegomo@users.noreply.github.com>
2023-09-14 08:38:47 +00:00
rand = { version = "0.7.3", optional = true }
Add log service (#4) * add log service * add ser/de to log config * add futures dep
2022-11-21 14:35:52 +00:00
futures = "0.3"
Implement #31: Mock network backend (#41) * relax trait bounds * mock mempool * remove unused generic * add mock network test case * fix some PR comments * simplify match branch * finish mempool adapter example * clippy happy * mock consensus
2023-02-01 13:58:23 +00:00
parking_lot = "0.12"
Mixnet PoC base branch (#316) * Add `mixnode` and `mixnet-client` crate (#302) * Add `mixnode` binary (#317) * Integrate mixnet with libp2p network backend (#318) * Fix #312: proper delays (#321) * proper delays * add missing duration param * tiny fix: compilation error caused by `rand` 0.8 -> 0.7 * use `get_available_port()` for mixnet integration tests (#333) * add missing comments * Overwatch mixnet node (#339) * Add mixnet service and overwatch app * remove #[tokio::main] --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * fix tests for the overwatch mixnode (#342) * fix panic when corner case happen in RandomDelayIter (#335) * Use `log` service for `mixnode` bin (#341) * Use `wire` for MixnetMessage in libp2p (#347) * Prevent tmixnet tests from running forever (#363) * Use random delay when sending msgs to mixnet (#362) * fix a minor compilation error caused by the latest master * Fix run output fd (#343) * add a connection pool * Exp backoff (#332) * move mixnet listening into separate task * add exponential retry for insufficient peers in libp2p * fix logging * Fix MutexGuard across await (#373) * Fix MutexGuard across await Holding a MutexGuard across an await point is not a good idea. Removing that solves the issues we had with the mixnet test * Make mixnode handle bodies coming from the same source concurrently (#372) --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * Move wait at network startup (#338) We now wait after the call to 'subscribe' to give the network the time to register peers in the mesh before starting to publish messages * Remove unused functions from mixnet connpool (#374) * Mixnet benchmark (#375) * merge fixes * add `connection_pool_size` field to `config.yaml` * Simplify mixnet topology (#393) * Simplify bytes and duration range ser/de (#394) * optimize bytes serde and duration serde --------- Co-authored-by: Al Liu <scygliu1@gmail.com> Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com> Co-authored-by: Giacomo Pasini <Zeegomo@users.noreply.github.com>
2023-09-14 08:38:47 +00:00
nomos-core = { path = "../../nomos-core" }
feat: add `nomos-libp2p` crate (for nomos-network backend) (#237) * feat: add libp2p network backend skeleton * use tokio runtime managed by Overwatch * feat: add nomos-libp2p crate * remove gossipsub_message_id_fn * clippy * use next() instead of select_next_some() * rename send_command to execute_command * const timeout * disable authn / msg signing to start from a clean slate * rename CommandSender to CommandResultSender * add comments * move node machinery to networkbackend * fmt * logs more network events --------- Co-authored-by: Giacomo Pasini <g.pasini98@gmail.com>
2023-07-11 08:33:57 +00:00
nomos-libp2p = { path = "../../nomos-libp2p", optional = true }
Refactor libp2p StreamSend command more generic (#614)
2024-03-19 01:03:00 +00:00
mixnet = { path = "../../mixnet", optional = true }
Implement #31: Mock network backend (#41) * relax trait bounds * mock mempool * remove unused generic * add mock network test case * fix some PR comments * simplify match branch * finish mempool adapter example * clippy happy * mock consensus
2023-02-01 13:58:23 +00:00
Nomos http API (#476) * Info api * Da blob api (#487) * Add storage api for new http backend (#488) * Mempool add APIs (#489)
2023-11-01 09:14:58 +00:00
utoipa = { version = "4.0", optional = true }
serde_json = { version = "1", optional = true }
Implement #31: Mock network backend (#41) * relax trait bounds * mock mempool * remove unused generic * add mock network test case * fix some PR comments * simplify match branch * finish mempool adapter example * clippy happy * mock consensus
2023-02-01 13:58:23 +00:00
[dev-dependencies]
tokio = { version = "1", features = ["full"] }
Add Waku network backend (#3) * Add Waku network backend Add Waku as the first supported network backend and rework API. In particular, the network message now depends on the underlying network backend so that it can properly reflects specificities of the protocol. Another choice could have been to hardwire domain-specific actions in the network message type (e.g. send block, send message, ...) but was discarded in favor of a more general network service. * address review comments * add debug impl * add Serialize/Deserialize to network settings * add waku functionalities * add a little bit of documentation
2022-11-21 11:03:47 +00:00
Storage service (#6) * Added storage main files and trait * Pipe skeleton for StorageService * Implement running StorageService * Add sled module * Refactor error reporting * Missing logging todo * Implement mock storage * Add channel for auto-converting types on channel replies * Simplify StorageBackend trait * Refactor mock backend and use HashMap * Remove sled for now * Refactor serialization scheme * Add storage traits docs * Make transaction a custom trait. This way we can return stuff from the transactions themselves if needed.
2022-11-18 08:46:54 +00:00
[features]
Consensus backbone (#16) * tmp * add peers implem * update return values * Backport network consensus adapter (#26) * Pipe network adapter with proper types over original implementation * Hold relay on CarnotConsensus * Scratch Network adapter methods * Fix tests blocking CI * Fix waku feature on network crate * Fix waku_bindings refs * Restructure consensus network * Stream block chunk * Pipe adapter creation with subscription * Add placeholder proposal chunk and approval messages * Implement waku backend * Clippy happy * Use full path for tokio oneshot and error types in message_subscriber_channel method * Clean imports * small fixes Co-authored-by: Daniel Sanchez Quiros <sanchez.quiros.daniel@gmail.com> Co-authored-by: Daniel Sanchez Quiros <sanchez.quiros.daniel@gmail.com>
2022-12-13 10:15:54 +00:00
default = []
Mixnet PoC base branch (#316) * Add `mixnode` and `mixnet-client` crate (#302) * Add `mixnode` binary (#317) * Integrate mixnet with libp2p network backend (#318) * Fix #312: proper delays (#321) * proper delays * add missing duration param * tiny fix: compilation error caused by `rand` 0.8 -> 0.7 * use `get_available_port()` for mixnet integration tests (#333) * add missing comments * Overwatch mixnet node (#339) * Add mixnet service and overwatch app * remove #[tokio::main] --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * fix tests for the overwatch mixnode (#342) * fix panic when corner case happen in RandomDelayIter (#335) * Use `log` service for `mixnode` bin (#341) * Use `wire` for MixnetMessage in libp2p (#347) * Prevent tmixnet tests from running forever (#363) * Use random delay when sending msgs to mixnet (#362) * fix a minor compilation error caused by the latest master * Fix run output fd (#343) * add a connection pool * Exp backoff (#332) * move mixnet listening into separate task * add exponential retry for insufficient peers in libp2p * fix logging * Fix MutexGuard across await (#373) * Fix MutexGuard across await Holding a MutexGuard across an await point is not a good idea. Removing that solves the issues we had with the mixnet test * Make mixnode handle bodies coming from the same source concurrently (#372) --------- Co-authored-by: Youngjoon Lee <taxihighway@gmail.com> * Move wait at network startup (#338) We now wait after the call to 'subscribe' to give the network the time to register peers in the mesh before starting to publish messages * Remove unused functions from mixnet connpool (#374) * Mixnet benchmark (#375) * merge fixes * add `connection_pool_size` field to `config.yaml` * Simplify mixnet topology (#393) * Simplify bytes and duration range ser/de (#394) * optimize bytes serde and duration serde --------- Co-authored-by: Al Liu <scygliu1@gmail.com> Co-authored-by: Daniel Sanchez <sanchez.quiros.daniel@gmail.com> Co-authored-by: Giacomo Pasini <Zeegomo@users.noreply.github.com>
2023-09-14 08:38:47 +00:00
libp2p = ["nomos-libp2p", "rand", "humantime-serde"]
Replace mixnet backend with mixnet addon (#615)
2024-03-19 10:15:09 +00:00
mixnet = ["dep:mixnet"]
deps: bump waku-bindings to handle `ephemeral` field (#160)
2023-06-20 11:58:22 +00:00
mock = ["rand", "chrono"]
Mixnet v1 (#569) * base * Remove mixnet client from libp2p network backend (#572) * Mixnet v1: Remove all mixnet legacies: mixnet crate, mixnode binary, tests, and docker (#573) * Mixnet v1: Skeleton (#570) * Use QUIC for libp2p (#580) * Add Poisson interval function for Mixnet (#575) * Mixnet network backend skeleton (#586) * Libp2p stream read/write (#587) * Emitting packets from mixclient using libp2p stream (#588) * Handle outputs from mixnode using libp2p stream/gossipsub (#589) * Refactor poisson (#590) * Mix client Poisson emission (#591) * Mix node packet handling (#592) * Mix Packet / Fragment logic (#593) * Move FisherYates to `nomos-utils` (#594) * Mixnet topology (#595) * Mix client/node unit tests (#596) * change multiaddr from tcp to udp with quic-v1 (#607) --------- Co-authored-by: Al Liu <scygliu1@gmail.com>
2024-03-12 06:47:35 +00:00
openapi = ["dep:utoipa", "serde_json"]