65 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 | //! onset-server serve --data DIR [--listen 127.0.0.1:8899] [--threads 16] |
| 7 | //! onset-server user add HANDLE [--name NAME] [--email EMAIL] prints a token |
| 8 | //! onset-server project add OWNER/NAME --owner HANDLE [--public] |
| 9 | //! onset-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 | // A folder from before Onset had its name keeps being used. |
| 26 | let default = if !std::path::Path::new("onset-data").exists() && std::path::Path::new("vcs-data").exists() { "vcs-data" } else { "onset-data" }; |
| 27 | let data = PathBuf::from(arg(&args, "--data").or_else(|| onset_cli::paths::var("SERVER_DATA")).unwrap_or_else(|| default.into())); |
| 28 | let words: Vec<&str> = args.iter().take_while(|a| !a.starts_with("--")).map(String::as_str).collect(); |
| 29 | match words.as_slice() { |
| 30 | ["serve"] => { |
| 31 | let listen = arg(&args, "--listen").unwrap_or_else(|| "127.0.0.1:8899".into()); |
| 32 | let threads: usize = arg(&args, "--threads").and_then(|t| t.parse().ok()).unwrap_or(16); |
| 33 | api::serve(&data, &listen, threads) |
| 34 | } |
| 35 | ["user", "add", handle] => { |
| 36 | let st = state::State::open(&data)?; |
| 37 | let name = arg(&args, "--name").unwrap_or_else(|| handle.to_string()); |
| 38 | let email = arg(&args, "--email").unwrap_or_else(|| format!("{handle}@localhost")); |
| 39 | let token = st.add_user(handle, &name, &email)?; |
| 40 | println!("{token}"); |
| 41 | Ok(()) |
| 42 | } |
| 43 | ["project", "add", key] => { |
| 44 | let st = state::State::open(&data)?; |
| 45 | let owner = arg(&args, "--owner").ok_or_else(|| anyhow::anyhow!("--owner HANDLE is required"))?; |
| 46 | st.add_project(key, &owner, args.iter().any(|a| a == "--public"))?; |
| 47 | println!("{key}"); |
| 48 | Ok(()) |
| 49 | } |
| 50 | ["member", "add", key, handle] => { |
| 51 | let st = state::State::open(&data)?; |
| 52 | let role = arg(&args, "--role").unwrap_or_else(|| "member".into()); |
| 53 | if !["owner", "member", "reader"].contains(&role.as_str()) { |
| 54 | bail!("--role is owner, member or reader"); |
| 55 | } |
| 56 | st.add_member(key, handle, &role)?; |
| 57 | Ok(()) |
| 58 | } |
| 59 | _ => { |
| 60 | eprintln!("usage: onset-server serve --data DIR [--listen ADDR] | user add HANDLE | project add OWNER/NAME --owner HANDLE [--public] | member add OWNER/NAME HANDLE [--role ROLE]"); |
| 61 | std::process::exit(2); |
| 62 | } |
| 63 | } |
| 64 | } |
| 65 |