luoshu 0.1.0

Luoshu
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

use crate::data::{ConfigurationReg, LuoshuDataHandle, LuoshuSledData};
use luoshu_core::Store;
use salvo::{handler, writer::Json, Depot, Request, Response, Router};
use std::sync::Arc;
use tokio::sync::RwLock;

use crate::web::error::WebResult;
use crate::web::resp::Resp;

// use crate::web::LUOSHU_DATA;

pub fn get_routers() -> Router {
    Router::with_path("configuration").post(append).get(list)
    // .push(Router::with_path("delete").post(delete))
}

#[handler]
async fn append(req: &mut Request, res: &mut Response, depot: &mut Depot) -> WebResult<()> {
    let value = req.parse_body::<ConfigurationReg>().await?;
    let data = depot.obtain::<Arc<RwLock<LuoshuSledData>>>().unwrap();
    data.write().await.append(&value.into(), None, None).await?;
    res.render(Json(Resp::success("ok")));
    Ok(())
}

#[handler]
async fn list(_: &mut Request, res: &mut Response, depot: &mut Depot) -> WebResult<()> {
    let data = depot.obtain::<Arc<RwLock<LuoshuSledData>>>().unwrap();
    res.render(Json(Resp::success(
        data.write().await.configuration_store.get_values(),
    )));
    Ok(())
}