quilt-rs 0.6.0

Rust library for accessing Quilt data packages.
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131

use std::path::PathBuf;

use crate::cli::model::Commands;
use crate::cli::output::Std;
use crate::cli::Error;

#[derive(Debug)]
pub struct Input {
    pub namespace: Option<String>,
    pub paths: Option<Vec<PathBuf>>,
    pub uri: String,
}

#[derive(Debug)]
pub struct Output {
    installed_package: quilt_rs::InstalledPackage,
    package_dir: std::path::PathBuf,
    paths: Option<Vec<std::path::PathBuf>>,
}

impl std::fmt::Display for Output {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let mut output = vec![format!(
            "Package {:?} installed to {:?}",
            self.installed_package, self.package_dir,
        )];
        match &self.paths {
            Some(paths) => {
                for path in paths {
                    output.push(format!("Path: {:?}", path));
                }
            }
            None => output.push("No paths installed".to_string()),
        }
        write!(f, "{}", output.join("\n"))
    }
}

pub async fn command(m: impl Commands, args: Input) -> Std {
    match m.install(args).await {
        Ok(output) => Std::Out(output.to_string()),
        Err(err) => Std::Err(err),
    }
}

async fn install_package(
    local_domain: &quilt_rs::LocalDomain,
    uri: &quilt_rs::S3PackageUri,
    namespace: Option<String>,
) -> Result<quilt_rs::InstalledPackage, Error> {
    let remote = quilt_rs::s3_utils::RemoteS3::new();
    let namespace = namespace.unwrap_or(uri.namespace.clone());
    let installed_package = local_domain.get_installed_package(&namespace).await?;
    if let Some(installed_package) = installed_package {
        // FIXME: check the actual remote_manifest
        return Ok(installed_package);
    }
    let remote_manifest = quilt_rs::RemoteManifest::resolve(&remote, uri).await?;
    Ok(local_domain.install_package(&remote_manifest).await?)
}

async fn install_paths(
    installed_package: &quilt_rs::InstalledPackage,
    paths: Vec<String>,
) -> Result<Vec<String>, Error> {
    installed_package.install_paths(&paths).await?;
    Ok(paths)
}

struct Entries {
    paths: Option<Vec<std::path::PathBuf>>,
    keys: Option<Vec<String>>,
}

fn get_entries(
    root: &std::path::Path,
    uri_path: Option<String>,
    arg_paths: Option<Vec<PathBuf>>,
) -> Entries {
    let mut keys = Vec::new();
    let mut paths = Vec::new();
    if uri_path.is_some() {
        let logical_key = uri_path.unwrap();
        paths.push(root.to_path_buf().join(&logical_key));
        keys.push(logical_key);
    }
    if arg_paths.is_some() {
        let logical_keys = arg_paths.unwrap();
        for logical_key in logical_keys {
            keys.push(logical_key.display().to_string());
            paths.push(root.to_path_buf().join(logical_key));
        }
    }
    Entries {
        paths: if paths.is_empty() { None } else { Some(paths) },
        keys: if keys.is_empty() { None } else { Some(keys) },
    }
}

pub async fn model(
    local_domain: &quilt_rs::LocalDomain,
    Input {
        namespace,
        paths,
        uri,
    }: Input,
) -> Result<Output, Error> {
    let uri: quilt_rs::S3PackageUri = uri.parse()?;
    let installed_package = install_package(local_domain, &uri, namespace).await?;
    let package_dir = installed_package.working_folder();
    let Entries { keys, paths } = get_entries(&package_dir, uri.path, paths);

    if let Some(keys) = keys {
        install_paths(&installed_package, keys).await?;
    }

    Ok(Output {
        installed_package,
        package_dir,
        paths,
    })
}

#[cfg(test)]
mod tests {
    #[tokio::test]
    #[ignore]
    async fn install() -> Result<(), String> {
        unreachable!()
    }
}