Chore: align interfaces (#352)

* adjust interfaces to new prime lib standards (Socket env var, event handling)

Author: JannikSt

crates/orchestrator/src/plugins/node_groups/mod.rs

@@ -98,7 +98,7 @@ impl NodeGroupsPlugin {
     fn generate_group_id() -> String {
         use rand::Rng;
         let mut rng = rand::rng();
-        format!("group_{}", rng.random::<u64>())
+        format!("{}", rng.random::<u64>())
     }
 
     fn get_group_key(group_id: &str) -> String {

crates/validator/src/validators/synthetic_data.rs

@@ -558,18 +558,6 @@ impl SyntheticDataValidator {
             };
             debug!("Key {} has {} work units", work_key, work_info.work_units);
 
-            // Invalidate work if work units exceed threshold
-            if work_info.work_units > U256::from(1) {
-                if let Err(e) = self_arc.invalidate_work(work_key).await {
-                    error!("Failed to invalidate work {}: {}", work_key, e);
-                    continue;
-                }
-                self_arc
-                    .update_work_validation_status(work_key, &ValidationResult::Invalidated)
-                    .await?;
-                continue;
-            }
-
             let cache_status = self_arc
                 .get_work_validation_status_from_redis(work_key)
                 .await?;

crates/worker/src/docker/service.rs

@@ -211,7 +211,7 @@ impl DockerService {
                                         }
 
                                         env_vars.insert("NODE_ADDRESS".to_string(), node_address);
-                                        env_vars.insert("PRIME_TASK_BRIDGE_SOCKET".to_string(), task_bridge_socket_path.to_string());
+                                        env_vars.insert("PRIME_SOCKET_PATH".to_string(), task_bridge_socket_path.to_string());
                                         env_vars.insert("PRIME_TASK_ID".to_string(), payload.id.to_string());
                                         if let Some(p2p_seed) = p2p_seed {
                                             env_vars.insert("IROH_SEED".to_string(), p2p_seed.to_string());

crates/worker/src/docker/taskbridge/bridge.rs

@@ -168,7 +168,7 @@ impl TaskBridge {
                                     extract_next_json(&data[current_pos..])
                                 {
                                     debug!("Extracted JSON object: {}", json_str);
-                                    if json_str.contains("file_name") {
+                                    if json_str.contains("output/save_path") {
                                         debug!("Processing file_name message");
                                         if let Some(storage_path) = storage_path_clone.clone() {
                                             if let Ok(file_info) =
@@ -221,7 +221,7 @@ impl TaskBridge {
                                         } else {
                                             error!("No storage path set");
                                         }
-                                    } else if json_str.contains("file_sha") {
+                                    } else if json_str.contains("output/sha256") {
                                         debug!("Processing file_sha message");
                                         if let Ok(file_info) =
                                             serde_json::from_str::<serde_json::Value>(json_str)