From 0faf496641019ec22bf1d946787ae349d9464d58 Mon Sep 17 00:00:00 2001
From: phoenix <kundeng00@pm.me>
Date: Thu, 24 Apr 2025 21:06:01 -0400
Subject: [PATCH] Added status

---
 src/callers/song.rs | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/src/callers/song.rs b/src/callers/song.rs
index a98d0a7..8af17b8 100644
--- a/src/callers/song.rs
+++ b/src/callers/song.rs
@@ -20,6 +20,13 @@ pub mod response {
 mod song_queue {
     use sqlx::Row;
 
+    pub mod status {
+        pub const PENDING: &str = "pending";
+        // Will be used later on
+        pub const _PROCESSING: &str = "processing";
+        pub const _DONE: &str = "done";
+    }
+
     #[derive(Debug, serde::Serialize, sqlx::FromRow)]
     pub struct InsertedData {
         pub id: uuid::Uuid,
@@ -29,14 +36,16 @@ mod song_queue {
         pool: &sqlx::PgPool,
         data: &Vec<u8>,
         filename: &String,
+        status: &String,
     ) -> Result<uuid::Uuid, sqlx::Error> {
         let result = sqlx::query(
             r#"
-            INSERT INTO "songQueue" (data, filename) VALUES($1, $2) RETURNING id;
+            INSERT INTO "songQueue" (data, filename, status) VALUES($1, $2, $3) RETURNING id;
             "#,
         )
         .bind(data)
         .bind(filename)
+        .bind(status)
         .fetch_one(pool)
         .await
         .map_err(|e| {
@@ -88,7 +97,7 @@ pub mod endpoint {
             file.write_all(&data).unwrap();
 
             let raw_data: Vec<u8> = data.to_vec();
-            let queue_repo = song_queue::insert(&pool, &raw_data, &file_name)
+            let queue_repo = song_queue::insert(&pool, &raw_data, &file_name, &song_queue::status::PENDING.to_string())
                 .await
                 .unwrap();
             results.push(queue_repo);