Implement basic server and test probe

.gitignore

@@ -8,3 +8,5 @@ Cargo.lock
 
 # These are backup files generated by rustfmt
 **/*.rs.bk
+
+.vscode

Cargo.toml

@@ -1,6 +1,8 @@
 [workspace]
 members = [
     "crates/dtrace-sys",
+    "crates/composer",
+    "crates/test_probe",
 ]
 
 # Specify a subset of member crates that compile on all supported architectures.

crates/composer/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "composer"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+bincode = "1.3.3"
+color-eyre = "0.6.2"
+eyre = "0.6.8"
+rodio = { version = "0.17.1", features = ["symphonia-wav"] }
+serde = { version = "1.0.160", features = ["serde_derive"] }

crates/composer/src/api.rs

@@ -0,0 +1,29 @@
+use eyre::Result;
+use serde::{Deserialize, Serialize};
+use std::net::UdpSocket;
+
+pub const DEFAULT_SERVER_ADDRESS: &str = "localhost:8888";
+
+#[derive(Serialize, Deserialize, Debug)]
+pub enum Event {
+    TestTick,
+}
+
+pub struct Client {
+    socket: UdpSocket,
+}
+
+impl Client {
+    pub fn new(server_address: Option<&str>) -> Result<Self> {
+        let socket = UdpSocket::bind("localhost:0")?;
+        socket.connect(server_address.unwrap_or(DEFAULT_SERVER_ADDRESS))?;
+
+        Ok(Self { socket })
+    }
+
+    pub fn send(&self, event: &Event) -> Result<()> {
+        let data = bincode::serialize(&event)?;
+        self.socket.send(&data)?;
+        Ok(())
+    }
+}

crates/composer/src/lib.rs

@@ -0,0 +1 @@
+pub mod api;

crates/composer/src/main.rs

@@ -0,0 +1,37 @@
+use composer::api::Event;
+use composer::api::DEFAULT_SERVER_ADDRESS;
+use eyre::Result;
+use rodio::{source::Source, Decoder, OutputStream};
+use std::fs::File;
+use std::io::BufReader;
+use std::net::UdpSocket;
+
+fn main() -> Result<()> {
+    color_eyre::install()?;
+
+    let socket = UdpSocket::bind(DEFAULT_SERVER_ADDRESS)?;
+    println!("Listening on {}", socket.local_addr()?);
+
+    let (_stream, stream_handle) = OutputStream::try_default()?;
+
+    loop {
+        if let Err(err) = {
+            // Should be more than enough.
+            let mut buf = [0; 1000];
+            let (number_of_bytes, _) = socket.recv_from(&mut buf)?;
+
+            let event: Event = bincode::deserialize(&buf)?;
+            println!("received a event ({number_of_bytes} bytes): {:?}", event);
+
+            // FIXME: do the decoding and file reading outside the loop
+            let file = BufReader::new(File::open("src/sound_samples/click.wav")?);
+            let source = Decoder::new(file)?;
+            stream_handle.play_raw(source.convert_samples())?;
+
+            Ok::<(), eyre::Error>(())
+        } {
+            eprintln!("Could not process data-gram: {:?}", err);
+            continue;
+        }
+    }
+}

crates/test_probe/Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "test_probe"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+color-eyre = "0.6.2"
+composer = { path = "../composer" }
+eyre = "0.6.8"

crates/test_probe/src/main.rs

@@ -0,0 +1,33 @@
+use composer::api::{Client, Event};
+use eyre::Result;
+use std::{env, thread, time::Duration};
+
+fn main() -> Result<()> {
+    color_eyre::install()?;
+
+    // Get server address, if given
+    let args: Vec<String> = env::args().collect();
+    let arg = args.get(1);
+    let server_address: Option<&str> = arg.map(|x: &String| x.as_str());
+
+    let client = Client::new(server_address)?;
+    let event = Event::TestTick;
+    let delays = {
+        let min_delay = 5;
+        let max_delay = 250;
+        let step = 10;
+        // Tick fast, then slow, and then fast again
+        (min_delay..max_delay)
+            .step_by(step)
+            .chain((min_delay..max_delay).step_by(step).rev())
+    };
+
+    loop {
+        for delay in delays.clone() {
+            if let Err(err) = client.send(&event) {
+                eprintln!("Could not send event {:?}", err)
+            };
+            thread::sleep(Duration::from_millis(delay.try_into().unwrap()));
+        }
+    }
+}