ruwebframe 0.1.8

a simple webframe for rust actix-web, based on rudi and rbatis.
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
112
113
114
115
116


use crate::rubase::{  BaseEntitySingle};
use std::sync::{  Mutex  };
use actix_web::web;
use crate::rulog;
use crate::ruweb::{webdto, webrouter};
use crate::ruweb::webrouter::route_factroy::with_container_mut;

// 路由配置函数类型别名
pub type RouteConfigFn = dyn Fn(&mut web::ServiceConfig) + Send + Sync + 'static;

#[derive()]
pub struct RouteContainer {
    configs: Mutex<Vec<Box<RouteConfigFn>>>,
    items: Mutex<Vec<webdto::WebRoute>>,
}

impl BaseEntitySingle for RouteContainer {}
impl RouteContainer {
    pub fn new() -> Self {
        Self {
            configs: Mutex::new(Vec::new()),
            items: Mutex::new(Vec::new()),
        }
    }

    // 添加单个路由配置函数
    pub fn add<F>(&self, config_fn: F,path: &str) -> &Self
    where
        F: Fn(&mut web::ServiceConfig) + Send + Sync + 'static,
    {
        let mut guard = self.configs.lock().unwrap();
        guard.push(Box::new(config_fn));
        //webdto::reg_route(path, path, "ident_to_string($method)", "$handler");
        let mut item=webdto::WebRoute::default();
        item.name=path.to_string();
        item.path=path.to_string();
        item.method="ident_to_string($method)".to_string();
        item.handler="$handler".to_string();
        let mut items = self.items.lock().unwrap();
        items.push(item);
        self
    }

    // 批量添加路由配置函数
    pub fn add_all<F>(&self, config_fns: Vec<F>) -> &Self
    where
        F: Fn(&mut web::ServiceConfig) + Send + Sync + 'static,
    {
        let mut guard = self.configs.lock().unwrap();
        for config_fn in config_fns {
            guard.push(Box::new(config_fn));
        }
        self
    }
    pub fn clear_items (&self ) {
       self.configs.lock().unwrap() .clear();

    }
    // 应用所有配置
    pub fn apply_routes(&self, cfg: &mut web::ServiceConfig) {

        let mut guard = self.configs.lock().unwrap();

        for config_fn in guard.iter_mut() {
            config_fn(cfg);
        }
    }
    pub fn list_routes(&self ) {
        let mut guard = self.configs.lock().unwrap();
        for item in guard.iter() {
            let ptr = item as *const Box<dyn Fn(&mut web::ServiceConfig) + Send + Sync>;

            rulog::info2("注册路由:", format!("{:p}", ptr).to_string());
        }

    }
    pub fn list_routes_items(&self ) {

        let mut guard  = self.items.lock().unwrap();
        for item in guard .iter() {
           // println!("注册路由:{}",  item .path.clone());
            rulog::info2("注册路由:",  item .path.clone());
        }
    }
    // 获取配置数量
}

pub fn register_route<F>(config_api_route: F,path: &str) -> ()
where
    F: Fn(&mut web::ServiceConfig) + Send + Sync + 'static,
{
        with_container_mut(|container| {
            container.add(config_api_route,path);
            println!("✅ API routes registered");
        });

}
pub fn register_route_all<F>(config_api_routes: Vec<F>) -> ()
where
    F: Fn(&mut web::ServiceConfig) + Send + Sync + 'static,
{

    with_container_mut(|container| {
        container.add_all(config_api_routes);
        println!("✅ API routes registered");
    });
}

pub fn clear_route_items (  )  {

    with_container_mut(|container| {
        container. configs= Mutex::new(Vec::new())
    });
}