sentry - routes - /cfg

elpiel · elpiel · commit 77962fcb7ccc · 2019-11-04T13:04:47.000+02:00
diff --git a/primitives/src/config.rs b/primitives/src/config.rs
@@ -15,6 +15,7 @@ lazy_static! {
 }
 
 #[derive(Serialize, Deserialize, Debug, Clone)]
+#[serde(rename_all(serialize = "SCREAMING_SNAKE_CASE"))]
 pub struct Config {
     pub identity: Option<String>, // should not be here maybe?
     pub max_channels: u32,
diff --git a/sentry/src/lib.rs b/sentry/src/lib.rs
@@ -2,13 +2,24 @@
 #![deny(rust_2018_idioms)]
 
 use hyper::service::{make_service_fn, service_fn};
-use hyper::{Body, Error, Request, Response, Server, StatusCode};
+use hyper::{Body, Error, Request, Response, Server, StatusCode, Method};
 use primitives::adapter::Adapter;
 use primitives::Config;
 use slog::{error, info, Logger};
 
 pub mod routes {
     pub mod channel;
+    pub mod cfg {
+        use hyper::{Body, Response};
+        use crate::ResponseError;
+        use primitives::Config;
+
+        pub fn return_config(config: &Config) -> Result<Response<Body>, ResponseError> {
+            let config_str = serde_json::to_string(config)?;
+
+            Ok(Response::builder().body(Body::from(config_str)).unwrap())
+        }
+    }
 }
 
 pub mod access;
@@ -43,7 +54,7 @@ impl<A: Adapter + 'static> Application<A> {
             async move {
                 Ok::<_, Error>(service_fn(move |req| {
                     let adapter_config = adapter_config.clone();
-                    async move { Ok::<_, Error>(handle_routing(req, adapter_config.0).await) }
+                    async move { Ok::<_, Error>(handle_routing(req, adapter_config).await) }
                 }))
             }
         });
@@ -71,8 +82,10 @@ where
     }
 }
 
-async fn handle_routing(req: Request<Body>, adapter: impl Adapter) -> Response<Body> {
-    if req.uri().path().starts_with("/channel") {
+async fn handle_routing(req: Request<Body>, (adapter, config): (impl Adapter, Config)) -> Response<Body> {
+    if req.uri().path().starts_with("/cfg") && req.method() == Method::GET {
+        crate::routes::cfg::return_config(&config)
+    }else if req.uri().path().starts_with("/channel") {
         crate::routes::channel::handle_channel_routes(req, adapter).await
     } else {
         Err(ResponseError::NotFound)

Original file line number	Diff line number	Diff line change
`@@ -15,6 +15,7 @@ lazy_static! {`
`15`	`15`	`}`
`16`	`16`
`17`	`17`	`#[derive(Serialize, Deserialize, Debug, Clone)]`
	`18`	`+#[serde(rename_all(serialize = "SCREAMING_SNAKE_CASE"))]`
`18`	`19`	`pub struct Config {`
`19`	`20`	`pub identity: Option<String>, // should not be here maybe?`
`20`	`21`	`pub max_channels: u32,`