orcs 0.0.8

Microservices monorepo orchestration tool
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

use crate::Error;
use crate::{get_store, Project, StageContext, Store};
use clap::ArgMatches;
use std::fs::File;
use std::io::Read;
use tracing::{info, instrument};

#[instrument(skip(subcommand))]
pub fn set(project_path: &str, subcommand: &ArgMatches) -> Result<(), Error> {
    info!("Set parameter value");
    // Load the project
    let project = Project::from_path(project_path)?;

    // Retrieve the param name
    let param_name = subcommand.value_of("name").unwrap();
    let param_value = subcommand.value_of("value").unwrap();

    // Fail if we are not in a stage context
    let context = match StageContext::from_env() {
        Some(context) => context,
        None => {
            return Err(Error::SetParameterError(
                "cannot run 'set' outside a stage context",
                param_name.to_string(),
            ))
        }
    };
    // Prefix the parameter with the service name
    let param_name = format!("{}:{}", context.service, &param_name);

    // Load the data store
    let mut store = get_store(project)?;

    // Store the value
    store.set(&param_name, param_value)?;

    Ok(())
}

#[instrument(skip(subcommand))]
pub fn set_file(project_path: &str, subcommand: &ArgMatches) -> Result<(), Error> {
    info!("Set parameter value file");
    // Load the project
    let project = Project::from_path(project_path)?;

    // Retrieve the param name
    let param_name = subcommand.value_of("name").unwrap();
    let filename = subcommand.value_of("filename").unwrap();

    // Fail if we are not in a stage context
    let context = match StageContext::from_env() {
        Some(context) => context,
        None => {
            return Err(Error::SetParameterError(
                "cannot run 'set' outside a stage context",
                param_name.to_string(),
            ))
        }
    };
    // Prefix the parameter with the service name
    let param_name = format!("{}:{}", context.service, &param_name);

    // Load the data store
    let mut store = get_store(project)?;

    // Read the file
    let mut file = File::open(filename)?;
    let mut data = Vec::new();
    file.read_to_end(&mut data)?;

    // Store the value
    store.set_bytes(&param_name, &data)?;

    Ok(())
}