// file: crates/ksp-store-postgres-lib/unit_tests/migration_v003.rs
// version: 3

fn applied(version: i64, name: &str, checksum: &str) -> super::AppliedMigration {
    return super::AppliedMigration { checksum: checksum.to_owned(), name: name.to_owned(), version };
}

#[test]
fn pre_003_v003_extension_preserves_frozen_history_and_advances_current_version() {
    assert_eq!(crate::current_migration_version_v003(), 3);
    assert_eq!(super::V000_CHECKSUM, "d29068b8c13b9dc0cc9ef6aaadd0fa12d41e0fe4c56541a1118c4bfc846a1450");
    assert_eq!(super::V001_CHECKSUM, "31488cda2f08f3f46c4cdbdbb6c18c243662fada02eac4487040c8735d72cc51");
    assert_eq!(super::V002_CHECKSUM, "ff21605ed45f7ab4c0f92bbb692700b4118a9488b04d50a31d259ac59bdb550e");
    let prefix = [
        applied(0, "bootstrap", super::V000_CHECKSUM),
        applied(1, "raw_transaction", super::V001_CHECKSUM),
        applied(2, "raw_account_state", super::V002_CHECKSUM),
    ];
    assert_eq!(super::validate_history(&prefix).ok(), std::option::Option::Some(3));
    return;
}

#[test]
fn pre_003_v003_resource_checksum_and_history_are_stable() {
    let checksum = super::migration_checksum_v003();
    assert_eq!(checksum, "3c9cf41877c96944a378abb41ee7a8d8ab7f99fc6dc2bb7a26c295cf8f9fc914");
    let full = [
        applied(0, "bootstrap", super::V000_CHECKSUM),
        applied(1, "raw_transaction", super::V001_CHECKSUM),
        applied(2, "raw_account_state", super::V002_CHECKSUM),
        applied(3, super::V003_NAME, checksum.as_str()),
    ];
    assert_eq!(super::validate_history(&full).ok(), std::option::Option::Some(4));
    return;
}

#[test]
fn pre_003_v003_history_rejects_divergence_and_future_versions() {
    let checksum = super::migration_checksum_v003();
    let divergent = [
        applied(0, "bootstrap", super::V000_CHECKSUM),
        applied(1, "raw_transaction", super::V001_CHECKSUM),
        applied(2, "raw_account_state", super::V002_CHECKSUM),
        applied(3, super::V003_NAME, "changed"),
    ];
    let divergent_result = super::validate_history(&divergent);
    assert_eq!(divergent_result.err().map(|value| return value.kind()), std::option::Option::Some(crate::PostgresBackendErrorKind::MigrationMismatch));
    let future = [
        applied(0, "bootstrap", super::V000_CHECKSUM),
        applied(1, "raw_transaction", super::V001_CHECKSUM),
        applied(2, "raw_account_state", super::V002_CHECKSUM),
        applied(3, super::V003_NAME, checksum.as_str()),
        applied(4, "future", "future"),
    ];
    let future_result = super::validate_history(&future);
    assert_eq!(future_result.err().map(|value| return value.kind()), std::option::Option::Some(crate::PostgresBackendErrorKind::SchemaNewer));
    let direct_future = [
        applied(0, "bootstrap", super::V000_CHECKSUM),
        applied(1, "raw_transaction", super::V001_CHECKSUM),
        applied(2, "raw_account_state", super::V002_CHECKSUM),
        applied(4, "future", "future"),
    ];
    let direct_future_result = super::validate_history(&direct_future);
    assert_eq!(direct_future_result.err().map(|value| return value.kind()), std::option::Option::Some(crate::PostgresBackendErrorKind::SchemaNewer),);
    return;
}

#[test]
fn pre_003_v003_bootstrap_uses_legacy_engine_only_before_v002_and_absorbs_completed_v003_race() {
    assert!(super::legacy_bootstrap_required(std::option::Option::None));
    assert!(super::legacy_bootstrap_required(std::option::Option::Some(0)));
    assert!(super::legacy_bootstrap_required(std::option::Option::Some(1)));
    assert!(!super::legacy_bootstrap_required(std::option::Option::Some(2)));
    assert!(!super::legacy_bootstrap_required(std::option::Option::Some(3)));
    assert!(super::legacy_schema_newer_is_completed_v003(std::option::Option::Some(3)));
    assert!(!super::legacy_schema_newer_is_completed_v003(std::option::Option::Some(2)));
    assert!(!super::legacy_schema_newer_is_completed_v003(std::option::Option::Some(4)));
    assert!(super::v003_apply_allowed(false, false));
    assert!(super::v003_apply_allowed(false, true));
    assert!(super::v003_apply_allowed(true, true));
    assert!(!super::v003_apply_allowed(true, false));
    return;
}