use std::sync::Arc;

use crate::test_both_dbs;

use super::{CreateProcessedStripeEventParams, Database};

test_both_dbs!(
    test_already_processed_stripe_event,
    test_already_processed_stripe_event_postgres,
    test_already_processed_stripe_event_sqlite
);

async fn test_already_processed_stripe_event(db: &Arc<Database>) {
    let unprocessed_event_id = "evt_1PiJOuRxOf7d5PNaw2zzWiyO".to_string();
    let processed_event_id = "evt_1PiIfMRxOf7d5PNakHrAUe8P".to_string();

    db.create_processed_stripe_event(&CreateProcessedStripeEventParams {
        stripe_event_id: processed_event_id.clone(),
        stripe_event_type: "customer.created".into(),
        stripe_event_created_timestamp: 1722355968,
    })
    .await
    .unwrap();

    assert!(
        db.already_processed_stripe_event(&processed_event_id)
            .await
            .unwrap(),
        "Expected {processed_event_id} to already be processed"
    );

    assert!(
        !db.already_processed_stripe_event(&unprocessed_event_id)
            .await
            .unwrap(),
        "Expected {unprocessed_event_id} to be unprocessed"
    );
}