leyoda/cosmic-applets
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

cargo fmt

Browse source
This commit is contained in:
Vukašin Vojinović 2025-10-08 16:45:44 +02:00 • committed by Ashley Wulber
parent 8e57d5b165
commit 02fb6e145a
3 changed files with 69 additions and 30 deletions
Download patch file Download diff file Expand all files Collapse all files

5
cosmic-applet-network/src/network_manager/available_vpns.rs
View file

@ -29,7 +29,10 @@ pub async fn load_vpn_connections(conn: &Connection) -> anyhow::Result<Vec<VpnCo
if let Some(conn_type) = &connection_settings.type_ {
// VPN connections have type "vpn" or "wireguard"
if conn_type == "vpn" || conn_type == "wireguard" {
let name = connection_settings.id.clone().unwrap_or_else(|| "Unknown VPN".to_string());
let name = connection_settings
.id
.clone()
.unwrap_or_else(|| "Unknown VPN".to_string());
let uuid = connection_settings.uuid.clone().unwrap_or_default();
vpn_connections.push(VpnConnection { name, uuid });

59
cosmic-applet-network/src/network_manager/mod.rs
View file

@ -294,7 +294,9 @@ async fn start_listening(
.send(NetworkManagerEvent::RequestResponse {
req: NetworkManagerRequest::ActivateVpn(uuid),
success: false,
state: NetworkManagerState::new(&conn).await.unwrap_or_default(),
state: NetworkManagerState::new(&conn)
.await
.unwrap_or_default(),
})
.await;
return State::Waiting(conn, rx);
@ -316,16 +318,31 @@ async fn start_listening(
use zbus::zvariant::ObjectPath;
let empty_device = ObjectPath::try_from("/").unwrap();
match network_manager.inner()
.call_method("ActivateConnection", &(connection.inner().path(), empty_device.clone(), empty_device))
match network_manager
.inner()
.call_method(
"ActivateConnection",
&(
connection.inner().path(),
empty_device.clone(),
empty_device,
),
)
.await
{
Ok(_) => {
tracing::info!("Successfully activated VPN: {}", uuid);
tracing::info!(
"Successfully activated VPN: {}",
uuid
);
success = true;
}
Err(e) => {
tracing::error!("Failed to activate VPN {}: {:?}", uuid, e);
tracing::error!(
"Failed to activate VPN {}: {:?}",
uuid,
e
);
}
}
break;
@ -337,7 +354,10 @@ async fn start_listening(
}
if !success {
tracing::warn!("VPN connection with UUID {} not found or failed to activate", uuid);
tracing::warn!(
"VPN connection with UUID {} not found or failed to activate",
uuid
);
}
let state = NetworkManagerState::new(&conn).await.unwrap_or_default();
@ -359,7 +379,9 @@ async fn start_listening(
.send(NetworkManagerEvent::RequestResponse {
req: NetworkManagerRequest::DeactivateVpn(name),
success: false,
state: NetworkManagerState::new(&conn).await.unwrap_or_default(),
state: NetworkManagerState::new(&conn)
.await
.unwrap_or_default(),
})
.await;
return State::Waiting(conn, rx);
@ -373,14 +395,22 @@ async fn start_listening(
for active_conn in active_connections {
if let Ok(conn_id) = active_conn.id().await {
if conn_id == name && active_conn.vpn().await.unwrap_or(false) {
match network_manager.deactivate_connection(&active_conn).await {
match network_manager.deactivate_connection(&active_conn).await
{
Ok(_) => {
tracing::info!("Successfully deactivated VPN: {}", name);
tracing::info!(
"Successfully deactivated VPN: {}",
name
);
success = true;
break;
}
Err(e) => {
tracing::error!("Failed to deactivate VPN {}: {:?}", name, e);
tracing::error!(
"Failed to deactivate VPN {}: {:?}",
name,
e
);
}
}
}
@ -389,7 +419,10 @@ async fn start_listening(
}
if !success {
tracing::warn!("Active VPN connection '{}' not found or failed to deactivate", name);
tracing::warn!(
"Active VPN connection '{}' not found or failed to deactivate",
name
);
}
let state = NetworkManagerState::new(&conn).await.unwrap_or_default();
@ -479,8 +512,8 @@ pub enum NetworkManagerRequest {
},
Forget(String, HwAddress),
Reload,
ActivateVpn(String), // UUID of VPN connection to activate
DeactivateVpn(String), // Name of active VPN connection to deactivate
ActivateVpn(String), // UUID of VPN connection to activate
DeactivateVpn(String), // Name of active VPN connection to deactivate
}
#[derive(Debug, Clone)]