feat: Carbide side changes to support Astra

crates/agent/src/ethernet_virtualization.rs

@@ -3079,6 +3079,7 @@ mod tests {
             stateful_acls_enabled: true,
             instance: None,
             dpu_extension_services: vec![],
+            astra_config: None,
         }
     }
 
@@ -3571,6 +3572,7 @@ mod tests {
             stateful_acls_enabled: true,
             instance: None,
             dpu_extension_services: vec![],
+            astra_config: None,
         };
 
         let f = tempfile::NamedTempFile::new()?;
@@ -3758,6 +3760,7 @@ mod tests {
             stateful_acls_enabled: false,
             instance: None,
             dpu_extension_services: vec![],
+            astra_config: None,
         };
 
         let f = tempfile::NamedTempFile::new()?;

crates/agent/src/main_loop.rs

@@ -570,6 +570,7 @@ impl MainLoop {
             last_dhcp_requests: vec![],
             dpu_extension_service_version: None,
             dpu_extension_services: vec![],
+            astra_config_status: None,
         };
 
         // `read` does not block

crates/agent/src/tests/full.rs

@@ -921,6 +921,7 @@ async fn handle_netconf(AxumState(state): AxumState<Arc<Mutex<State>>>) -> impl
         stateful_acls_enabled: true,
         instance: Some(instance),
         dpu_extension_services: vec![],
+        astra_config: None,
     };
     common::respond(netconf)
 }

crates/api-core/src/api.rs

@@ -2857,7 +2857,7 @@ impl Forge for Api {
         &self,
         request: Request<mlx_device_pb::PublishMlxDeviceReportRequest>,
     ) -> Result<Response<mlx_device_pb::PublishMlxDeviceReportResponse>, Status> {
-        crate::handlers::dpa::publish_mlx_device_report(self, request).await
+        crate::handlers::svpc::publish_mlx_device_report(self, request).await
     }
 
     // Scout is telling carbide the observed status (locking status, card mode) of the
@@ -2866,7 +2866,7 @@ impl Forge for Api {
         &self,
         request: Request<mlx_device_pb::PublishMlxObservationReportRequest>,
     ) -> Result<Response<mlx_device_pb::PublishMlxObservationReportResponse>, Status> {
-        crate::handlers::dpa::publish_mlx_observation_report(self, request).await
+        crate::handlers::svpc::publish_mlx_observation_report(self, request).await
     }
 
     async fn trim_table(