Merge pull request #14 from habibi-dev/develop

💱 feat(api): Add currency exchange & crypto price endpoints

Author: habibi-dev

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "rust_rest_api"
-version = "0.3.0"
+version = "0.4.0"
 edition = "2024"
 license = "MIT"
 authors = ["Habibi-Dev"]

Cargo.toml

@@ -1,5 +1,6 @@
 use crate::core::config::Config;
-use crate::jobs::{cache_flush::CacheFlushJob, coin_sync::CoinSyncJob};
+use crate::jobs::cache_flush::CacheFlushJob;
+use crate::jobs::tgju_sync::TgjuSyncJob;
 use crate::server;
 use crate::services::{cache::StatsCache, routes::Routes};
 use crate::state::{self, APP_STATE, AppState};
@@ -48,9 +49,9 @@ async fn setup_database() -> Result<sea_orm::DatabaseConnection> {
 
 fn start_background_jobs(cache: &Arc<StatsCache>) -> Result<()> {
     let flush_job = CacheFlushJob::new(Arc::clone(cache));
-    let coin_job = CoinSyncJob::new();
+    let tgju_job = TgjuSyncJob::new();
 
-    crate::services::jobs::FlushJob::start(vec![flush_job.into_task(), coin_job.into_task()], None);
+    crate::services::jobs::FlushJob::start(vec![flush_job.into_task(), tgju_job.into_task()], None);
 
     Ok(())
 }

src/app.rs

@@ -1,5 +1,5 @@
 pub mod cache_flush;
-pub mod coin_sync;
+pub mod tgju_sync;
 
 use std::{future::Future, pin::Pin, sync::Arc};
 

src/jobs/coin_sync.rs

@@ -0,0 +1,36 @@
+use crate::jobs::JobTask;
+use crate::request::request_handler;
+use crate::state::APP_STATE;
+use std::sync::Arc;
+
+pub struct TgjuSyncJob;
+
+impl TgjuSyncJob {
+    pub fn new() -> Self {
+        Self
+    }
+
+    pub fn into_task(self) -> JobTask {
+        Arc::new(|| {
+            Box::pin(async {
+                if let Err(e) = tgju_sync().await {
+                    eprintln!("Gold sync job failed: {}", e);
+                }
+            })
+        })
+    }
+}
+
+async fn tgju_sync() -> Result<(), Box<dyn std::error::Error>> {
+    let service = request_handler::RequestHandler::new();
+    let tg = service.tgju_typed().await?;
+
+    let state = APP_STATE.get().ok_or("Application state not available")?;
+
+    state
+        .financial_rates_tx
+        .send(tg)
+        .map_err(|_| "Failed to send golds to channel")?;
+
+    Ok(())
+}

src/jobs/mod.rs

@@ -4,6 +4,7 @@ mod entities;
 mod jobs;
 mod middleware;
 mod repository;
+mod request;
 mod server;
 mod services;
 mod state;

src/jobs/tgju_sync.rs

@@ -0,0 +1 @@
+

src/main.rs

@@ -0,0 +1,3 @@
+pub mod data;
+pub mod request_handler;
+pub mod tgju_data;

src/request/data.rs

@@ -1,24 +1,24 @@
-use crate::services::coin_ir::data::{ApiResponse, CoinData};
+use crate::request::tgju_data::{ApiResponse, TgjuData};
 use reqwest::Client;
 use uuid::Uuid;
 
-pub struct RequestCoinIr {
+pub struct RequestHandler {
     client: Client,
 }
 
-impl RequestCoinIr {
+impl RequestHandler {
     pub fn new() -> Self {
         let client = Client::builder()
             .use_rustls_tls()
             .timeout(std::time::Duration::from_secs(10))
             .build()
-            .expect("reqwest client build failed");
+            .expect("reqwest client [RequestGold] build failed");
         Self { client }
     }
 
     pub async fn start(&self) -> Result<ApiResponse, reqwest::Error> {
         let uuid = Uuid::new_v4();
-        let url = format!("https://call1.tgju.org/ajax.json?rev={}", uuid);
+        let url = format!("https://call3.tgju.org/ajax.json?rev={}", uuid);
         let resp = self
             .client
             .get(url)
@@ -31,8 +31,8 @@ impl RequestCoinIr {
         Ok(api)
     }
 
-    pub async fn coins_typed(&self) -> Result<CoinData, reqwest::Error> {
+    pub async fn tgju_typed(&self) -> Result<TgjuData, reqwest::Error> {
         let api = self.start().await?;
-        Ok(CoinData::from(&api.current))
+        Ok(TgjuData::from(&api.current))
     }
 }