feat: start implementing free wisdoms route nad daily rotator worker

Cargo.toml

@@ -1,5 +1,5 @@
 [workspace]
-members = ["server", "worker"]
+members = ["server", "worker_wisdoms_checker", "worker_wisdoms_daily_rotator"]
 
 resolver = "2"
 

run.sh

@@ -1,7 +1,12 @@
 #!/bin/bash
 
-# Build worker
-cd worker
+# Build worker worker_wisdoms_checker
+cd worker_wisdoms_checker
+cargo build --release
+cd ..
+
+# Build worker worker_wisdoms_daily_rotator
+cd worker_wisdoms_daily_rotator
 cargo build --release
 cd ..
 
@@ -10,8 +15,11 @@ cd server
 cargo build --release
 cd ..
 
-# Start worker
-./target/release/worker &
+# Start worker worker_wisdoms_checker
+./target/release/worker_wisdoms_checker &
+
+# Start worker worker_wisdoms_daily_rotator
+./target/release/worker_wisdoms_daily_rotator &
 
 # Start server
 ./target/release/wisdomia-monolithic

server/src/routes/wisdoms.rs

@@ -14,6 +14,10 @@ fn _routes() -> Router {
     Router::new().route("/", get(get_wisdoms))
 }
 
+async fn get_free_wisdoms(Extension(state): Extension<Arc<AppState>>) -> impl IntoResponse {
+    (StatusCode::OK)
+}
+
 async fn get_wisdoms(Extension(state): Extension<Arc<AppState>>) -> impl IntoResponse {
     tracing_fast_dev::tfd().info("GET_WISDOM", "FUNCTION");
     match _get_wisdoms(&state.db).await {

worker/Cargo.toml → worker_wisdoms_checker/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "worker"
+name = "worker_wisdoms_checker"
 version = "0.1.0"
 edition = "2021"
 

worker/src/wisdoms_checker.rs → worker_wisdoms_checker/src/wisdoms_checker.rs

@@ -36,6 +36,7 @@ pub async fn worker_thread(pool: PgPool) {
     });
 
     loop {
+        dbg!("Checking wisdoms...");
         tokio::time::sleep(Duration::from_secs(5)).await;
 
         //Its one dot (.) because we are running the worker it from the root.

worker_wisdoms_daily_rotator/Cargo.toml

@@ -0,0 +1,13 @@
+[package]
+name = "worker_wisdoms_daily_rotator"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+tokio = { version = "1.35.1", features = ["full"] }
+serde = { version = "1.0.194", features = ["derive"] }
+serde_json = "1.0.112"
+dotenv = "0.15.0"
+sqlx = { version = "0.7.4", features = ["postgres","runtime-tokio-rustls"] }
+base64="0.22.1"
+teloxide = { version = "0.12", features = ["macros"] }

worker_wisdoms_daily_rotator/src/daily_rotator.rs

@@ -0,0 +1,10 @@
+use std::time::Duration;
+
+use sqlx::PgPool;
+
+pub async fn worker_thread(_pool: PgPool) {
+    loop {
+        dbg!("Rotating...");
+        tokio::time::sleep(Duration::from_secs(5)).await;
+    }
+}

worker_wisdoms_daily_rotator/src/db_connect.rs

@@ -0,0 +1,27 @@
+pub type Result<T> = core::result::Result<T, Error>;
+
+use sqlx::postgres::PgPoolOptions;
+
+pub type Database = sqlx::Pool<sqlx::Postgres>;
+
+#[derive(Debug)]
+pub enum Error {
+    FailedConnectingToDatabase { error: String },
+}
+
+impl From<sqlx::Error> for Error {
+    fn from(value: sqlx::Error) -> Self {
+        Self::FailedConnectingToDatabase {
+            error: value.to_string(),
+        }
+    }
+}
+
+pub async fn connect(db_url: &str) -> Result<Database> {
+    let pool: Database = PgPoolOptions::new()
+        // TODO: Max connections! Dynamic?
+        .max_connections(5)
+        .connect(db_url)
+        .await?;
+    Ok(pool)
+}

worker_wisdoms_daily_rotator/src/main.rs

@@ -0,0 +1,19 @@
+mod daily_rotator;
+mod db_connect;
+
+use std::env;
+
+use daily_rotator::worker_thread;
+use db_connect::connect;
+
+#[tokio::main]
+async fn main() {
+    let _ = dotenv::dotenv();
+
+    let database_url = env::var("DATABASE_URL")
+        .unwrap_or_else(|_| panic!("Missing required environment variable: {}", "DATABASE_URL"));
+
+    let db = connect(database_url.as_str()).await.unwrap();
+
+    tokio::spawn(worker_thread(db)).await.unwrap();
+}