wip: improving inventory discovery

examples/harmony_inventory_builder/src/main.rs

@@ -11,7 +11,7 @@ async fn main() {
         role: HostRole::Worker,
         number_desired_hosts: 3,
         discovery_strategy: HarmonyDiscoveryStrategy::SUBNET {
-            cidr: cidrv4!("192.168.0.1/25"),
+            cidr: cidrv4!("192.168.2.0/24"),
             port: 25000,
         },
     };
@@ -20,7 +20,7 @@ async fn main() {
         role: HostRole::ControlPlane,
         number_desired_hosts: 3,
         discovery_strategy: HarmonyDiscoveryStrategy::SUBNET {
-            cidr: cidrv4!("192.168.0.1/25"),
+            cidr: cidrv4!("192.168.2.0/24"),
             port: 25000,
         },
     };
@@ -28,7 +28,8 @@ async fn main() {
     harmony_cli::run(
         Inventory::autoload(),
         LocalhostTopology::new(),
-        vec![Box::new(discover_worker), Box::new(discover_control_plane)],
+        vec![Box::new(discover_worker)],
+        //vec![Box::new(discover_worker), Box::new(discover_control_plane)],
         None,
     )
     .await

harmony/src/modules/inventory/discovery.rs

@@ -45,7 +45,7 @@ impl<T: Topology> Interpret<T> for DiscoverHostForRoleInterpret {
         topology: &T,
     ) -> Result<Outcome, InterpretError> {
         info!(
-            "Launching discovery agent, make sure that your nodes are successfully PXE booted and running inventory agent. They should answer on `http://<node_ip>:8080/inventory`"
+            "Launching discovery agent, make sure that your nodes are successfully PXE booted and running inventory agent. They should answer on `http://<node_ip>:25000/inventory`"
         );
         LaunchDiscoverInventoryAgentScore {
             discovery_timeout: None,
@@ -58,6 +58,8 @@ impl<T: Topology> Interpret<T> for DiscoverHostForRoleInterpret {
         let host_repo = InventoryRepositoryFactory::build().await?;
 
         let mut assigned_hosts = 0;
+        // let hosts_for_role = host_repo.get_hosts_for_role(&self.score.role);
+
         loop {
             let all_hosts = host_repo.get_all_hosts().await?;