#![cfg(all(test, feature = "test_e2e"))]

extern crate chrono;
extern crate env_logger;
extern crate futures;
extern crate hyper;
#[macro_use]
extern crate log;
extern crate azure_sdk_for_rust;
extern crate serde;
extern crate time;
extern crate tokio_core;

use azure_sdk_for_rust::{core::errors::AzureError, service_bus::event_hub::Client};
use time::Duration;
use tokio_core::reactor::Core;

#[test]
fn send_events_to_event_hub() {
    let (mut eh_client, mut core) = create_client().unwrap();

    for i in 0..2 {
        info!("Sending message {}", i);
        send_event(&mut eh_client, &mut core);
    }
}

fn send_event(cli: &mut Client, core: &mut Core) {
    debug!("running send_event");

    let text_to_send = "{ numero: 100, testo: \"sample\" }";
    core.run(cli.send_event(&text_to_send, Duration::hours(1))).unwrap()
}

fn create_client() -> Result<(Client, Core), AzureError> {
    let policy_name = std::env::var("AZURE_POLICY_NAME").expect("Please set AZURE_POLICY_NAME env variable first!");

    let policy_key = std::env::var("AZURE_POLICY_KEY").expect("Please set AZURE_POLICY_KEY env variable first!");

    let service_bus_namespace =
        std::env::var("AZURE_SERVICE_BUS_NAMESPACE").expect("Please set AZURE_SERVICE_BUS_NAMESPACE env variable first!");

    let event_hub_name = std::env::var("AZURE_EVENT_HUB_NAME").expect("Please set AZURE_EVENT_HUB_NAME env variable first!");

    let core = Core::new()?;

    Ok((Client::new(service_bus_namespace, event_hub_name, policy_name, policy_key)?, core))
}