🔧 TDD実装: news:upsert タスクで YAML の ID を DB の主キーとして使用

YAML をマスターデータとして、DB の News レコードが YAML の ID に従うように実装。
TDD (Test-Driven Development) サイクルに従って実装を完了。

- YAML の ID をそのまま DB の主キー (id) として使用
- 同じ URL だが異なる ID のレコードを事前に削除する処理を追加
- News.find_or_initialize_by(id: item['id']) で YAML の ID を使用
- YAML に存在しない ID のレコードを削除する処理を追加
- ID を 4桁でゼロパディング表示 (例: ID 0001)

- YAML ID と DB ID の一致を確認するテスト
- 既存レコードの ID 更新を確認するテスト
- 不要レコードの削除を確認するテスト

1. RED: テストを追加し、失敗を確認 ✅
2. GREEN: タスクを修正し、テストが通ることを確認 ✅
3. REFACTOR: ID 表示フォーマットの改善 ✅

- 182 件の重複 URL を持つレコードを正しい ID に置き換え
- 全てのニュースアイテムの ID が YAML と一致
- 全テストスイート (news_spec, news requests, rake task) がパス

Author: yasulab

lib/tasks/news.rake

@@ -142,7 +142,7 @@ namespace :news do
   end
 
 
-  desc "#{NEWS_YAML_PATH} からデータベースに upsert"
+  desc "#{NEWS_YAML_PATH} からデータベースに upsert (YAMLのIDを使用)"
   task upsert: :environment do
     TASK_LOGGER.info "==== START news:upsert ===="
 
@@ -151,9 +151,20 @@ namespace :news do
     updated_count = 0
 
     News.transaction do
+      # まず、同じURLだが異なるIDのレコードを削除
       news_items.each do |item|
-        news = News.find_or_initialize_by(url: item['url'])
+        existing_with_different_id = News.where(url: item['url']).where.not(id: item['id']).first
+        if existing_with_different_id
+          TASK_LOGGER.info "[News] Removing duplicate: ID:#{existing_with_different_id.id} (URL: #{item['url']}) to be replaced by ID:#{item['id']}"
+          existing_with_different_id.destroy
+        end
+      end
+
+      news_items.each do |item|
+        # YAMLのIDを使ってレコードを検索または初期化
+        news = News.find_or_initialize_by(id: item['id'])
         news.assign_attributes(
+          url:          item['url'],
           title:        item['title'],
           published_at: item['published_at']
         )
@@ -166,9 +177,16 @@ namespace :news do
           created_count += 1 if     is_new_record
           updated_count += 1 unless is_new_record
 
-          TASK_LOGGER.info "[News] #{news.published_at.to_date} #{news.title} (#{status})"
+          TASK_LOGGER.info "[News] ID #{format('%04d', news.id)}: #{news.published_at.to_date} #{news.title} (#{status})"
         end
       end
+
+      # YAMLに存在しないレコードを削除
+      yaml_ids = news_items.map { |item| item['id'] }
+      deleted_count = News.where.not(id: yaml_ids).destroy_all.size
+      if deleted_count > 0
+        TASK_LOGGER.info "Deleted #{deleted_count} items that are not in YAML."
+      end
     end
 
     TASK_LOGGER.info "Upserted #{created_count + updated_count} items (#{created_count} new, #{updated_count} updated)."

spec/lib/tasks/news_spec.rb

