use lakewatch::v1::ramps::domain::{Ramp, RampStatus};
use sqlx::PgPool;

#[sqlx::test]
async fn ramps_returns_200_ok(pool: PgPool) {
    let app = crate::helpers::TestApp::spawn(&pool).await;
    let client = reqwest::Client::new();
    let ramps_url = app.url("/v1/ramps");
    println!("{}", ramps_url);
    let response = client
        .get(ramps_url)
        .send()
        .await
        .expect("Failed to execute request");
    assert!(response.status().is_success());
}

#[sqlx::test]
async fn ramps_returns_expected_ramps(pool: PgPool) {
    let app = crate::helpers::TestApp::spawn(&pool).await;
    let mock_ramps = [
        Ramp {
            number: 1,
            name: "Canyon Lake Village".to_string(),
            operator: "Comal County".to_string(),
            address: "569 Skyline Dr, Canyon Lake, TX 78134".to_string(),
            status: RampStatus::Open,
            last_updated: chrono::NaiveDate::from_ymd_opt(2024, 8, 2).unwrap(),
            operating_times: Some("8am - Sunset".to_string()),
        },
        Ramp {
            number: 2,
            name: "Canyon Lake Village West".to_string(),
            operator: "Comal County".to_string(),
            address: "2410 Colleen Dr, Canyon Lake, TX 78133".to_string(),
            status: RampStatus::Closed,
            last_updated: chrono::NaiveDate::from_ymd_opt(2024, 8, 2).unwrap(),
            operating_times: Some("8am - Sunset".to_string()),
        },
    ];
    for ramp in &mock_ramps[..] {
        sqlx::query!(
            r#"INSERT INTO rampdata(
            number,
            name,
            operator,
            address,
            status,
            last_updated,
            operating_times
        ) VALUES (
            $1,
            $2,
            $3,
            $4,
            $5,
            $6,
            $7
        );"#,
            ramp.number,
            ramp.name,
            ramp.operator,
            ramp.address,
            String::from(ramp.status),
            ramp.last_updated,
            ramp.operating_times
        )
        .execute(&pool)
        .await
        .expect("Failed to insert mock data!");
    }
    let client = reqwest::Client::new();
    let ramps_url = app.url("/v1/ramps");
    println!("{}", ramps_url);
    let response = client
        .get(ramps_url)
        .send()
        .await
        .expect("Failed to execute request");
    assert!(response.status().is_success());
    assert_eq!(
        response.headers().get("content-type").unwrap(),
        "application/json"
    );
    let ramps: Vec<Ramp> = serde_json::from_str(
        &response
            .text()
            .await
            .expect("Failed to ready body of response!"),
    )
    .expect("Failed to parse body into json!");

    assert_eq!(ramps[0], mock_ramps[0]);
}