cyfs-lib 0.8.3

Rust cyfs-lib package
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

use super::request::*;
use crate::*;
use cyfs_base::BuckyResult;

use http_types::{Method, Request, Url};


pub struct SyncRequestor {
    requestor: HttpRequestorRef,
    service_url: Url,
}

impl SyncRequestor {
    pub fn new(requestor: HttpRequestorRef) -> Self {
        let addr = requestor.remote_addr();

        let url = format!("http://{}/sync/", addr);
        let url = Url::parse(&url).unwrap();

        Self {
            requestor,
            service_url: url,
        }
    }

    pub async fn sync_status(&self, flush: bool) -> BuckyResult<DeviceSyncStatus> {
        let url = self.service_url.join("status").unwrap();

        let http_req = match flush {
            true => Request::new(Method::Post, url),
            false => Request::new(Method::Get, url),
        };

        debug!("will get device sync status: flush={}", flush);

        let mut resp = self.requestor.request_timeout(http_req, std::time::Duration::from_secs(30)).await?;

        match resp.status() {
            code if code.is_success() => {
                let ret = RequestorHelper::decode_json_body(&mut resp).await?;

                info!(
                    "get device sync status success: flush={}, status={:?}",
                    flush, ret
                );
                Ok(ret)
            }
            code @ _ => {
                let e = RequestorHelper::error_from_resp(&mut resp).await;

                error!("get device sync status failed: code={}, err={}", code, e);
                Err(e)
            }
        }
    }
}