geph4-client 4.4.20

Geph client
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

use std::collections::HashMap;

use crate::cache::ClientCache;
use crate::{AuthOpt, CommonOpt};
use structopt::StructOpt;

#[derive(Debug, StructOpt)]
pub struct SyncOpt {
    #[structopt(flatten)]
    common: CommonOpt,

    #[structopt(flatten)]
    auth: AuthOpt,

    /// Forces synchronization of fresh data.
    #[structopt(long)]
    force: bool,
}

pub async fn main_sync(opt: SyncOpt) -> anyhow::Result<()> {
    let client_cache = ClientCache::from_opts(&opt.common, &opt.auth).await?;
    if opt.force {
        client_cache.purge_all()?;
    }
    log::info!("sync mode started (force = {})", opt.force);
    if let Err(err) = attempt(&client_cache).await {
        let mut haha = HashMap::new();
        haha.insert("error".to_string(), err.to_string());
        let json = serde_json::to_string(&haha)?;
        println!("{}", json);
    }
    Ok(())
}

#[allow(clippy::eval_order_dependence)]
async fn attempt(ccache: &ClientCache) -> anyhow::Result<()> {
    let exec = smol::Executor::new();
    let atok = ccache.get_auth_token().await?;
    let exits = exec.spawn(ccache.get_exits());
    let exits_free = exec.spawn(ccache.get_free_exits());
    exec.run(async move {
        let json = serde_json::to_string(&(atok.user_info, exits.await?, exits_free.await?))?;
        println!("{}", json);
        Ok(())
    })
    .await
}