extern crate azure_core_sdk;
extern crate azure_service_bus_sdk;

extern crate futures;
extern crate hyper;
extern crate hyper_tls;
extern crate tokio;
extern crate tokio_core;

use std::error::Error;

use tokio_core::reactor::Core;
use futures::Future;

use azure_service_bus_sdk::event_hub::Client;

extern crate time;

fn main() {
    code().unwrap();
}

// We run a separate method to use the elegant quotation mark operator.
// A series of unwrap(), unwrap() would have achieved the same result.
fn code() -> Result<(), Box<Error>> {
    // First we retrieve the account name and master key from environment variables.
    // We expect master keys (ie, not resource constrained)
    let service_bus_namespace = std::env::var("AZURE_SERVICE_BUS_NAMESPACE")
        .expect("Set env variable AZURE_SERVICE_BUS_NAMESPACE first!");
    let event_hub_name = std::env::var("AZURE_EVENT_HUB_NAME")
        .expect("Set env variable AZURE_EVENT_HUB_NAME first!");
    let policy_name =
        std::env::var("AZURE_POLICY_NAME").expect("Set env variable AZURE_POLICY_NAME first!");
    let policy_key =
        std::env::var("AZURE_POLICY_KEY").expect("Set env variable AZURE_POLICY_KEY first!");

    let mut core = Core::new()?;

    let mut client = Client::new(
        core.handle(),
        &service_bus_namespace,
        &event_hub_name,
        &policy_name,
        &policy_key,
    );

    let messages = vec![
        "These", "are", "useless", "messages", "provided", "for", "free", "with", "love"
    ];
    println!(
        "Sending the following messages: {:?}. \
         Please note they will be sent out of order!",
        messages
    );

    let mut v = Vec::new();
    for s in messages {
        v.push(client.send_event(s, time::Duration::days(1)).map(move |_| {
            println!("{:?} event sent!", s);
        }))
    }

    let future = futures::future::join_all(v);

    core.run(future)?;

    Ok(())
}