2025-06-29 23:41:20 -04:00
|
|
|
use crate::utils::{
|
|
|
|
request::{Request, Response},
|
|
|
|
task_log,
|
2025-06-30 22:58:52 -04:00
|
|
|
};
|
|
|
|
use storage::services::{
|
|
|
|
aws::{S3Client, S3ClientConfig},
|
|
|
|
ObjectStorageClient,
|
2025-06-29 23:41:20 -04:00
|
|
|
};
|
|
|
|
|
|
|
|
pub fn register(pool: &sqlx::Pool<sqlx::Postgres>) {
|
|
|
|
let p = pool.clone();
|
|
|
|
tokio::spawn(async move {
|
|
|
|
let _ = upload_rss(&p).await;
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
async fn upload_rss(pool: &sqlx::Pool<sqlx::Postgres>) -> Result<(), Box<dyn std::error::Error>> {
|
|
|
|
// start task logging
|
|
|
|
task_log::start(2, pool).await?;
|
|
|
|
|
|
|
|
// get request and request the things
|
|
|
|
let request = Request::new();
|
|
|
|
let rss_url = format!("{}/posts/rss", request.base_url);
|
|
|
|
let rss_result = request.request_url::<String>(&rss_url).await.unwrap();
|
|
|
|
|
|
|
|
// upload the sucker to obj storage
|
|
|
|
if let Response::Xml(rss) = rss_result {
|
|
|
|
let client_config = S3ClientConfig::from_env().unwrap();
|
2025-06-30 22:58:52 -04:00
|
|
|
let s3_client = S3Client::new(&client_config);
|
|
|
|
let _ = s3_client
|
|
|
|
.put_object(
|
|
|
|
client_config.bucket.as_str(),
|
|
|
|
"feed.xml",
|
|
|
|
rss.as_bytes().to_vec(),
|
|
|
|
)
|
|
|
|
.await;
|
2025-06-29 23:41:20 -04:00
|
|
|
println!("Finished uploading RSS feed");
|
|
|
|
}
|
|
|
|
|
|
|
|
Ok(())
|
|
|
|
}
|