kellnr-db 6.2.0

use std::collections::BTreeMap;
use std::path::PathBuf;

use chrono::{DateTime, TimeDelta, TimeZone, Utc};
use kellnr_common::crate_data::{CrateData, CrateRegistryDep, CrateVersionData};
use kellnr_common::crate_overview::CrateOverview;
use kellnr_common::index_metadata::IndexMetadata;
use kellnr_common::normalized_name::NormalizedName;
use kellnr_common::original_name::OriginalName;
use kellnr_common::prefetch::Prefetch;
use kellnr_common::publish_metadata::{PublishMetadata, RegistryDep};
use kellnr_common::version::Version;
use kellnr_common::webhook::{Webhook, WebhookEvent};
use kellnr_db::password::hash_pwd;
use kellnr_db::provider::PrefetchState;
use kellnr_db::test_utils::*;
use kellnr_db::{DbProvider, DocQueueEntry};
use kellnr_db_testcontainer::db_test;
use serde_json::json;
mod image;

#[db_test]
async fn get_total_unique_crates_returns_number_of_unique_crates(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate2",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();

    let total_versions = test_db.get_total_crate_versions().await.unwrap();

    assert_eq!(3, total_versions);
}

#[db_test]
async fn get_total_crate_versions_returns_number_of_crate_versions(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate2",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();

    let total_versions = test_db.get_total_crate_versions().await.unwrap();

    assert_eq!(3, total_versions);
}

