proof of concept

src/flrig.rs

@@ -0,0 +1,88 @@
+use crate::cloudlog::RadioData;
+
+use quick_xml::events::Event;
+use quick_xml::reader::Reader;
+use reqwest::{self, header::CONTENT_TYPE, Error};
+use std::result::Result;
+
+pub fn get_radio_data(fl_host: &str, fl_port: &str) -> Result<RadioData, Error> {
+    let cmd_freq = "rig.get_vfo";
+    let cmd_mode = "rig.get_mode";
+    let cmd_power = "rig.get_power";
+
+    let client = reqwest::Client::new();
+
+    let freq = get_value_from_flrig(fl_host, fl_port, &client, &cmd_freq).unwrap();
+    let mode = get_value_from_flrig(fl_host, fl_port, &client, &cmd_mode).unwrap();
+    let power = get_value_from_flrig(fl_host, fl_port, &client, &cmd_power).unwrap();
+
+    let freq = parse_xml(&freq);
+    let mode = parse_xml(&mode);
+    let power = parse_xml(&power);
+
+    println!("{freq} --- {mode} --- {power}");
+
+    let radio_data = RadioData {
+        key: String::from(""),
+        radio: String::from(""),
+        frequency: freq,
+        mode: mode,
+        power: power,
+    };
+
+    Ok(radio_data)
+}
+
+#[tokio::main]
+async fn get_value_from_flrig(
+    fl_host: &str,
+    fl_port: &str,
+    client: &reqwest::Client,
+    cmd: &str,
+) -> Result<String, Error> {
+    let xml_cmd = create_xml_cmd(&cmd);
+
+    let res = client
+        .post(fl_host.to_owned() + ":" + fl_port)
+        .header(CONTENT_TYPE, "application/x-www-form-urlencoded")
+        .body(xml_cmd)
+        .send()
+        .await?;
+
+    let body = res.text().await?;
+
+    Ok(body)
+}
+
+fn create_xml_cmd(cmd: &str) -> String {
+    format!("<?xml version=\"1.0\"?><methodCall><methodName>{cmd}</methodName><params></params></methodCall>")
+}
+
+fn parse_xml(xml: &str) -> String {
+    let mut reader = Reader::from_str(&xml);
+    reader.trim_text(true);
+
+    let mut value = String::new();
+
+    loop {
+        let mut found = false;
+
+        match reader.read_event() {
+            Err(e) => panic!("Error at position {}: {:?}", reader.buffer_position(), e),
+            // exits the loop when reaching end of file
+            Ok(Event::Eof) => break,
+
+            Ok(Event::Start(e)) => match e.name().as_ref() {
+                b"value" => found = true,
+                _ => (),
+            },
+            Ok(Event::Text(e)) => value = e.unescape().unwrap().to_owned().to_string(),
+
+            _ => (),
+        }
+        // if we don't keep a borrow elsewhere, we can clear the buffer to keep memory usage low
+        //buf.clear();
+    }
+
+    value
+}

src/main.rs

@@ -1,5 +1,6 @@
 mod cloudlog;
 mod settings;
+mod flrig;
 
 use settings::Settings;
 use crate::cloudlog::RadioData;
@@ -7,7 +8,7 @@ use crate::cloudlog::RadioData;
 fn main() {
     let settings = Settings::new().expect("Could not read settings.");
 
-    let rd = RadioData {
+    let mut radio_data_current = RadioData {
         key: settings.cloudlog.key,
         radio: settings.cloudlog.identifier,
         frequency: String::from("14017000"),
@@ -15,5 +16,11 @@ fn main() {
         power: String::from("5"),
     };
 
-    cloudlog::upload(&settings.cloudlog.url, &rd);
+    let radio_data_new = flrig::get_radio_data(&settings.flrig.host, &settings.flrig.port).unwrap();
+
+    radio_data_current.frequency = radio_data_new.frequency;
+    radio_data_current.mode = radio_data_new.mode;
+    radio_data_current.power = radio_data_new.power;
+
+    cloudlog::upload(&settings.cloudlog.url, &radio_data_current);
 }

src/settings.rs

@@ -21,7 +21,7 @@ pub struct Flrig {
 #[allow(unused)]
 pub struct Settings {
     pub cloudlog: Cloudlog,
-    flrig: Flrig,
+    pub flrig: Flrig,
 }
 
 impl Settings {