From 95b944b819d7a1320d3083929177676f93d4a3e3 Mon Sep 17 00:00:00 2001
From: niliara-edu <nil.jimeno@estudiant.fjaverianas.com>
Date: Sun, 19 Jan 2025 14:58:26 +0100
Subject: add album and artist routes

---
 src/main.rs          |  2 ++
 src/routes.rs        | 18 ++++++++++-
 src/routes/album.rs  | 87 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 src/routes/artist.rs | 66 +++++++++++++++++++++++++++++++++++++++
 4 files changed, 172 insertions(+), 1 deletion(-)
 create mode 100644 src/routes/album.rs
 create mode 100644 src/routes/artist.rs

(limited to 'src')

diff --git a/src/main.rs b/src/main.rs
index 9d6ec4f..bddb0b6 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -31,6 +31,8 @@ async fn main() -> std::io::Result<()> {
             .app_data(web::Data::new(app_state.clone()))
             .route("/", web::get().to(root))
             .service(routes::song::song)
+            .service(routes::album::album)
+            .service(routes::artist::artist)
     })
     .bind(("127.0.0.1", 8000))?
     .run()
diff --git a/src/routes.rs b/src/routes.rs
index a219da1..d984505 100644
--- a/src/routes.rs
+++ b/src/routes.rs
@@ -1,14 +1,30 @@
 use serde::Serialize;
 
 pub mod song;
+pub mod album;
+pub mod artist;
 
 #[derive(Serialize)]
 pub struct Song {
-    id: Option<i32>,
     name: Option<String>,
+    id: Option<i32>,
     lyrics: Option<String>,
     album_name: Option<String>,
     album_id: Option<i32>,
     artist_name: Option<String>,
     artist_id: Option<i32>,
 }
+
+#[derive(Serialize)]
+pub struct Album {
+    name: Option<String>,
+    id: Option<i32>,
+    artist_name: Option<String>,
+    artist_id: Option<i32>,
+}
+
+#[derive(Serialize)]
+pub struct Artist {
+    name: Option<String>,
+    id: Option<i32>,
+}
diff --git a/src/routes/album.rs b/src/routes/album.rs
new file mode 100644
index 0000000..1948339
--- /dev/null
+++ b/src/routes/album.rs
@@ -0,0 +1,87 @@
+use crate::routes::Album;
+use crate::AppState;
+use actix_web::{get, web, HttpResponse};
+use serde::Deserialize;
+
+#[derive(Deserialize)]
+struct AlbumQueryOptions {
+    id: Option<String>,
+    name: Option<String>,
+    artist: Option<String>,
+}
+
+#[get("/api/album")]
+pub async fn album(
+    app_state: web::Data<AppState>,
+    get_args: web::Query<AlbumQueryOptions>,
+) -> HttpResponse {
+    let search_attempt: sqlx::Result<Vec<Album>>;
+
+    match true {
+        _ if check_if_exists(&get_args.id) => {
+            search_attempt = sqlx::query_as!(
+                Album,
+                "SELECT album.name, album.id,
+                artist.name as artist_name, artist.id as artist_id
+                FROM album
+                INNER JOIN artist ON album.artist_id = artist.id
+                WHERE album.id=?",
+                &get_args.id,
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+        _ if check_if_exists(&get_args.name) => {
+            let new_name : String = format!("{}{}{}", "%", &get_args.name.clone().unwrap(), "%");
+            search_attempt = sqlx::query_as!(
+                Album,
+                "SELECT album.name, album.id,
+                artist.name as artist_name, artist.id as artist_id
+                FROM album
+                INNER JOIN artist ON album.artist_id = artist.id
+                WHERE LOWER(album.name) LIKE LOWER(?)",
+                new_name,
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+        _ if check_if_exists(&get_args.artist) => {
+            search_attempt = sqlx::query_as!(
+                Album,
+                "SELECT album.name, album.id,
+                artist.name as artist_name, artist.id as artist_id
+                FROM album
+                INNER JOIN artist ON album.artist_id = artist.id
+                WHERE album.artist_id=?
+                ",
+                &get_args.artist,
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+        _ => {
+            search_attempt = sqlx::query_as!(
+                Album,
+                "SELECT album.name, album.id,
+                artist.name as artist_name, artist.id as artist_id
+                FROM album
+                INNER JOIN artist ON album.artist_id = artist.id
+                ",
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+    };
+
+    match search_attempt {
+        Ok(album_list) => HttpResponse::Ok().json(album_list),
+        Err(e) => HttpResponse::Ok().body(format!("{}", e)),
+    }
+}
+
+fn check_if_exists(value: &Option<String>) -> bool {
+    match value {
+        Some(_) => true,
+        None => false,
+    }
+}
diff --git a/src/routes/artist.rs b/src/routes/artist.rs
new file mode 100644
index 0000000..bf18e34
--- /dev/null
+++ b/src/routes/artist.rs
@@ -0,0 +1,66 @@
+use crate::routes::Artist;
+use crate::AppState;
+use actix_web::{get, web, HttpResponse};
+use serde::Deserialize;
+
+#[derive(Deserialize)]
+struct ArtistQueryOptions {
+    id: Option<String>,
+    name: Option<String>,
+}
+
+#[get("/api/artist")]
+pub async fn artist(
+    app_state: web::Data<AppState>,
+    get_args: web::Query<ArtistQueryOptions>,
+) -> HttpResponse {
+    let search_attempt: sqlx::Result<Vec<Artist>>;
+
+    match true {
+        _ if check_if_exists(&get_args.id) => {
+            search_attempt = sqlx::query_as!(
+                Artist,
+                "SELECT name, id
+                FROM artist
+                WHERE id=?",
+                &get_args.id,
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+        _ if check_if_exists(&get_args.name) => {
+            let new_name : String = format!("{}{}{}", "%", &get_args.name.clone().unwrap(), "%");
+            search_attempt = sqlx::query_as!(
+                Artist,
+                "SELECT name, id
+                FROM artist
+                WHERE LOWER(name) LIKE LOWER(?)",
+                new_name,
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+        _ => {
+            search_attempt = sqlx::query_as!(
+                Artist,
+                "SELECT name, id
+                FROM artist
+                ",
+            )
+            .fetch_all(&app_state.pool)
+            .await;
+        }
+    };
+
+    match search_attempt {
+        Ok(artist_list) => HttpResponse::Ok().json(artist_list),
+        Err(e) => HttpResponse::Ok().body(format!("{}", e)),
+    }
+}
+
+fn check_if_exists(value: &Option<String>) -> bool {
+    match value {
+        Some(_) => true,
+        None => false,
+    }
+}
-- 
cgit v1.2.3