diff options
| author | David Lönnhager <david.l@mullvad.net> | 2021-11-02 10:39:54 +0100 |
|---|---|---|
| committer | David Lönnhager <david.l@mullvad.net> | 2022-03-14 12:08:40 +0100 |
| commit | 2a6b37574609850cc5f5271f4e85bba309372ce7 (patch) | |
| tree | ed30890f198fb61db3a8fe7a734d0c4e30a1ef23 /mullvad-daemon/src | |
| parent | 35e6fbe52cdb0cfeceb951ce35d51fe5994858aa (diff) | |
| download | mullvadvpn-2a6b37574609850cc5f5271f4e85bba309372ce7.tar.xz mullvadvpn-2a6b37574609850cc5f5271f4e85bba309372ce7.zip | |
Include token in device update event
Diffstat (limited to 'mullvad-daemon/src')
| -rw-r--r-- | mullvad-daemon/src/lib.rs | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/mullvad-daemon/src/lib.rs b/mullvad-daemon/src/lib.rs index a51c8bf2c6..181ff2f313 100644 --- a/mullvad-daemon/src/lib.rs +++ b/mullvad-daemon/src/lib.rs @@ -1383,7 +1383,7 @@ where self.schedule_reconnect(WG_RECONNECT_DELAY).await; } self.event_listener - .notify_device_event(DeviceEvent(Some(Device::from(event.0)))); + .notify_device_event(DeviceEvent::from(event.0)); } async fn handle_device_migration_event(&mut self, data: DeviceData) { @@ -1391,11 +1391,10 @@ where // Discard stale device return; } - let device = data.device.clone(); + let event = DeviceEvent::from(data.clone()); self.account_manager.set(data); self.reconnect_tunnel(); - self.event_listener - .notify_device_event(DeviceEvent(Some(device))); + self.event_listener.notify_device_event(event); } #[cfg(windows)] @@ -1658,7 +1657,7 @@ where .await .map_err(Error::LoginError)?; self.event_listener - .notify_device_event(DeviceEvent(Some(Device::from(device_data)))); + .notify_device_event(DeviceEvent::from(device_data)); } None => { self.account_manager.logout(); @@ -2302,9 +2301,8 @@ 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 = self.account_manager.get().map(Device::from); - self.event_listener - .notify_device_event(DeviceEvent(device.clone())); + let device = DeviceEvent::from(self.account_manager.get()); + self.event_listener.notify_device_event(device); } let _ = tx.send(result.map(|_| ()).map_err(Error::KeyRotationError)); } |