@@ -0,0 +1,141 @@
+require 'rails_helper'
+require 'rake'
+
+RSpec.describe 'news:upsert' do
+  let(:news_yaml_path) { Rails.root.join('db', 'news.yml') }
+  
+  before(:all) do
+    # Rakeタスクをロード
+    Rails.application.load_tasks
+  end
+  
+  before do
+    # 既存のNewsレコードをクリア
+    News.destroy_all
+  end
+
+  describe 'YAMLのIDとDBのIDの一致' do
+    it 'YAMLファイルのIDがそのままDBのIDとして使用される' do
+      # テスト用のYAMLデータを作成
+      test_yaml_data = [
+        {
+          'id' => 10,
+          'url' => 'https://example.com/news10',
+          'title' => 'テストニュース10',
+          'published_at' => '2025-12-10T09:00:00+09:00'
+        },
+        {
+          'id' => 5,
+          'url' => 'https://example.com/news5', 
+          'title' => 'テストニュース5',
+          'published_at' => '2025-12-05T09:00:00+09:00'
+        },
+        {
+          'id' => 1,
+          'url' => 'https://example.com/news1',
+          'title' => 'テストニュース1',
+          'published_at' => '2025-12-01T09:00:00+09:00'
+        }
+      ]
+
+      # 一時的にYAMLファイルを置き換え
+      original_yaml_content = File.read(news_yaml_path) if File.exist?(news_yaml_path)
+      File.write(news_yaml_path, test_yaml_data.to_yaml)
+
+      # タスクを実行
+      Rake::Task['news:upsert'].execute
+
+      # データベースのレコードを確認
+      expect(News.count).to eq(3)
+      
+      # YAMLのIDとDBのIDが一致することを確認
+      test_yaml_data.each do |yaml_item|
+        db_news = News.find(yaml_item['id'])
+        expect(db_news).not_to be_nil
+        expect(db_news.id).to eq(yaml_item['id'])
+        expect(db_news.url).to eq(yaml_item['url'])
+        expect(db_news.title).to eq(yaml_item['title'])
+      end
+
+      # IDの配列が完全に一致することを確認
+      yaml_ids = test_yaml_data.map { |item| item['id'] }.sort
+      db_ids = News.pluck(:id).sort
+      expect(db_ids).to eq(yaml_ids)
+
+    ensure
+      # 元のYAMLファイルを復元
+      File.write(news_yaml_path, original_yaml_content) if original_yaml_content
+    end
+
+    it '既存レコードのIDも更新される' do
+      # 既存のレコードを作成（異なるID）
+      News.create!(id: 100, url: 'https://example.com/old', title: '古いニュース', published_at: 1.month.ago)
+      
+      # テスト用のYAMLデータ（同じURLだが異なるID）
+      test_yaml_data = [
+        {
+          'id' => 1,
+          'url' => 'https://example.com/old',
+          'title' => '更新されたニュース',
+          'published_at' => '2025-12-01T09:00:00+09:00'
+        }
+      ]
+
+      # 一時的にYAMLファイルを置き換え
+      original_yaml_content = File.read(news_yaml_path) if File.exist?(news_yaml_path)
+      File.write(news_yaml_path, test_yaml_data.to_yaml)
+
+      # タスクを実行
+      Rake::Task['news:upsert'].execute
+
+      # ID 100のレコードは削除され、ID 1のレコードが存在することを確認
+      expect(News.exists?(100)).to be false
+      expect(News.exists?(1)).to be true
+      
+      news = News.find(1)
+      expect(news.title).to eq('更新されたニュース')
+
+    ensure
+      # 元のYAMLファイルを復元
+      File.write(news_yaml_path, original_yaml_content) if original_yaml_content
+    end
+
+    it 'YAMLに存在しないレコードは削除される' do
+      # YAMLに存在しないレコードを作成
+      News.create!(id: 999, url: 'https://example.com/tobedeleted', title: '削除されるニュース', published_at: 1.day.ago)
+      
+      # テスト用のYAMLデータ（ID 999は含まない）
+      test_yaml_data = [
+        {
+          'id' => 1,
+          'url' => 'https://example.com/news1',
+          'title' => 'テストニュース1',
+          'published_at' => '2025-12-01T09:00:00+09:00'
+        }
+      ]
+
+      # 一時的にYAMLファイルを置き換え
+      original_yaml_content = File.read(news_yaml_path) if File.exist?(news_yaml_path)
+      File.write(news_yaml_path, test_yaml_data.to_yaml)
+
+      # タスクを実行
+      Rake::Task['news:upsert'].execute
+
+      # ID 999のレコードが削除されていることを確認
+      expect(News.exists?(999)).to be false
+      expect(News.count).to eq(1)
+      expect(News.pluck(:id)).to eq([1])
+
+    ensure
+      # 元のYAMLファイルを復元
+      File.write(news_yaml_path, original_yaml_content) if original_yaml_content
+    end
+  end
+
+  # Rakeタスクをテストごとにリロード
+  before do
+    Rake.application.tasks.each do |task|
+      task.reenable if task.name.start_with?('news:')
+    end
+  end
+end