krankerl 0.8.0

A CLI helper to manage Nextcloud apps
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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

use std::fs::File;
use std::path::{Path, PathBuf};
use std::thread;

use failure::Error;
use flate2::Compression;
use flate2::write::GzEncoder;
use indicatif::{MultiProgress, ProgressBar};
use nextcloud_appinfo::get_appinfo;
use walkdir::{DirEntry, WalkDir};

mod archive;
mod artifacts;
mod commands;
mod exclude;

use config;
use console::default_spinner;
use self::commands::PackageCommands;
use config::app::AppConfig;

fn build_file_list(build_path: &Path, excludes: &exclude::ExcludedFiles) -> Vec<DirEntry> {
    WalkDir::new(build_path)
        .into_iter()
        .filter_entry(|e| !excludes.is_excluded(e.path(), build_path))
        .map(|e| e.unwrap())
        .collect()
}

fn package(
    artifacts_path: &Path,
    app_id: &String,
    app_config: &AppConfig,
    progress: ProgressBar,
) -> Result<(), Error> {
    progress.set_message("Packaging app files into an archive...");
    let excludes = exclude::ExcludedFiles::new(app_config.package().exclude())?;

    let mut compressed_archive_path = PathBuf::from(artifacts_path);
    let mut compressed_archive_filename = app_id.clone();
    compressed_archive_filename.push_str(".tar.gz");
    compressed_archive_path.push(compressed_archive_filename);
    progress.set_message(&format!(
        "Writing compressed app archive to {:?}...",
        compressed_archive_path
    ));

    let gz_archive_file = File::create(&compressed_archive_path)?;
    let encoder = GzEncoder::new(gz_archive_file, Compression::default());

    let mut app_path = PathBuf::from(artifacts_path);
    app_path.push(&app_id);
    let base = Path::new(app_id);

    let file_list = build_file_list(&app_path, &excludes);
    let encoder = archive::build_app_archive(&base, &app_path, file_list, encoder)?;
    encoder.finish()?;

    progress.finish_with_message(&format!(
        "Packaged app as {:?}",
        compressed_archive_path
    ));
    Ok(())
}

fn ensure_config_exists(app_path: &Path) -> Result<(), Error> {
    match config::app::get_config(app_path) {
        Ok(_) => Ok(()),
        Err(e) => Err(format_err!("could not load krankerl.toml: {}", e)),
    }
}

fn run_package_commands(
    app_path: &Path,
    cmds: commands::CommandList,
    prog: ProgressBar,
) -> Result<(), Error> {
    cmds.execute(app_path, prog)
}

fn package_app_thread(
    prog_clone: ProgressBar,
    prog_config: ProgressBar,
    prog_package_cmds: ProgressBar,
    prog_package: ProgressBar,
) -> Result<(), Error> {
    let cwd = Path::new(".");
    let mut artifacts_path = PathBuf::from(cwd);
    artifacts_path.push("build");
    artifacts_path.push("artifacts");

    ensure_config_exists(&cwd)?;

    let app_info = get_appinfo(&cwd)?;
    let app_id = app_info.id();

    let package_path = artifacts_path.clone();
    artifacts::clear(&artifacts_path)?;
    artifacts_path.push(&app_id);
    prog_clone.set_message("Cloning app to build directory...");
    artifacts::clone_app(&cwd, &artifacts_path)?;
    prog_clone.finish_with_message("App cloned to build directory.");

    prog_config.set_message("Reading config...");
    let app_config = config::app::get_config(&artifacts_path).map(|config| match config {
        Some(cfg) => {
            prog_config.finish_with_message("Found krankerl.toml config file.");
            cfg
        }
        None => {
            prog_config.finish_with_message(
                "Warning: No krankerl.toml found. A default configuration is used.",
            );
            AppConfig::default()
        }
    })?;

    run_package_commands(
        &artifacts_path,
        app_config.package().into(),
        prog_package_cmds,
    )?;

    package(package_path.as_path(), &app_id, &app_config, prog_package)?;
    Ok(())
}

pub fn package_app() -> Result<(), Error> {
    let mp = MultiProgress::new();
    let prog_clone = mp.add(default_spinner());
    prog_clone.enable_steady_tick(200);
    prog_clone.set_message("waiting...");
    let prog_config = mp.add(default_spinner());
    prog_config.enable_steady_tick(200);
    prog_config.set_message("waiting...");
    let prog_package_cmds = mp.add(default_spinner());
    prog_package_cmds.enable_steady_tick(200);
    prog_package_cmds.set_message("waiting...");
    let prog_package = mp.add(default_spinner());
    prog_package.enable_steady_tick(200);
    prog_package.set_message("waiting...");

    let worker = thread::spawn(move || {
        package_app_thread(prog_clone, prog_config, prog_package_cmds, prog_package)
    });

    mp.join()?;
    worker.join().unwrap()?;
    Ok(())
}