feat(anni): migrate with commit=false

anni-metadata/queries/add-album.graphql

@@ -52,8 +52,16 @@ fragment AlbumDetail on Album {
     }
 }
 
-mutation addAlbum($album: AddAlbumInput!) {
-    addAlbum(input: $album) {
+fragment TagBase on Tag {
+    id
+    name
+    type
+    createdAt
+    updatedAt
+}
+
+mutation addAlbum($album: AddAlbumInput!, $commit: Boolean) {
+    addAlbum(input: $album, commit: $commit) {
         ...AlbumDetail
     }
 }

anni-metadata/schemas/annim.graphql

@@ -182,7 +182,7 @@ type MetadataMutation {
   """
   Add the metatada of a full album to annim.
   """
-  addAlbum(input: AddAlbumInput!): Album!
+  addAlbum(input: AddAlbumInput!, commit: Boolean): Album!
   """
   Update basic album information.
   Use this method to update basic album information such as title, artist and others.
@@ -262,6 +262,7 @@ enum MetadataOrganizeLevel {
 type MetadataQuery {
   album(albumId: UUID!): Album
   albums(by: AlbumsBy!, after: String, first: Int): AlbumConnection!
+  tracks(keyword: String!): [TrackSearchResult!]!
   tag(tagName: String!, tagType: TagType): [Tag!]!
 }
 
@@ -338,6 +339,20 @@ type Track {
   updatedAt: DateTime!
 }
 
+type TrackSearchResult {
+  """
+  Return the search score of the track.
+  """
+  score: Float!
+  """
+  Return a `TrackIdentifier` string which represents the track.
+  """
+  identifier: String!
+  album: Album
+  disc: Disc
+  track: Track
+}
+
 enum TrackType {
   NORMAL
   INSTRUMENTAL

anni-metadata/src/annim/client.rs

@@ -49,6 +49,7 @@ impl AnnimClient {
     pub async fn add_album(
         &self,
         album: &model::Album,
+        commit: bool,
     ) -> anyhow::Result<query::album::AlbumFragment> {
         let discs: Vec<_> = album.iter().collect();
         let input = mutation::add_album::AddAlbumInput {
@@ -82,6 +83,7 @@ impl AnnimClient {
         let query =
             mutation::add_album::AddAlbumMutation::build(mutation::add_album::AddAlbumVariables {
                 album: input,
+                commit: Some(commit),
             });
         let response = self.client.post(&self.endpoint).run_graphql(query).await?;
         if let Some(errors) = response.errors {

anni-metadata/src/annim/mutation/add_album.rs

@@ -4,12 +4,13 @@ use crate::annim::{schema, Json, Uuid};
 #[derive(cynic::QueryVariables, Debug)]
 pub struct AddAlbumVariables<'a> {
     pub album: AddAlbumInput<'a>,
+    pub commit: Option<bool>,
 }
 
 #[derive(cynic::QueryFragment, Debug)]
 #[cynic(graphql_type = "MetadataMutation", variables = "AddAlbumVariables")]
 pub struct AddAlbumMutation {
-    #[arguments(input: $album)]
+    #[arguments(input: $album, commit: $commit)]
     pub add_album: AlbumFragment,
 }
 

anni/src/subcommands/repo/migrate.rs

@@ -58,8 +58,20 @@ async fn repo_migrate(me: RepoMigrateAction, manager: RepositoryManager) -> anyh
 
     let mut albums = HashMap::new();
     log::info!("Start inserting albums...");
-    for album in repo.albums_iter() {
-        let annim_album = client.add_album(album).await?;
+    let mut albums_iter = repo.albums_iter();
+    let last = albums_iter.next(); // read the first album for further commit
+
+    for album in albums_iter {
+        let annim_album = client.add_album(album, false).await?;
+        log::info!(
+            "Inserted album {}, id = {}",
+            annim_album.title,
+            annim_album.id.inner()
+        );
+        albums.insert(album.album_id, annim_album);
+    }
+    if let Some(album) = last {
+        let annim_album = client.add_album(album, true).await?;
         log::info!(
             "Inserted album {}, id = {}",
             annim_album.title,

anni/src/subcommands/workspace/add.rs

@@ -108,7 +108,7 @@ fn handle_workspace_add(me: WorkspaceAddAction) -> anyhow::Result<()> {
             }
             anni_workspace::config::WorkspaceMetadata::Remote { endpoint, token } => {
                 let client = AnnimClient::new(endpoint, token.as_deref());
-                client.add_album(&album).await?;
+                client.add_album(&album, true).await?;
             }
         }
     }