#[db_test]
async fn get_total_downloads_returns_number_of_total_downloads(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let id1 = test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    let id2 = test_add_crate(
        test_db,
        "crate2",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate_meta(
        test_db,
        id1,
        &Version::try_from("1.1.0").unwrap(),
        &created,
        None,
    )
    .await
    .unwrap();
    test_add_crate_meta(
        test_db,
        id1,
        &Version::try_from("2.0.0").unwrap(),
        &created,
        None,
    )
    .await
    .unwrap();
    test_add_crate_meta(
        test_db,
        id2,
        &Version::try_from("1.1.0").unwrap(),
        &created,
        None,
    )
    .await
    .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate1"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate1"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate1"),
            &Version::from_unchecked_str("2.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate2"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();

    let total_downloads = test_db.get_total_downloads().await.unwrap();

    assert_eq!(4, total_downloads);
}

#[db_test]
async fn get_top_crates_downloads_returns_top_crates_with_downloads(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let crate_id = test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();

    test_add_crate_meta(
        test_db,
        crate_id,
        &Version::try_from("0.1.0").unwrap(),
        &created1,
        None,
    )
    .await
    .unwrap();

    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("mycrate"),
            &Version::from_unchecked_str("0.1.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("mycrate"),
            &Version::from_unchecked_str("0.1.0"),
        )
        .await
        .unwrap();
}

#[db_test]
async fn increase_download_counter_works(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate2",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate3",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate2",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate3",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();

    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate1"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate1"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate1"),
            &Version::from_unchecked_str("2.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate2"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate3"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    test_db
        .increase_download_counter(
            &NormalizedName::from_unchecked_str("crate3"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();

    let tops = test_db.get_top_crates_downloads(2).await.unwrap();
    assert_eq!(2, tops.len());
    assert_eq!(("crate1".to_string(), 3), tops[0]);
    assert_eq!(("crate3".to_string(), 2), tops[1]);
}

#[db_test]
async fn get_max_version_from_id(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 13, 18, 00).unwrap();
    let crate_id1 = test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("0.1.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("0.2.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("0.10.0").unwrap(),
        &created2,
    )
    .await
    .unwrap();

    let version = test_db.get_max_version_from_id(crate_id1).await.unwrap();

    assert_eq!("0.10.0", version.to_string());
}

#[db_test]
async fn get_max_version_from_name(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("0.1.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("0.2.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("0.10.0").unwrap(),
        &created2,
    )
    .await
    .unwrap();

    let version = test_db
        .get_max_version_from_name(&NormalizedName::from_unchecked("acrate".to_string()))
        .await
        .unwrap();

    assert_eq!("0.10.0", version.to_string());
}

#[db_test]
async fn get_crate_summaries_works(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 11, 22, 12).unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("1.1.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "bcrate",
        "admin",
        &Version::try_from("1.1.0").unwrap(),
        &created2,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("1.2.0").unwrap(),
        &created2,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "bcrate",
        "admin",
        &Version::try_from("1.2.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();

    let crates = test_db.get_crate_summaries().await.unwrap();

    assert_eq!(2, crates.len());
    assert_eq!("acrate", crates[0].name);
    assert_eq!("1.2.0", crates[0].max_version);
    assert_eq!(0, crates[0].total_downloads);
    assert_eq!("2020-10-08 11:22:12", crates[0].last_updated);
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 11, 22, 12).unwrap();
    test_add_crate(
        test_db,
        "acrate",
        "admin",
        &Version::try_from("1.3.0").unwrap(),
        &created2,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "bcrate",
        "admin",
        &Version::try_from("1.3.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();

    let crates = test_db.get_crate_summaries().await.unwrap();

    assert_eq!(2, crates.len());
    assert_eq!("acrate", crates[0].name);
    assert_eq!("1.3.0", crates[0].max_version);
    assert_eq!(0, crates[0].total_downloads);
    assert_eq!("2020-10-08 11:22:12", crates[0].last_updated);

    assert_eq!("bcrate", crates[1].name);
    assert_eq!("1.3.0", crates[1].max_version);
    assert_eq!(0, crates[1].total_downloads);
    assert_eq!("2020-10-07 13:18:00", crates[1].last_updated);
}

#[db_test]
async fn get_crate_versions_returns_all_versions(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate1",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate2",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();

    let versions = test_db
        .get_crate_versions(&NormalizedName::from_unchecked_str("crate1"))
        .await
        .unwrap();

    let expected = vec![
        Version::try_from("1.0.0").unwrap(),
        Version::try_from("2.0.0").unwrap(),
    ];
    assert_eq!(expected, versions);
}

#[db_test]
async fn get_crate_versions_with_yanked_version(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();

    // Yank crate version 2.0.0
    test_db
        .yank_crate(
            &NormalizedName::from_unchecked_str("crate"),
            &Version::from_unchecked_str("2.0.0"),
        )
        .await
        .unwrap();

    let versions = test_db
        .get_crate_versions(&NormalizedName::from_unchecked_str("crate"))
        .await
        .unwrap();

    let expected = vec![
        Version::try_from("1.0.0").unwrap(),
        Version::try_from("2.0.0").unwrap(),
    ];
    assert_eq!(expected, versions);
}

#[db_test]
async fn get_crate_versions_for_nonexistant_crate(test_db: &kellnr_db::Database) {
    let outcome = test_db
        .get_crate_versions(&NormalizedName::from_unchecked_str("crate1"))
        .await
        .unwrap();

    assert_eq!(outcome, vec![]);
}

#[db_test]
async fn test_add_crate_meta_and_read_meta(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 11, 22, 12).unwrap();
    let crate_id = test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("0.1.0").unwrap(),
        &created1,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("0.1.1").unwrap(),
        &created2,
    )
    .await
    .unwrap();
    let meta = get_crate_meta_list(test_db, crate_id).await.unwrap();

    assert_eq!(2, meta.len());
    assert_eq!("0.1.0", meta[0].version);
    assert_eq!("0.1.1", meta[1].version);
    assert_eq!(0, meta[0].downloads);
    assert_eq!(0, meta[1].downloads);
    assert_eq!("2020-10-07 13:18:00", meta[0].created);
    assert_eq!("2020-10-08 11:22:12", meta[1].created);
}

#[db_test]
async fn is_owner_true(test_db: &kellnr_db::Database) {
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    assert!(
        test_db
            .is_owner(
                &NormalizedName::from_unchecked("mycrate".to_string()),
                "admin"
            )
            .await
            .unwrap()
    );
}

#[db_test]
async fn is_owner_false(test_db: &kellnr_db::Database) {
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    assert!(
        !test_db
            .is_owner(
                &NormalizedName::from_unchecked("mycrate".to_string()),
                "user"
            )
            .await
            .unwrap()
    );
}

#[db_test]
async fn delete_owner_valid_owner(test_db: &kellnr_db::Database) {
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    test_db.delete_owner("mycrate", "admin").await.unwrap();

    assert!(
        test_db
            .get_crate_owners(&NormalizedName::from_unchecked("mycrate".to_string()))
            .await
            .is_ok()
    );
}

#[db_test]
async fn test_add_crate_duplicate(test_db: &kellnr_db::Database) {
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.1.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    let owners = test_db
        .get_crate_owners(&NormalizedName::from_unchecked("mycrate".to_string()))
        .await
        .unwrap();
    assert_eq!(1, owners.len());
    assert_eq!("admin", owners[0].name);
}

#[db_test]
async fn test_add_crate_different_user(test_db: &kellnr_db::Database) {
    test_db
        .add_user("user", "123", "123", false, false)
        .await
        .unwrap();
    let pm = PublishMetadata::minimal("mycrate", "1.0.0");
    let created = Utc::now();

    test_db
        .add_crate(&pm, "cksum", &created, "admin")
        .await
        .unwrap();
    assert!(
        test_db
            .add_crate(&pm, "cksum", &created, "user")
            .await
            .is_err()
    );
}

#[db_test]
async fn test_add_empty_crate(test_db: &kellnr_db::Database) {
    let created = Utc::now();
    test_db.add_empty_crate("mycrate", &created).await.unwrap();

    let normalized_name = NormalizedName::from(OriginalName::try_from("mycrate").unwrap());
    let crate_id = test_db.get_crate_id(&normalized_name).await.unwrap();
    assert!(crate_id.is_some());
}

#[db_test]
async fn test_add_empty_crate_exists(test_db: &kellnr_db::Database) {
    let created = Utc::now();

    // add a crate with version first
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    // now try to add an empty crate with the same name
    let result = test_db.add_empty_crate("mycrate", &created).await;

    assert!(result.is_err());
}

#[db_test]
async fn get_user_from_token_works(test_db: &kellnr_db::Database) {
    test_db
        .add_auth_token("test1", "mytoken1", "admin")
        .await
        .unwrap();

    let user = test_db.get_user_from_token("mytoken1").await.unwrap();

    assert_eq!("admin", user.name);
}

#[db_test]
async fn get_auth_tokens_returns_all_tokens(test_db: &kellnr_db::Database) {
    test_db
        .add_auth_token("test1", "mytoken1", "admin")
        .await
        .unwrap();
    test_db
        .add_auth_token("test2", "mytoken2", "admin")
        .await
        .unwrap();

    let tokens = test_db.get_auth_tokens("admin").await.unwrap();

    assert_eq!(3, tokens.len());
    assert_eq!("admin", tokens[0].name);
    assert_eq!("test1", tokens[1].name);
    assert_eq!("test2", tokens[2].name);
}

#[db_test]
async fn auth_token_insert_and_read(test_db: &kellnr_db::Database) {
    test_db
        .add_auth_token("test", "mytoken", "admin")
        .await
        .unwrap();
    let user = test_db.get_user_from_token("mytoken").await.unwrap();

    assert_eq!("admin", user.name);
}

#[db_test]
async fn auth_token_insert_and_delete(test_db: &kellnr_db::Database) {
    test_db
        .add_auth_token("test", "mytoken", "admin")
        .await
        .unwrap();

    test_db.delete_auth_token(2).await.unwrap();

    assert!(test_db.get_user_from_token("mytoken").await.is_err());
}

#[db_test]
async fn get_user_from_token_no_token(test_db: &kellnr_db::Database) {
    test_db
        .add_auth_token("test", "mytoken", "admin")
        .await
        .unwrap();

    assert!(test_db.get_user_from_token("wrong_token").await.is_err());
}

#[db_test]
async fn add_auth_token_no_user(test_db: &kellnr_db::Database) {
    assert!(
        test_db
            .add_auth_token("test", "mytoken", "nouser")
            .await
            .is_err()
    );
}

#[db_test]
async fn delete_user_with_sessions(test_db: &kellnr_db::Database) {
    test_db
        .add_user("user", "pwd", "salt", false, false)
        .await
        .unwrap();
    test_db.add_session_token("user", "123").await.unwrap();
    test_db.add_session_token("user", "abc").await.unwrap();

    test_db.delete_user("user").await.unwrap();

    assert!(test_db.validate_session("123").await.is_err());
    assert!(test_db.validate_session("abc").await.is_err());
    assert!(test_db.get_user("user").await.is_err());
}

#[db_test]
async fn add_user_works(test_db: &kellnr_db::Database) {
    test_db
        .add_user("user", "pwd", "salt", false, false)
        .await
        .unwrap();

    let user = test_db.get_user("user").await.unwrap();
    // Compare fields individually since created is dynamic
    assert_eq!(2, user.id);
    assert_eq!("user", user.name);
    assert_eq!(hash_pwd("pwd", "salt"), user.pwd);
    assert_eq!("salt", user.salt);
    assert!(!user.is_admin);
    assert!(!user.is_read_only);
    assert!(!user.created.is_empty());
}

#[db_test]
async fn add_user_duplicate(test_db: &kellnr_db::Database) {
    test_db
        .add_user("user", "pwd", "salt", false, false)
        .await
        .unwrap();

    assert!(
        test_db
            .add_user("user", "pwd", "salt", false, false)
            .await
            .is_err()
    );
}

#[db_test]
async fn get_users_works(test_db: &kellnr_db::Database) {
    test_db
        .add_user("user", "123", "abc", false, false)
        .await
        .unwrap();

    let users = test_db.get_users().await.unwrap();

    assert_eq!(2, users.len());
    assert_eq!("admin", users[0].name);
    assert_eq!("user", users[1].name);
}

#[db_test]
async fn get_user_existing_user(test_db: &kellnr_db::Database) {
    let users = test_db.get_user("admin").await.unwrap();

    assert_eq!("admin", users.name);
}

#[db_test]
async fn get_user_no_user(test_db: &kellnr_db::Database) {
    assert!(test_db.get_user("no_user").await.is_err());
}

#[db_test]
async fn change_pwd_works(test_db: &kellnr_db::Database) {
    test_db.change_pwd("admin", "abc").await.unwrap();

    assert!(test_db.authenticate_user("admin", "abc").await.is_ok());
}

#[db_test]
async fn is_crate_group_user_works(test_db: &kellnr_db::Database) {
    let group = "group";
    let user = "user";
    test_db
        .add_user(user, "pwd", "salt", false, false)
        .await
        .unwrap();
    test_db.add_group(group).await.unwrap();
    test_db.add_group_user(group, user).await.unwrap();
    let id = test_add_crate(
        test_db,
        "foobar",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();
    let crate_name_norm = NormalizedName::from_unchecked_str("foobar");
    test_db
        .add_crate_group(&crate_name_norm, group)
        .await
        .unwrap();

    let res = test_db.is_crate_group_user(&crate_name_norm, user).await;
    assert!(res.is_ok_and(|user_is_in_crate_group| user_is_in_crate_group));
}

#[db_test]
async fn clean_db_after_time(test_db: &kellnr_db::Database) {
    test_db
        .add_session_token("admin", "session_token")
        .await
        .unwrap();
    let (name, _) = test_db.validate_session("session_token").await.unwrap();
    assert_eq!("admin", name);

    let duration = std::time::Duration::from_secs(2);
    std::thread::sleep(duration);
    clean_db(test_db, std::time::Duration::from_secs(1))
        .await
        .unwrap();

    assert!(test_db.validate_session("session_token").await.is_err());
}

#[db_test]
async fn delete_session_token_works(test_db: &kellnr_db::Database) {
    test_db
        .add_session_token("admin", "session_token")
        .await
        .unwrap();
    let (name, _) = test_db.validate_session("session_token").await.unwrap();
    assert_eq!("admin", name);

    test_db.delete_session_token("session_token").await.unwrap();

    let r = test_db.validate_session("session_token");
    assert!(r.await.is_err());
}

#[db_test]
async fn delete_session_token_no_token(test_db: &kellnr_db::Database) {
    test_db
        .add_session_token("admin", "session_token")
        .await
        .unwrap();
    let (name, _) = test_db.validate_session("session_token").await.unwrap();
    assert_eq!("admin", name);

    let r = test_db.delete_session_token("no_token").await;

    assert!(r.is_ok());
}

#[db_test]
async fn get_name_valid_user_and_token(test_db: &kellnr_db::Database) {
    test_db
        .add_session_token("admin", "session_token")
        .await
        .unwrap();
    let (name, _) = test_db.validate_session("session_token").await.unwrap();

    assert_eq!("admin", name);
}

#[db_test]
async fn get_session_no_session_in_db(test_db: &kellnr_db::Database) {
    assert!(test_db.validate_session("no_session_token").await.is_err());
}

#[db_test]
async fn bootstrap_db_inserts_admin(test_db: &kellnr_db::Database) {
    let admin = test_db.get_user("admin").await.unwrap();
    assert_eq!(1, admin.id);
    assert_eq!("admin", admin.name);
    assert_eq!(
        "81d40d94fee4fb4eeb1a21bb7adb93c06aad35b929c1a2b024ae33b3a9b79e23",
        admin.pwd
    );
    assert_eq!("salt", admin.salt);
    assert!(admin.is_admin);
}

#[db_test]
async fn authenticate_user_valid(test_db: &kellnr_db::Database) {
    assert!(test_db.authenticate_user("admin", "123").await.is_ok());
}

#[db_test]
async fn authenticate_user_unknown_user(test_db: &kellnr_db::Database) {
    assert!(test_db.authenticate_user("unknown", "123").await.is_err());
}

#[db_test]
async fn authenticate_user_wrong_pwd(test_db: &kellnr_db::Database) {
    assert!(test_db.authenticate_user("admin", "abc").await.is_err());
}

#[db_test]
async fn crate_version_exists_with_existing_version(test_db: &kellnr_db::Database) {
    let id = test_add_crate(
        test_db,
        "foobar",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();
    assert!(
        test_add_crate_meta(test_db, id, "1.0.0", &Utc::now(), None)
            .await
            .is_err()
    );
}

#[db_test]
async fn crate_version_exists_with_no_existing_version(test_db: &kellnr_db::Database) {
    let id = test_add_crate(
        test_db,
        "foobar",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    assert!(!test_db.crate_version_exists(id, "2.0.0").await.unwrap());
}

#[db_test]
async fn get_total_unique_crates_returns_correct_number(test_db: &kellnr_db::Database) {
    let _ = test_add_crate(
        test_db,
        "foobar",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    let _ = test_add_crate(
        test_db,
        "bar",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    assert_eq!(2, test_db.get_total_unique_crates().await.unwrap());
}

#[db_test]
async fn add_and_get_doc_queue_entries(test_db: &kellnr_db::Database) {
    test_db
        .add_doc_queue(
            &NormalizedName::from_unchecked("my_crate".to_string()),
            &Version::try_from("1.0.0").unwrap(),
            &PathBuf::from("/tmp/foo"),
        )
        .await
        .unwrap();
    test_db
        .add_doc_queue(
            &NormalizedName::from_unchecked("my_crate2".to_string()),
            &Version::try_from("2.0.0").unwrap(),
            &PathBuf::from("/tmp/bar"),
        )
        .await
        .unwrap();

    let queue_entries = test_db.get_doc_queue().await.unwrap();

    assert_eq!(
        DocQueueEntry {
            id: 1,
            normalized_name: NormalizedName::from_unchecked("my_crate".to_string()),
            version: "1.0.0".to_string(),
            path: PathBuf::from("/tmp/foo")
        },
        queue_entries[0]
    );

    assert_eq!(
        DocQueueEntry {
            id: 2,
            normalized_name: NormalizedName::from_unchecked("my_crate2".to_string()),
            version: "2.0.0".to_string(),
            path: PathBuf::from("/tmp/bar")
        },
        queue_entries[1]
    );
}

#[db_test]
async fn delete_doc_queue_entry(test_db: &kellnr_db::Database) {
    test_db
        .add_doc_queue(
            &NormalizedName::from_unchecked("my_crate".to_string()),
            &Version::try_from("1.0.0").unwrap(),
            &PathBuf::from("/tmp/foo"),
        )
        .await
        .unwrap();
    test_db
        .add_doc_queue(
            &NormalizedName::from_unchecked("my_crate2".to_string()),
            &Version::try_from("2.0.0").unwrap(),
            &PathBuf::from("/tmp/bar"),
        )
        .await
        .unwrap();

    let queue_entries = test_db.get_doc_queue().await.unwrap();
    assert_eq!(2, queue_entries.len());
    test_db.delete_doc_queue(1).await.unwrap();

    let queue_entries = test_db.get_doc_queue().await.unwrap();
    assert_eq!(1, queue_entries.len());
    assert_eq!(
        DocQueueEntry {
            id: 2,
            normalized_name: NormalizedName::from_unchecked("my_crate2".to_string()),
            version: "2.0.0".to_string(),
            path: PathBuf::from("/tmp/bar")
        },
        queue_entries[0]
    );
}

#[db_test]
async fn delete_crate_one_of_multiple_versions(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("3.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    let total_versions_before = test_db.get_total_crate_versions().await.unwrap();

    test_db
        .delete_crate(
            &NormalizedName::from_unchecked("crate".to_string()),
            &Version::try_from("2.0.0").unwrap(),
        )
        .await
        .unwrap();

    let summaries = get_crate_meta_list(test_db, 1).await.unwrap();
    let krate = test_db
        .get_crate_id(&NormalizedName::from_unchecked("crate".to_string()))
        .await
        .unwrap();
    assert_eq!(3, total_versions_before);
    assert_eq!(2, summaries.len());
    assert_eq!("1.0.0", summaries[0].version);
    assert_eq!("3.0.0", summaries[1].version);
    assert_eq!(1, krate.unwrap());
}

#[db_test]
async fn delete_crate_max_version(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("3.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    let total_versions_before = test_db.get_total_crate_versions().await.unwrap();

    test_db
        .delete_crate(
            &NormalizedName::from_unchecked("crate".to_string()),
            &Version::try_from("3.0.0").unwrap(),
        )
        .await
        .unwrap();

    let crate_metas = get_crate_meta_list(test_db, 1).await.unwrap();
    let krate = test_db
        .get_crate_id(&NormalizedName::from_unchecked("crate".to_string()))
        .await
        .unwrap()
        .unwrap();
    let max_version = test_db.get_max_version_from_id(krate).await.unwrap();
    assert_eq!(3, total_versions_before);
    assert_eq!(2, crate_metas.len());
    assert_eq!("1.0.0", crate_metas[0].version);
    assert_eq!("2.0.0", crate_metas[1].version);
    assert_eq!("2.0.0", max_version.to_string());
    assert_eq!(1, krate);
}

#[db_test]
async fn delete_crate_only_versions(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
    )
    .await
    .unwrap();
    let total_versions_before = test_db.get_total_crate_versions().await.unwrap();

    test_db
        .delete_crate(
            &NormalizedName::from_unchecked("crate".to_string()),
            &Version::try_from("1.0.0").unwrap(),
        )
        .await
        .unwrap();

    let summaries = get_crate_meta_list(test_db, 1).await.unwrap();
    let krate = test_db
        .get_crate_id(&NormalizedName::from_unchecked("crate".to_string()))
        .await
        .unwrap();
    assert_eq!(1, total_versions_before);
    assert_eq!(0, summaries.len());
    assert!(krate.is_none());
}

#[db_test]
async fn search_in_crate_name_found_match(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created_string = created.format("%Y-%m-%d %H:%M:%S").to_string();
    test_add_crate_with_downloads(
        test_db,
        "crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(4),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "crate",
        "admin",
        &Version::try_from("2.2.0").unwrap(),
        &created,
        Some(4),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "foo_crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(3),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "foo_crate",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
        Some(3),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "crate_foo",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(5),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "crate_foo",
        "admin",
        &Version::try_from("3.0.0").unwrap(),
        &created,
        Some(5),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "no_match",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(1),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "no_match",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
        Some(1),
    )
    .await
    .unwrap();
    let expected = vec![
        CrateOverview {
            name: "crate".to_string(),
            version: "2.2.0".to_string(),
            date: created_string.clone(),
            total_downloads: 8,
            ..CrateOverview::default()
        },
        CrateOverview {
            name: "crate_foo".to_string(),
            version: "3.0.0".to_string(),
            date: created_string.clone(),
            total_downloads: 10,
            ..CrateOverview::default()
        },
        CrateOverview {
            name: "foo_crate".to_string(),
            version: "2.0.0".to_string(),
            date: created_string.clone(),
            total_downloads: 6,
            ..CrateOverview::default()
        },
    ];

    let search_results = test_db.search_in_crate_name("crate", false).await.unwrap();

    assert_eq!(expected, search_results);
}

#[db_test]
async fn get_crate_overview_list(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created_string = created.format("%Y-%m-%d %H:%M:%S").to_string();
    test_add_crate_with_downloads(
        test_db,
        "crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(4),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "crate",
        "admin",
        &Version::try_from("2.2.0").unwrap(),
        &created,
        Some(4),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "foo_crate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(3),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "foo_crate",
        "admin",
        &Version::try_from("2.0.0").unwrap(),
        &created,
        Some(3),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "crate_foo",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &created,
        Some(5),
    )
    .await
    .unwrap();
    test_add_crate_with_downloads(
        test_db,
        "crate_foo",
        "admin",
        &Version::try_from("3.0.0").unwrap(),
        &created,
        Some(5),
    )
    .await
    .unwrap();
    let expected = vec![
        CrateOverview {
            name: "crate".to_string(),
            version: "2.2.0".to_string(),
            date: created_string.clone(),
            total_downloads: 8,
            ..CrateOverview::default()
        },
        CrateOverview {
            name: "crate_foo".to_string(),
            version: "3.0.0".to_string(),
            date: created_string.clone(),
            total_downloads: 10,
            ..CrateOverview::default()
        },
        CrateOverview {
            name: "foo_crate".to_string(),
            version: "2.0.0".to_string(),
            date: created_string.clone(),
            total_downloads: 6,
            ..CrateOverview::default()
        },
    ];

    let overview_list = test_db.get_crate_overview_list(10, 0, false).await.unwrap();

    assert_eq!(expected, overview_list);
}

#[db_test]
async fn add_crate_and_get_crate_data(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created_string = created.format("%Y-%m-%d %H:%M:%S").to_string();
    let pm1_v1 = PublishMetadata {
        name: "crate1".to_string(),
        vers: "1.0.0".to_string(),
        deps: vec![
            RegistryDep {
                name: "dep1".to_string(),
                version_req: "5.0.0".to_string(),
                features: Some(vec!["feature1".to_string(), "feature2".to_string()]),
                optional: false,
                default_features: true,
                target: Some("normal".to_string()),
                kind: Some("kind1".to_string()),
                registry: Some("registry1".to_string()),
                explicit_name_in_toml: Some("explicit_name_in_toml1".to_string()),
            },
            RegistryDep {
                name: "dep2".to_string(),
                version_req: "6.0.0".to_string(),
                features: Some(vec!["feature3".to_string(), "feature4".to_string()]),
                optional: true,
                default_features: false,
                target: Some("normal".to_string()),
                kind: Some("kind2".to_string()),
                registry: Some("registry2".to_string()),
                explicit_name_in_toml: None,
            },
        ],
        features: BTreeMap::from_iter(vec![
            ("feature1".to_string(), vec!["dep1".to_string()]),
            ("feature2".to_string(), vec!["dep1".to_string()]),
        ]),
        authors: Some(vec!["author1".to_string(), "author2".to_string()]),
        description: Some("description1".to_string()),
        documentation: Some("documentation1".to_string()),
        homepage: Some("homepage1".to_string()),
        readme: Some("readme1".to_string()),
        readme_file: Some("readme_file1".to_string()),
        keywords: vec!["keyword1".to_string(), "keyword2".to_string()],
        categories: vec!["category1".to_string(), "category2".to_string()],
        license: Some("license1".to_string()),
        license_file: Some("license_file1".to_string()),
        repository: Some("repository1".to_string()),
        badges: None,
        links: Some("links1".to_string()),
        rust_version: None,
    };
    let pm1_v2 = PublishMetadata {
        name: "crate1".to_string(),
        vers: "2.0.0".to_string(),
        deps: vec![
            RegistryDep {
                name: "dep1".to_string(),
                version_req: "5.0.0".to_string(),
                features: Some(vec!["feature1".to_string(), "feature2".to_string()]),
                optional: false,
                default_features: true,
                target: Some("normal".to_string()),
                kind: Some("kind1".to_string()),
                registry: Some("registry1".to_string()),
                explicit_name_in_toml: Some("explicit_name_in_toml1".to_string()),
            },
            RegistryDep {
                name: "dep2".to_string(),
                version_req: "6.0.0".to_string(),
                features: Some(vec!["feature3".to_string(), "feature4".to_string()]),
                optional: true,
                default_features: false,
                target: Some("normal".to_string()),
                kind: Some("kind2".to_string()),
                registry: Some("registry2".to_string()),
                explicit_name_in_toml: None,
            },
        ],
        features: BTreeMap::from_iter(vec![
            ("feature1".to_string(), vec!["dep1".to_string()]),
            ("feature2".to_string(), vec!["dep1".to_string()]),
        ]),
        authors: Some(vec![
            "author1".to_string(),
            "author2".to_string(),
            "author3".to_string(),
        ]),
        description: Some("description2".to_string()),
        documentation: Some("documentation2".to_string()),
        homepage: Some("homepage2".to_string()),
        readme: Some("readme2".to_string()),
        readme_file: Some("readme_file2".to_string()),
        keywords: vec!["keyword1".to_string()],
        categories: vec!["category1".to_string(), "category4".to_string()],
        license: Some("license2".to_string()),
        license_file: Some("license_file2".to_string()),
        repository: Some("repository2".to_string()),
        badges: None,
        links: Some("links2".to_string()),
        rust_version: None,
    };
    let pm2_v1 = PublishMetadata {
        name: "crate2".to_string(),
        vers: "3.0.0".to_string(),
        deps: vec![
            RegistryDep {
                name: "dep1".to_string(),
                version_req: "5.0.0".to_string(),
                features: Some(vec!["feature1".to_string(), "feature2".to_string()]),
                optional: false,
                default_features: true,
                target: Some("normal".to_string()),
                kind: Some("kind1".to_string()),
                registry: Some("registry1".to_string()),
                explicit_name_in_toml: Some("explicit_name_in_toml1".to_string()),
            },
            RegistryDep {
                name: "dep2".to_string(),
                version_req: "6.0.0".to_string(),
                features: Some(vec!["feature3".to_string(), "feature4".to_string()]),
                optional: true,
                default_features: false,
                target: Some("normal".to_string()),
                kind: Some("kind2".to_string()),
                registry: Some("registry2".to_string()),
                explicit_name_in_toml: None,
            },
        ],
        features: BTreeMap::from_iter(vec![
            ("feature1".to_string(), vec!["dep1".to_string()]),
            ("feature2".to_string(), vec!["dep1".to_string()]),
        ]),
        authors: Some(vec!["author1".to_string(), "author2".to_string()]),
        description: Some("description1".to_string()),
        documentation: Some("documentation1".to_string()),
        homepage: Some("homepage1".to_string()),
        readme: Some("readme1".to_string()),
        readme_file: Some("readme_file1".to_string()),
        keywords: vec!["keyword1".to_string(), "keyword2".to_string()],
        categories: vec!["category1".to_string(), "category2".to_string()],
        license: Some("license1".to_string()),
        license_file: Some("license_file1".to_string()),
        repository: Some("repository1".to_string()),
        badges: None,
        links: Some("links1".to_string()),
        rust_version: None,
    };
    let pm2_v2 = PublishMetadata {
        name: "crate2".to_string(),
        vers: "4.0.0".to_string(),
        deps: vec![RegistryDep {
            name: "dep1".to_string(),
            version_req: "5.0.0".to_string(),
            features: Some(vec!["feature1".to_string(), "feature2".to_string()]),
            optional: false,
            default_features: true,
            target: Some("normal".to_string()),
            kind: Some("kind1".to_string()),
            registry: Some("registry1".to_string()),
            explicit_name_in_toml: Some("explicit_name_in_toml1".to_string()),
        }],
        ..Default::default()
    };
    test_db
        .add_user("owner1", "pwd1", "salt1", false, false)
        .await
        .unwrap();
    test_db
        .add_user("owner2", "pwd2", "salt2", false, false)
        .await
        .unwrap();

    // Test, if adding a new crate with multiple versions works as expected
    test_db
        .add_crate(&pm1_v1, "cksum1_1", &created, "owner1")
        .await
        .unwrap();
    test_db
        .add_owner(
            &NormalizedName::from_unchecked("crate1".to_string()),
            "owner2",
        )
        .await
        .unwrap();

    let crate_data1_v1 = test_db
        .get_crate_data(&NormalizedName::from_unchecked("crate1".to_string()))
        .await
        .unwrap();
    let etag1_v1 = test_db.get_prefetch_data("crate1").await.unwrap().etag;

    assert_eq!(
        CrateData {
            name: pm1_v1.name.clone(),
            owners: vec!["owner1".to_string(), "owner2".to_string()],
            max_version: pm1_v1.vers.clone(),
            total_downloads: 0,
            last_updated: created_string.clone(),
            homepage: pm1_v1.homepage.clone(),
            description: pm1_v1.description.clone(),
            repository: pm1_v1.repository.clone(),
            categories: pm1_v1.categories.clone(),
            keywords: pm1_v1.keywords.clone(),
            authors: pm1_v1.authors.clone().unwrap(),
            versions: vec![CrateVersionData {
                version: pm1_v1.vers.clone(),
                created: created_string.clone(),
                downloads: 0,
                documentation: pm1_v1.documentation.clone(),
                readme: pm1_v1.readme.clone(),
                license: pm1_v1.license.clone(),
                license_file: pm1_v1.license_file.clone(),
                dependencies: pm1_v1
                    .deps
                    .clone()
                    .into_iter()
                    .map(CrateRegistryDep::from)
                    .collect(),
                checksum: "cksum1_1".to_string(),
                features: pm1_v1.features.clone(),
                yanked: false,
                links: pm1_v1.links.clone(),
                v: 1,
            }],
        },
        crate_data1_v1
    );

    test_db
        .add_crate(&pm1_v2, "cksum1_2", &created, "owner1")
        .await
        .unwrap();

    let crate_data1_v2 = test_db
        .get_crate_data(&NormalizedName::from_unchecked("crate1".to_string()))
        .await
        .unwrap();
    let etag1_v2 = test_db.get_prefetch_data("crate1").await.unwrap().etag;

    assert_eq!(
        CrateData {
            name: pm1_v2.name.clone(),
            owners: vec!["owner1".to_string(), "owner2".to_string()],
            max_version: pm1_v2.vers.clone(),
            total_downloads: 0,
            last_updated: created_string.clone(),
            homepage: pm1_v2.homepage.clone(),
            description: pm1_v2.description.clone(),
            repository: pm1_v2.repository.clone(),
            categories: pm1_v2.categories.clone(),
            keywords: pm1_v2.keywords.clone(),
            authors: pm1_v2.authors.clone().unwrap(),
            versions: vec![
                CrateVersionData {
                    version: pm1_v2.vers.clone(),
                    created: created_string.clone(),
                    downloads: 0,
                    readme: pm1_v2.readme.clone(),
                    license: pm1_v2.license.clone(),
                    license_file: pm1_v2.license_file.clone(),
                    documentation: pm1_v2.documentation.clone(),
                    dependencies: pm1_v2
                        .deps
                        .into_iter()
                        .map(CrateRegistryDep::from)
                        .collect(),
                    checksum: "cksum1_2".to_string(),
                    features: pm1_v2.features.clone(),
                    yanked: false,
                    links: pm1_v2.links.clone(),
                    v: 1,
                },
                CrateVersionData {
                    version: pm1_v1.vers.clone(),
                    created: created_string.clone(),
                    downloads: 0,
                    readme: pm1_v1.readme.clone(),
                    license: pm1_v1.license.clone(),
                    license_file: pm1_v1.license_file.clone(),
                    documentation: pm1_v1.documentation.clone(),
                    dependencies: pm1_v1
                        .deps
                        .into_iter()
                        .map(CrateRegistryDep::from)
                        .collect(),
                    checksum: "cksum1_1".to_string(),
                    features: pm1_v1.features.clone(),
                    yanked: false,
                    links: pm1_v1.links.clone(),
                    v: 1,
                }
            ],
        },
        crate_data1_v2
    );

    // Check that the etag changed with newly published version
    assert_ne!(etag1_v1, etag1_v2);

    test_db
        .add_crate(&pm2_v1, "cksum2_1", &created, "owner2")
        .await
        .unwrap();

    let crate_data2_v1 = test_db
        .get_crate_data(&NormalizedName::from_unchecked("crate2".to_string()))
        .await
        .unwrap();

    assert_eq!(
        CrateData {
            name: pm2_v1.name.clone(),
            owners: vec!["owner2".to_string()],
            max_version: pm2_v1.vers.clone(),
            total_downloads: 0,
            last_updated: created_string.clone(),
            homepage: pm2_v1.homepage.clone(),
            description: pm2_v1.description.clone(),
            repository: pm2_v1.repository.clone(),
            categories: pm2_v1.categories.clone(),
            keywords: pm2_v1.keywords.clone(),
            authors: pm2_v1.authors.clone().unwrap(),
            versions: vec![CrateVersionData {
                version: pm2_v1.vers.clone(),
                created: created_string.clone(),
                downloads: 0,
                readme: pm2_v1.readme.clone(),
                license: pm2_v1.license.clone(),
                license_file: pm2_v1.license_file.clone(),
                documentation: pm2_v1.documentation.clone(),
                dependencies: pm2_v1
                    .deps
                    .clone()
                    .into_iter()
                    .map(CrateRegistryDep::from)
                    .collect(),
                checksum: "cksum2_1".to_string(),
                features: pm2_v1.features.clone(),
                yanked: false,
                links: pm2_v1.links.clone(),
                v: 1,
            }],
        },
        crate_data2_v1
    );

    test_db
        .add_crate(&pm2_v2, "cksum2_2", &created, "owner2")
        .await
        .unwrap();

    let crate_data2_v2 = test_db
        .get_crate_data(&NormalizedName::from_unchecked("crate2".to_string()))
        .await
        .unwrap();

    assert_eq!(
        CrateData {
            name: pm2_v2.name.clone(),
            owners: vec!["owner2".to_string()],
            max_version: pm2_v2.vers.clone(),
            total_downloads: 0,
            last_updated: created_string.clone(),
            homepage: pm2_v2.homepage.clone(),
            description: pm2_v2.description.clone(),
            repository: pm2_v2.repository.clone(),
            categories: Vec::default(),
            keywords: Vec::default(),
            authors: Vec::default(),
            versions: vec![
                CrateVersionData {
                    version: pm2_v2.vers.clone(),
                    created: created_string.clone(),
                    downloads: 0,
                    readme: pm2_v2.readme.clone(),
                    license: pm2_v2.license.clone(),
                    license_file: pm2_v2.license_file.clone(),
                    documentation: pm2_v2.documentation.clone(),
                    dependencies: pm2_v2
                        .deps
                        .into_iter()
                        .map(CrateRegistryDep::from)
                        .collect(),
                    checksum: "cksum2_2".to_string(),
                    features: BTreeMap::default(),
                    yanked: false,
                    links: pm2_v2.links.clone(),
                    v: 1,
                },
                CrateVersionData {
                    version: pm2_v1.vers.clone(),
                    created: created_string.clone(),
                    downloads: 0,
                    documentation: pm2_v1.documentation.clone(),
                    license: pm2_v1.license.clone(),
                    license_file: pm2_v1.license_file.clone(),
                    dependencies: pm2_v1
                        .deps
                        .into_iter()
                        .map(CrateRegistryDep::from)
                        .collect(),
                    checksum: "cksum2_1".to_string(),
                    features: pm2_v1.features.clone(),
                    yanked: false,
                    links: pm2_v1.links.clone(),
                    v: 1,
                    readme: pm2_v1.readme.clone(),
                }
            ],
        },
        crate_data2_v2
    );
}

#[db_test]
async fn update_docs_link(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let pm = PublishMetadata::minimal("crate1", "1.0.0");
    test_db
        .add_user("owner1", "pwd", "salt", false, false)
        .await
        .unwrap();
    test_db
        .add_crate(&pm, "cksum1_1", &created, "owner1")
        .await
        .unwrap();

    let crate_before = test_db
        .get_crate_data(&NormalizedName::from_unchecked("crate1".to_string()))
        .await
        .unwrap();
    assert_eq!(crate_before.versions[0].documentation, None);

    test_db
        .update_docs_link(
            &NormalizedName::from_unchecked("crate1".to_string()),
            &Version::try_from("1.0.0").unwrap(),
            "https://docs.rs/crate1/1.0.0/crate1/",
        )
        .await
        .unwrap();

    let crate_after = test_db
        .get_crate_data(&NormalizedName::from_unchecked("crate1".to_string()))
        .await
        .unwrap();
    assert_eq!(
        crate_after.versions[0].documentation,
        Some("https://docs.rs/crate1/1.0.0/crate1/".to_string())
    );
}

#[db_test]
async fn get_prefetch_data_with_minimal_data(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::from_unchecked_str("1.0.0"),
        &created1,
    )
    .await
    .unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::from_unchecked_str("2.0.0"),
        &created2,
    )
    .await
    .unwrap();

    let prefetch_data = test_db.get_prefetch_data("crate").await.unwrap();

    // etag changes with pubtime (set to Utc::now()), so just verify it's not empty
    assert!(!prefetch_data.etag.is_empty());
    assert_eq!(
        created2.format("%Y-%m-%d %H:%M:%S").to_string(),
        prefetch_data.last_modified
    );
    // data length varies with pubtime, just verify data is present and can be parsed
    assert!(!prefetch_data.data.is_empty());
    let json_str = String::from_utf8(prefetch_data.data).unwrap();
    assert!(json_str.contains(r#""name":"crate""#));
}

#[db_test]
async fn get_prefetch_data_with_full_data(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 13, 18, 00).unwrap();
    let created3 = Utc.with_ymd_and_hms(2020, 10, 9, 13, 18, 00).unwrap();
    let pm1 = PublishMetadata {
        name: "crate".to_string(),
        vers: "1.0.0".to_string(),
        deps: vec![RegistryDep {
            name: "dep1".to_string(),
            version_req: "1.0.0".to_string(),
            features: Some(vec!["feat1".to_string(), "feat2".to_string()]),
            optional: true,
            default_features: false,
            target: Some("normal".to_string()),
            kind: Some("kind1".to_string()),
            registry: Some("registry1".to_string()),
            explicit_name_in_toml: None,
        }],
        features: BTreeMap::from_iter(vec![
            ("feature1".to_string(), vec!["dep1".to_string()]),
            ("feature2".to_string(), vec!["dep1".to_string()]),
        ]),
        authors: Some(vec!["author1".to_string(), "author2".to_string()]),
        description: Some("description1".to_string()),
        homepage: Some("homepage1".to_string()),
        documentation: Some("documentation1".to_string()),
        readme: Some("readme1".to_string()),
        repository: Some("repository1".to_string()),
        keywords: vec!["keyword1".to_string()],
        categories: vec!["category1".to_string()],
        license: Some("license1".to_string()),
        license_file: Some("license_file1".to_string()),
        badges: None,
        links: Some("links1".to_string()),
        readme_file: Some("readme_file1".to_string()),
        rust_version: None,
    };
    let pm2 = PublishMetadata {
        name: "crate".to_string(),
        vers: "2.0.0".to_string(),
        deps: vec![RegistryDep {
            name: "dep2".to_string(),
            version_req: "2.0.0".to_string(),
            features: Some(vec!["feat2".to_string(), "feat3".to_string()]),
            optional: true,
            default_features: false,
            target: Some("normal".to_string()),
            kind: Some("kind2".to_string()),
            registry: Some("registry2".to_string()),
            explicit_name_in_toml: None,
        }],
        features: BTreeMap::from_iter(vec![
            ("feature3".to_string(), vec!["dep2".to_string()]),
            ("feature4".to_string(), vec!["dep2".to_string()]),
        ]),
        authors: Some(vec!["author2".to_string(), "author3".to_string()]),
        description: Some("description2".to_string()),
        homepage: Some("homepage2".to_string()),
        documentation: Some("documentation2".to_string()),
        readme: Some("readme2".to_string()),
        repository: Some("repository2".to_string()),
        keywords: vec!["keyword2".to_string()],
        categories: vec!["category2".to_string()],
        license: Some("license2".to_string()),
        license_file: Some("license_file2".to_string()),
        badges: None,
        links: Some("links2".to_string()),
        readme_file: Some("readme_file2".to_string()),
        rust_version: None,
    };
    let pm3 = PublishMetadata {
        name: "crate".to_string(),
        vers: "3.0.0".to_string(),
        deps: vec![RegistryDep {
            name: "dep3".to_string(),
            version_req: "3.0.0".to_string(),
            features: Some(vec!["feat3".to_string(), "feat4".to_string()]),
            optional: true,
            default_features: false,
            target: Some("target3".to_string()),
            kind: Some("kind3".to_string()),
            registry: Some("registry3".to_string()),
            explicit_name_in_toml: None,
        }],
        features: BTreeMap::from_iter(vec![
            ("feature5".to_string(), vec!["dep3".to_string()]),
            ("feature6".to_string(), vec!["dep3".to_string()]),
        ]),
        authors: Some(vec!["author3".to_string(), "author4".to_string()]),
        description: Some("description3".to_string()),
        homepage: Some("homepage3".to_string()),
        documentation: Some("documentation3".to_string()),
        readme: Some("readme3".to_string()),
        repository: Some("repository3".to_string()),
        keywords: vec!["keyword3".to_string()],
        categories: vec!["category3".to_string()],
        license: Some("license3".to_string()),
        license_file: Some("license_file3".to_string()),
        badges: None,
        links: Some("links3".to_string()),
        readme_file: Some("readme_file3".to_string()),
        rust_version: None,
    };

    test_db
        .add_crate(&pm1, "cksum1_1", &created1, "admin")
        .await
        .unwrap();
    test_db
        .add_crate(&pm2, "cksum2_1", &created2, "admin")
        .await
        .unwrap();
    test_db
        .add_crate(&pm3, "cksum3_1", &created3, "admin")
        .await
        .unwrap();

    let prefetch_data = test_db.get_prefetch_data("crate").await.unwrap();

    // data length and etag vary with pubtime (set to Utc::now()), just verify data is present
    assert!(!prefetch_data.data.is_empty());
    assert_eq!(
        created3.format("%Y-%m-%d %H:%M:%S").to_string(),
        prefetch_data.last_modified
    );
    // etag changes with pubtime, so just verify it's not empty
    assert!(!prefetch_data.etag.is_empty());
    // Verify the data contains expected crate info
    let json_str = String::from_utf8(prefetch_data.data).unwrap();
    assert!(json_str.contains(r#""name":"crate""#));
    assert!(json_str.contains(r#""vers":"1.0.0""#));
    assert!(json_str.contains(r#""vers":"2.0.0""#));
    assert!(json_str.contains(r#""vers":"3.0.0""#));
}

#[db_test]
async fn delete_updates_etag(test_db: &kellnr_db::Database) {
    let created1 = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    let created2 = Utc.with_ymd_and_hms(2020, 10, 8, 13, 18, 00).unwrap();
    let pm1 = PublishMetadata {
        name: "crate".to_string(),
        vers: "1.0.0".to_string(),
        deps: vec![RegistryDep {
            name: "dep1".to_string(),
            version_req: "1.0.0".to_string(),
            features: Some(vec!["feat1".to_string(), "feat2".to_string()]),
            optional: true,
            default_features: false,
            target: Some("normal".to_string()),
            kind: Some("kind1".to_string()),
            registry: Some("registry1".to_string()),
            explicit_name_in_toml: None,
        }],
        features: BTreeMap::from_iter(vec![
            ("feature1".to_string(), vec!["dep1".to_string()]),
            ("feature2".to_string(), vec!["dep1".to_string()]),
        ]),
        authors: Some(vec!["author1".to_string(), "author2".to_string()]),
        description: Some("description1".to_string()),
        homepage: Some("homepage1".to_string()),
        documentation: Some("documentation1".to_string()),
        readme: Some("readme1".to_string()),
        repository: Some("repository1".to_string()),
        keywords: vec!["keyword1".to_string()],
        categories: vec!["category1".to_string()],
        license: Some("license1".to_string()),
        license_file: Some("license_file1".to_string()),
        badges: None,
        links: Some("links1".to_string()),
        readme_file: Some("readme_file1".to_string()),
        rust_version: None,
    };
    let pm2 = PublishMetadata {
        name: "crate".to_string(),
        vers: "2.0.0".to_string(),
        deps: vec![RegistryDep {
            name: "dep2".to_string(),
            version_req: "2.0.0".to_string(),
            features: Some(vec!["feat2".to_string(), "feat3".to_string()]),
            optional: true,
            default_features: false,
            target: Some("normal".to_string()),
            kind: Some("kind2".to_string()),
            registry: Some("registry2".to_string()),
            explicit_name_in_toml: None,
        }],
        features: BTreeMap::from_iter(vec![
            ("feature3".to_string(), vec!["dep2".to_string()]),
            ("feature4".to_string(), vec!["dep2".to_string()]),
        ]),
        authors: Some(vec!["author2".to_string(), "author3".to_string()]),
        description: Some("description2".to_string()),
        homepage: Some("homepage2".to_string()),
        documentation: Some("documentation2".to_string()),
        readme: Some("readme2".to_string()),
        repository: Some("repository2".to_string()),
        keywords: vec!["keyword2".to_string()],
        categories: vec!["category2".to_string()],
        license: Some("license2".to_string()),
        license_file: Some("license_file2".to_string()),
        badges: None,
        links: Some("links2".to_string()),
        readme_file: Some("readme_file2".to_string()),
        rust_version: None,
    };
    test_db
        .add_crate(&pm1, "cksum1_1", &created1, "admin")
        .await
        .unwrap();
    test_db
        .add_crate(&pm2, "cksum2_1", &created2, "admin")
        .await
        .unwrap();
    let prefetch_data = test_db.get_prefetch_data("crate").await.unwrap();
    let etag_before = prefetch_data.etag;

    test_db
        .delete_crate(
            &NormalizedName::from_unchecked("crate".to_string()),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();
    let prefetch_data = test_db.get_prefetch_data("crate").await.unwrap();
    let etag_after = prefetch_data.etag;

    assert_ne!(etag_before, etag_after);
}

#[db_test]
async fn is_cratesio_cache_up_to_date_not_found(test_db: &kellnr_db::Database) {
    let prefetch_state = test_db
        .is_cratesio_cache_up_to_date(
            &NormalizedName::from(OriginalName::try_from("crate").unwrap()),
            Some("etag".to_string()),
            Some("last_modified".to_string()),
        )
        .await
        .unwrap();

    assert_eq!(PrefetchState::NotFound, prefetch_state);
}

#[db_test]
async fn is_cratesio_cache_up_to_date_up_to_date(test_db: &kellnr_db::Database) {
    test_db
        .add_cratesio_prefetch_data(
            &OriginalName::from_unchecked("crate".to_string()),
            "etag",
            "last_modified",
            None,
            &[IndexMetadata {
                name: "crate".to_string(),
                vers: "1.0.0".to_string(),
                deps: vec![],
                cksum: "cksum".to_string(),
                features: BTreeMap::default(),
                yanked: false,
                links: None,
                pubtime: None,
                v: Some(1),
                features2: None,
            }],
        )
        .await
        .unwrap();

    let prefetch_state = test_db
        .is_cratesio_cache_up_to_date(
            &NormalizedName::from(OriginalName::try_from("crate").unwrap()),
            Some("etag".to_string()),
            Some("last_modified".to_string()),
        )
        .await
        .unwrap();

    assert_eq!(PrefetchState::UpToDate, prefetch_state);
}

#[db_test]
async fn is_cratesio_cache_up_to_date_needs_update(test_db: &kellnr_db::Database) {
    let indices1 = vec![IndexMetadata {
        name: "crate".to_string(),
        vers: "1.0.0".to_string(),
        deps: vec![],
        cksum: "cksum".to_string(),
        features: BTreeMap::default(),
        yanked: false,
        links: None,
        pubtime: None,
        v: Some(1),
        features2: None,
    }];
    test_db
        .add_cratesio_prefetch_data(
            &OriginalName::from_unchecked("crate".to_string()),
            "etag",
            "last_modified",
            None,
            &indices1,
        )
        .await
        .unwrap();
    let indices2 = vec![
        IndexMetadata {
            name: "crate".to_string(),
            vers: "1.0.0".to_string(),
            deps: vec![],
            cksum: "cksum".to_string(),
            features: BTreeMap::default(),
            yanked: true,
            links: None,
            pubtime: None,
            v: Some(1),
            features2: None,
        },
        IndexMetadata {
            name: "crate".to_string(),
            vers: "2.0.0".to_string(),
            deps: vec![],
            cksum: "cksum".to_string(),
            features: BTreeMap::default(),
            yanked: false,
            links: None,
            pubtime: None,
            v: Some(1),
            features2: None,
        },
    ];
    test_db
        .add_cratesio_prefetch_data(
            &OriginalName::from_unchecked("crate".to_string()),
            "etag2",
            "last_modified2",
            None,
            &indices2,
        )
        .await
        .unwrap();

    let expected_prefetch = Prefetch {
        data: IndexMetadata::serialize_indices(&indices2)
            .unwrap()
            .into_bytes(),
        etag: "etag2".to_string(),
        last_modified: "last_modified2".to_string(),
    };

    // Old etag
    let prefetch_state = test_db
        .is_cratesio_cache_up_to_date(
            &NormalizedName::from(OriginalName::try_from("crate").unwrap()),
            Some("old_etag".to_string()),
            Some("last_modified".to_string()),
        )
        .await
        .unwrap();

    assert_eq!(
        PrefetchState::NeedsUpdate(expected_prefetch.clone()),
        prefetch_state
    );

    // Old last_modified
    let prefetch_state = test_db
        .is_cratesio_cache_up_to_date(
            &NormalizedName::from(OriginalName::try_from("crate").unwrap()),
            Some("etag".to_string()),
            Some("old_last_modified".to_string()),
        )
        .await
        .unwrap();
    assert_eq!(
        PrefetchState::NeedsUpdate(expected_prefetch.clone()),
        prefetch_state
    );

    // Old etag and last_modified
    let prefetch_state = test_db
        .is_cratesio_cache_up_to_date(
            &NormalizedName::from(OriginalName::try_from("crate").unwrap()),
            Some("etag".to_string()),
            Some("old_last_modified".to_string()),
        )
        .await
        .unwrap();
    assert_eq!(
        PrefetchState::NeedsUpdate(expected_prefetch),
        prefetch_state
    );
}

#[db_test]
async fn un_yank_crate(test_db: &kellnr_db::Database) {
    let created = Utc.with_ymd_and_hms(2020, 10, 7, 13, 18, 00).unwrap();
    test_add_crate(
        test_db,
        "crate",
        "admin",
        &Version::from_unchecked_str("1.0.0"),
        &created,
    )
    .await
    .unwrap();

    // Yank the version
    test_db
        .yank_crate(
            &NormalizedName::from_unchecked_str("crate"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();

    // Test if yanked
    let ci = test_db
        .get_crate_data(&NormalizedName::from_unchecked_str("crate"))
        .await
        .unwrap();
    assert!(
        ci.versions
            .iter()
            .find(|v| v.version == "1.0.0")
            .unwrap()
            .yanked
    );

    // Unyank the version
    test_db
        .unyank_crate(
            &NormalizedName::from_unchecked_str("crate"),
            &Version::from_unchecked_str("1.0.0"),
        )
        .await
        .unwrap();

    // Test if unyanked
    let ci = test_db
        .get_crate_data(&NormalizedName::from_unchecked_str("crate"))
        .await
        .unwrap();
    assert!(
        !ci.versions
            .iter()
            .find(|v| v.version == "1.0.0")
            .unwrap()
            .yanked
    );
}

#[db_test]
async fn test_get_last_updated_crate_works(test_db: &kellnr_db::Database) {
    let created1 = DateTime::parse_from_rfc3339("2021-01-01T00:00:00Z").unwrap();
    let created1 = DateTime::<Utc>::from(created1);

    test_add_crate(
        test_db,
        "my_crate",
        "admin",
        &Version::from_unchecked_str("1.0.0"),
        &created1,
    )
    .await
    .unwrap();

    let created2 = DateTime::parse_from_rfc3339("2021-02-01T00:00:00Z").unwrap();
    let created2 = DateTime::<Utc>::from(created2);

    test_add_crate(
        test_db,
        "my_crate",
        "admin",
        &Version::from_unchecked_str("2.0.0"),
        &created2,
    )
    .await
    .unwrap();

    let created3 = DateTime::parse_from_rfc3339("2021-03-01T00:00:00Z").unwrap();
    let created3 = DateTime::<Utc>::from(created3);

    test_add_crate(
        test_db,
        "my_crate2",
        "admin",
        &Version::from_unchecked_str("1.0.0"),
        &created3,
    )
    .await
    .unwrap();

    let last_updated = test_db.get_last_updated_crate().await.unwrap().unwrap();

    assert_eq!("my_crate2", last_updated.0.to_string());
}

#[db_test]
async fn test_get_last_updated_crate_empty(test_db: &kellnr_db::Database) {
    let last_updated = test_db.get_last_updated_crate().await.unwrap();

    assert_eq!(None, last_updated);
}

#[db_test]
async fn test_get_total_unique_cached_crates_works(test_db: &kellnr_db::Database) {
    test_add_cached_crate(test_db, "my_crate", "1.0.0")
        .await
        .unwrap();

    test_add_cached_crate(test_db, "my_crate", "2.0.0")
        .await
        .unwrap();

    test_add_cached_crate(test_db, "my_crate2", "1.0.0")
        .await
        .unwrap();

    let unique_cached_crates = test_db.get_total_unique_cached_crates().await.unwrap();

    assert_eq!(2, unique_cached_crates);
}

#[db_test]
async fn test_get_total_cached_crate_versions_works(test_db: &kellnr_db::Database) {
    test_add_cached_crate(test_db, "my_crate", "1.0.0")
        .await
        .unwrap();

    test_add_cached_crate(test_db, "my_crate", "2.0.0")
        .await
        .unwrap();

    test_add_cached_crate(test_db, "my_crate2", "1.0.0")
        .await
        .unwrap();

    let unique_cached_versions = test_db.get_total_cached_crate_versions().await.unwrap();

    assert_eq!(3, unique_cached_versions);
}

#[db_test]
async fn test_get_total_cached_downloads_works(test_db: &kellnr_db::Database) {
    test_add_cached_crate_with_downloads(test_db, "my_crate", "1.0.0", 10)
        .await
        .unwrap();

    test_add_cached_crate_with_downloads(test_db, "my_crate", "2.0.0", 20)
        .await
        .unwrap();

    test_add_cached_crate_with_downloads(test_db, "my_crate2", "1.0.0", 30)
        .await
        .unwrap();

    let total_downloads = test_db.get_total_cached_downloads().await.unwrap();

    assert_eq!(60, total_downloads);
}

#[db_test]
async fn test_add_crate_rollback(test_db: &kellnr_db::Database) {
    test_add_crate(
        test_db,
        "mycrate",
        "admin",
        &Version::try_from("1.0.0").unwrap(),
        &Utc::now(),
    )
    .await
    .unwrap();

    let result = test_add_crate(
        test_db,
        "mycrate",
        "user",
        &Version::try_from("2.0.0").unwrap(),
        &Utc::now(),
    )
    .await;
    // The result is err, as the `user` does not exist.
    assert!(result.is_err());

    let max_version = test_db
        .get_max_version_from_name(&NormalizedName::from_unchecked("mycrate".to_string()))
        .await
        .unwrap();

    // The version should not be bumped to 2.0.0 as the db transaction is not committed.
    assert_eq!("1.0.0", max_version.to_string());
}

#[db_test]
async fn test_delete_crate_rollback(test_db: &kellnr_db::Database) {
    let version = Version::try_from("1.0.0").unwrap();
    let crate_id = test_add_crate(test_db, "mycrate", "admin", &version, &Utc::now())
        .await
        .unwrap();

    // Manually delete crate index entry so the crate delete method fails in the middle.
    test_delete_crate_index(test_db, crate_id).await.unwrap();

    let normalized_name = NormalizedName::from_unchecked("mycrate".to_string());
    let result = test_db.delete_crate(&normalized_name, &version).await;
    assert!(result.is_err());

    let meta = test_db.get_crate_meta_list(&normalized_name).await.unwrap();
    // Crate meta is deleted first, but the actions should be rolled back on error.
    assert_eq!(1, meta.len());
}

#[db_test]
async fn test_register_webhook(test_db: &kellnr_db::Database) {
    let webhook = Webhook {
        id: None,
        event: WebhookEvent::CrateYank,
        callback_url: "https://my-other-service:8005".to_string(),
        name: Some("myWebhook".to_string()),
    };
    let id = test_db.register_webhook(webhook).await.unwrap();
    let entry = test_db.get_webhook(&id).await.unwrap();

    assert_eq!(WebhookEvent::CrateYank, entry.event);
    assert_eq!(
        "https://my-other-service:8005".to_string(),
        entry.callback_url
    );
    assert_eq!(Some("myWebhook".to_string()), entry.name);
}

#[db_test]
async fn test_delete_webhook(test_db: &kellnr_db::Database) {
    let webhook = Webhook {
        id: None,
        event: WebhookEvent::CrateYank,
        callback_url: "https://my-other-service:8005".to_string(),
        name: None,
    };
    let id = test_db.register_webhook(webhook).await.unwrap();

    let result = test_db.delete_webhook(&id).await;
    assert!(result.is_ok());

    let result = test_db.get_webhook(&id).await;
    assert!(result.is_err());
}

#[db_test]
async fn test_get_all_webhooks(test_db: &kellnr_db::Database) {
    let mut ids = vec![];
    for i in 0..10 {
        ids.push(
            test_db
                .register_webhook(Webhook {
                    id: None,
                    event: if i % 2 == 0 {
                        WebhookEvent::CrateYank
                    } else {
                        WebhookEvent::CrateAdd
                    },
                    callback_url: String::new(),
                    name: None,
                })
                .await
                .unwrap(),
        );
    }

    let entries = test_db.get_all_webhooks().await.unwrap();

    assert_eq!(10, entries.len());
    for id in &ids {
        assert!(entries.iter().any(|a| a.id.as_ref().unwrap() == id));
    }
}

#[db_test]
async fn test_add_webhook_queue(test_db: &kellnr_db::Database) {
    let webhook = Webhook {
        id: None,
        event: WebhookEvent::CrateUpdate,
        callback_url: "https://update-service.io".to_string(),
        name: None,
    };
    let webhook_id = test_db.register_webhook(webhook).await.unwrap();

    let payload = json!({"test": "data"});
    let result = test_db
        .add_webhook_queue(WebhookEvent::CrateUpdate, payload.clone())
        .await;
    assert!(result.is_ok());

    // New entry should always be `pending`
    let entries = test_db
        .get_pending_webhook_queue_entries(Utc::now())
        .await
        .unwrap();

    assert_eq!(entries[0].payload, payload);
    assert_eq!(
        entries[0].callback_url,
        "https://update-service.io".to_string()
    );
    assert_eq!(entries[0].last_attempt, None);
}

#[db_test]
async fn test_get_pending_webhook_queue_entries(test_db: &kellnr_db::Database) {
    let webhook = Webhook {
        id: None,
        event: WebhookEvent::CrateUpdate,
        callback_url: String::new(),
        name: None,
    };
    let webhook_id = test_db.register_webhook(webhook).await.unwrap();

    let payloads = (0..3).map(|i| json!(i)).collect::<Vec<_>>();
    for payload in &payloads {
        test_db
            .add_webhook_queue(WebhookEvent::CrateUpdate, payload.clone())
            .await
            .unwrap();
    }

    let entries = test_db
        .get_pending_webhook_queue_entries(Utc::now())
        .await
        .unwrap();

    // Do not rely on indexing as DB order is not deterministic
    let entry_1 = entries.iter().find(|a| a.payload == json!(1)).unwrap();

    test_db
        .update_webhook_queue(
            &entry_1.id,
            entry_1.next_attempt,
            Utc::now() + TimeDelta::minutes(15),
        )
        .await
        .unwrap();

    // Schedule one of the entries for a future time.
    let entries = test_db
        .get_pending_webhook_queue_entries(Utc::now())
        .await
        .unwrap();

    assert_eq!(2, entries.len());
    assert!(!entries.iter().any(|a| a.payload == json!(1)));
}

#[db_test]
async fn test_delete_webhook_queue(test_db: &kellnr_db::Database) {
    let webhook = Webhook {
        id: None,
        event: WebhookEvent::CrateUpdate,
        callback_url: String::new(),
        name: None,
    };
    let webhook_id = test_db.register_webhook(webhook).await.unwrap();

    let payload = json!(0);
    let result = test_db
        .add_webhook_queue(WebhookEvent::CrateUpdate, payload.clone())
        .await;
    assert!(result.is_ok());

    let entry = &test_db
        .get_pending_webhook_queue_entries(Utc::now())
        .await
        .unwrap()[0];

    test_db.delete_webhook_queue(&entry.id).await.unwrap();
    let entries = test_db
        .get_pending_webhook_queue_entries(Utc::now())
        .await
        .unwrap();
    assert!(entries.is_empty());
}

#[db_test]
async fn pubtime_stored_and_serialized_correctly(test_db: &kellnr_db::Database) {
    // Add a crate - pubtime will be set to current time by IndexMetadata::from_reg_meta
    let created = Utc.with_ymd_and_hms(2025, 1, 2, 9, 5, 7).unwrap();
    test_add_crate(
        test_db,
        "testcrate",
        "admin",
        &Version::from_unchecked_str("1.0.0"),
        &created,
    )
    .await
    .unwrap();

    // Retrieve the prefetch data
    let prefetch_data = test_db.get_prefetch_data("testcrate").await.unwrap();

    // Convert the bytes to string
    let json_str = String::from_utf8(prefetch_data.data).unwrap();

    // Verify pubtime is present in JSON
    assert!(
        json_str.contains(r#""pubtime":""#),
        "Expected pubtime field to be present in JSON: {json_str}"
    );

    // Verify pubtime does NOT contain fractional seconds (no dot after seconds)
    // Valid: "pubtime":"2025-01-02T09:05:07Z"
    // Invalid: "pubtime":"2025-01-02T09:05:07.123456Z"
    assert!(
        !json_str.contains(r".000") || !json_str.contains("pubtime"),
        "pubtime should not contain fractional seconds, got: {json_str}"
    );

    // Deserialize and verify the pubtime value is preserved
    let deserialized: IndexMetadata = serde_json::from_str(&json_str).unwrap();
    assert!(
        deserialized.pubtime.is_some(),
        "Expected pubtime to be Some after deserialization"
    );

    // Verify the deserialized pubtime can be formatted back to the same format
    let pubtime = deserialized.pubtime.unwrap();
    let formatted = pubtime.format("%Y-%m-%dT%H:%M:%SZ").to_string();
    assert!(
        json_str.contains(&format!(r#""pubtime":"{formatted}""#)),
        "Expected pubtime '{formatted}' in JSON: {json_str}"
    );
}