refactor: YAGNI 原則に従いメソッドをインライン化、Fail-Fast 実装

yasulab · yasulab · commit caae80233ec1 · 2025-11-14T14:06:07.000+09:00
- 不要なヘルパーメソッド fetch_all_wordpress_posts() と fetch_prtimes_feed() を削除
- タスク内にロジックをインライン化してシンプルな構造に変更
- PR TIMES RSS 取得の rescue を削除し、Fail-Fast 原則を実装
- エラー時は即座にタスク停止、部分的に壊れたデータでの継続を防止
- TASK_LOGGER の構文エラーを修正（括弧の適切な配置）
diff --git a/lib/tasks/news.rake b/lib/tasks/news.rake
@@ -2,23 +2,24 @@ require 'rss'
 require 'net/http'
 require 'json'
 
+PR_TIMES_FEED  = 'https://prtimes.jp/companyrdf.php?company_id=38935'.freeze
+DOJO_NEWS_FEED = 'https://news.coderdojo.jp/feed/'.freeze
+TEST_NEWS_FEED = Rails.root.join('spec', 'fixtures', 'sample_news.rss').freeze
+
 NEWS_YAML_PATH = 'db/news.yml'.freeze
-NEWS_LOG_PATH = 'log/news.log'.freeze
+NEWS_LOGS_PATH = 'log/news.log'.freeze
+TASK_LOGGER    = ActiveSupport::BroadcastLogger.new(
+                   ActiveSupport::Logger.new(NEWS_LOGS_PATH),
+                   ActiveSupport::Logger.new(STDOUT)
+                 )
 
 namespace :news do
   desc "RSS フィードを取得し、#{NEWS_YAML_PATH} に保存"
   task fetch: :environment do
     # ロガー設定（ファイル＋コンソール出力）
-    console     = ActiveSupport::Logger.new(STDOUT)
-    logger_file = ActiveSupport::Logger.new(NEWS_LOG_PATH)
-    logger      = ActiveSupport::BroadcastLogger.new(logger_file, console)
-
-    logger.info('==== START news:fetch ====')
+    TASK_LOGGER.info('==== START news:fetch ====')
 
     # 本番/開発環境では実フィード、それ以外（テスト環境など）ではテスト用フィード
-    DOJO_NEWS_FEED = 'https://news.coderdojo.jp/feed/'
-    PR_TIMES_FEED  = 'https://prtimes.jp/companyrdf.php?company_id=38935'
-    TEST_NEWS_FEED = Rails.root.join('spec', 'fixtures', 'sample_news.rss')
     RSS_FEED_LIST  = (Rails.env.test? || Rails.env.staging?) ?
       [TEST_NEWS_FEED] :
       [DOJO_NEWS_FEED, PR_TIMES_FEED]
@@ -96,31 +97,66 @@ namespace :news do
       f.write(formatted_items.to_yaml)
     end
 
-    logger.info "✅ Wrote #{merged_items.size} items to #{NEWS_YAML_PATH} (#{created_items.size} new, #{updated_items.size} updated)"
-    logger.info "====  END news:fetch  ===="
-    logger.info ""
+    TASK_LOGGER.info "✅ Wrote #{merged_items.size} items to #{NEWS_YAML_PATH} (#{created_items.size} new, #{updated_items.size} updated)"
+    TASK_LOGGER.info "====  END news:fetch  ===="
+    TASK_LOGGER.info ""
   end
 
   desc "news.yml をリセットし、すべてのフィードから全記事を取得"
   task 'fetch:reset' => :environment do
     # ロガー設定（ファイル＋コンソール出力）
-    console     = ActiveSupport::Logger.new(STDOUT)
-    logger_file = ActiveSupport::Logger.new(NEWS_LOG_PATH)
-    logger      = ActiveSupport::BroadcastLogger.new(logger_file, console)
-
-    logger.info('==== START news:fetch:reset ====')
+    TASK_LOGGER.info('==== START news:fetch:reset ====')
 
     # 1. news.yml を空にする
     File.write(NEWS_YAML_PATH, [].to_yaml)
-    logger.info("📄 news.yml をリセットしました")
+    TASK_LOGGER.info("📄 news.yml をリセットしました")
 
     # 2. WordPress REST API からすべての投稿を取得
-    dojo_news_items = fetch_all_wordpress_posts(logger)
-    logger.info("📰 news.coderdojo.jp から #{dojo_news_items.size} 件を取得")
+    dojo_news_items = []
+    page = 1
+    per_page = 100
+
+    loop do
+      uri = URI("https://news.coderdojo.jp/wp-json/wp/v2/posts")
+      uri.query = URI.encode_www_form(page: page, per_page: per_page, status: 'publish')
+
+      response = Net::HTTP.get_response(uri)
+      break unless response.is_a?(Net::HTTPSuccess)
+
+      posts = JSON.parse(response.body)
+      break if posts.empty?
+
+      posts.each do |post|
+        dojo_news_items << {
+          'url' => post['link'],
+          'title' => post['title']['rendered'],
+          'published_at' => Time.parse(post['date_gmt'] + ' UTC').iso8601
+        }
+      end
+
+      TASK_LOGGER.info("📄 WordPress API: ページ #{page} から #{posts.size} 件取得")
+      page += 1
+    end
+    TASK_LOGGER.info("📰 news.coderdojo.jp から #{dojo_news_items.size} 件を取得")
 
     # 3. PR TIMES RSS フィードからすべてのプレスリリースを取得
