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

use crate::http::{base_headers, get_http_client};
use crate::media_container::ServerMediaContainer;
use crate::server::Server;
use crate::PlexApiError;

impl Server {
    /// Establish a connection with the server server by provided url.
    ///
    /// This call will fail if anonymous access is denied.
    pub async fn connect<U: reqwest::IntoUrl + crate::AsStr + Send>(url: U) -> crate::Result<Self> {
        let response = get_http_client()?
            .get(url.as_str())
            .headers(base_headers())
            .send()
            .await?;
        if response.status() == reqwest::StatusCode::OK {
            let mc: ServerMediaContainer =
                quick_xml::de::from_str(response.text().await?.as_str())?;
            Ok(Server {
                info: mc,
                url: url.into_url()?,
                auth_token: String::from(""),
            })
        } else {
            Err(PlexApiError::UnexpectedApiResponse(response.text().await?))
        }
    }

    /// Establish a connection with the server server by provided url and [`authentication token`].
    ///
    /// [`authentication token`]: struct.MyPlexAccount.html#method.get_auth_token
    pub async fn connect_auth<U: reqwest::IntoUrl + crate::AsStr + Send>(
        url: U,
        auth_token: &str,
    ) -> crate::Result<Self> {
        let response = get_http_client()?
            .get(url.as_str())
            .headers(base_headers())
            .header("X-Plex-Token", auth_token)
            .send()
            .await?;
        if response.status() == reqwest::StatusCode::OK {
            let mc: ServerMediaContainer =
                quick_xml::de::from_str(response.text().await?.as_str())?;
            Ok(Server {
                info: mc,
                url: url.into_url()?,
                auth_token: String::from(auth_token),
            })
        } else {
            Err(PlexApiError::UnexpectedApiResponse(response.text().await?))
        }
    }
}