s3ec 0.2.1

File sync daemon and CLI for an S3-compatible event server
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

use clap::{Parser, Subcommand};

#[derive(Parser)]
#[command(name = "s3ec", about = "S3 Event Client")]
pub struct Cli {
    #[command(subcommand)]
    pub command: Commands,
}

#[derive(Subcommand)]
pub enum Commands {
    Login {
        #[arg(long)]
        server: String,
        #[arg(long)]
        api_key: String,
    },
    Upload {
        file: String,
        #[arg(long)]
        path: Option<String>,
    },
    Download {
        id: String,
        #[arg(short = 'o')]
        output: Option<String>,
    },
    #[command(name = "ls")]
    List {
        #[arg(long)]
        path: Option<String>,
        #[arg(long)]
        search: Option<String>,
        #[arg(long)]
        limit: Option<i64>,
        #[arg(long)]
        offset: Option<i64>,
    },
    Info {
        id: String,
    },
    Rm {
        id: String,
    },
    Daemon {
        #[arg(long, short = 'w')]
        watch: String,
        #[arg(long, alias = "debounce", default_value = "500")]
        debounce_ms: u64,
    },
    #[command(name = "sync")]
    Sync {
        #[arg(long, short = 'w')]
        watch: String,
    },
}

impl Commands {
    pub async fn execute(self) -> anyhow::Result<()> {
        use Commands::*;
        match self {
            Login { server, api_key } => crate::client::login(&server, &api_key).await,
            Upload { file, path } => crate::client::upload(&file, path.as_deref()).await,
            Download { id, output } => crate::client::download(&id, output.as_deref()).await,
            List { path, search, limit, offset } => {
                crate::client::list(path.as_deref(), search.as_deref(), limit, offset).await
            }
            Info { id } => crate::client::info(&id).await,
            Rm { id } => crate::client::rm(&id).await,
            Daemon { watch, debounce_ms } => crate::daemon::run(&watch, debounce_ms).await,
            Sync { watch } => crate::daemon::sync_dir(&watch).await,
        }
    }
}