rustploy 0.1.22

Rustploy PaaS daemon — lightweight self-hosted deployment platform
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

//! Handlers da sincronização do estado de infra com o git (Fase 6 do plano de estado em git).

use crate::bootstrap::state::AppState;
use crate::features::state_git::StateGitError;
use shared::{Command, Response as RpResponse};

fn erro(e: StateGitError) -> RpResponse {
    match e {
        StateGitError::Plaintext(_) => RpResponse::err("PlaintextFound", e.to_string()),
        StateGitError::Invalid(m) => RpResponse::err("InvalidInput", m),
        StateGitError::Other(e) => RpResponse::err("StateGitFailed", format!("{e:#}")),
    }
}

pub async fn dispatch(state: AppState, cmd: Command) -> RpResponse {
    match cmd {
        Command::StateGitStatus => match state.state_git.status().await {
            Ok(s) => RpResponse::StateGit(Box::new(s)),
            Err(e) => RpResponse::err("StateGitFailed", format!("{e:#}")),
        },
        Command::StateGitConfigure {
            mode,
            remote,
            branch,
            provider_id,
        } => match state
            .state_git
            .configure(&mode, remote, branch, provider_id)
            .await
        {
            Ok(s) => RpResponse::StateGit(Box::new(s)),
            Err(e) => erro(e),
        },
        Command::StateGitSyncNow => match state.state_git.sync_now().await {
            Ok(s) => RpResponse::StateGit(Box::new(s)),
            Err(e) => erro(e),
        },
        Command::StateGitResume => match state.state_git.resume().await {
            Ok(s) => RpResponse::StateGit(Box::new(s)),
            Err(e) => erro(e),
        },
        Command::StateGitResolve { choice } => match state.state_git.resolve(choice).await {
            Ok(s) => RpResponse::StateGit(Box::new(s)),
            Err(e) => erro(e),
        },
        Command::StateGitDismissRemoval { id } => {
            match state.state_git.dismiss_removal(&id).await {
                Ok(()) => RpResponse::Ok,
                Err(e) => erro(e),
            }
        }
        Command::InfraAuditAllow {
            project,
            scope,
            what,
            allowed,
        } => match state
            .state_git
            .set_allowed(&project, &scope, &what, allowed)
            .await
        {
            Ok(()) => RpResponse::Ok,
            Err(e) => erro(e),
        },
        _ => RpResponse::err("NotImplemented", "command not yet implemented"),
    }
}