wekan-cli 2.0.0

Agent-first, human-friendly command-line client for Wekan
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

use crate::{
    client::WekanClientFactory,
    command_result::CommandSuccess,
    commands::{authenticated::AuthenticatedContext, client_error::map_client_error},
    credentials::CredentialStore,
    error::AppError,
    redaction::Redactor,
};
use clap::{Args, Subcommand};

#[derive(Debug, Args)]
pub struct ProblemArgs {
    #[command(subcommand)]
    pub command: ProblemCommand,
}
#[derive(Debug, Subcommand)]
pub enum ProblemCommand {
    /// Read the status overview and counts of new problems.
    List,
    /// Read a page of one event stream.
    Get(GetArgs),
    /// Mark the current problems in a stream as seen.
    Acknowledge(AcknowledgeArgs),
}
#[derive(Debug, Args)]
pub struct GetArgs {
    /// Event stream, or api for API usage.
    #[arg(value_parser=["security","speed","tests","cpu","ram","disk","database","integrity","mail","api"])]
    stream: String,
    /// Rows per page, from 1 through 200.
    #[arg(long,default_value_t=50,value_parser=clap::value_parser!(u64).range(1..=200))]
    limit: u64,
    /// Number of matching rows to skip.
    #[arg(long,default_value_t=0,value_parser=clap::value_parser!(u64).range(0..=9_007_199_254_740_991))]
    skip: u64,
    /// Case-insensitive text filter.
    #[arg(long)]
    search: Option<String>,
}
#[derive(Debug, Args)]
pub struct AcknowledgeArgs {
    /// Problem stream to acknowledge; API usage is read-only.
    #[arg(value_parser=crate::client::admin::problems::PROBLEM_STREAMS)]
    stream: String,
}
pub(crate) async fn execute(
    command: ProblemCommand,
    factory: &WekanClientFactory,
    store: &dyn CredentialStore,
) -> Result<CommandSuccess, AppError> {
    let context = AuthenticatedContext::load(factory, store)?;
    let redactor = Redactor::with_secret(context.record().token());
    match command {
        ProblemCommand::List => context
            .client()
            .problems_overview(context.record().token())
            .await
            .map(|response| CommandSuccess::ProblemsOverview(response.into())),
        ProblemCommand::Get(args) => context
            .client()
            .problem_stream(
                &args.stream,
                args.limit,
                args.skip,
                args.search.as_deref(),
                context.record().token(),
            )
            .await
            .map(|response| CommandSuccess::ProblemStream(response.into())),
        ProblemCommand::Acknowledge(args) => context
            .client()
            .acknowledge_problem_stream(&args.stream, context.record().token())
            .await
            .map(|response| CommandSuccess::ProblemAcknowledged(response.into())),
    }
    .map_err(|e| map_client_error(e, &redactor, "admin problems"))
}