//!
//! This test is also an example of the basic use the library.
//! The client side is limited to the body of the `run_test` function.
//!
//! This test:
//!
//!   1. Creates a new JVM instance
//!   1. Connects to a JMX server using the specified instance
//!   2. Fetch two specific JMX attributes
//!
extern crate j4rs;
extern crate jmx;

use std::process::Command;
use std::thread;
use std::time::Duration;

use j4rs::JvmBuilder;

use jmx::MBeanAddress;
use jmx::MBeanClient;
use jmx::MBeanClientOptions;
use jmx::MBeanClientTrait;


static JMX_PORT: u16 = 1617;


#[test]
fn with_jvm() {
    // Start the server and wait for it to be up.
    let mut server = Command::new("java")
        .arg("-Dcom.sun.management.jmxremote")
        .arg(format!("-Dcom.sun.management.jmxremote.port={}", JMX_PORT))
        .arg("-Dcom.sun.management.jmxremote.authenticate=false")
        .arg("-Dcom.sun.management.jmxremote.ssl=false")
        .arg("TestServer")
        .current_dir("tests/jmxserver")
        .spawn()
        .expect("Could not start JMX server");
    thread::sleep(Duration::from_secs(1));

    run_test();

    // Stop the server once we are done.
    let _ = server.kill();
}

fn run_test() {
    // Create a new JVM instance.
    // Customise the instance as desired.
    // See: https://github.com/astonbitecode/j4rs/blob/master/rust/src/lib.rs#L44
    let jvm = JvmBuilder::new();

    // Create a connection to the remote JMX server.
    let url = MBeanAddress::service_url(format!(
        "service:jmx:rmi://localhost:{}/jndi/rmi://localhost:{}/jmxrmi",
        JMX_PORT, JMX_PORT
    ));
    let options = MBeanClientOptions::default().builder(jvm);
    let server = MBeanClient::connect_with_options(url, options)
        .expect("Failed to connect to the JMX test server");

    // Fetch some attributes from the server.
    let threads: i32 = server.get_attribute("FOO:name=ServerBean", "ThreadCount").unwrap();
    let schema: String = server.get_attribute("FOO:name=ServerBean", "SchemaName").unwrap();
    assert_eq!(threads, 16);
    assert_eq!(schema, "test");
}