cargo-pipe 0.1.11

A command-line tool to generate and build data integration app using pipebase framework
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

use crate::ops::do_cargo::{
    CARGO_APP_MAIN, CARGO_DEBUG_DIRECTORY, CARGO_MANIFEST_FILE, CARGO_RELEASE_DIRECTORY,
    CARGO_SRC_DIRECTORY, CARGO_TARGET_DIRECTORY,
};
use std::{env::current_dir, path::PathBuf};

const DEFAULT_PIPE_MANIFEST: &str = "pipe.yml";
const DEFAULT_APP_DIRECTORY: &str = "app";

pub struct Config {
    working_drectory: PathBuf,
    manifest: String,
}

impl Config {
    pub fn new(directory: Option<&str>, manifest: Option<&str>) -> anyhow::Result<Self> {
        let working_drectory = match directory {
            Some(directory) => PathBuf::from(directory),
            None => current_dir()?,
        };
        let manifest = String::from(manifest.unwrap_or(DEFAULT_PIPE_MANIFEST));
        Ok(Config {
            working_drectory,
            manifest,
        })
    }

    pub fn get_pipe_manifest_path(&self) -> PathBuf {
        let mut manifest_path = self.working_drectory.to_owned();
        manifest_path.push(&self.manifest);
        manifest_path
    }

    pub fn get_app_directory(&self, app_name: Option<&String>) -> PathBuf {
        let mut app_directory = self.working_drectory.to_owned();
        let app_name = &Self::get_app_name_or_default(app_name);
        app_directory.push(app_name);
        app_directory
    }

    pub fn get_app_manifest(&self, app_name: Option<&String>) -> PathBuf {
        let mut manifest = self.working_drectory.to_owned();
        let app_name = &Self::get_app_name_or_default(app_name);
        manifest.push(app_name);
        manifest.push(CARGO_MANIFEST_FILE);
        manifest
    }

    pub fn get_app_main_path(&self, app_name: Option<&String>) -> PathBuf {
        let mut main_path = self.working_drectory.to_owned();
        let app_name = &Self::get_app_name_or_default(app_name);
        main_path.push(app_name);
        main_path.push(CARGO_SRC_DIRECTORY);
        main_path.push(CARGO_APP_MAIN);
        main_path
    }

    pub fn get_target_release_app_binary(&self, app_name: Option<&String>) -> PathBuf {
        let mut app_binary = self.working_drectory.to_owned();
        let app_name = &Self::get_app_name_or_default(app_name);
        app_binary.push(app_name);
        app_binary.push(CARGO_TARGET_DIRECTORY);
        app_binary.push(CARGO_RELEASE_DIRECTORY);
        app_binary.push(app_name);
        app_binary
    }

    pub fn get_target_debug_app_binary(&self, app_name: Option<&String>) -> PathBuf {
        let mut app_binary = self.working_drectory.to_owned();
        let app_name = &Self::get_app_name_or_default(app_name);
        app_binary.push(app_name);
        app_binary.push(CARGO_TARGET_DIRECTORY);
        app_binary.push(CARGO_DEBUG_DIRECTORY);
        app_binary.push(app_name);
        app_binary
    }

    pub fn get_app_name_or_default(app_name: Option<&String>) -> String {
        match app_name {
            Some(app_name) => app_name.to_owned(),
            None => DEFAULT_APP_DIRECTORY.to_owned(),
        }
    }

    pub fn get_run_app_binary(&self, app_name: Option<&String>) -> PathBuf {
        let mut app_binary = self.working_drectory.to_owned();
        let app_name = &Self::get_app_name_or_default(app_name);
        app_binary.push(format!("run_{}", app_name));
        app_binary
    }
}