use nakadi_types::subscription::*;
use nakadi_types::RandomFlowId;

use nakadion::api::{ApiClient, SubscriptionApi};

#[cfg(feature = "reqwest")]
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = ApiClient::default_builder().finish_from_env()?;

    let subscription_id = SubscriptionId::from_env()?;

    let subscription = client
        .get_subscription(subscription_id, RandomFlowId)
        .await?;

    println!("Subscription:\n {:#?}\n", subscription);

    let subscription = client
        .get_subscription_cursors(subscription_id, RandomFlowId)
        .await?;

    println!("Committed offsets:\n {:#?}\n", subscription);

    let stats = client
        .get_subscription_stats(subscription_id, false, RandomFlowId)
        .await?;

    println!("Stats:\n {:#?}\n", stats);

    Ok(())
}

#[cfg(not(feature = "reqwest"))]
fn main() {
    println!("Please enable the `reqwest` feature which is a default feature");
}