use crate::structures::BaseTestsBuildup;
use serde::{Deserialize, Serialize};
use solrstice::AsyncSolrCloudClient;
// use solrstice::SolrSingleServerHost;
// use solrstice::SolrBasicAuth;
// use solrstice::SolrServerContextBuilder;
use serial_test::parallel;
use solrstice::Error;
use solrstice::SelectQuery;
use solrstice::{DeleteQuery, UpdateQuery};
use std::path::Path;

#[derive(Serialize, Deserialize, Debug)]
struct TestData {
    id: String,
}

#[tokio::test]
#[parallel]
pub async fn example() -> Result<(), Error> {
    let config = BaseTestsBuildup::new().await;

    //Create a solr client. You can also use a list of zookeeper hosts instead of a single server.
    // let context = SolrServerContextBuilder::new(SolrSingleServerHost::new("http://localhost:8983"))
    //     .with_auth(SolrBasicAuth::new("solr", Some("SolrRocks")))
    //     .build();
    let context = config.context;
    let client = AsyncSolrCloudClient::new(context);

    let _ = client.delete_collection("example_collection").await;
    let _ = client.delete_config("example_config").await;

    // Upload config
    client
        .upload_config("example_config", Path::new(&config.config_path))
        .await?;
    // client
    //     .upload_config("example_config", Path::new("/path/to/config"))
    //     .await?;

    // Create collection
    client
        .create_collection("example_collection", "example_config", 1, 1)
        .await?;

    // Index document
    let docs = vec![TestData {
        id: "example_document".to_string(),
    }];
    client
        .index(&UpdateQuery::new(), "example_collection", docs.as_slice())
        .await?;

    // Search and retrieve the document
    let docs = client
        .select(
            &SelectQuery::new().fq(["id:example_document"]),
            "example_collection",
        )
        .await?
        .get_docs_response()
        .ok_or("No response provided")?
        .get_docs::<TestData>()?;
    assert_eq!(docs.len(), 1);

    // Delete the document
    client
        .delete(
            &DeleteQuery::new().ids(["example_document"]),
            "example_collection",
        )
        .await?;

    let _ = client.delete_collection("example_collection").await;
    let _ = client.delete_config("example_config").await;
    Ok(())
}