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

41 lines
1.2 KiB
TOML
Raw 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"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[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 }
Fix cheap clone Bytes and Overwatch crate name update
2022-11-22 12:44:17 +00:00
overwatch-rs = { git = "https://github.com/logos-co/Overwatch", branch = "main" }
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 }
deps: bump waku-bindings to handle `ephemeral` field (#160)
2023-06-20 11:58:22 +00:00
waku-bindings = { version = "0.1.1", 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
tracing-appender = "0.2"
deps: bump waku-bindings to handle `ephemeral` field (#160)
2023-06-20 11:58:22 +00:00
tracing-subscriber = { version = "0.3", features = ["json"] }
Add log service (#4) * add log service * add ser/de to log config * add futures dep
2022-11-21 14:35:52 +00:00
tracing-gelf = "0.7"
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 }
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
mixnet-client = { path = "../../mixnet/client" }
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 = []
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
waku = ["waku-bindings"]
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"]
deps: bump waku-bindings to handle `ephemeral` field (#160)
2023-06-20 11:58:22 +00:00
mock = ["rand", "chrono"]