#414

backend/spec/services/post_bulk_creator_spec.rb

@@ -88,3 +88,86 @@ RSpec.describe PostBulkCreator do
     expect(creator).to have_received(:create!).with(locale).once
   end
 end
+
+RSpec.describe 'PostBulkCreator event grouping', type: :model do
+  self.use_transactional_tests = false
+
+  before do
+    expect(Rails.env.test?).to be(true)
+    expect(ApplicationRecord.connection.open_transactions).to eq(0)
+    @prefix = "bulk_event_#{ SecureRandom.hex(8) }"
+    @actor = create(:user, :member)
+    allow(PostCreatePreflight).to receive(:new) do |attributes:, **|
+      specs = [{ name: attributes.fetch(:title), category: :general }]
+      instance_double(PostCreatePreflight, run: attributes.merge(
+          existing_post_id: nil, snapshot_tag_specs: specs, post_tag_specs: specs,
+          normalised_parent_post_ids: [], tag_sections: { }, video_ms: nil))
+    end
+  end
+
+  after do
+    if @actor
+      posts = Post.where(uploaded_user: @actor)
+      PostTagSection.where(post_id: posts.select(:id)).delete_all
+      PostTag.where(post_id: posts.select(:id)).delete_all
+      PostVersion.where(post_id: posts.select(:id)).delete_all
+      posts.delete_all
+      tag_ids = TagName.where(name: ["#{ @prefix }_1", "#{ @prefix }_2"]).pluck(:tag_id)
+      TagVersion.where(tag_id: tag_ids).delete_all
+      TagName.where(tag_id: tag_ids).delete_all
+      Tag.where(id: tag_ids).delete_all
+      EventRecords::EventRow.where(created_by_user_id: @actor.id).delete_all
+      @actor.delete
+    end
+  end
+
+  it 'shares one creation event between real workers and their tag histories' do
+    posts = [1, 2].map do |number|
+      { title: "#{ @prefix }_#{ number }",
+        url: "https://example.com/#{ @prefix }/#{ number }" }
+    end
+
+    result = nil
+    expect {
+      result = PostBulkCreator.new(actor: @actor, posts:, thumbnails: { })
+          .run(Locale.nipponese)
+    }.to change { event_rows.length }.by(1)
+
+    expect(result.fetch(:results).map { _1.fetch(:status) }).to eq(['created', 'created'])
+    event = event_rows.last
+    expect(event).to include(
+        'event_type' => 'posts.create', 'created_by_user_id' => @actor.id)
+    versions = PostVersion.where(created_by_user_id: @actor.id)
+    expect(versions.count).to eq(2)
+    expect(versions.pluck(:event_id).uniq).to eq([event.fetch('id')])
+    tag_versions = TagVersion.where(created_by_user_id: @actor.id)
+    expect(tag_versions.count).to eq(2)
+    expect(tag_versions.pluck(:event_id).uniq).to eq([event.fetch('id')])
+  end
+
+  it 'does not leave an event when every row fails validation' do
+    preflight = instance_double(PostCreatePreflight)
+    allow(PostCreatePreflight).to receive(:new).and_return(preflight)
+    allow(preflight).to receive(:run).and_raise(
+        PostCreatePreflight::ValidationFailed.new(fields: { url: ['invalid'] }))
+    events = event_rows
+
+    result = PostBulkCreator.new(
+        actor: @actor, posts: [{ title: 'invalid' }], thumbnails: { }).run(Locale.nipponese)
+
+    expect(result.fetch(:results).map { _1.fetch(:status) }).to eq(['failed'])
+    expect(event_rows).to eq(events)
+  end
+
+  it 'does not leave an event when every row is skipped' do
+    preflight = instance_double(PostCreatePreflight, run: { existing_post_id: 123 })
+    allow(PostCreatePreflight).to receive(:new).and_return(preflight)
+    events = event_rows
+
+    result = PostBulkCreator.new(
+        actor: @actor, posts: [{ title: 'existing' }], thumbnails: { }).run(Locale.nipponese)
+
+    expect(result.fetch(:results).map { _1.fetch(:status) }).to eq(['skipped'])
+    expect(event_rows).to eq(events)
+  end
+end