news:fetch:reset タスクを実装

WordPress REST API と PR TIMES RSS フィードから
全記事を取得してリセットする新機能を追加:

機能:
- news.yml を空にリセット
- WordPress REST API で全投稿を取得（ページネーション対応）
- PR TIMES RSS フィードから全プレスリリースを取得
- 古い順でID付与、最新順で保存
- データベースへの反映は別タスク（news:upsert）

実行例:
- WordPress: 136件取得（2018年〜2025年）
- PR TIMES: 11件取得
- 合計: 147件を news.yml に保存

Author: yasulab

lib/tasks/news.rake

@@ -1,4 +1,6 @@
 require 'rss'
+require 'net/http'
+require 'json'
 
 NEWS_YAML_PATH = 'db/news.yml'.freeze
 NEWS_LOG_PATH = 'log/news.log'.freeze
@@ -99,6 +101,121 @@ namespace :news do
     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 ====')
+
+    # 1. news.yml を空にする
+    File.write(NEWS_YAML_PATH, [].to_yaml)
+    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} 件を取得")
+
+    # 3. PR TIMES RSS フィードからすべてのプレスリリースを取得
+    prtimes_items = fetch_prtimes_feed(logger)
+    logger.info("📢 PR TIMES から #{prtimes_items.size} 件を取得")
+
+    # 4. すべてのアイテムをマージし、ID を付与
+    all_items = (dojo_news_items + prtimes_items).sort_by { |item|
+      Time.parse(item['published_at'])
+    }
+
+    # ID を付与（古い順で1から）
+    all_items.each.with_index(1) do |item, index|
+      item['id'] = index
+    end
+
+    # 最新順にソート
+    sorted_items = all_items.sort_by { |item| 
+      Time.parse(item['published_at'])
+    }.reverse
+
+    # 5. YAML ファイルに書き出し
+    File.open(NEWS_YAML_PATH, 'w') do |f|
+      formatted_items = sorted_items.map do |item|
+        {
+          'id'           => item['id'],
+          'url'          => item['url'],
+          'title'        => item['title'],
+          'published_at' => item['published_at']
+        }
+      end
+
+      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  ====")
+  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)