phoenix/icarus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 33 Wiki Activity

Reorganizing metadata queue code

Browse Source
This commit is contained in:
kdeng00
2025-06-18 19:26:01 -04:00
parent fa792be9cc
commit 92449aa807
1 changed files with 50 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/callers/metadata.rs
+14 -8
View File
@@ -1,10 +1,12 @@
// TODO: Explicitly make this module target queueing a song's metadata // TODO: Explicitly make this module target queueing a song's metadata
pub mod request { pub mod request {
pub mod queue_metadata {
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
#[derive(Debug, Default, Deserialize, Serialize, sqlx::FromRow)] #[derive(Debug, Default, Deserialize, Serialize, sqlx::FromRow)]
pub struct Request { pub struct Request {
pub id: uuid::Uuid, pub song_queue_id: uuid::Uuid,
pub album: String, pub album: String,
pub album_artist: String, pub album_artist: String,
pub artist: String, pub artist: String,
@@ -22,7 +24,7 @@ pub mod request {
pub async fn to_json_value(&self) -> serde_json::Value { pub async fn to_json_value(&self) -> serde_json::Value {
serde_json::json!( serde_json::json!(
{ {
"id": &self.id, "song_queue_id": &self.song_queue_id,
"album": &self.album, "album": &self.album,
"album_artist": &self.album_artist, "album_artist": &self.album_artist,
"genre": &self.genre, "genre": &self.genre,
@@ -37,6 +39,7 @@ pub mod request {
}) })
} }
} }
}
pub mod fetch_metadata { pub mod fetch_metadata {
#[derive( #[derive(
@@ -50,6 +53,8 @@ pub mod request {
} }
pub mod response { pub mod response {
pub mod queue_metadata {
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
#[derive(Default, Deserialize, Serialize)] #[derive(Default, Deserialize, Serialize)]
@@ -57,6 +62,7 @@ pub mod response {
pub message: String, pub message: String,
pub data: Vec<uuid::Uuid>, pub data: Vec<uuid::Uuid>,
} }
}
pub mod fetch_metadata { pub mod fetch_metadata {
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
@@ -203,14 +209,14 @@ pub mod endpoint {
pub async fn queue_metadata( pub async fn queue_metadata(
axum::Extension(pool): axum::Extension<sqlx::PgPool>, axum::Extension(pool): axum::Extension<sqlx::PgPool>,
Json(payload): Json<super::request::Request>, Json(payload): Json<super::request::queue_metadata::Request>,
) -> (StatusCode, Json<super::response::Response>) { ) -> (StatusCode, Json<super::response::queue_metadata::Response>) {
let mut results: Vec<uuid::Uuid> = Vec::new(); let mut results: Vec<uuid::Uuid> = Vec::new();
let mut response = super::response::Response::default(); let mut response = super::response::queue_metadata::Response::default();
let meta = payload.to_json_value().await; let meta = payload.to_json_value().await;
match super::metadata_queue::insert(&pool, &meta, &payload.id).await { match super::metadata_queue::insert(&pool, &meta, &payload.song_queue_id).await {
Ok(id) => { Ok(metadata_queue_id) => {
results.push(id); results.push(metadata_queue_id);
response.data = results; response.data = results;
response.message = if response.data.is_empty() { response.message = if response.data.is_empty() {
String::from("Error") String::from("Error")