diff options
| author | David Lönnhager <david.l@mullvad.net> | 2022-02-22 16:01:01 +0100 |
|---|---|---|
| committer | David Lönnhager <david.l@mullvad.net> | 2022-03-14 12:08:51 +0100 |
| commit | 1bbcbb0be1cfe655578d9db7a03b71967d030121 (patch) | |
| tree | 56e3d38365043b9def6314b4fd7769ac186f2de8 | |
| parent | 58978f97a509e750139c0f06a7378006cea92b3a (diff) | |
| download | mullvadvpn-1bbcbb0be1cfe655578d9db7a03b71967d030121.tar.xz mullvadvpn-1bbcbb0be1cfe655578d9db7a03b71967d030121.zip | |
Rename account manager get() to data()
| -rw-r--r-- | mullvad-daemon/src/device.rs | 4 | ||||
| -rw-r--r-- | mullvad-daemon/src/lib.rs | 28 |
2 files changed, 16 insertions, 16 deletions
diff --git a/mullvad-daemon/src/device.rs b/mullvad-daemon/src/device.rs index de7bfd9a7f..89cbc04ac7 100644 --- a/mullvad-daemon/src/device.rs +++ b/mullvad-daemon/src/device.rs @@ -296,11 +296,11 @@ impl AccountManager { result } - pub fn get(&self) -> Option<DeviceData> { + pub fn data(&self) -> Option<DeviceData> { self.inner.lock().unwrap().data.clone() } - pub fn is_some(&self) -> bool { + pub fn has_data(&self) -> bool { self.inner.lock().unwrap().data.is_some() } diff --git a/mullvad-daemon/src/lib.rs b/mullvad-daemon/src/lib.rs index ab1db73830..19da406c2d 100644 --- a/mullvad-daemon/src/lib.rs +++ b/mullvad-daemon/src/lib.rs @@ -674,12 +674,12 @@ where let account_history = account_history::AccountHistory::new( &settings_dir, - account_manager.get().map(|device| device.token), + account_manager.data().map(|device| device.token), ) .await .map_err(Error::LoadAccountHistory)?; - let target_state = if !account_manager.is_some() { + let target_state = if !account_manager.has_data() { PersistentTargetState::force(&cache_dir, TargetState::Unsecured).await } else if settings.auto_connect { log::info!("Automatically connecting since auto-connect is turned on"); @@ -1010,7 +1010,7 @@ where >, retry_attempt: u32, ) { - if let Some(device) = self.account_manager.get() { + if let Some(device) = self.account_manager.data() { let result = match self.settings.get_relay_settings() { RelaySettings::CustomTunnelEndpoint(custom_relay) => { self.last_generated_relay = None; @@ -1179,7 +1179,7 @@ where let wg_data = self .account_manager - .get() + .data() .map(|device| device.wg_data) .ok_or(Error::NoKeyAvailable)?; let tunnel = wireguard::TunnelConfig { @@ -1215,7 +1215,7 @@ where } device::ValidationResult::Updated => { self.event_listener - .notify_device_event(DeviceEvent::new(self.account_manager.get(), true)); + .notify_device_event(DeviceEvent::new(self.account_manager.data(), true)); } } } @@ -1424,7 +1424,7 @@ where if Some(device_id) != self .account_manager - .get() + .data() .map(|device| device.device.id) .as_ref() { @@ -1439,7 +1439,7 @@ where } async fn handle_device_migration_event(&mut self, data: DeviceData) { - if self.account_manager.get().is_some() { + if self.account_manager.has_data() { // Discard stale device return; } @@ -1585,7 +1585,7 @@ where } async fn on_create_new_account(&mut self, tx: ResponseTx<String, Error>) { - if self.account_manager.is_some() { + if self.account_manager.has_data() { let _ = tx.send(Err(Error::AlreadyLoggedIn)); return; } @@ -1620,7 +1620,7 @@ where } async fn on_get_www_auth_token(&mut self, tx: ResponseTx<String, Error>) { - if let Some(device) = self.account_manager.get() { + if let Some(device) = self.account_manager.data() { let future = self .account_manager .account_service() @@ -1647,7 +1647,7 @@ where tx: ResponseTx<VoucherSubmission, Error>, voucher: String, ) { - if let Some(device) = self.account_manager.get() { + if let Some(device) = self.account_manager.data() { let mut account = self.account_manager.account_service(); tokio::spawn(async move { Self::oneshot_send( @@ -1705,7 +1705,7 @@ where } async fn set_account(&mut self, account_token: Option<String>) -> Result<bool, Error> { - let previous_token = self.account_manager.get().map(|device| device.token); + let previous_token = self.account_manager.data().map(|device| device.token); if previous_token == account_token { return Ok(false); } @@ -1754,7 +1754,7 @@ where Self::oneshot_send( tx, - Ok(self.account_manager.get().map(DeviceConfig::from)), + Ok(self.account_manager.data().map(DeviceConfig::from)), "get_device response", ); } @@ -2412,14 +2412,14 @@ where async fn on_rotate_wireguard_key(&mut self, tx: ResponseTx<(), Error>) { let result = self.account_manager.rotate_key().await; if let Ok(ref _wg_data) = result { - let device = DeviceEvent::new(self.account_manager.get(), false); + let device = DeviceEvent::new(self.account_manager.data(), false); self.event_listener.notify_device_event(device); } let _ = tx.send(result.map(|_| ()).map_err(Error::KeyRotationError)); } async fn on_get_wireguard_key(&mut self, tx: ResponseTx<Option<PublicKey>, Error>) { - let result = if let Some(device) = self.account_manager.get() { + let result = if let Some(device) = self.account_manager.data() { Ok(Some(device.wg_data.get_public_key())) } else { Err(Error::NoAccountToken) |
