summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorDavid Lönnhager <david.l@mullvad.net>2022-02-22 16:01:01 +0100
committerDavid Lönnhager <david.l@mullvad.net>2022-03-14 12:08:51 +0100
commit1bbcbb0be1cfe655578d9db7a03b71967d030121 (patch)
tree56e3d38365043b9def6314b4fd7769ac186f2de8
parent58978f97a509e750139c0f06a7378006cea92b3a (diff)
downloadmullvadvpn-1bbcbb0be1cfe655578d9db7a03b71967d030121.tar.xz
mullvadvpn-1bbcbb0be1cfe655578d9db7a03b71967d030121.zip
Rename account manager get() to data()
-rw-r--r--mullvad-daemon/src/device.rs4
-rw-r--r--mullvad-daemon/src/lib.rs28
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)