Fix creation of duplicate tags on import

Signed-off-by: trivernis <trivernis@protonmail.com>

mediarepo-daemon/mediarepo-model/src/repo.rs

@@ -110,7 +110,7 @@ impl Repo {
             .map(|t| parse_namespace_and_tag(t.0.clone()))
             .collect();
 
-        let db_tags = self.all_tags(parsed_tags).await?;
+        let db_tags = self.tags_by_names(parsed_tags).await?;
         let tag_map: HashMap<String, bool> = HashMap::from_iter(tags.into_iter());
 
         let tag_ids: Vec<(i64, bool)> = db_tags
@@ -197,7 +197,7 @@ impl Repo {
 
     /// Finds all tags by name
     #[tracing::instrument(level = "debug", skip(self))]
-    pub async fn all_tags(&self, tags: Vec<(Option<String>, String)>) -> RepoResult<Vec<Tag>> {
+    pub async fn tags_by_names(&self, tags: Vec<(Option<String>, String)>) -> RepoResult<Vec<Tag>> {
         Tag::all_by_name(self.db.clone(), tags).await
     }
 

mediarepo-daemon/mediarepo-model/src/tag.rs

@@ -95,6 +95,7 @@ impl Tag {
         let tags: Vec<Self> = tag::Entity::find()
             .find_also_related(namespace::Entity)
             .filter(or_condition)
+            .group_by(tag::Column::Id)
             .all(&db)
             .await?
             .into_iter()

mediarepo-daemon/src/main.rs

@@ -238,16 +238,20 @@ async fn add_tags_from_tags_file(
     log::info!("Adding tags");
     if tags_path.exists() {
         let mut tags = parse_tags_file(tags_path).await?;
-        let resolved_tags = repo.all_tags(tags.clone()).await?;
+        log::info!("Found {} tags in the tag file", tags.len());
+        let resolved_tags = repo.tags_by_names(tags.clone()).await?;
+
         tags.retain(|tag| {
             resolved_tags
                 .iter()
                 .find(|t| if let (Some(ns1), Some(ns2)) = (t.namespace(), &tag.0) {
                     *ns1.name() == *ns2
-                } else { false } && *t.name() == *tag.1)
+                } else { t.namespace().is_none() && tag.0.is_none() } && *t.name() == *tag.1)
                 .is_none()
         });
         let mut tag_ids: Vec<i64> = resolved_tags.into_iter().map(|t| t.id()).collect();
+        log::info!("Existing tag_ids count is {}", tag_ids.len());
+        log::info!("{} tags need to be created", tags.len());
 
         for (namespace, name) in tags {
             let tag = if let Some(namespace) = namespace {