Rakeタスクのリファクタリングをしたい

[nacchan99]

cf. #1704 （cf. #1577）

背景

lib/tasks/fetch_news.rake の可読性・再利用性を高めたい

To Do

Rake タスクのリファクタリング

• URL バリデーション処理を専用メソッドに切り出す
• fetch_news タスクの更新ロジック改善
• import_news タスクの保存ロジック改善

[nacchan99]

リファクタリング案

毎回焦って、構造を理解できていないまま手を動かしがちなので、今回は先に大まな手順を整理してみます🙌

問題点1 → ネストが深く読みづらい

lib/tasks/fetch_news.rake

現状

# RSS 取得＆パース
    new_items = feed_urls.flat_map do |url|
      logger.info("Fetching RSS → #{url}")
      begin
        rss = safe_open(url)
        feed = RSS::Parser.parse(rss, false)
        feed.items.map do |item|
          {
            'url'          => item.link,
            'title'        => item.title,
            'published_at' => item.pubDate.to_s
          }
        end
      rescue => e
        logger.warn("⚠️ Failed to fetch #{url}: #{e.message}")
        []
      end
    end

改善案

def fetch_rss_items(url, logger)
  logger.info("Fetching RSS → #{url}")
  begin
    rss = safe_open(url)
    feed = RSS::Parser.parse(rss, false)
    feed.items.map { |item| item_to_hash(item) }
  rescue => e
    logger.warn("⚠️ Failed to fetch #{url}: #{e.message}")
    []
  end
end

def item_to_hash(item)
  {
    'url'          => item.link,
    'title'        => item.title,
    'published_at' => item.pubDate.to_s
  }
end

namespace :news do
  desc 'RSS フィードから最新ニュースを取得し、db/news.yml に書き出す'
  task fetch: :environment do
    # ...ロガー設定・既存データ読み込み・feed_urls定義...

    new_items = feed_urls.flat_map { |url| fetch_rss_items(url, logger) }

    # ...既存データとのマージ・ID割り当て・ソート・YAML書き出し...
  end
end

• メソッド分割でネストを減らす
• 役割ごとに処理をまとめる
• （必要ならクラス化・外部ファイル化も検討）

[nacchan99]

問題点2 → 常に全ての既存アイテムが更新されてしまう

lib/tasks/fetch_news.rake

現状

new_items.each do |new_item|
  if existing_items_hash.key?(new_item['url'])
    # 既存アイテムの更新
    existing_item = existing_items_hash[new_item['url']]
    updated_item = existing_item.merge(new_item)  # 新しい情報で更新
    updated_items << updated_item
  else
    # 完全に新しいアイテム
    truly_new_items << new_item
  end
end

改善案

new_items.each do |new_item|
  if existing_items_hash.key?(new_item['url'])
    existing_item = existing_items_hash[new_item['url']]
    # タイトルまたは公開日が変わった場合のみ更新
    if existing_item['title'] != new_item['title'] || existing_item['published_at'] != new_item['published_at']
      updated_items << existing_item.merge(new_item)
    end
  else
    truly_new_items << new_item
  end
end

• 差分がある場合のみ updated_items に追加
• 無駄な更新を防ぎ、履歴が見やすくなる

[nacchan99]

解決済みです🙌
メモ：#1704 でコメントしていただいた

lib/tasks/import_news.rake も毎日実行したい
Heroku で設定できる → 最終的に共有しながらやりましょう🛠️ についても近いうちに相談させていただく💡