radicle-cli 0.20.0

Radicle CLI
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use std::time;

use clap::Parser;

use nonempty::NonEmpty;
use radicle::node::policy::Scope;
use radicle::prelude::*;

use crate::node::SyncSettings;
use crate::terminal;

const ABOUT: &str = "Manage repository seeding policies";

const LONG_ABOUT: &str = r#"
The `seed` command, when no Repository ID is provided, will list the
repositories being seeded.

When a Repository ID is provided it updates or creates the seeding policy for
that repository. To delete a seeding policy, use the `rad unseed` command.

When seeding a repository, a scope can be specified: this can be either `all` or
`followed`. When using `all`, all remote nodes will be followed for that repository.
On the other hand, with `followed`, only the repository delegates will be followed,
plus any remote that is explicitly followed via `rad follow <nid>`.
"#;

#[derive(Parser, Debug)]
#[command(about = ABOUT, long_about = LONG_ABOUT, disable_version_flag = true)]
pub struct Args {
    #[arg(value_name = "RID", num_args = 1..)]
    pub(super) rids: Option<Vec<RepoId>>,

    /// Fetch repository after updating seeding policy
    #[arg(long, overrides_with("no_fetch"), hide(true))]
    fetch: bool,

    /// Do not fetch repository after updating seeding policy
    #[arg(long, overrides_with("fetch"))]
    no_fetch: bool,

    /// Fetch from the given node (may be specified multiple times)
    #[arg(long, value_name = "NID", action = clap::ArgAction::Append)]
    pub(super) from: Vec<NodeId>,

    /// Fetch timeout in seconds
    ///
    /// Valid arguments are for example "10s", "5min" or "2h 37min"
    #[arg(long, short, value_parser = humantime::parse_duration, default_value = "9s")]
    timeout: std::time::Duration,

    /// Peer follow scope for this repository
    #[arg(long, value_parser = terminal::args::ScopeParser)]
    pub(super) scope: Option<Scope>,

    /// Verbose output
    #[arg(long, short)]
    pub(super) verbose: bool,
}

pub(super) enum Operation {
    List,
    Seed {
        rids: NonEmpty<RepoId>,
        should_fetch: bool,
        settings: SyncSettings,
        scope: Option<Scope>,
    },
}

impl From<Args> for Operation {
    fn from(args: Args) -> Self {
        let should_fetch = args.should_fetch();
        let timeout = args.timeout();
        let Args {
            rids, from, scope, ..
        } = args;
        match rids.and_then(NonEmpty::from_vec) {
            Some(rids) => Operation::Seed {
                rids,
                should_fetch,
                settings: SyncSettings::default().seeds(from).timeout(timeout),
                scope,
            },
            None => Self::List,
        }
    }
}

impl Args {
    fn timeout(&self) -> time::Duration {
        self.timeout
    }

    fn should_fetch(&self) -> bool {
        match (self.fetch, self.no_fetch) {
            (true, false) => true,
            (false, true) => false,
            // Default it to fetch
            (_, _) => true,
        }
    }
}