Add SignalLight component and demo with RPPAL

pod-operation/Cargo.toml

@@ -13,3 +13,4 @@ serde = { version = "1.0.192", features = ["derive"] }
 serde_json = "1.0.108"
 tracing = "0.1.40"
 tracing-subscriber = { version = "0.3.17", features = ["env-filter"] }
+rppal = "0.17.1"

pod-operation/src/components/mod.rs

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

pod-operation/src/components/signal_light.rs

@@ -0,0 +1,31 @@
+use tracing::debug;
+
+use rppal::gpio::{Gpio, OutputPin};
+
+pub struct SignalLight {
+	pin: OutputPin,
+}
+
+const PIN_SIGNAL_LIGHT: u8 = 21;
+
+impl SignalLight {
+	pub fn new() -> Self {
+		SignalLight {
+			pin: Gpio::new()
+				.unwrap()
+				.get(PIN_SIGNAL_LIGHT)
+				.unwrap()
+				.into_output(),
+		}
+	}
+
+	pub fn disable(&mut self) {
+		debug!("Disabling signal light.");
+		self.pin.set_low();
+	}
+
+	pub fn enable(&mut self) {
+		debug!("Enabling signal light.");
+		self.pin.set_high();
+	}
+}

pod-operation/src/demo.rs

@@ -0,0 +1,19 @@
+use tracing::info;
+
+use crate::components::signal_light::SignalLight;
+
+pub async fn blink(mut signal_light: SignalLight) {
+	let mut i = 0;
+
+	info!("Starting blink demo.");
+	loop {
+		tokio::time::sleep(std::time::Duration::from_millis(500)).await;
+		if i % 4 == 0 {
+			signal_light.enable();
+		} else if i % 4 == 1 {
+			signal_light.disable();
+		}
+
+		i += 1;
+	}
+}

pod-operation/src/main.rs

@@ -3,8 +3,12 @@ use socketioxide::{extract::SocketRef, SocketIo};
 use tracing::{error, info};
 use tracing_subscriber::FmtSubscriber;
 
+mod components;
+mod demo;
 mod handlers;
 
+use crate::components::signal_light::SignalLight;
+
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
 	tracing::subscriber::set_global_default(FmtSubscriber::default())?;
@@ -16,6 +20,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 		socket.on("ping", handlers::handle_ping);
 	});
 
+	let signal_light = SignalLight::new();
+	tokio::spawn(demo::blink(signal_light));
+
 	let app = axum::Router::new().layer(layer);
 
 	info!("Starting server on port 5000");