libmodbus-rs 0.4.3

/// This is an example client,
extern crate libmodbus_rs;

use libmodbus_rs::{Modbus, ModbusClient, ModbusTCP};
use libmodbus_rs::errors::*;


fn test_read_bits(modbus: &Modbus) {
    let address = 1;
    let mut dest = vec![0u8; 100];

    println!("{:?}", modbus.read_bits(address, 1, &mut dest));
}

fn test_reply_exception(modbus: &Modbus) {
    use libmodbus_rs::Exception;

    let request: Vec<u8> = vec![0x01];
    assert_eq!(modbus.reply_exception(&request, Exception::ACKNOWLEDGE as u32).unwrap(), 9);
}

fn test_write_and_read_registers(modbus: &Modbus) {
    let address = 1;
    let request_bytes = vec![1337u16];
    let mut response_bytes = vec![0u16];

    assert_eq!(modbus.write_and_read_registers(
             address, 1, &request_bytes,
             address, 1, &mut response_bytes).unwrap(), 1);

    println!("reponse_bytes: {:?}", response_bytes);
}

fn test_raw_request(modbus: &Modbus) {
    use libmodbus_rs::{FunctionCode, MODBUS_TCP_MAX_ADU_LENGTH};

    let mut raw_request: Vec<u8> = vec![0xFF, FunctionCode::READ_HOLDING_REGISTERS as u8, 0x00, 0x01, 0x0, 0x05];
    let mut response: Vec<u8> = vec![0; MODBUS_TCP_MAX_ADU_LENGTH as usize];

    assert_eq!(modbus.send_raw_request(&mut raw_request).unwrap(), 12);
    assert_eq!(modbus.receive_confirmation(&mut response).unwrap(), 19);
    println!(">> response: {:?}", &response);
}


fn run() -> Result<()> {
    let mut modbus = Modbus::new_tcp("127.0.0.1", 1502)?;
    modbus.set_debug(true)?;

    // `accept()` and `listen()` are not working yeat?
    // let mut socket = modbus.tcp_listen(10)?;
    // modbus.tcp_accept(&mut socket)?;
    modbus.connect()?;

    // Write and read registers test
    // test_write_and_read_registers(&modbus);
    // Raw request tests
    // test_raw_request(&modbus);
    // test_reply_exception(&modbus);
    // test_read_bits(&modbus);


    Ok(())
}

fn main() {
    if let Err(ref err) = run() {
        println!("Error: {}", err);

        std::process::exit(1)
    }
}