feat: add wisdoms checker

src/main.rs

@@ -5,6 +5,7 @@ mod middlewares;
 mod models;
 mod routes;
 mod state;
+mod wisdoms_checker;
 
 use db::connect;
 use state::AppState;
@@ -14,6 +15,8 @@ use axum::{middleware, Extension, Router};
 use middlewares::response_mapper;
 use tokio::net::TcpListener;
 
+use crate::wisdoms_checker::worker_thread;
+
 #[tokio::main]
 async fn main() {
     let _ = dotenv::dotenv();
@@ -44,6 +47,8 @@ async fn main() {
         .layer(middleware::from_fn(middlewares::rate_limit))
         .layer(middleware::map_response(response_mapper));
 
+    tokio::spawn(worker_thread());
+
     axum::serve(
         listener,
         router.into_make_service_with_connect_info::<SocketAddr>(),

src/wisdoms_checker.rs

@@ -0,0 +1,31 @@
+use base64::{self, Engine};
+use serde::Deserialize;
+use std::fs;
+use std::time::Duration;
+
+#[derive(Debug, Deserialize)]
+struct Wisdom {
+    description: String,
+}
+
+pub async fn worker_thread() {
+    loop {
+        let base64_string = fs::read_to_string("encoded-wisdoms.b64")
+            .expect("Failed to read encoded-wisdoms.b64 file")
+            .replace(['\n','\r'], "");
+
+        dbg!(&base64_string);
+
+        let decoded_bytes = base64::prelude::BASE64_STANDARD.decode(base64_string)
+            .expect("Failed to decode base64 string");
+
+        let wisdoms: Vec<Wisdom> =
+            serde_json::from_slice(&decoded_bytes).expect("Failed to parse JSON");
+
+        for wisdom in wisdoms {
+            println!("Decoded wisdom: {:?}", wisdom);
+        }
+
+        tokio::time::sleep(Duration::from_secs(1)).await;
+    }
+}