rustploy 0.1.12

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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

//! Handlers de jobs: o `dispatch` recebe os `Command` da seção e chama o handler certo.

pub mod get_job_logs;
pub mod job_create;
pub mod job_delete;
pub mod job_list;
pub mod job_list_all;
pub mod job_run_cancel;
pub mod job_run_history;
pub mod job_run_now;
pub mod job_update;
pub mod job_warm;
pub mod job_warm_status;

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

pub async fn dispatch(state: AppState, cmd: Command) -> RpResponse {
    match cmd {
        Command::JobCreate {
            project_id,
            trigger_service_id,
            name,
            compose,
            git_source,
            main_service,
            env_vars,
            env_comments,
            recurrence,
        } => {
            job_create::handle(
                state,
                project_id,
                trigger_service_id,
                name,
                compose,
                git_source,
                main_service,
                env_vars,
                env_comments,
                recurrence,
            )
            .await
        }
        Command::JobUpdate {
            id,
            name,
            compose,
            git_source,
            main_service,
            env_vars,
            env_comments,
            enabled,
            recurrence,
        } => {
            job_update::handle(
                state,
                id,
                name,
                compose,
                git_source,
                main_service,
                env_vars,
                env_comments,
                enabled,
                recurrence,
            )
            .await
        }
        Command::JobDelete { id } => job_delete::handle(state, id).await,
        Command::JobList { project_id } => job_list::handle(state, project_id).await,
        Command::JobListAll => job_list_all::handle(state).await,
        Command::JobRunNow { id } => job_run_now::handle(state, id).await,
        Command::JobRunCancel { job_run_id } => job_run_cancel::handle(state, job_run_id).await,
        Command::JobRunHistory { job_id, limit } => {
            job_run_history::handle(state, job_id, limit).await
        }
        Command::GetJobLogs { job_run_id } => get_job_logs::handle(state, job_run_id).await,
        Command::JobWarmStatus { job_id } => job_warm_status::handle(state, job_id).await,
        Command::JobWarm { job_id, force } => job_warm::handle(state, job_id, force).await,
        _ => RpResponse::err("NotImplemented", "command not yet implemented"),
    }
}