wip: OKD Installation full process automation underway, ready to test bootstrapping very soon

harmony/src/domain/topology/ha_cluster.rs

@@ -161,7 +161,11 @@ impl DhcpServer for HAClusterTopology {
         self.dhcp_server.set_pxe_options(options).await
     }
 
-    async fn set_dhcp_range(&self, start: &IpAddress, end: &IpAddress) -> Result<(), ExecutorError> {
+    async fn set_dhcp_range(
+        &self,
+        start: &IpAddress,
+        end: &IpAddress,
+    ) -> Result<(), ExecutorError> {
         self.dhcp_server.set_dhcp_range(start, end).await
     }
 
@@ -302,7 +306,11 @@ impl DhcpServer for DummyInfra {
     async fn set_pxe_options(&self, _options: PxeOptions) -> Result<(), ExecutorError> {
         unimplemented!("{}", UNIMPLEMENTED_DUMMY_INFRA)
     }
-    async fn set_dhcp_range(&self, start: &IpAddress, end: &IpAddress) -> Result<(), ExecutorError> {
+    async fn set_dhcp_range(
+        &self,
+        start: &IpAddress,
+        end: &IpAddress,
+    ) -> Result<(), ExecutorError> {
         unimplemented!("{}", UNIMPLEMENTED_DUMMY_INFRA)
     }
     fn get_ip(&self) -> IpAddress {

harmony/src/domain/topology/network.rs

@@ -59,7 +59,8 @@ pub trait DhcpServer: Send + Sync + std::fmt::Debug {
     async fn remove_static_mapping(&self, mac: &MacAddress) -> Result<(), ExecutorError>;
     async fn list_static_mappings(&self) -> Vec<(MacAddress, IpAddress)>;
     async fn set_pxe_options(&self, pxe_options: PxeOptions) -> Result<(), ExecutorError>;
-    async fn set_dhcp_range(&self, start: &IpAddress, end: &IpAddress) -> Result<(), ExecutorError>;
+    async fn set_dhcp_range(&self, start: &IpAddress, end: &IpAddress)
+    -> Result<(), ExecutorError>;
     fn get_ip(&self) -> IpAddress;
     fn get_host(&self) -> LogicalHost;
     async fn commit_config(&self) -> Result<(), ExecutorError>;

harmony/src/modules/dhcp.rs

@@ -108,7 +108,9 @@ impl<T: Topology + DhcpServer> Interpret<T> for DhcpInterpret {
         info!("Executing DhcpInterpret on inventory {inventory:?}");
 
         self.set_pxe_options(inventory, topology).await?;
-        topology.set_dhcp_range(&self.score.dhcp_range.0, &self.score.dhcp_range.1).await?;
+        topology
+            .set_dhcp_range(&self.score.dhcp_range.0, &self.score.dhcp_range.1)
+            .await?;
 
         DhcpHostBindingScore {
             host_binding: self.score.host_binding.clone(),

harmony/src/modules/inventory/mod.rs

@@ -46,7 +46,6 @@ impl<T: Topology> Interpret<T> for DiscoverInventoryAgentInterpret {
         _inventory: &Inventory,
         _topology: &T,
     ) -> Result<Outcome, InterpretError> {
-
         match self.score.discovery_timeout {
             Some(timeout) => info!("Discovery agent will wait for {timeout} seconds"),
             None => info!(

harmony/src/modules/okd/installation.rs

@@ -59,7 +59,7 @@ use crate::{
     data::Version,
     hardware::PhysicalHost,
     infra::inventory::InventoryRepositoryFactory,
-    instrumentation::{instrument, HarmonyEvent},
+    instrumentation::{HarmonyEvent, instrument},
     interpret::{Interpret, InterpretError, InterpretName, InterpretStatus, Outcome},
     inventory::{HostRole, Inventory},
     modules::{

opnsense-config/src/modules/dnsmasq.rs

@@ -1,7 +1,7 @@
 // dnsmasq.rs
 use crate::modules::dhcp::DhcpError;
 use log::{debug, info, warn};
-use opnsense_config_xml::dnsmasq::{DnsMasq, DnsmasqHost, DhcpRange};  // Assuming DhcpRange is defined in opnsense_config_xml::dnsmasq
+use opnsense_config_xml::dnsmasq::{DhcpRange, DnsMasq, DnsmasqHost}; // Assuming DhcpRange is defined in opnsense_config_xml::dnsmasq
 use opnsense_config_xml::{MaybeString, StaticMap};
 use std::collections::HashSet;
 use std::net::Ipv4Addr;
@@ -230,7 +230,10 @@ impl<'a> DhcpConfigDnsMasq<'a> {
 
         // Assuming DnsMasq has dhcp_ranges: Vec<DhcpRange>
         // Find existing range for "lan" interface
-        if let Some(range) = ranges.iter_mut().find(|r| r.interface == Some("lan".to_string())) {
+        if let Some(range) = ranges
+            .iter_mut()
+            .find(|r| r.interface == Some("lan".to_string()))
+        {
             // Update existing range
             range.start_addr = Some(start.to_string());
             range.end_addr = Some(end.to_string());