wip impl auth middleware

src/app/args.rs

@@ -23,4 +23,10 @@ pub struct AppArgs {
 
     #[structopt(long = "certs_dir", default_value = "/etc/letsencrypt/live")]
     pub ssl_certs_dir: PathBuf,
+
+    #[structopt(short = "u", long = "username", default_value = "admin")]
+    pub admin_id: String,
+
+    #[structopt(short = "p", long = "password", default_value = "password")]
+    pub admin_pwd: String,
 }

src/app/config.rs

@@ -18,6 +18,8 @@ pub struct AppConfig {
     pub port_tls: u16,
     pub load: Option<PathBuf>,
     pub ssl_certs_dir: PathBuf,
+    pub admin_id: String,
+    pub admin_pwd: String,
 }
 
 impl AppConfig {
@@ -57,6 +59,8 @@ impl AppConfig {
             port_tls: app_args.port_tls,
             load: app_args.load,
             ssl_certs_dir,
+            admin_id: app_args.admin_id,
+            admin_pwd: app_args.admin_pwd,
         }
     }
     pub fn get_log_level(&self) -> String {

src/main.rs

 mod app;
+mod middleware;
 mod service;
 mod static_files;
 mod testing;

src/middleware/authentication.rs

+use actix_web::{
+    dev::{forward_ready, Service, ServiceRequest, ServiceResponse, Transform},
+    Error,
+};
+use futures::prelude::future::LocalBoxFuture;
+use std::future::{ready, Ready};
+
+pub struct AuthData;
+
+impl<S, B> Transform<S, ServiceRequest> for AuthData
+where
+    S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
+    S::Future: 'static,
+    B: 'static,
+{
+    type Response = ServiceResponse<B>;
+    type Error = Error;
+    type InitError = ();
+    type Transform = AuthenticatedMiddleware<S>;
+    type Future = Ready<Result<Self::Transform, Self::InitError>>;
+
+    fn new_transform(&self, service: S) -> Self::Future {
+        ready(Ok(AuthenticatedMiddleware { service }))
+    }
+}
+
+pub struct AuthenticatedMiddleware<S> {
+    service: S,
+}
+
+impl<S, B> Service<ServiceRequest> for AuthenticatedMiddleware<S>
+where
+    S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
+    S::Future: 'static,
+    B: 'static,
+{
+    type Response = ServiceResponse<B>;
+    type Error = Error;
+    type Future = LocalBoxFuture<'static, Result<Self::Response, Self::Error>>;
+
+    forward_ready!(service);
+
+    fn call(&self, req: ServiceRequest) -> Self::Future {
+        println!("AUTH MW");
+        let fut = self.service.call(req);
+        Box::pin(async move {
+            let res = fut.await?;
+            println!("RESP");
+            Ok(res)
+        })
+    }
+}

src/middleware/mod.rs

+mod authentication;
+pub use authentication::*;