refactor: renamed wait_for_server to wait_for_start (same as in aw-cl…

…ient-python)

aw-client-rust/src/blocking.rs

@@ -80,7 +80,7 @@ impl AwClient {
     proxy_method!(get_event_count, i64, bucketname: &str);
     proxy_method!(get_info, aw_models::Info,);
 
-    pub fn wait_for_server(&self) -> Result<(), Box<dyn Error>> {
-        self.client.wait_for_server()
+    pub fn wait_for_start(&self) -> Result<(), Box<dyn Error>> {
+        self.client.wait_for_start()
     }
 }

aw-client-rust/src/lib.rs

@@ -225,9 +225,10 @@ impl AwClient {
     }
 
     // TODO: make async
-    pub fn wait_for_server(&self) -> Result<(), Box<dyn Error>> {
+    pub fn wait_for_start(&self) -> Result<(), Box<dyn Error>> {
         let socket_addrs = self.baseurl.socket_addrs(|| None)?;
-        let socket_addr = socket_addrs.first()
+        let socket_addr = socket_addrs
+            .first()
             .ok_or("Unable to resolve baseurl into socket address")?;
 
         // Check if server is running with exponential backoff

aw-sync/src/sync_wrapper.rs

@@ -1,7 +1,5 @@
 use std::error::Error;
 use std::fs;
-use std::net::TcpStream;
-use std::time::Duration;
 
 use crate::sync::{sync_run, SyncMode, SyncSpec};
 use aw_client_rust::blocking::AwClient;
@@ -15,7 +13,7 @@ pub fn pull_all(client: &AwClient) -> Result<(), Box<dyn Error>> {
 }
 
 pub fn pull(host: &str, client: &AwClient) -> Result<(), Box<dyn Error>> {
-    client.wait_for_server()?;
+    client.wait_for_start()?;
 
     // Path to the sync folder
     // Sync folder is structured ./{hostname}/{device_id}/test.db