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

Added user_id to SongQueue and added more related code

Browse Source
This commit is contained in:
kdeng00
2025-07-21 19:39:00 -04:00
parent b6d409d39a
commit 56520eb47e
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/callers/song.rs
+5 -2
View File
@@ -336,6 +336,7 @@ mod song_queue {
pub id: uuid::Uuid, pub id: uuid::Uuid,
pub filename: String, pub filename: String,
pub status: String, pub status: String,
pub user_id: uuid::Uuid
} }
pub async fn insert( pub async fn insert(
@@ -409,7 +410,7 @@ mod song_queue {
FOR UPDATE SKIP LOCKED FOR UPDATE SKIP LOCKED
LIMIT 1 LIMIT 1
) )
RETURNING id, filename, status; RETURNING id, filename, status, user_id;
"#, "#,
) )
.bind(super::status::PROCESSING) .bind(super::status::PROCESSING)
@@ -434,6 +435,7 @@ mod song_queue {
.try_get("status") .try_get("status")
.map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
.unwrap(), .unwrap(),
user_id: row.try_get("user_id").map_err(|_e| sqlx::Error::RowNotFound).unwrap()
}), }),
Err(_err) => Err(sqlx::Error::RowNotFound), Err(_err) => Err(sqlx::Error::RowNotFound),
} }
@@ -524,7 +526,7 @@ mod song_queue {
) -> Result<SongQueue, sqlx::Error> { ) -> Result<SongQueue, sqlx::Error> {
let result = sqlx::query( let result = sqlx::query(
r#" r#"
SELECT id, filename, status FROM "songQueue" WHERE id = $1 SELECT id, filename, status, user_id FROM "songQueue" WHERE id = $1
"#, "#,
) )
.bind(id) .bind(id)
@@ -548,6 +550,7 @@ mod song_queue {
.try_get("status") .try_get("status")
.map_err(|_e| sqlx::Error::RowNotFound) .map_err(|_e| sqlx::Error::RowNotFound)
.unwrap(), .unwrap(),
user_id: row.try_get("user_id").map_err(|_e| sqlx::Error::RowNotFound).unwrap()
}), }),
Err(_err) => Err(sqlx::Error::RowNotFound), Err(_err) => Err(sqlx::Error::RowNotFound),
} }