63 lines · 3 KBtext/plain; charset=utf-8
Onset: version control where nobody waits and nothing gets lost. The on command, its core and onset-server.
| 6 | //! vcs-server serve --data DIR [--listen 127.0.0.1:8899] [--threads 16] |
| 7 | //! vcs-server user add HANDLE [--name NAME] [--email EMAIL] prints a token |
| 8 | //! vcs-server project add OWNER/NAME --owner HANDLE [--public] |
| 9 | //! vcs-server member add OWNER/NAME HANDLE [--role member|reader|owner] |
| 10 | //! ``` |
| 11 |
| 12 | mod api; |
| 13 | mod state; |
| 14 |
| 15 | use std::path::PathBuf; |
| 16 |
| 17 | use anyhow::{Result, bail}; |
| 18 |
| 19 | fn arg(args: &[String], name: &str) -> Option<String> { |
| 20 | args.iter().position(|a| a == name).and_then(|i| args.get(i + 1)).cloned() |
| 21 | } |
| 22 |
| 23 | fn main() -> Result<()> { |
| 24 | let args: Vec<String> = std::env::args().skip(1).collect(); |
| 25 | let data = PathBuf::from(arg(&args, "--data").or_else(|| std::env::var("VCS_SERVER_DATA").ok()).unwrap_or_else(|| "vcs-data".into())); |
| 26 | let words: Vec<&str> = args.iter().take_while(|a| !a.starts_with("--")).map(String::as_str).collect(); |
| 27 | match words.as_slice() { |
| 28 | ["serve"] => { |
| 29 | let listen = arg(&args, "--listen").unwrap_or_else(|| "127.0.0.1:8899".into()); |
| 30 | let threads: usize = arg(&args, "--threads").and_then(|t| t.parse().ok()).unwrap_or(16); |
| 31 | api::serve(&data, &listen, threads) |
| 32 | } |
| 33 | ["user", "add", handle] => { |
| 34 | let st = state::State::open(&data)?; |
| 35 | let name = arg(&args, "--name").unwrap_or_else(|| handle.to_string()); |
| 36 | let email = arg(&args, "--email").unwrap_or_else(|| format!("{handle}@localhost")); |
| 37 | let token = st.add_user(handle, &name, &email)?; |
| 38 | println!("{token}"); |
| 39 | Ok(()) |
| 40 | } |
| 41 | ["project", "add", key] => { |
| 42 | let st = state::State::open(&data)?; |
| 43 | let owner = arg(&args, "--owner").ok_or_else(|| anyhow::anyhow!("--owner HANDLE is required"))?; |
| 44 | st.add_project(key, &owner, args.iter().any(|a| a == "--public"))?; |
| 45 | println!("{key}"); |
| 46 | Ok(()) |
| 47 | } |
| 48 | ["member", "add", key, handle] => { |
| 49 | let st = state::State::open(&data)?; |
| 50 | let role = arg(&args, "--role").unwrap_or_else(|| "member".into()); |
| 51 | if !["owner", "member", "reader"].contains(&role.as_str()) { |
| 52 | bail!("--role is owner, member or reader"); |
| 53 | } |
| 54 | st.add_member(key, handle, &role)?; |
| 55 | Ok(()) |
| 56 | } |
| 57 | _ => { |
| 58 | eprintln!("usage: vcs-server serve --data DIR [--listen ADDR] | user add HANDLE | project add OWNER/NAME --owner HANDLE [--public] | member add OWNER/NAME HANDLE [--role ROLE]"); |
| 59 | std::process::exit(2); |
| 60 | } |
| 61 | } |
| 62 | } |
| 63 |