loonfs-cli 0.2.0

The LoonFS command-line interface.
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

//! Command implementations, one submodule per command group.

mod admin;
mod config;
mod context;
mod fs;
mod namespace;
mod output;
mod partial;
mod profile;
mod profile_config;
mod recursive;

pub(crate) use self::output::{CommandData, CommandFailure, CommandOutput, MaintenanceKeyReport};

use crate::args::{Cli, Command, RuntimeBehavior};
use crate::config::resolve_config_location;

pub(crate) async fn run(
    cli: Cli,
    runtime: RuntimeBehavior,
) -> Result<CommandOutput, CommandFailure> {
    let kind = cli.kind();
    if runtime.json && !kind.supports_json() {
        return Err(CommandFailure {
            kind,
            profile: None,
            mode: None,
            error: Box::new(crate::error::CliError::json_not_supported_for_streaming()),
        });
    }

    // One resolution for the whole invocation: every command below reads
    // and writes the same file, whichever way it was named.
    let location = resolve_config_location(cli.config.as_deref())
        .map_err(|error| context::fail(kind, None, None, error))?;
    let config_path = location.path.as_path();

    match cli.command {
        Command::Version => Ok(CommandOutput {
            kind,
            profile: None,
            mode: None,
            data: CommandData::Version {
                version: env!("CARGO_PKG_VERSION").to_owned(),
                commit: env!("LOON_GIT_COMMIT").to_owned(),
                commit_date: env!("LOON_GIT_COMMIT_DATE").to_owned(),
            },
        }),
        Command::Init(args) => config::run_config_init(kind, config_path, args, runtime),
        Command::Config { command } => config::run_config_command(kind, &location, command),
        Command::Profile { command } => {
            profile::run_profile_command(kind, config_path, command, runtime)
        }
        Command::Namespace { command } => {
            namespace::run_namespace_command(kind, config_path, command, runtime).await
        }
        Command::Use(args) => namespace::run_namespace_use(kind, config_path, args).await,
        Command::Current(args) => namespace::run_namespace_current(kind, config_path, args).await,
        Command::Ls(args) => fs::run_filesystem_ls(kind, config_path, args).await,
        Command::Stat(args) => fs::run_filesystem_stat(kind, config_path, args).await,
        Command::Cat(args) => fs::run_filesystem_cat(kind, config_path, args).await,
        Command::Grep(args) => fs::run_filesystem_grep(kind, config_path, args).await,
        Command::Get(args) => fs::run_filesystem_get(kind, config_path, args, runtime).await,
        Command::Put(args) => fs::run_filesystem_put(kind, config_path, args, runtime).await,
        Command::Revisions(args) => fs::run_filesystem_revisions(kind, config_path, args).await,
        Command::Restore(args) => fs::run_filesystem_restore(kind, config_path, args).await,
        Command::Undelete(args) => fs::run_filesystem_undelete(kind, config_path, args).await,
        Command::Mkdir(args) => fs::run_filesystem_mkdir(kind, config_path, args).await,
        Command::Rm(args) => fs::run_filesystem_rm(kind, &location, args).await,
        Command::Mv(args) => fs::run_filesystem_mv(kind, config_path, args, runtime).await,
        Command::Cp(args) => fs::run_filesystem_cp(kind, config_path, args, runtime).await,
        Command::Trash(args) => fs::run_filesystem_trash(kind, &location, args).await,
        Command::Changes(args) => admin::run_admin_changes(kind, config_path, args).await,
        Command::Admin { command } => {
            admin::run_admin_command(kind, config_path, command, runtime).await
        }
    }
}