Fix synchronization issues and bump 0.16.1

Author: astonbitecode

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rust_keylock"
-version = "0.16.0"
+version = "0.16.1"
 authors = ["aston <astonbitecode@gmail.com>"]
 description = "A password manager with goals to be Secure, Simple to use, Portable and Extensible"
 keywords = ["password", "manager", "safe", "encryption", "key"]

src/lib.rs

@@ -325,6 +325,23 @@ impl CoreLogicHandler {
                         .map_err(|error| error!("Cannot update system for save: {:?}", error));
                     // Reset the filter
                     s.safe.set_filter("".to_string());
+                    // Initialize the synchronizers
+                    let mut nc_synchronizer = nextcloud::Synchronizer::new(
+                       &s.configuration.nextcloud, 
+                       &s.configuration.system,
+                           FILENAME
+                       ).unwrap();
+                    nc_synchronizer.init().await;
+                    s.nc_synchronizer = nc_synchronizer;
+
+                    let mut dbx_synchronizer = dropbox::Synchronizer::new(
+                        &s.configuration.dropbox, 
+                        &s.configuration.system,
+                            FILENAME
+                        ).unwrap();
+                    dbx_synchronizer.init().await;
+                    s.dbx_synchronizer = dbx_synchronizer;
+
                     let rkl_content = RklContent::from((
                         &s.safe,
                         &s.configuration.nextcloud,
@@ -686,11 +703,26 @@ Warning: Saving will discard all the entries that could not be recovered.
                         debug!("A valid configuration for Nextcloud synchronization was found after being updated by the User. Spawning \
                             nextcloud sync task");
                         s.contents_changed = true;
+                        // Initialize the synchronizer
+                        let mut nc_synchronizer = nextcloud::Synchronizer::new(
+                            &s.configuration.nextcloud, 
+                            &s.configuration.system,
+                                FILENAME
+                            ).unwrap();
+                        nc_synchronizer.init().await;
+                        s.nc_synchronizer = nc_synchronizer;
                     }
                     if s.configuration.dropbox.is_filled() {
                         debug!("A valid configuration for dropbox synchronization was found after being updated by the User. Spawning \
                             dropbox sync task");
                         s.contents_changed = true;
+                        let mut dbx_synchronizer = dropbox::Synchronizer::new(
+                            &s.configuration.dropbox, 
+                            &s.configuration.system,
+                                FILENAME
+                            ).unwrap();
+                        dbx_synchronizer.init().await;
+                        s.dbx_synchronizer = dbx_synchronizer;
                     }
                     Box::pin(future::ready(UserSelection::GoTo(Menu::Main)))
                 }

tests/execution_cases.rs

@@ -524,58 +524,58 @@ impl TestEditor {
 #[async_trait]
 impl AsyncEditor for TestEditor {
     async fn show_password_enter(&self) -> UserSelection {
-        println!("TestEditor::show_password_enter");
+        println!("====== TestEditor::show_password_enter");
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn show_change_password(&self) -> UserSelection {
-        println!("TestEditor::show_change_password");
+        println!("====== TestEditor::show_change_password");
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn show_menu(&self, m: Menu) -> UserSelection {
-        println!("TestEditor::show_menu {:?}", m);
+        println!("====== TestEditor::show_menu {:?}", m);
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn show_entries(&self, entries: Vec<Entry>, filter: String) -> UserSelection {
-        println!("TestEditor::show_entries {:?} with filter {}", entries, filter);
+        println!("====== TestEditor::show_entries {:?} with filter {}", entries, filter);
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn show_entry(&self, entry: Entry, index: usize, presentation_type: EntryPresentationType) -> UserSelection {
-        println!("TestEditor::show_entry {:?} with index {} and presentation_type {:?}", entry, index, presentation_type);
+        println!("====== TestEditor::show_entry {:?} with index {} and presentation_type {:?}", entry, index, presentation_type);
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn exit(&self, force: bool) -> UserSelection {
-        println!("TestEditor::exit {}", force);
+        println!("====== TestEditor::exit {}", force);
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn show_configuration(&self, nextcloud: NextcloudConfiguration, dropbox: DropboxConfiguration, gen: GeneralConfiguration) -> UserSelection {
-        println!("TestEditor::show_configuration with {:?}, {:?} and {:?}", nextcloud, dropbox, gen);
+        println!("====== TestEditor::show_configuration with {:?}, {:?} and {:?}", nextcloud, dropbox, gen);
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }
 
     async fn show_message(&self, m: &str, _: Vec<UserOption>, _: MessageSeverity) -> UserSelection {
-        println!("TestEditor::show_message {}", m);
+        println!("====== TestEditor::show_message {}", m);
         let to_ret = self.return_first_selection();
-        println!("Returning {:?}", to_ret);
+        println!("====== Returning {:?}", to_ret);
         to_ret
     }