Gonk
/
AP-5
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add more config files

This commit is contained in:
Alex 2022-09-10 16:00:27 -04:00
parent 0ceef499bb
commit 1be6b4318e
Signed by: technically
GPG Key ID: 46E0A080F69E83F1
1 changed files with 56 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
src/lib.rs
View File

@ -136,6 +136,62 @@ pub async fn main(req: Request, env: Env, _ctx: worker::Context) -> Result<Respo
}
Response::error("Bad Request", 400)
})
.get_async("/logger/:hostname/:token", |_req, ctx| async move {
if let Some(token) = ctx.param("token") {
if !check_endpoint_auth(token, ctx.kv("GONK_NODES")?).await {
return Response::error("Unauthorized", 401);
}
}
if let Some(hostname) = ctx.param("hostname") {
let kv = ctx.kv("GONK_NODES")?;
return match kv.get("base_logger").cache_ttl(300).text().await? {
Some(base) => Response::ok(&base),
None => {
Response::error(format!("Could not find logger.conf for {}", hostname), 404)
}
};
}
Response::error("Bad Request", 400)
})
.get_async("/f2b/asterisk/:hostname/:token", |_req, ctx| async move {
if let Some(token) = ctx.param("token") {
if !check_endpoint_auth(token, ctx.kv("GONK_NODES")?).await {
return Response::error("Unauthorized", 401);
}
}
if let Some(hostname) = ctx.param("hostname") {
let kv = ctx.kv("GONK_NODES")?;
return match kv.get("base_f2b_asterisk").cache_ttl(300).text().await? {
Some(base) => Response::ok(&base),
None => Response::error(
format!("Could not find fail2ban asterisk.conf for {}", hostname),
404,
),
};
}
Response::error("Bad Request", 400)
})
.get_async("/f2b/voipbl/:hostname/:token", |_req, ctx| async move {
if let Some(token) = ctx.param("token") {
if !check_endpoint_auth(token, ctx.kv("GONK_NODES")?).await {
return Response::error("Unauthorized", 401);
}
}
if let Some(hostname) = ctx.param("hostname") {
let kv = ctx.kv("GONK_NODES")?;
return match kv.get("base_f2b_voipbl").cache_ttl(300).text().await? {
Some(base) => Response::ok(&base),
None => Response::error(
format!("Could not find fail2ban voipbl.conf for {}", hostname),
404,
),
};
}
Response::error("Bad Request", 400)
})
.run(req, env)
.await
}