chore: adjust taskbridge to simple new logfmt (#368)

* adjust taskbridge to simple new logfmt

Author: JannikSt

Cargo.lock

@@ -53,7 +53,7 @@ async fn main() -> Result<()> {
 
     let call = contracts
         .compute_pool
-        .build_work_submission_call(pool_id, node, work_key)
+        .build_work_submission_call(pool_id, node, work_key, U256::from(1))
         .await
         .map_err(|e| eyre::eyre!("Failed to build work submission call: {}", e))?;
 

crates/dev-utils/examples/submit_work.rs

@@ -5,6 +5,7 @@ edition.workspace = true
 
 [dependencies]
 actix-web = { workspace = true }
+actix-web-prometheus = "0.1.2"
 alloy = { workspace = true }
 anyhow = { workspace = true }
 async-trait = "0.1.88"

crates/orchestrator/Cargo.toml

@@ -131,14 +131,12 @@ impl ComputePool {
         pool_id: U256,
         node: Address,
         data: Vec<u8>,
+        work_units: U256,
     ) -> Result<PrimeCallBuilder<'_, alloy::json_abi::Function>, Box<dyn std::error::Error>> {
         // Extract the work key from the first 32 bytes
         // Create a new data vector with work key and work units (set to 1)
         let mut submit_data = Vec::with_capacity(64);
         submit_data.extend_from_slice(&data[0..32]); // Work key
-
-        // We leave work units simple for now and only set this to 1 (1 file = 1 work unit)
-        let work_units = U256::from(1);
         submit_data.extend_from_slice(&work_units.to_be_bytes::<32>());
 
         let call = self.instance.instance().function(

crates/shared/src/web3/contracts/implementations/compute_pool_contract.rs

@@ -97,10 +97,6 @@ pub enum Commands {
         #[arg(long, default_value = "false")]
         skip_system_checks: bool,
 
-        /// Silence metrics logging
-        #[arg(long, default_value = "false")]
-        silence_metrics: bool,
-
         /// Loki URL
         #[arg(long)]
         loki_url: Option<String>,
@@ -184,7 +180,6 @@ pub async fn execute_command(
             auto_accept,
             funding_retry_count,
             skip_system_checks,
-            silence_metrics,
             loki_url: _,
             log_level: _,
         } => {
@@ -401,16 +396,15 @@ pub async fn execute_command(
                 Some(specs) => specs.storage_path.clone(),
                 None => None,
             };
-            let task_bridge = Arc::new(TaskBridge::new(
+            let task_bridge = TaskBridge::new(
                 None,
                 metrics_store,
                 Some(bridge_contracts),
                 Some(node_config.clone()),
                 Some(bridge_wallet),
                 docker_storage_path.clone(),
                 state.clone(),
-                *silence_metrics,
-            ));
+            );
 
             let system_memory = node_config
                 .compute_specs
@@ -437,10 +431,11 @@ pub async fn execute_command(
 
             let bridge_cancellation_token = cancellation_token.clone();
             tokio::spawn(async move {
+                let bridge_clone = task_bridge.clone();
                 tokio::select! {
                     _ = bridge_cancellation_token.cancelled() => {
                     }
-                    _ = task_bridge.run() => {
+                    _ = bridge_clone.run() => {
                     }
                 }
             });