rusty-hub/src/controllers.rs

use actions::{create_subscription, remove_subscription};
use actix_web::{http, HttpRequest, HttpResponse};
use askama::Template;
use url::form_urlencoded;
use utils::{validate_parsed_data, AppState};

#[derive(Template)]
#[template(path = "index.html")]
struct IndexView;

pub fn index(_req: HttpRequest<AppState>) -> HttpResponse {
    HttpResponse::Ok()
        .content_type("text/html")
        .body(IndexView.render().unwrap())
}

pub fn hub(_req: HttpRequest<AppState>, params: String) -> HttpResponse {
    let log = &_req.state().log;
    info!(log, "Received Request");
    debug!(log, "Content: {}", params);
    let parsed_data = form_urlencoded::parse(params.as_bytes());

    if !validate_parsed_data(parsed_data) {
        return HttpResponse::Ok()
            .status(http::StatusCode::from_u16(400).unwrap())
            .finish();
    }

    HttpResponse::Ok().body("Hello World!")
}

#[cfg(test)]
mod tests {
    use super::*;
    use actix_web::actix::{SyncArbiter, System};
    use actix_web::{http, test};
    use diesel::prelude::*;
    use utils::{setup_logging, DbExecutor};

    #[test]
    fn test_index() {
        let _sys = System::new("rusty-hub-test");
        let addr = SyncArbiter::start(1, || {
            DbExecutor(SqliteConnection::establish("test.db").unwrap())
        });

        let resp = index(
            test::TestRequest::with_state(AppState {
                log: setup_logging(),
                db: addr.clone(),
            })
            .finish(),
        );
        assert_eq!(resp.status(), http::StatusCode::OK);
    }

    #[test]
    fn test_hub() {
        let _sys = System::new("rusty-hub-test");
        let addr = SyncArbiter::start(1, || {
            DbExecutor(SqliteConnection::establish("test.db").unwrap())
        });

        let resp = hub(test::TestRequest::with_state(AppState {
            log: setup_logging(),
            db: addr.clone(),
        })
        .finish());
        assert_eq!(resp.status(), http::StatusCode::OK);
    }
}