Adds RabbitMQ messaging and management hub

1 files changed, 22 insertions, 10 deletions

diff --git a/rust/scraper/src/main.rs b/rust/scraper/src/main.rs
index 901a833..1ba8b36 100644
--- a/rust/scraper/src/main.rs
+++ b/rust/scraper/src/main.rs
@@ -1,23 +1,35 @@
+#![allow(dead_code)]
+
+use crate::messaging::{RabbitMQClient, RabbitMQClientOptions};
+use lapin::options::BasicAckOptions;
+use tracing::Level;
 use touchpad::TouchpadLiveClient;
 
 mod database;
+mod hub;
+mod messaging;
 mod touchpad;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let client = TouchpadLiveClient::new();
+    let subscriber = tracing_subscriber::FmtSubscriber::builder()
+        .with_max_level(Level::DEBUG)
+        .finish();
 
-    let meet_info = client.meet_info(18618).await?;
-    println!("{:?}", meet_info);
+    tracing::subscriber::set_global_default(subscriber).unwrap();
 
-    let events = client.events(18618).await?;
-    println!("{:?}", events);
+    let client = RabbitMQClient::new(
+        "amqp://127.0.0.1:5672",
+        "scraper_queue",
+        RabbitMQClientOptions::default(),
+    )?;
 
-    let swimmers = client.swimmers(18618).await?;
-    println!("{:?}", swimmers);
+    let mut rx = client.start().await;
 
-    let event = client.individual_event(18618, 1031911).await?;
-    println!("{:?}", event);
+    while let Some(delivery) = rx.recv().await {
+        println!("\"{}\" - {:?}", std::str::from_utf8(&delivery.data)?, delivery);
+        delivery.ack(BasicAckOptions::default()).await.unwrap();
+    }
 
     Ok(())
-}
\ No newline at end of file
+}