From 241622ff7fd612eb521dec8829153851406c5884 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Sun, 7 Jan 2024 22:22:51 +0100
Subject: Store incoming frames in DB and show most recent 10 in dashboard

---
 src/bin/fake-radio.rs | 93 ++++++++++++++++++++++++++++-----------------------
 1 file changed, 51 insertions(+), 42 deletions(-)

(limited to 'src/bin')

diff --git a/src/bin/fake-radio.rs b/src/bin/fake-radio.rs
index fd38149..b7daf67 100644
--- a/src/bin/fake-radio.rs
+++ b/src/bin/fake-radio.rs
@@ -1,5 +1,4 @@
 use anyhow::{anyhow, Context};
-use tokio::net::UdpSocket;
 use ham_cats::{
     buffer::Buffer,
     whisker::{Arbitrary, Identification, Gps},
@@ -7,46 +6,7 @@ use ham_cats::{
 
 const MAX_PACKET_LEN : usize = 8191;
 
-#[tokio::main]
-async fn main() -> std::io::Result<()> {
-    eprintln!("Sending example packet");
-
-    let packet = build_example_packet().await.unwrap();
-    let sock = UdpSocket::bind("127.0.0.1:9074").await.unwrap();
-    sock.send_to(&packet, "127.0.0.1:9073").await.unwrap();
-
-    eprintln!("Receiving packets. Ctrl-C to stop");
-
-    let mut data = [0; MAX_PACKET_LEN];
-    while let Ok((len, _addr)) = sock.recv_from(&mut data).await {
-        let mut buf = [0; MAX_PACKET_LEN];
-        match ham_cats::packet::Packet::fully_decode(&data[2..len], &mut buf) {
-            Ok(packet) => {
-                if let Some(ident) = packet.identification() {
-                    eprintln!(" Ident {}-{}", ident.callsign, ident.ssid);
-                }
-
-                if let Some(gps) = packet.gps() {
-                    eprintln!(" GPS {} {}", gps.latitude(), gps.longitude());
-                }
-
-                let mut comment = [0; 1024];
-                if let Ok(c) = packet.comment(&mut comment) {
-                    eprintln!(" Comment {}", c);
-                }
-
-                eprintln!(" With {} Arbitrary whiskers", packet.arbitrary_iter().count());
-            },
-            Err(e) => {
-                eprintln!(" Cannot decode packet of length {} {:?}", len, e);
-            }
-        }
-    }
-
-    Ok(())
-}
-
-async fn build_example_packet() -> anyhow::Result<Vec<u8>> {
+fn build_example_packet(comment: &str) -> anyhow::Result<Vec<u8>> {
     let callsign = "EX4MPLE";
     let ssid = 0;
     let icon = 0;
@@ -59,7 +19,7 @@ async fn build_example_packet() -> anyhow::Result<Vec<u8>> {
     )
     .map_err(|e| anyhow!("Could not add identification to packet: {e}"))?;
 
-    pkt.add_comment("Debugging packet")
+    pkt.add_comment(comment)
         .map_err(|e| anyhow!("Could not add comment to packet: {e}"))?;
 
     let latitude = 46.5;
@@ -89,3 +49,52 @@ async fn build_example_packet() -> anyhow::Result<Vec<u8>> {
 
     Ok(data.to_vec())
 }
+
+fn main() -> std::io::Result<()> {
+    std::thread::spawn(receive_loop);
+
+    eprintln!("Receiving messages. Write a comment and press ENTER to send. Ctrl-C to stop");
+    let mut stdin_lines = std::io::stdin().lines();
+    let sock = std::net::UdpSocket::bind("127.0.0.1:9075").unwrap();
+
+    while let Some(Ok(line)) = stdin_lines.next() {
+        eprintln!("Sending with comment = {}", line);
+
+        let packet = build_example_packet(&line).unwrap();
+        sock.send_to(&packet, "127.0.0.1:9073").unwrap();
+    }
+
+    Ok(())
+}
+
+fn receive_loop() {
+    let sock = std::net::UdpSocket::bind("127.0.0.1:9074").unwrap();
+    let mut data = [0; MAX_PACKET_LEN];
+    while let Ok((len, _addr)) = sock.recv_from(&mut data) {
+        eprintln!("Packet of length {}", len);
+
+        let mut buf = [0; MAX_PACKET_LEN];
+        match ham_cats::packet::Packet::fully_decode(&data[2..len], &mut buf) {
+            Ok(packet) => {
+                if let Some(ident) = packet.identification() {
+                    eprintln!(" Ident {}-{}", ident.callsign, ident.ssid);
+                }
+
+                if let Some(gps) = packet.gps() {
+                    eprintln!(" GPS {} {}", gps.latitude(), gps.longitude());
+                }
+
+                let mut comment = [0; 1024];
+                if let Ok(c) = packet.comment(&mut comment) {
+                    eprintln!(" Comment {}", c);
+                }
+
+                eprintln!(" With {} Arbitrary whiskers", packet.arbitrary_iter().count());
+            },
+            Err(e) => {
+                eprintln!(" Cannot decode {:?}", e);
+            }
+        }
+    }
+}
+
-- 
cgit v1.2.3