投稿に対する履歴（#264） (#307)

Merge branch 'main' into feature/264

#264

#264

#264

#264

Co-authored-by: miteruzo <miteruzo@naver.com>
Reviewed-on: #307

backend/app/controllers/posts_controller.rb

@@ -127,17 +127,20 @@ class PostsController < ApplicationController
     post = Post.new(title:, url:, thumbnail_base: nil, uploaded_user: current_user,
                     original_created_from:, original_created_before:)
     post.thumbnail.attach(thumbnail)
-    if post.save
-      post.resized_thumbnail!
+
+    ActiveRecord::Base.transaction do
+      post.save!
       tags = Tag.normalise_tags(tag_names)
       tags = Tag.expand_parent_tags(tags)
       sync_post_tags!(post, tags)
-
-      post.reload
-      render json: PostRepr.base(post), status: :created
-    else
-      render json: { errors: post.errors.full_messages }, status: :unprocessable_entity
+      post.resized_thumbnail!
+      PostVersionRecorder.record!(post:, event_type: :create, created_by_user: current_user)
     end
+
+    post.reload
+    render json: PostRepr.base(post), status: :created
+  rescue ActiveRecord::RecordInvalid
+    render json: { errors: post.errors.full_messages }, status: :unprocessable_entity
   rescue Tag::NicoTagNormalisationError
     head :bad_request
   end
@@ -166,19 +169,22 @@ class PostsController < ApplicationController
     original_created_before = params[:original_created_before]
 
     post = Post.find(params[:id].to_i)
-    if post.update(title:, original_created_from:, original_created_before:)
+
+    ActiveRecord::Base.transaction do
+      post.update!(title:, original_created_from:, original_created_before:)
       tags = post.tags.where(category: 'nico').to_a +
              Tag.normalise_tags(tag_names, with_tagme: false)
       tags = Tag.expand_parent_tags(tags)
       sync_post_tags!(post, tags)
-
-      post.reload
-      json = post.as_json
-      json['tags'] = build_tag_tree_for(post.tags)
-      render json:, status: :ok
-    else
-      render json: post.errors, status: :unprocessable_entity
+      PostVersionRecorder.record!(post:, event_type: :update, created_by_user: current_user)
     end
+
+    post.reload
+    json = post.as_json
+    json['tags'] = build_tag_tree_for(post.tags)
+    render json:, status: :ok
+  rescue ActiveRecord::RecordInvalid
+    render json: post.errors, status: :unprocessable_entity
   rescue Tag::NicoTagNormalisationError
     head :bad_request
   end

backend/app/models/post.rb

@@ -11,6 +11,7 @@ class Post < ApplicationRecord
 
   has_many :user_post_views, dependent: :delete_all
   has_many :post_similarities, dependent: :delete_all
+  has_many :post_versions
 
   has_one_attached :thumbnail
 
@@ -30,6 +31,8 @@ class Post < ApplicationRecord
     super(options).merge(thumbnail: nil)
   end
 
+  def snapshot_tag_names = tags.joins(:tag_name).order('tag_names.name').pluck('tag_names.name')
+
   def related limit: nil
     ids = post_similarities.order(cos: :desc)
     ids = ids.limit(limit) if limit

backend/app/models/post_version.rb

@@ -0,0 +1,38 @@
+class PostVersion < ApplicationRecord
+  before_update do
+    raise ActiveRecord::ReadOnlyRecord, '版は更新できません．'
+  end
+
+  before_destroy do
+    raise ActiveRecord::ReadOnlyRecord, '版は削除できません．'
+  end
+
+  belongs_to :post
+  belongs_to :parent, class_name: 'Post', optional: true
+  belongs_to :created_by_user, class_name: 'User', optional: true
+
+  enum :event_type, { create: 'create',
+                      update: 'update',
+                      discard: 'discard',
+                      restore: 'restore' }, prefix: true, validate: true
+
+  validates :version_no, presence: true, numericality: { only_integer: true, greater_than: 0 }
+  validates :event_type, presence: true, inclusion: { in: event_types.keys }
+  validates :url, presence: true
+
+  validate :validate_original_created_range
+
+  scope :chronological, -> { order(:version_no, :id) }
+
+  private
+
+  def validate_original_created_range
+    f = original_created_from
+    b = original_created_before
+    return if f.blank? || b.blank?
+
+    if f >= b
+      errors.add :original_created_before, 'オリジナルの作成日時の順番がをかしぃです．'
+    end
+  end
+end

backend/app/models/tag.rb

@@ -1,3 +1,6 @@
+require 'set'
+
+
 class Tag < ApplicationRecord
   include MyDiscard
 
@@ -150,6 +153,8 @@ class Tag < ApplicationRecord
   def self.merge_tags! target_tag, source_tags
     target_tag => Tag
 
+    affected_post_ids = Set.new
+
     Tag.transaction do
       Array(source_tags).compact.uniq.each do |source_tag|
         source_tag => Tag
@@ -158,6 +163,7 @@ class Tag < ApplicationRecord
 
         source_tag.post_tags.kept.find_each do |source_pt|
           post_id = source_pt.post_id
+          affected_post_ids << post_id
           source_pt.discard_by!(nil)
           unless PostTag.kept.exists?(post_id:, tag: target_tag)
             PostTag.create!(post_id:, tag: target_tag)
@@ -180,6 +186,10 @@ class Tag < ApplicationRecord
         end
       end
 
+      Post.where(id: affected_post_ids.to_a).find_each do |post|
+        PostVersionRecorder.record!(post:, event_type: :update, created_by_user: nil)
+      end
+
       # 投稿件数を再集計
       target_tag.update_columns(post_count: PostTag.kept.where(tag: target_tag).count)
     end

backend/app/services/post_version_recorder.rb

@@ -0,0 +1,57 @@
+class PostVersionRecorder
+  def self.record! post:, event_type:, created_by_user:
+    new(post:, event_type:, created_by_user:).record!
+  end
+
+  def initialize post:, event_type:, created_by_user:
+    @post = post
+    @event_type = event_type
+    @created_by_user = created_by_user
+  end
+
+  def record!
+    @post.with_lock do
+      latest = @post.post_versions.order(version_no: :desc).first
+      attrs = snapshot_attributes
+
+      return latest if @event_type == :update && latest && same_snapshot?(latest, attrs)
+
+      PostVersion.create!(
+          post: @post,
+          version_no: (latest&.version_no || 0) + 1,
+          event_type: @event_type,
+          title: attrs[:title],
+          url: attrs[:url],
+          thumbnail_base: attrs[:thumbnail_base],
+          tags: attrs[:tags],
+          parent: attrs[:parent],
+          original_created_from: attrs[:original_created_from],
+          original_created_before: attrs[:original_created_before],
+          created_at: Time.current,
+          created_by_user: @created_by_user)
+    end
+  end
+
+  private
+
+  def snapshot_attributes
+    { title: @post.title,
+      url: @post.url,
+      thumbnail_base: @post.thumbnail_base,
+      tags: @post.snapshot_tag_names.join(' '),
+      parent: @post.parent,
+      original_created_from: @post.original_created_from,
+      original_created_before: @post.original_created_before }
+  end
+
+  def same_snapshot? version, attrs
+    true &&
+        version.title == attrs[:title] &&
+        version.url == attrs[:url] &&
+        version.thumbnail_base == attrs[:thumbnail_base] &&
+        version.tags == attrs[:tags] &&
+        version.parent_id == attrs[:parent]&.id &&
+        version.original_created_from == attrs[:original_created_from] &&
+        version.original_created_before == attrs[:original_created_before]
+  end
+end