nexus-watcher 0.4.1

use crate::{
    users::utils::{check_member_most_followed, check_member_user_influencer, find_user_details},
    utils::watcher::WatcherTest,
};
use anyhow::Result;
use nexus_common::{
    db::RedisOps,
    models::user::{UserCounts, UserSearch, USER_NAME_KEY_PARTS},
};
use pubky::Keypair;
use pubky_app_specs::{PubkyAppUser, PubkyAppUserLink};

#[tokio_shared_rt::test(shared)]
async fn test_homeserver_user_put_event() -> Result<()> {
    let mut test = WatcherTest::setup().await?;

    let keypair = Keypair::random();

    let user = PubkyAppUser {
        bio: Some("test_homeserver_user_event".to_string()),
        image: Some("pubky://4snwyct86m383rsduhw5xgcxpw7c63j3pq8x4ycqikxgik8y64ro/pub/pubky.app/files/003286NSMY490".to_string()),
        links: Some(vec![PubkyAppUserLink {
            title: "User Event".to_string(),
            url: "pubky://watcher.nexus".to_string(),
        }]),
        name: "Watcher:UserEvent:User".to_string(),
        status: Some("Running Nexus Watcher".to_string()),
    };

    let user_id = test.create_user(&keypair, &user).await?;

    // GRAPH_OP: Assert if the event writes the graph
    // Cannot use UserDetails::from_graph because it indexes also, Sorted:Users:Name and that
    // operation has to be executed in the ingest_user
    let user_details = find_user_details(&user_id).await.unwrap();

    assert_eq!(user_details.name, user.name);
    assert_eq!(user_details.bio, user.bio);
    assert_eq!(user_details.status, user.status);
    assert_eq!(user_details.image, user.image);

    let result_links = user_details.links.unwrap_or_default();
    let expected_links = user.links.unwrap_or_default();
    for (result_link, expected_link) in result_links.iter().zip(expected_links.iter()) {
        assert_eq!(
            result_link.title, expected_link.title,
            "Link titles do not match."
        );
        assert_eq!(
            result_link.url, expected_link.url,
            "Link URLs do not match."
        );
    }

    // CACHE_OP: Check if the event writes in the graph
    // User:Counts:user_id
    let user_counts = UserCounts::get_from_index(&user_id)
        .await
        .unwrap()
        .expect("The new post was not served from Nexus");

    assert_eq!(user_counts.followers, 0);
    assert_eq!(user_counts.tagged, 0);
    assert_eq!(user_counts.posts, 0);

    // Sorted:Users:Name
    let is_member = UserSearch::check_sorted_set_member(
        None,
        &USER_NAME_KEY_PARTS,
        &[&user.name.to_lowercase(), &user_id],
    )
    .await
    .unwrap();

    assert!(is_member.is_some());
    assert_eq!(is_member.unwrap(), 0);

    // influencers score: Sorted:Users:Influencers
    let influencer_score = check_member_user_influencer(&user_id).await.unwrap();
    assert!(influencer_score.is_some());
    assert_eq!(influencer_score.unwrap(), 0);

    // most_followed score: Sorted:Users:MostFollowed
    let influencer_score = check_member_most_followed(&user_id).await.unwrap();
    assert!(influencer_score.is_some());
    assert_eq!(influencer_score.unwrap(), 0);

    // Cleanup
    test.cleanup_user(&user_id).await?;

    // Assert the new user does not exist in Nexus
    // let result = UserView::get_by_id(&user_id, None).await.unwrap();
    // assert!(result.is_none(), "The user should have been deleted");

    Ok(())
}