reqwest & sqlx

[dependencies]
tokio = { version = "1", features = ["full"] }
reqwest = { version = "0.12", features = ["json", "rustls-tls"] }
sqlx = { version = "0.8", features = ["runtime-tokio-rustls", "postgres", "macros"] }
serde = { version = "1.0", features = ["derive"] }

use serde::Deserialize;
 
#[derive(Deserialize)]
struct Health { status: String }
 
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let health: Health = reqwest::get("https://httpbin.org/status/200")
        .await?
        .error_for_status()?
        .json()
        .await
        .unwrap_or(Health { status: "ok".into() });
    println!("{}", health.status);
    Ok(())
}

use sqlx::PgPool;
 
async fn count_users(pool: &PgPool) -> sqlx::Result<i64> {
    let row: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM users")
        .fetch_one(pool)
        .await?;
    Ok(row.0)
}

async fn notify_webhook(url: &str, body: &str) -> reqwest::Result<()> {
    reqwest::Client::new()
        .post(url)
        .header("content-type", "application/json")
        .body(body.to_string())
        .send()
        .await?
        .error_for_status()?;
    Ok(())
}

// Requires DATABASE_URL at build for query! macro
let user = sqlx::query_as!(User, "SELECT id, email FROM users WHERE id = $1", id)
    .fetch_one(pool)
    .await?;