use marine-rs-sdk with worker_id in CallParameters

fluencelabs · Jan 18, 2024 · 99cee2f · 99cee2f
1 parent 609edab
commit 99cee2f
Show file tree

Hide file tree

Showing 5 changed files with 77 additions and 10 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/module-info-parser/Cargo.toml b/crates/module-info-parser/Cargo.toml
@@ -12,7 +12,7 @@ name = "marine_module_info_parser"
 path = "src/lib.rs"
 
 [dependencies]
-marine-rs-sdk-main = {version = "0.10.0", default-features = false }
+marine-rs-sdk-main = { version = "0.10.3", default-features = false, git = "https://github.com/fluencelabs/marine-rs-sdk", branch = "feat/worker-id-in-call-params" }
 
 marine-wasm-backend-traits = { path = "../wasm-backend-traits", version = "0.5.1" }
 

diff --git a/marine/Cargo.toml b/marine/Cargo.toml
@@ -15,8 +15,8 @@ path = "src/lib.rs"
 marine-core = { path = "../core", version = "0.26.1", default-features = false}
 marine-module-interface = { path = "../crates/module-interface", version = "0.8.1" }
 marine-utils = { path = "../crates/utils", version = "0.5.1" }
-marine-rs-sdk-main = {version = "0.10.0", default-features = false, features = ["logger"] }
-marine-rs-sdk = {version = "0.10.0", default-features = false, features = ["logger"] }
+marine-rs-sdk-main = { version = "0.10.3", default-features = false, features = ["logger"], git = "https://github.com/fluencelabs/marine-rs-sdk", branch = "feat/worker-id-in-call-params" }
+marine-rs-sdk = { version = "0.10.3", default-features = false, features = ["logger"], git = "https://github.com/fluencelabs/marine-rs-sdk", branch = "feat/worker-id-in-call-params" }
 
 it-json-serde = { path = "../crates/it-json-serde", version = "0.5.1" }
 marine-wasm-backend-traits = { path = "../crates/wasm-backend-traits", version = "0.5.1" }

diff --git a/tools/repl/Cargo.toml b/tools/repl/Cargo.toml
@@ -13,7 +13,7 @@ path = "src/main.rs"
 
 [dependencies]
 fluence-app-service = { path = "../../crates/fluence-app-service", version = "0.31.1", features = ["raw-module-api"] }
-marine-rs-sdk-main = { version = "0.10.0", default-features = false, features = ["logger"] }
+marine-rs-sdk-main = { version = "0.10.3", default-features = false, features = ["logger"], git = "https://github.com/fluencelabs/marine-rs-sdk", branch = "feat/worker-id-in-call-params" }
 marine-wasm-backend-traits = {path = "../../crates/wasm-backend-traits", version = "0.5.1" }
 
 anyhow = "1.0.75"

diff --git a/tools/repl/src/repl.rs b/tools/repl/src/repl.rs
@@ -302,10 +302,14 @@ struct PartialCallParameters {
     #[serde(default)]
     pub service_creator_peer_id: String,
 
-    /// PeerId of the peer who hosts this service.
+    /// PeerId of the peer who hosts worker with this service.
     #[serde(default)]
     pub host_id: String,
 
+    /// PeerId of the worker who hosts this service.
+    #[serde(default)]
+    pub worker_id: String,
+
     /// Id of the particle which execution resulted a call this service.
     #[serde(default)]
     pub particle_id: String,
@@ -322,6 +326,7 @@ impl From<PartialCallParameters> for CallParameters {
             service_id,
             service_creator_peer_id,
             host_id,
+            worker_id,
             particle_id,
             tetraplets,
         } = partial_call_params;
@@ -331,6 +336,7 @@ impl From<PartialCallParameters> for CallParameters {
             service_id,
             service_creator_peer_id,
             host_id,
+            worker_id,
             particle_id,
             tetraplets,
         }