feat(metadata): get albums by ids

Author: Yesterday17

anni-metadata/queries/albums.graphql

@@ -0,0 +1,67 @@
+fragment AlbumDetail on Album {
+    id
+    albumId
+    level
+
+    title
+    edition
+    catalog
+    artist
+
+    year
+    month
+    day
+
+    tags {
+        ...TagBase
+    }
+
+    createdAt
+    updatedAt
+    extra
+
+    discs {
+        id
+        index
+        title
+        catalog
+        artist
+
+        tags {
+            ...TagBase
+        }
+
+        createdAt
+        updatedAt
+
+        tracks {
+            id
+            index
+            title
+            artist
+            type
+            artists
+
+            tags {
+                ...TagBase
+            }
+
+            createdAt
+            updatedAt
+        }
+    }
+}
+
+query albums($albumIds: [UUID!]!) {
+    albums(by: { albumIds: $albumIds }) {
+        pageInfo {
+            hasPreviousPage
+            hasNextPage
+            startCursor
+            endCursor
+        }
+        nodes {
+            ...AlbumDetail
+        }
+    }
+}

anni-metadata/src/annim/client.rs

@@ -48,6 +48,27 @@ impl AnnimClient {
         Ok(response.data.and_then(|data| data.album))
     }
 
+    pub async fn albums(
+        &self,
+        album_ids: Vec<uuid::Uuid>,
+    ) -> anyhow::Result<Vec<query::album::AlbumFragment>> {
+        let query = query::albums::AlbumsQuery::build(query::albums::AlbumsVariables {
+            after: None,
+            first: Some(album_ids.len() as i32),
+            album_ids: Some(album_ids),
+        });
+        let response = self.client.post(&self.endpoint).run_graphql(query).await?;
+        if let Some(errors) = response.errors {
+            anyhow::bail!("GraphQL error: {:?}", errors);
+        }
+
+        Ok(response
+            .data
+            .and_then(|data| data.albums)
+            .map(|d| d.nodes)
+            .unwrap())
+    }
+
     pub async fn add_album(
         &self,
         album: &model::Album,

anni-metadata/src/annim/query.rs

@@ -1,2 +1,3 @@
 pub mod album;
+pub mod albums;
 pub mod tag;

anni-metadata/src/annim/query/albums.rs

@@ -0,0 +1,31 @@
+use crate::annim::{schema, Uuid};
+
+use super::album::AlbumFragment;
+
+#[derive(cynic::QueryVariables, Debug)]
+pub struct AlbumsVariables {
+    pub album_ids: Option<Vec<Uuid>>,
+    pub after: Option<String>,
+    pub first: Option<i32>,
+}
+
+#[derive(cynic::QueryFragment, Debug)]
+#[cynic(graphql_type = "MetadataQuery", variables = "AlbumsVariables")]
+pub struct AlbumsQuery {
+    #[arguments(by: { albumIds: $album_ids }, after: $after, first: $first )]
+    pub albums: Option<AlbumConnection>,
+}
+
+#[derive(cynic::QueryFragment, Debug)]
+pub struct AlbumConnection {
+    pub page_info: PageInfo,
+    pub nodes: Vec<AlbumFragment>,
+}
+
+#[derive(cynic::QueryFragment, Debug)]
+pub struct PageInfo {
+    pub end_cursor: Option<String>,
+    pub has_next_page: bool,
+    pub has_previous_page: bool,
+    pub start_cursor: Option<String>,
+}