Got it somewhat working

This commit is contained in:
kdeng00
2025-04-29 21:14:50 -04:00
parent 1d4db581b1
commit 4597f2d016
+12 -7
View File
@@ -80,7 +80,7 @@ pub mod metadata_queue {
pub struct MetadataQueue { pub struct MetadataQueue {
pub id: uuid::Uuid, pub id: uuid::Uuid,
// pub metadata: serde_json::Value, // pub metadata: serde_json::Value,
// pub metadata: serde_json::Value, pub metadata: serde_json::Value,
#[serde(with = "time::serde::rfc3339")] #[serde(with = "time::serde::rfc3339")]
pub created_at: time::OffsetDateTime, pub created_at: time::OffsetDateTime,
pub song_queue_id: uuid::Uuid, pub song_queue_id: uuid::Uuid,
@@ -138,10 +138,10 @@ pub mod metadata_queue {
.try_get("id") .try_get("id")
.map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
.unwrap(), .unwrap(),
// metadata: row metadata: row
// .try_get("metadata") .try_get("metadata")
// .map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
// .unwrap(), .unwrap(),
created_at: row created_at: row
.try_get("created_at") .try_get("created_at")
.map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
@@ -174,11 +174,15 @@ pub mod metadata_queue {
// println!("SQL {:?}", result); // println!("SQL {:?}", result);
match result { match result {
Ok(row) => Ok(MetadataQueue { Ok(row) =>
{
let data: serde_json::Value = row.try_get("metadata").map_err(|_e| sqlx::Error::RowNotFound).unwrap();
Ok(MetadataQueue {
id: row id: row
.try_get("id") .try_get("id")
.map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
.unwrap(), .unwrap(),
metadata: data,
// metadata: row // metadata: row
// .try_get("metadata") // .try_get("metadata")
// .map_err(|_e| sqlx::Error::RowNotFound) // .map_err(|_e| sqlx::Error::RowNotFound)
@@ -192,7 +196,8 @@ pub mod metadata_queue {
.try_get("song_queue_id") .try_get("song_queue_id")
.map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
.unwrap(), .unwrap(),
}), })
},
Err(_err) => Err(sqlx::Error::RowNotFound), Err(_err) => Err(sqlx::Error::RowNotFound),
} }
} }