94 lines
2.9 KiB
Rust
94 lines
2.9 KiB
Rust
use std::i64;
|
|
use std::io::Write;
|
|
use std::net;
|
|
|
|
fn listen(socket: &net::UdpSocket) {
|
|
let mut buf: [u8; 20] = [0; 20];
|
|
let number_of_bytes: usize = 0;
|
|
let mut result: Vec<u8> = Vec::new();
|
|
match socket.recv_from(&mut buf) {
|
|
Ok((number_of_bytes, _)) => {
|
|
result = Vec::from(&buf[0..number_of_bytes]);
|
|
}
|
|
Err(fail) => println!("failed listening {:?}", fail),
|
|
}
|
|
|
|
let display_result = result.clone();
|
|
let result_str = String::from_utf8(display_result).unwrap();
|
|
println!("received message: {:?}", result_str);
|
|
|
|
if result_str.contains("S0R1") {
|
|
write_file("Race active".to_string(), "racestate.txt");
|
|
write_file("0".to_string(), "rx1.txt");
|
|
write_file("0".to_string(), "rx2.txt");
|
|
write_file("0".to_string(), "rx3.txt");
|
|
}
|
|
if result_str.contains("S0R0") {
|
|
write_file("Race inactive".to_string(), "racestate.txt");
|
|
}
|
|
|
|
if result_str.contains("S0L") {
|
|
// zb sS1L0000000DAF
|
|
let lap_time = i64::from_str_radix(&result_str[5..13], 16).unwrap_or(-1);
|
|
if lap_time != -1 {
|
|
let lap_seconds = (lap_time as f64) / (1000 as f64);
|
|
write_file(lap_seconds.to_string(), "rx1_laptime.txt");
|
|
}
|
|
let intval = &result_str[3..5].parse::<i32>().unwrap_or(-1);
|
|
if *intval != -1 {
|
|
write_file((intval + 1).to_string(), "rx1.txt");
|
|
}
|
|
}
|
|
if result_str.contains("S1L") {
|
|
let lap_time = i64::from_str_radix(&result_str[5..13], 16).unwrap_or(-1);
|
|
if lap_time != -1 {
|
|
let lap_seconds = (lap_time as f64) / (1000 as f64);
|
|
write_file(lap_seconds.to_string(), "rx2_laptime.txt");
|
|
}
|
|
let intval = &result_str[3..5].parse::<i32>().unwrap_or(-1);
|
|
if *intval != -1 {
|
|
write_file((intval + 1).to_string(), "rx2.txt");
|
|
}
|
|
}
|
|
if result_str.contains("S2L") {
|
|
let lap_time = i64::from_str_radix(&result_str[5..13], 16).unwrap_or(-1);
|
|
if lap_time != -1 {
|
|
let lap_seconds = (lap_time as f64) / (1000 as f64);
|
|
write_file(lap_seconds.to_string(), "rx3_laptime.txt");
|
|
}
|
|
let intval = &result_str[3..5].parse::<i32>().unwrap_or(-1);
|
|
if *intval != -1 {
|
|
write_file((intval + 1).to_string(), "rx3.txt");
|
|
}
|
|
}
|
|
}
|
|
|
|
fn write_file(text: String, filename: &str) {
|
|
let mut file = std::fs::File::create(filename).expect("create failed");
|
|
file.write_all(text.as_bytes()).expect("write failed");
|
|
//println!("data written to file");
|
|
}
|
|
|
|
fn main() {
|
|
write_file("Race inactive".to_string(), "racestate.txt");
|
|
write_file("0".to_string(), "rx1.txt");
|
|
write_file("0".to_string(), "rx2.txt");
|
|
write_file("0".to_string(), "rx3.txt");
|
|
|
|
write_file("-.-".to_string(), "rx1_laptime.txt");
|
|
write_file("-.-".to_string(), "rx2_laptime.txt");
|
|
write_file("-.-".to_string(), "rx3_laptime.txt");
|
|
|
|
let socket = net::UdpSocket::bind("0.0.0.0:0").expect("failed to bind host socket"); // local bind port
|
|
|
|
let msg = String::from("ok").into_bytes();
|
|
|
|
socket
|
|
.send_to(&msg, "192.168.0.141:9000")
|
|
.expect("cannot send");
|
|
|
|
loop {
|
|
listen(&socket); // this call is blockig
|
|
}
|
|
}
|