ratchjob 0.2.1

一个rust实现的分布式任务调度平台服务。计划完全兼容xxl-job协议，然后再增强一些任务调度平台能力。
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
103
104
105
106
107
108
109
110
111

use crate::common::app_config::AppConfig;
use crate::common::get_app_version;
use crate::console::v1::console_api_v1;
use crate::openapi::openapi_config;
use crate::openapi::xxljob::xxl_api_config;
use actix_web::web::ServiceConfig;
use actix_web::{web, HttpResponse, Responder};
use mime_guess::from_path;
use ratchjob_web_dist_wrap::get_embedded_file;
use std::sync::Arc;

fn handle_embedded_file_inner(path: &str, cache: bool) -> HttpResponse {
    match get_embedded_file(path) {
        Some(content) => {
            let mut resp = HttpResponse::Ok();
            resp.content_type(from_path(path).first_or_octet_stream().as_ref());
            if cache {
                resp.insert_header(("Cache-Control", "max-age=604800, public"));
            }
            resp.body(content.data.into_owned())
        }
        None => HttpResponse::NotFound().body("404 Not Found"),
    }
}

fn handle_embedded_file(path: &str) -> HttpResponse {
    handle_embedded_file_inner(path, false)
}

fn handle_embedded_file_with_cache(path: &str) -> HttpResponse {
    handle_embedded_file_inner(path, true)
}

pub(crate) async fn index() -> impl Responder {
    handle_embedded_file("index.html")
}

#[actix_web::get("/server.svg")]
pub(crate) async fn icon() -> impl Responder {
    handle_embedded_file_with_cache("server.svg")
}

#[actix_web::get("/ratchjob/server.svg")]
pub(crate) async fn console_icon() -> impl Responder {
    handle_embedded_file_with_cache("ratchjob/server.svg")
}

#[actix_web::get("/assets/{_:.*}")]
pub(crate) async fn assets(path: web::Path<String>) -> impl Responder {
    let file = format!("assets/{}", path.as_ref());
    handle_embedded_file_with_cache(&file)
}

#[actix_web::get("/ratchjob/assets/{_:.*}")]
pub(crate) async fn console_assets(path: web::Path<String>) -> impl Responder {
    let file = format!("ratchjob/assets/{}", path.as_ref());
    handle_embedded_file_with_cache(&file)
}

#[allow(dead_code)]
async fn disable_no_auth_console_index() -> impl Responder {
    let body = "<!DOCTYPE html>
<html lang='en'>
  <head>
    <meta charset='UTF-8' />
    <meta name='viewport' content='width=device-width, initial-scale=1.0' />
    <title>RATCH-JOB</title>
  </head>
  <body>
    <p>请使用控制台: http://localhost:8845/ratchjob/ </p>
  </body>
</html>";
    HttpResponse::Ok().content_type("text/html").body(body)
}

pub async fn about_info() -> impl Responder {
    format!("ratch-job version:{}", get_app_version())
}

pub fn app_config(app_config: Arc<AppConfig>) -> impl FnOnce(&mut ServiceConfig) {
    move |config: &mut ServiceConfig| {
        openapi_config(config);
        xxl_api_config(config, &app_config);
    }
}

pub fn console_config(config: &mut ServiceConfig) {
    console_page_config(config);
    console_api_v1(config);
}
pub fn console_page_config(config: &mut ServiceConfig) {
    config
        .service(web::resource("/").route(web::get().to(index)))
        .service(icon)
        .service(assets)
        .service(web::resource("/index.html").route(web::get().to(index)))
        .service(web::resource("/404").route(web::get().to(index)))
        .service(web::resource("/nopermission").route(web::get().to(index)))
        .service(web::resource("/manage/{_:.*}").route(web::get().to(index)))
        .service(web::resource("/p/{_:.*}").route(web::get().to(index)))
        //new console path
        .service(web::resource("/ratchjob").route(web::get().to(index)))
        .service(web::resource("/ratchjob/").route(web::get().to(index)))
        .service(console_icon)
        .service(console_assets)
        .service(web::resource("/ratchjob/index.html").route(web::get().to(index)))
        .service(web::resource("/ratchjob/404").route(web::get().to(index)))
        .service(web::resource("/ratchjob/nopermission").route(web::get().to(index)))
        .service(web::resource("/ratchjob/manage/{_:.*}").route(web::get().to(index)))
        .service(web::resource("/ratchjob/p/{_:.*}").route(web::get().to(index)));
}