1 files changed, 23 insertions, 8 deletions
diff --git a/src/main.rs b/src/main.rs
index 3a8bcb0..97e28b5 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,6 +1,6 @@
-use std::sync::{Mutex, Arc};
+use std::sync::{Arc, Mutex};
 use std::{thread::sleep, time::Duration};
-use zbus::{ConnectionBuilder, Result};
+use zbus::{connection::Builder, Result};
 
 use crate::config::PomdConfig;
 use crate::interface::PomdInterface;
@@ -14,12 +14,27 @@ mod pomd;
 async fn main() -> Result<()> {
     let config: PomdConfig = confy::load("pomd", "config").expect("Failed to load config!");
     let pomd = Arc::new(Mutex::new(Pomd::new(config)));
-    let pomd_interface = PomdInterface::new(pomd.clone());
-    let _connection = ConnectionBuilder::session()?
-        .name("dev.exvacuum.pomd")?
-        .serve_at("/dev/exvacuum/pomd", pomd_interface)?
-        .build()
-        .await?;
+    let mut _connection;
+    loop {
+        let pomd_interface = PomdInterface::new(pomd.clone());
+        match Builder::session()?
+            .name("dev.exvacuum.pomd")?
+            .serve_at("/dev/exvacuum/pomd", pomd_interface)?
+            .build()
+            .await
+        {
+            Ok(connection) => {
+                _connection = connection;
+                break;
+            }
+            Err(e) => {
+                eprintln!("Failed to start D-Bus session: {e:?}");
+                eprintln!("Trying again in 10 seconds...");
+                sleep(Duration::from_secs(10));
+                continue;
+            }
+        }
+    }
     loop {
         pomd.lock().unwrap().update();
         sleep(Duration::from_millis(100));