From da7870eeba88cd84f69c9c839e9c995d072b9558 Mon Sep 17 00:00:00 2001
From: Kitaiti Makoto <KitaitiMakoto@gmail.com>
Date: Mon, 21 Mar 2022 10:11:35 +0900
Subject: [PATCH] Implement Post::update_hashtags07()

---
 plume-models/src/posts.rs | 37 +++++++++++++++++++++++++++++++++++++
 1 file changed, 37 insertions(+)

diff --git a/plume-models/src/posts.rs b/plume-models/src/posts.rs
index bd87714d..422f4b7d 100644
--- a/plume-models/src/posts.rs
+++ b/plume-models/src/posts.rs
@@ -747,6 +747,43 @@ impl Post {
         Ok(())
     }
 
+    pub fn update_hashtags07(&self, conn: &Connection, tags: Vec<Hashtag07>) -> Result<()> {
+        let tags_name = tags
+            .iter()
+            .filter_map(|t| t.name.as_ref().map(|name| name.as_str().to_string()))
+            .collect::<HashSet<_>>();
+
+        let old_tags = Tag::for_post(&*conn, self.id)?;
+        let old_tags_name = old_tags
+            .iter()
+            .filter_map(|tag| {
+                if tag.is_hashtag {
+                    Some(tag.tag.clone())
+                } else {
+                    None
+                }
+            })
+            .collect::<HashSet<_>>();
+
+        for t in tags {
+            if !t
+                .name
+                .as_ref()
+                .map(|n| old_tags_name.contains(n.as_str()))
+                .unwrap_or(true)
+            {
+                Tag::from_activity07(conn, &t, self.id, true)?;
+            }
+        }
+
+        for ot in old_tags.into_iter().filter(|t| t.is_hashtag) {
+            if !tags_name.contains(&ot.tag) {
+                ot.delete(conn)?;
+            }
+        }
+        Ok(())
+    }
+
     pub fn url(&self, conn: &Connection) -> Result<String> {
         let blog = self.get_blog(conn)?;
         Ok(format!("/~/{}/{}", blog.fqn, self.slug))