autocall 0.1.6

rust autocall macro,single scan load ioc aop
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

use actix_web::HttpServer;
use dashmap::DashMap;


#[macro_export]
macro_rules! actix_config_service {
    ($key:expr,$($x:expr), *) => {

            let group_url = $key;
            let fun = Box::new(
                ||->Box<dyn Fn(&mut  web::ServiceConfig)->()>{
                    return Box::new(|cfg: &mut web::ServiceConfig|{
                        $(cfg.service($x);)*
                    });
                }
            );
            let config_key = "actix_config_service_map";
            single_get_ref_try!(config_key,
            DashMap<String,Box<dyn Fn()->Box<dyn Fn(&mut  web::ServiceConfig)->()>>>,
            |m:&DashMap<String,Box<dyn Fn()->Box<dyn Fn(&mut  web::ServiceConfig)->()>>>|{
                m.entry(group_url.to_string()).or_insert(fun);
            },{
                let map = DashMap::<String,Box<dyn Fn()->Box<dyn Fn(&mut  web::ServiceConfig)->()>>>::new();
                single_push!(config_key,map);
                single_get_ref_try!(config_key,
                DashMap<String,Box<dyn Fn()->Box<dyn Fn(&mut  web::ServiceConfig)->()>>>,
                |m:&DashMap<String,Box<dyn Fn()->Box<dyn Fn(&mut  web::ServiceConfig)->()>>>|{
                    m.entry(group_url.to_string()).or_insert(fun);
                },{
                    info!("add service error");
                });
            });
        
    };
}

#[macro_export]
macro_rules! actix_web_run {
    () => {
        $crate::auto_config::actix_web_config::loading()
    };
}

pub async fn loading()-> std::io::Result<()>{
    let mut addr_str = String::new();
    single_get_ref_try!("actix_config_addr",String,|addr:&String|{
        info!("actix addr:{}",addr);
        addr_str = addr.clone();
    },{
        error!("actix not set addr");
    }); 
    if addr_str.is_empty(){
        panic!("actix-web error addr is null");
    }
    HttpServer::new(move || {
        let mut app = actix_web::App::new();
        let mut service_vec = vec!();
        single_get_ref_try!("actix_config_service_map",DashMap<String,Box<dyn Fn()->Box<dyn Fn(&mut  actix_web::web::ServiceConfig)->()>>>,
        |m:&DashMap<String,Box<dyn Fn()->Box<dyn Fn(&mut  actix_web::web::ServiceConfig)->()>>>|{
            info!("start add actix service");
            for map in m{
                info!("add group:{}",map.key());
                match m.get(map.key()){
                    Some(r) => {
                        service_vec.push(r.value()());
                    },
                    None => {
                        info!("not other config");
                    }
                }
                
            }
        },{
            error!("not find actix_config_service_map");
        });
        for ser in service_vec{
            app = app.configure(ser);
        }
        app
    })
    .bind(&addr_str)?
    .run()
    .await
}