iwdrs 0.2.7

Rust crate for iwd
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use std::str::FromStr;

use futures_lite::Stream;
use strum::EnumString;
use zbus::{Connection, Proxy, Result as ZbusResult};
use zvariant::{OwnedObjectPath, OwnedValue};

use crate::{
    device::Device,
    error::{IWDError, network::ConnectError},
    iwd_interface::{IwdInterface, iwd_interface_impl},
    known_network::KnownNetwork,
};

iwd_interface_impl!(Network, "net.connman.iwd.Network");

impl Network {
    // Methods
    pub async fn connect(&self) -> Result<(), IWDError<ConnectError>> {
        self.proxy.call_method("Connect", &()).await?;
        Ok(())
    }

    // Properties

    pub async fn name(&self) -> ZbusResult<String> {
        let name: String = self.proxy.get_property("Name").await?;
        Ok(name)
    }

    pub async fn connected(&self) -> ZbusResult<bool> {
        self.proxy.get_property("Connected").await
    }

    pub async fn connected_stream(
        &self,
    ) -> zbus::Result<impl Stream<Item = zbus::Result<bool>> + Unpin + 'static> {
        crate::property_stream(self.proxy.clone(), self.connected().await, "Connected").await
    }

    pub async fn device(&self) -> ZbusResult<Device> {
        let device_path: OwnedObjectPath = self.proxy.get_property("Device").await?;

        Device::new(self.proxy.connection().clone(), device_path).await
    }

    pub async fn network_type(&self) -> ZbusResult<NetworkType> {
        self.proxy.get_property("Type").await
    }

    pub async fn known_network(&self) -> ZbusResult<Option<KnownNetwork>> {
        if let Ok(known_network_path) = self
            .proxy
            .get_property::<OwnedObjectPath>("KnownNetwork")
            .await
        {
            let network =
                KnownNetwork::new(self.proxy.connection().clone(), known_network_path).await?;
            return Ok(Some(network));
        }
        Ok(None)
    }
}

#[derive(Debug, Clone, Copy, PartialEq, EnumString, strum::Display)]
#[strum(ascii_case_insensitive)]
pub enum NetworkType {
    Open,
    Wep,
    Psk,
    #[strum(serialize = "8021x")]
    Eap,
}

impl TryFrom<OwnedValue> for NetworkType {
    type Error = zvariant::Error;

    fn try_from(value: OwnedValue) -> Result<Self, Self::Error> {
        let state_string: String = value.try_into()?;
        Self::from_str(&state_string).map_err(|_| zvariant::Error::IncorrectType)
    }
}