Function main

ch_11/integration-tests/src/main.rs:34–108

()

#[tokio::main]
async fn main() -> Result<(), handle_errors::Error> {
    dotenvy::dotenv().ok();
    let config = config::Config::new().expect("Config can't be set");

    let s = Command::new("sqlx")
        .arg("database")
        .arg("drop")
        .arg("--database-url")
        .arg(format!("postgres://{}:{}/{}", config.db_host, config.db_port, config.db_name))
        .arg("-y")
        .output()
        .expect("sqlx command failed to start");

    io::stdout().write_all(&s.stderr).unwrap();

    let s = Command::new("sqlx")
            .arg("database")
            .arg("create")
            .arg("--database-url")
            .arg(format!("postgres://{}:{}/{}", config.db_host, config.db_port, config.db_name))
            .output()
            .expect("sqlx command failed to start");

    // Exdcute DB commands to drop and create a new test database
    io::stdout().write_all(&s.stderr).unwrap();

    // set up a new store instance with a db connection pool
    let store = setup_store(&config).await?;

    // start the server and listen for a sender signal to shut it down
    let handler = oneshot(store).await;

    // create a test user to use throughout the tests
    let u = User {
        email: "test@email.com".to_string(),
        password: "password".to_string(),
    };

    let token;

    print!("Running register_new_user...");
    let result = std::panic::AssertUnwindSafe(register_new_user(&u)).catch_unwind().await;
    match result {
        Ok(_) => println!("✓"),
        Err(_) => {
            let _ = handler.sender.send(1);
            std::process::exit(1);
        }
    }

    print!("Running login...");
    match std::panic::AssertUnwindSafe(login(u)).catch_unwind().await {
        Ok(t) => {
            token = t;
            println!("✓");
        },
        Err(_) => {
            let _ = handler.sender.send(1);