Cut the program down to absolute minimum I need. #1
+5
-5
@@ -1,11 +1,11 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "RUST_NMEA_PARSER"
|
name = "gpsll"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
eframe = { version = "0.27", features = ["wgpu", "persistence"] }
|
|
||||||
egui = "0.27"
|
|
||||||
egui_plot = "0.27"
|
|
||||||
serialport = "4.2"
|
serialport = "4.2"
|
||||||
nmea = "0.6"
|
nmea = {version = "0.6", features = ["GGA"]}
|
||||||
|
clap = { version = "4", features = ["derive"] }
|
||||||
|
chrono = "0.4.45"
|
||||||
|
|
||||||
|
|||||||
+51
-188
@@ -1,113 +1,46 @@
|
|||||||
use eframe::egui;
|
use nmea::Nmea;
|
||||||
use serialport::available_ports;
|
use nmea::SentenceType;
|
||||||
use std::sync::{Arc, Mutex};
|
|
||||||
use std::thread;
|
use std::thread;
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
|
use clap::Parser;
|
||||||
|
use chrono::Local;
|
||||||
|
|
||||||
use egui_plot::{Plot, PlotPoints, Points, Text, Line};
|
/// Command-line arguments using Clap.
|
||||||
|
#[derive(Parser, Debug)]
|
||||||
|
#[command(author, version, about = "A tool for echoing latitude and longitude from a GPS USB dongle.")]
|
||||||
|
struct Cli {
|
||||||
|
|
||||||
#[derive(Default, Clone)]
|
/// COM port
|
||||||
struct Satellite {
|
#[arg(short = 'c', long)]
|
||||||
id: String,
|
com: Option<String>,
|
||||||
latitude: f64,
|
|
||||||
longitude: f64,
|
|
||||||
strength: u8,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Default)]
|
fn main() {
|
||||||
struct AppState {
|
|
||||||
ports: Vec<String>,
|
|
||||||
selected_port: Option<String>,
|
|
||||||
satellites: Vec<Satellite>,
|
|
||||||
is_reading: bool,
|
|
||||||
|
|
||||||
// 🔵 NEW: live NMEA data buffer
|
let cli = Cli::parse();
|
||||||
nmea_log: Vec<String>,
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct MyApp {
|
let com = match cli.com {
|
||||||
state: Arc<Mutex<AppState>>,
|
Some(com) => com,
|
||||||
}
|
None => {
|
||||||
|
// https://github.com/serialport/serialport-rs#listing-available-ports
|
||||||
impl Default for MyApp {
|
let ports = serialport::available_ports().expect("No ports found!");
|
||||||
fn default() -> Self {
|
println!("Available Ports:");
|
||||||
let ports = available_ports()
|
for p in ports {
|
||||||
.map(|ps| ps.into_iter().map(|p| p.port_name).collect())
|
println!("{}", p.port_name);
|
||||||
.unwrap_or_default();
|
|
||||||
|
|
||||||
Self {
|
|
||||||
state: Arc::new(Mutex::new(AppState {
|
|
||||||
ports,
|
|
||||||
..Default::default()
|
|
||||||
})),
|
|
||||||
}
|
}
|
||||||
}
|
println!("\nMissing `-c` port argument, use one listed above.");
|
||||||
}
|
return;
|
||||||
|
} //todo!()
|
||||||
|
} ;
|
||||||
|
println!("Reading from {com:?}");
|
||||||
|
|
||||||
// =====================================================================
|
// Inifnite loop until I add controls
|
||||||
// Satellite Map Drawing Method
|
while 1 == 1 {
|
||||||
// =====================================================================
|
let mut nmea = Nmea::default();
|
||||||
impl MyApp {
|
|
||||||
fn draw_satellite_map(&self, ui: &mut egui::Ui, sats: &[Satellite]) {
|
|
||||||
Plot::new("satellite_map")
|
|
||||||
.width(300.0)
|
|
||||||
.height(300.0)
|
|
||||||
.view_aspect(1.0)
|
|
||||||
.show(ui, |plot_ui| {
|
|
||||||
// Draw outline circle
|
|
||||||
let circle: PlotPoints = (0..360)
|
|
||||||
.map(|deg| {
|
|
||||||
let rad = (deg as f64).to_radians();
|
|
||||||
[rad.cos(), rad.sin()]
|
|
||||||
})
|
|
||||||
.collect::<Vec<_>>()
|
|
||||||
.into();
|
|
||||||
|
|
||||||
plot_ui.line(Line::new(circle));
|
// Harcode port for dev
|
||||||
|
//let port_name = "/dev/tty.usbmodem1301";
|
||||||
// Draw satellites
|
let port_name = com.clone();
|
||||||
for sat in sats {
|
|
||||||
let az = sat.longitude.to_radians();
|
|
||||||
let el = sat.latitude.to_radians();
|
|
||||||
|
|
||||||
let x = el.cos() * az.cos();
|
|
||||||
let y = el.cos() * az.sin();
|
|
||||||
|
|
||||||
plot_ui.points(Points::new(vec![[x, y]]).radius(3.0));
|
|
||||||
plot_ui.text(Text::new([x, y].into(), sat.id.clone()));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// =====================================================================
|
|
||||||
// Main App UI
|
|
||||||
// =====================================================================
|
|
||||||
impl eframe::App for MyApp {
|
|
||||||
fn update(&mut self, ctx: &egui::Context, _frame: &mut eframe::Frame) {
|
|
||||||
let mut state = self.state.lock().unwrap();
|
|
||||||
|
|
||||||
// Main panel
|
|
||||||
egui::CentralPanel::default().show(ctx, |ui| {
|
|
||||||
ui.heading("Select COM Port");
|
|
||||||
|
|
||||||
let ports = state.ports.clone();
|
|
||||||
|
|
||||||
egui::ComboBox::from_label("COM Port")
|
|
||||||
.selected_text(state.selected_port.as_deref().unwrap_or("Select a Port"))
|
|
||||||
.show_ui(ui, |cb| {
|
|
||||||
for port in ports {
|
|
||||||
cb.selectable_value(
|
|
||||||
&mut state.selected_port,
|
|
||||||
Some(port.clone()),
|
|
||||||
port,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
if ui.button("Start Reading").clicked() && !state.is_reading {
|
|
||||||
if let Some(port_name) = state.selected_port.clone() {
|
|
||||||
let state_clone = Arc::clone(&self.state);
|
|
||||||
|
|
||||||
// Thread for GPS streaming
|
// Thread for GPS streaming
|
||||||
thread::spawn(move || {
|
thread::spawn(move || {
|
||||||
@@ -122,108 +55,38 @@ impl eframe::App for MyApp {
|
|||||||
match serial.read(&mut buf) {
|
match serial.read(&mut buf) {
|
||||||
Ok(n) => {
|
Ok(n) => {
|
||||||
let data = String::from_utf8_lossy(&buf[..n]);
|
let data = String::from_utf8_lossy(&buf[..n]);
|
||||||
let mut satellites = Vec::new();
|
|
||||||
|
|
||||||
for line in data.lines() {
|
for line in data.lines() {
|
||||||
|
|
||||||
// 🔵 Append NMEA line to log
|
// Check sentence type
|
||||||
{
|
let sentence_type = match nmea.parse(line) {
|
||||||
let mut st = state_clone.lock().unwrap();
|
Ok(sentence_type) => sentence_type,
|
||||||
st.nmea_log.push(line.to_string());
|
Err(_) => {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
// Keep log trimmed
|
// Only keep the GLL sentences
|
||||||
if st.nmea_log.len() > 500 {
|
if sentence_type == SentenceType::GLL {
|
||||||
st.nmea_log.remove(0);
|
let lat = match nmea.latitude {
|
||||||
}
|
Some(lat) => lat,
|
||||||
}
|
None => todo!()
|
||||||
|
} ;
|
||||||
|
let lon = match nmea.longitude {
|
||||||
|
Some(lon) => lon,
|
||||||
|
None => todo!()
|
||||||
|
} ;
|
||||||
|
let date = Local::now();
|
||||||
|
println!("{}, {lat}, {lon}", date.format("%Y-%m-%d %H:%M:%S"));
|
||||||
|
|
||||||
// Parse GSV
|
|
||||||
if line.starts_with("$GPGSV") {
|
|
||||||
let fields: Vec<&str> = line.split(',').collect();
|
|
||||||
let mut i = 4;
|
|
||||||
|
|
||||||
while i + 3 < fields.len() {
|
|
||||||
satellites.push(Satellite {
|
|
||||||
id: fields[i].to_string(),
|
|
||||||
latitude: fields[i + 1].parse().unwrap_or(0.0),
|
|
||||||
longitude: fields[i + 2].parse().unwrap_or(0.0),
|
|
||||||
strength: fields[i + 3].parse().unwrap_or(0),
|
|
||||||
});
|
|
||||||
i += 4;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Update satellites
|
|
||||||
let mut st = state_clone.lock().unwrap();
|
|
||||||
st.satellites = satellites;
|
|
||||||
}
|
|
||||||
Err(_) => break,
|
Err(_) => break,
|
||||||
}
|
}
|
||||||
|
|
||||||
thread::sleep(Duration::from_millis(200));
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
state.is_reading = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
ui.separator();
|
|
||||||
ui.heading("Satellites");
|
|
||||||
|
|
||||||
egui::ScrollArea::vertical().show(ui, |ui| {
|
|
||||||
for sat in &state.satellites {
|
|
||||||
ui.horizontal(|ui| {
|
|
||||||
ui.label(format!("ID: {}", sat.id));
|
|
||||||
ui.label(format!("Elv: {:.2}", sat.latitude));
|
|
||||||
ui.label(format!("Azm: {:.2}", sat.longitude));
|
|
||||||
ui.label(format!("Strength: {}", sat.strength));
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
// =====================================================================
|
|
||||||
// NEW: Live GPS Stream Window
|
|
||||||
// =====================================================================
|
|
||||||
egui::Window::new("GPS Stream")
|
|
||||||
.default_width(400.0)
|
|
||||||
.default_height(300.0)
|
|
||||||
.resizable(true)
|
|
||||||
.show(ctx, |ui| {
|
|
||||||
ui.label("Live NMEA Data:");
|
|
||||||
|
|
||||||
egui::ScrollArea::vertical()
|
|
||||||
.stick_to_bottom(true)
|
|
||||||
.show(ui, |ui| {
|
|
||||||
for line in &state.nmea_log {
|
|
||||||
ui.monospace(line);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
// =====================================================================
|
|
||||||
// Mini floating sky map
|
|
||||||
// =====================================================================
|
|
||||||
egui::Area::new("mini_sky_map".into())
|
|
||||||
.anchor(egui::Align2::RIGHT_TOP, [-10.0, 10.0])
|
|
||||||
.show(ctx, |ui| {
|
|
||||||
self.draw_satellite_map(ui, &state.satellites);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// =====================================================================
|
|
||||||
// Run
|
|
||||||
// =====================================================================
|
|
||||||
fn main() -> eframe::Result<()> {
|
|
||||||
let options = eframe::NativeOptions::default();
|
|
||||||
|
|
||||||
eframe::run_native(
|
|
||||||
"NMEA GPS Viewer",
|
|
||||||
options,
|
|
||||||
Box::new(|_cc| Box::new(MyApp::default())),
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user