//! This sample showcases execution of stored procedure

use azure_data_cosmos::prelude::*;
use clap::Parser;
use futures::StreamExt;

#[derive(Debug, Parser)]
struct Args {
    /// Cosmos primary key name
    #[clap(env = "COSMOS_PRIMARY_KEY")]
    primary_key: String,
    /// The cosmos account your're using
    #[clap(env = "COSMOS_ACCOUNT")]
    account: String,
    /// The name of the database
    database_name: String,
    /// The name of the collection
    collection_name: String,
    /// The name of the stored procedure
    stored_procedure_name: String,
}

const FUNCTION_BODY: &str = r#"
    function f(personToGreet) {
        var context = getContext();
        var response = context.getResponse();
        response.setBody("Hello, " + personToGreet);
    }
"#;

#[tokio::main]
async fn main() -> azure_core::Result<()> {
    let args = Args::parse();
    let authorization_token = AuthorizationToken::primary_key(args.primary_key)?;

    let collection = CosmosClient::new(args.account.clone(), authorization_token)
        .database_client(args.database_name)
        .collection_client(args.collection_name);
    let stored_procedure = collection.stored_procedure_client(args.stored_procedure_name);

    // List the existing stored procedures
    let list_stored_procedures_response = collection
        .list_stored_procedures()
        .into_stream()
        .next()
        .await
        .unwrap()?;
    println!("list_stored_procedures_response == {list_stored_procedures_response:#?}");

    let create_stored_procedure_response = stored_procedure
        .create_stored_procedure(FUNCTION_BODY)
        .await?;
    println!("create_stored_procedure_response == {create_stored_procedure_response:#?}");

    let execute_stored_procedure_response = stored_procedure
        .execute_stored_procedure::<serde_json::Value>()
        .parameters(["Robert"])
        .await?;

    println!("execute_stored_procedure_response == {execute_stored_procedure_response:#?}");
    println!(
        "Response as JSON:\n{}",
        execute_stored_procedure_response.payload
    );

    let delete_stored_procedure_response = stored_procedure.delete_stored_procedure().await?;
    println!("delete_stored_procedure_response == {delete_stored_procedure_response:#?}");

    Ok(())
}