oma-refresh 0.53.0

APT repository refresh handler library
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

use std::{path::Path, result::Result};

use apt_auth_config::AuthConfig;
use oma_apt::config::Config;
use oma_fetch::reqwest::ClientBuilder;
use oma_refresh::db::{Event, OmaRefresh, RefreshError};
use oma_utils::dpkg::dpkg_arch;

#[tokio::main]
async fn main() -> Result<(), RefreshError> {
    let p = Path::new("./oma-fetcher-test");
    tokio::fs::create_dir_all(p).await.unwrap();
    let client = ClientBuilder::new().user_agent("oma").build().unwrap();

    let apt_config = Config::new();

    let auth = AuthConfig::system("/").unwrap();

    let (tx, rx) = flume::unbounded();

    let refresh = OmaRefresh::builder()
        .client(&client)
        .apt_config(&apt_config)
        .arch(dpkg_arch("/").unwrap())
        .download_dir(p.to_path_buf())
        .source("/".into())
        .topic_msg("test")
        .refresh_topics(false)
        .auth_config(&auth)
        .another_apt_options(vec![])
        .build();

    tokio::spawn(async move {
        while let Ok(event) = rx.recv_async().await {
            println!("{:#?}", event);
            if let Event::Done = event {
                break;
            }
        }
    });

    refresh
        .start(|event| async {
            if let Err(e) = tx.send_async(event).await {
                eprintln!("{:#?}", e);
            }
        })
        .await?;

    Ok(())
}