ax 2.18.2

ax distributed event databank and command line tool
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

mod get;
mod init;
mod set;
mod unset;

use ax_core::{
    node::{self, lock_working_dir},
    settings::Repository,
    util::formats::{ActyxOSCode, ActyxOSError, ActyxOSResult},
};

use self::{
    get::{SettingsLocalGet, SettingsLocalGetOpts},
    init::{SettingsLocalInit, SettingsLocalInitOpts},
    set::{SettingsLocalSet, SettingsLocalSetOpts},
    unset::{SettingsLocalUnset, SettingsLocalUnsetOpts},
};
use crate::cmd::AxCliCommand;
use core::future::Future;
use std::path::Path;

#[derive(clap::Subcommand, Debug, Clone)]
pub enum SettingsLocalOpts {
    Get(SettingsLocalGetOpts),
    Init(SettingsLocalInitOpts),
    Set(SettingsLocalSetOpts),
    Unset(SettingsLocalUnsetOpts),
}

pub fn run(arg: SettingsLocalOpts, json: bool) -> Box<dyn Future<Output = ()> + Unpin> {
    match arg {
        SettingsLocalOpts::Get(x) => SettingsLocalGet::output(x, json),
        SettingsLocalOpts::Init(x) => SettingsLocalInit::output(x, json),
        SettingsLocalOpts::Set(x) => SettingsLocalSet::output(x, json),
        SettingsLocalOpts::Unset(x) => SettingsLocalUnset::output(x, json),
    }
}

pub(crate) fn lock_and_load_repo(working_dir: &Path) -> ActyxOSResult<(fslock::LockFile, Repository)> {
    if !working_dir.exists() {
        return Err(ActyxOSError::new(
            ActyxOSCode::ERR_INVALID_INPUT,
            format!("{} does not exist", &working_dir.display()),
        ));
    };

    let lock = lock_working_dir(working_dir).map_err(|e| ActyxOSError::new(ActyxOSCode::ERR_IO, format!("{}", e)))?;

    let repository = node::initialize_repository(working_dir).map_err(|e| ActyxOSError::internal(format!("{}", e)))?;

    Ok((lock, repository))
}