feat: add connector.send_tx; introduce listener (#2078)

* WIP add connector and listener * fix build * add endline * wip * submit mocked proofs * process submit proof errors * fix error handling * fix build * add test * rename * refactor configs * add reexport * update crates * feat(cores): cpu_range set * feat(cores): core manager * small improvements * small improvements * small improvements * small improvements * small improvements * small improvements * small improvements * small improvements * pin system threads * pin worker threads * Fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * use CUID * feat(config): Introduce ephemeral and persistent storage * fix * fix * fix * change layout + inject persistent dirs into services * fix test * Expose applied config in CreatedSwarm * rename stepper * fix * fix fd in core manager * fix fd in core manager * fix fd in core manager * update spell * update spell * update spell * update crates * shutdown workers runtime at shutdown signal * refactoring * fluence-spell-dtos update * fluence-spell-dtos update * fluence-spell-dtos update * wip * use EIP-1559 * fix * feat(cores): cpu_range set * feat(cores): core manager * small improvements * small improvements * small improvements * small improvements * small improvements * small improvements * small improvements * small improvements * pin system threads * pin worker threads * Fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * Review fixes * use CUID * feat(config): Introduce ephemeral and persistent storage * fix * fix * fix * change layout + inject persistent dirs into services * fix test * Expose applied config in CreatedSwarm * rename stepper * fix * fix fd in core manager * fix fd in core manager * fix fd in core manager * update spell * update spell * shutdown workers runtime at shutdown signal * fix * fluence-spell-dtos update * fluence-spell-dtos update * fix * fix * fix * fix * fix * fix * fix * fix * fix * update distro * fix * fix * remove unused * update fluence-spell-dtos * make injecttion async * fix(deps): decider 0.6.7 * fixes * fix * fix * update lock * fix * update decider * remove unused import --------- Co-authored-by: Nick <[email protected]> Co-authored-by: folex <[email protected]>
fluencelabs · Feb 23, 2024 · 81f00ea · 81f00ea
1 parent 06f253b
commit 81f00ea
Show file tree

Hide file tree

Showing 50 changed files with 2,784 additions and 242 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -44,10 +44,13 @@ members = [
     "particle-execution",
     "crates/system-services",
     "crates/chain-listener",
+    "crates/chain-connector",
     "crates/hex-utils",
     "crates/chain-data",
+    "crates/chain-types",
     "crates/types",
-    "crates/core-manager"]
+    "crates/core-manager"
+]
 exclude = [
     "nox/tests/tetraplets",
 ]
@@ -97,6 +100,8 @@ subnet-resolver = { path = "crates/subnet-resolver" }
 hex-utils = { path = "crates/hex-utils" }
 chain-data = { path = "crates/chain-data" }
 chain-listener = { path = "crates/chain-listener" }
+chain-connector = { path = "crates/chain-connector" }
+chain-types = { path = "crates/chain-types" }
 types = { path = "crates/types" }
 core-manager = { path = "crates/core-manager" }
 
@@ -165,6 +170,12 @@ futures-util = "0.3.30"
 num_cpus = "1.16.0"
 enum_dispatch = "0.3.12"
 serde_with = "3.6.0"
+mockito = "1.2.0"
+clarity = "1.3.0"
+cpu-utils = { git = "https://github.com/fluencelabs/capacity-commitment-prover/", branch = "main" }
+ccp-shared = { git = "https://github.com/fluencelabs/capacity-commitment-prover/", branch = "main" }
+ccp-rpc-client = { git = "https://github.com/fluencelabs/capacity-commitment-prover.git", branch = "main" }
+
 
 # Enable a small amount of optimization in debug mode
 [profile.dev]

diff --git a/crates/chain-connector/Cargo.toml b/crates/chain-connector/Cargo.toml
@@ -0,0 +1,29 @@
+[package]
+name = "chain-connector"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+particle-builtins = { workspace = true }
+particle-execution = { workspace = true }
+particle-args = { workspace = true }
+chain-data = { workspace = true }
+chain-types = { workspace = true }
+ethabi = { workspace = true }
+jsonrpsee = { workspace = true, features = ["macros", "server", "client"] }
+eyre = { workspace = true }
+fluence-libp2p = { workspace = true }
+serde_json = { workspace = true }
+hex = { workspace = true }
+server-config = { workspace = true }
+clarity = { workspace = true }
+tokio = { workspace = true, features = ["rt", "macros"] }
+hex-utils = { workspace = true }
+futures = { workspace = true }
+ccp-shared = { workspace = true }
+thiserror =  { workspace = true }
+
+[dev-dependencies]
+mockito = { workspace = true }