mod prepare_tests;

#[tokio::test]
async fn test_create_listener() -> Result<(), Box<dyn std::error::Error>> {
    let mut client = prepare_tests::prepare_test().await?;
    let mut listener = client.create_listener().await?;
    listener
        .add_entity_listener("swid:entity:n38SnDi9UbFLGVBMz2N9N")
        .await?;
    let entity = client
        .query_for_entity("swid:entity:n38SnDi9UbFLGVBMz2N9N")
        .await?;
    client
        .upsert_one(&entity, genius_core_client::CollisionStrategy::Overwrite)
        .await?;
    //let event = listener.next().await?;
    //dbg!(event);
    Ok(())
}