qbit-rs 0.6.0

A Rust library for interacting with qBittorrent's Web API
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

use tap::Pipe;
use tracing::{debug, trace};

use crate::{
    ApiError, Error, Qbit, Result,
    client::{CheckError, Method, StatusCode},
    ext::*,
};

impl Qbit {
    /// Return the authentication cookie currently used by this client.
    pub async fn get_cookie(&self) -> Option<String> {
        self.state
            .lock()
            .unwrap()
            .as_header()
            .1
            .map(ToOwned::to_owned)
    }

    /// Log out of the qBittorrent WebUI session.
    pub async fn logout(&self) -> Result<()> {
        self.get("auth/logout").await?.end()
    }

    /// Log in to qBittorrent.
    ///
    /// Set force to `true` to force re-login regardless if cookie is already
    /// set.
    pub async fn login(&self, force: bool) -> Result<()> {
        let re_login = force || { self.state().as_header().1.is_none() };
        if re_login {
            let credential = match self.state().as_credential() {
                Some(credential) => credential.clone(),
                None => {
                    trace!("API key or cookie auth in use, skipping login");
                    return Ok(());
                }
            };
            debug!("Cookie not found, logging in");
            self.client
                .request(Method::POST, self.url("auth/login"))
                .check()?
                .pipe(|req| req.form(&credential))
                .check()?
                .send()
                .await?
                .map_status(|code| match code as _ {
                    StatusCode::FORBIDDEN => Some(Error::ApiError(ApiError::IpBanned)),
                    StatusCode::UNAUTHORIZED => Some(Error::ApiError(ApiError::BadCredentials)),
                    _ => None,
                })?
                .extract::<Cookie>()?
                .pipe(|Cookie(cookie)| self.state.lock().unwrap().add_cookie(cookie));

            debug!("Log in success");
        } else {
            trace!("Already logged in, skipping");
        }

        Ok(())
    }
}