-    prtimes_items = fetch_prtimes_feed(logger)
-    logger.info("📢 PR TIMES から #{prtimes_items.size} 件を取得")
+    prtimes_items = []
+    feed = RSS::Parser.parse('https://prtimes.jp/companyrdf.php?company_id=38935', false)
+    feed.items.each do |item|
+      published_at = if item.respond_to?(:dc_date) && item.dc_date
+                       item.dc_date.iso8601
+                     else
+                       raise "PR TIMES feed: dc:date not found for item: #{item.link}"
+                     end
+
+      prtimes_items << {
+        'url' => item.link,
+        'title' => item.title,
+        'published_at' => published_at
+      }
+    end
+    TASK_LOGGER.info("📢 PR TIMES RSS: #{prtimes_items.size} 件取得")
+    TASK_LOGGER.info("📢 PR TIMES から #{prtimes_items.size} 件を取得")
 
     # 4. すべてのアイテムをマージし、ID を付与
     all_items = (dojo_news_items + prtimes_items).sort_by { |item|
@@ -133,7 +169,7 @@ namespace :news do
     end
 
     # 最新順にソート
-    sorted_items = all_items.sort_by { |item| 
+    sorted_items = all_items.sort_by { |item|
       Time.parse(item['published_at'])
     }.reverse
 
@@ -151,78 +187,15 @@ namespace :news do
       f.write(formatted_items.to_yaml)
     end
 
-    logger.info("✅ 合計 #{sorted_items.size} 件を news.yml に保存しました")
-    logger.info("📌 次は 'bundle exec rails news:upsert' でデータベースに反映してください")
-    logger.info("====  END news:fetch:reset  ====")
+    TASK_LOGGER.info("✅ 合計 #{sorted_items.size} 件を news.yml に保存しました")
+    TASK_LOGGER.info("📌 次は 'bundle exec rails news:upsert' でデータベースに反映してください")
+    TASK_LOGGER.info("====  END news:fetch:reset  ====")
   end
 
-  # WordPress REST API からすべての投稿を取得
-  def fetch_all_wordpress_posts(logger)
-    items = []
-    page = 1
-    per_page = 100
-
-    loop do
-      uri = URI("https://news.coderdojo.jp/wp-json/wp/v2/posts")
-      uri.query = URI.encode_www_form(page: page, per_page: per_page, status: 'publish')
-
-      response = Net::HTTP.get_response(uri)
-      break unless response.is_a?(Net::HTTPSuccess)
-
-      posts = JSON.parse(response.body)
-      break if posts.empty?
-
-      posts.each do |post|
-        items << {
-          'url' => post['link'],
-          'title' => post['title']['rendered'],
-          'published_at' => Time.parse(post['date_gmt'] + ' UTC').iso8601
-        }
-      end
-
-      logger.info("📄 WordPress API: ページ #{page} から #{posts.size} 件取得")
-      page += 1
-    end
-
-    items
-  end
-
-  # PR TIMES RSS フィードから全記事を取得
-  def fetch_prtimes_feed(logger)
-    items = []
-
-    begin
-      feed = RSS::Parser.parse('https://prtimes.jp/companyrdf.php?company_id=38935', false)
-      
-      feed.items.each do |item|
-        published_at = if item.respond_to?(:dc_date) && item.dc_date
-                         item.dc_date.iso8601
-                       else
-                         raise "PR TIMES feed: dc:date not found for item: #{item.link}"
-                       end
-
-        items << {
-          'url' => item.link,
-          'title' => item.title,
-          'published_at' => published_at
-        }
-      end
-
-      logger.info("📢 PR TIMES RSS: #{items.size} 件取得")
-    rescue => e
-      logger.error("❌ PR TIMES フィード取得エラー: #{e.message}")
-    end
-
-    items
-  end
 
   desc "#{NEWS_YAML_PATH} からデータベースに upsert"
   task upsert: :environment do
-    console     = ActiveSupport::Logger.new(STDOUT)
-    logger_file = ActiveSupport::Logger.new(NEWS_LOG_PATH)
-    logger      = ActiveSupport::BroadcastLogger.new(logger_file, console)
-
-    logger.info "==== START news:upsert ===="
+    TASK_LOGGER.info "==== START news:upsert ===="
 
     news_items = YAML.safe_load File.read(NEWS_YAML_PATH)
     created_count = 0
@@ -244,13 +217,13 @@ namespace :news do
           created_count += 1 if     is_new_record
           updated_count += 1 unless is_new_record
 
-          logger.info "[News] #{news.published_at.to_date} #{news.title} (#{status})"
+          TASK_LOGGER.info "[News] #{news.published_at.to_date} #{news.title} (#{status})"
         end
       end
     end
 
-    logger.info "Upserted #{created_count + updated_count} items (#{created_count} new, #{updated_count} updated)."
-    logger.info "==== END news:upsert ===="
-    logger.info ""
+    TASK_LOGGER.info "Upserted #{created_count + updated_count} items (#{created_count} new, #{updated_count} updated)."
+    TASK_LOGGER.info "==== END news:upsert ===="
+    TASK_LOGGER.info ""
   end
 end
