Testing routing

src/main.rs

@@ -9,13 +9,30 @@ pub struct SpeakRequest {
   text: String,
 }*/
 
-use hyper::server::conn::AddrStream;
-use hyper::{Body, Request, Response, Server};
-use hyper::service::{service_fn, make_service_fn};
 use futures::future::{self, Future};
+use hyper::server::conn::AddrStream;
+use hyper::service::{service_fn, make_service_fn};
+use hyper::{Body, Request, Response, Server};
+use std::env;
 
 type BoxFut = Box<Future<Item=Response<Body>, Error=hyper::Error> + Send>;
 
+const ENV_ROUTE_ONE : &'static str = "ROUTE_ONE";
+const ENV_ROUTE_TWO : &'static str = "ROUTE_TWO";
+
+const ROUTE_ONE_DEFAULT : &'static str = "http://127.0.0.1:12345";
+const ROUTE_TWO_DEFAULT : &'static str = "http://127.0.0.1:3000";
+
+fn get_env_string(env_name: &str, default: &str) -> String {
+  match env::var(env_name).as_ref().ok() {
+    Some(s) => s.to_string(),
+    None => {
+      warn!("Env var '{}' not supplied. Using default '{}'.", env_name, default);
+      default.to_string()
+    },
+  }
+}
+
 fn debug_request(req: Request<Body>) -> BoxFut {
   let body_str = format!("{:?}", req);
   let response = Response::new(Body::from(body_str));
@@ -23,6 +40,11 @@ fn debug_request(req: Request<Body>) -> BoxFut {
 }
 
 fn main() {
+  let route_one = get_env_string(ENV_ROUTE_ONE, ROUTE_ONE_DEFAULT);
+  let route_two = get_env_string(ENV_ROUTE_TWO, ROUTE_TWO_DEFAULT);
+
+  info!("Route one: {}", route_one);
+  info!("Route two: {}", route_two);
 
   // This is our socket address...
   let addr = ([127, 0, 0, 1], 13900).into();
@@ -32,15 +54,11 @@ fn main() {
     let remote_addr = socket.remote_addr();
     service_fn(move |req: Request<Body>| { // returns BoxFut
 
-      if req.uri().path().starts_with("/target/first") {
+      if req.uri().path().starts_with("/first") {
+        return hyper_reverse_proxy::call(remote_addr.ip(), &route_one, req)
 
-        // will forward requests to port 13901
+      } else if req.uri().path().starts_with("/second") {
-        return hyper_reverse_proxy::call(remote_addr.ip(), "http://127.0.0.1:12345", req)
+        return hyper_reverse_proxy::call(remote_addr.ip(), &route_two, req)
-
-      } else if req.uri().path().starts_with("/target/second") {
-
-        // will forward requests to port 13902
-        return hyper_reverse_proxy::call(remote_addr.ip(), "http://127.0.0.1:3000", req)
 
       } else {
         debug_request(req)

src/middlewares.rs

@@ -1,66 +0,0 @@
-//use chrono::{DateTime, Utc};
-//use serde_json;
-
-use hyper::{Body, Request, Response};
-use simple_proxy::proxy::error::MiddlewareError;
-use simple_proxy::proxy::middleware::MiddlewareResult::Next;
-use simple_proxy::proxy::middleware::{Middleware, MiddlewareResult};
-use simple_proxy::proxy::service::{ServiceContext, State};
-
-#[derive(Clone, Default)]
-pub struct Logger;
-
-/// # Panics
-/// May panic if the request state has not been initialized in `before_request`.
-/// e.g If a middleware responded early before the logger in `before_request`.
-impl Middleware for Logger {
-  fn name() -> String {
-    String::from("Logger")
-  }
-
-  fn before_request(
-    &mut self,
-    req: &mut Request<Body>,
-    context: &ServiceContext,
-    state: &State,
-  ) -> Result<MiddlewareResult, MiddlewareError> {
-    info!(
-      "[{}] Starting a {} request to {}",
-      &context.req_id.to_string()[..6],
-      req.method(),
-      req.uri()
-    );
-    //let now = serde_json::to_string(&Utc::now()).expect("[Logger] Cannot serialize DateTime");
-    self.set_state(context.req_id, state, "foo".to_string())?;
-    Ok(Next)
-  }
-
-  fn after_request(
-    &mut self,
-    _res: Option<&mut Response<Body>>,
-    context: &ServiceContext,
-    state: &State,
-  ) -> Result<MiddlewareResult, MiddlewareError> {
-    let start_time = self.get_state(context.req_id, state)?;
-    match start_time {
-      Some(time) => {
-        //let start_time: DateTime<Utc> = serde_json::from_str(&time)?;
-
-        info!(
-          "[{}] Request took {}ms",
-          &context.req_id.to_string()[..6],
-          12345
-          //(Utc::now() - start_time).num_milliseconds()
-        );
-      }
-      None => error!("[Logger] start time not found in state"),
-    }
-    Ok(Next)
-  }
-}
-
-impl Logger {
-  pub fn new() -> Self {
-    Logger {}
-  }
-}