use std::time::Duration;
use tokio::time::sleep;
use xpress::middleware::body_parser::BodyParser;
use xpress::middleware::serve::ServeStatic;
use xpress::path::Path;
use xpress::Xpress;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut app = Xpress::new();

    app._use_(BodyParser::json()).await;
    app._use_(BodyParser::url_encoded()).await;
    app._use_(ServeStatic::dir("public")).await;

    app.get("/", |_req, mut res| {
        Box::pin(async move {
            let path = Path::new("public");
            res.send_file(path.join("index.html").to_str()).await?;
            Ok(())
        })
    })
    .await?;

    app.post("/", |req, mut res| {
        Box::pin(async move {
            if let Some(body) = req.body {
                println!("RAW: {:?}", body.raw.unwrap());

                if let Some(json_data) = body.json {
                    println!("JSON: {:?}", json_data);
                }

                if let Some(url_encoded_data) = body.url_encoded {
                    println!("URL-ENCODED: {:?}", url_encoded_data);
                }

                let path = Path::new("public");
                res.send_file(path.join("index.html").to_str()).await?;
            } else {
                res.send("No Data!").await?;
            }

            Ok(())
        })
    })
    .await?;

    app.get("/about", |_req, mut res| {
        Box::pin(async move {
            sleep(Duration::from_secs(4)).await;
            res.send("About Page!").await?;
            Ok(())
        })
    })
    .await?;

    app.listen("127.0.0.1:8080", || {
        println!("Server is running on http://localhost:8080");
        Ok(())
    })
    .await?;

    Ok(())
}