Rakefile

require 'rake/testtask'
require 'fileutils'
require 'json'
require 'open3'
require 'time'
require 'net/http'
require 'uri'
require 'csv'

# 表示用の定数
SEPARATOR_WIDTH = 60  # セパレーター行の幅

# Minitestタスクの定義
Rake::TestTask.new(:test) do |t|
  t.libs << "test"
  t.test_files = FileList['test/*_test.rb']
  t.verbose = false  # 詳細な実行コマンドを非表示
  t.warning = false  # 警告を無効化（必要に応じて）
end

# 短縮エイリアス
task :t => :test

# テストの詳細情報を表示
desc "Run all tests with detailed output"
task :test_verbose do
  ENV['TESTOPTS'] = '--verbose'
  Rake::Task[:test].invoke
end

# CSV検証のみ実行
desc "Validate CSV format only"
task :test_csv do
  ruby "test/csv_test.rb"
end

task :default => :test

# Rakeの高度な機能を活用した改善
# - 依存関係の明確化
# - インクリメンタル実行
# - エラーハンドリング
# - 並列実行サポート

# ================================================================
# DojoPaaS 管理タスク
# ================================================================
# このRakefileは実行可能な操作のカタログとして機能します
# 'rake -T' ですべての利用可能なタスクを確認できます
# ================================================================


desc "利用可能なDojoPaaS管理タスクをすべて表示"
task :default do
  puts "\n🔧 DojoPaaS 管理タスク"
  puts "=" * SEPARATOR_WIDTH
  puts "'rake -T' ですべての利用可能なタスクを確認"
  puts "'rake -D [タスク名]' で詳細な説明を表示"
  puts "=" * SEPARATOR_WIDTH
  sh "rake -T"
end

namespace :server do
  # ========================================
  # 環境検証タスク（他のタスクの前提条件）
  # ========================================
  task :check_api_credentials do
    required_vars = %w[SACLOUD_ACCESS_TOKEN SACLOUD_ACCESS_TOKEN_SECRET]
    missing_vars = required_vars.reject { |var| ENV[var] }

    unless missing_vars.empty?
      abort "❌ エラー: 必要な環境変数が設定されていません: #{missing_vars.join(', ')}\n" \
            "設定方法:\n" \
            "  export SACLOUD_ACCESS_TOKEN=xxxx\n" \
            "  export SACLOUD_ACCESS_TOKEN_SECRET=xxxx"
    end

    puts "✅ API認証情報を確認しました" if ENV['VERBOSE']
  end

  # ========================================
  # ステータスファイル管理（インクリメンタル実行用）
  # ========================================
  directory 'tmp/rake_status'

  def status_file_for(task_name)
    "tmp/rake_status/#{task_name.gsub(':', '_')}.json"
  end

  def save_task_status(task_name, status)
    FileUtils.mkdir_p('tmp/rake_status')
    File.write(status_file_for(task_name), JSON.pretty_generate({
      task: task_name,
      status: status,
      timestamp: Time.now.iso8601,
      details: status[:details] || {}
    }))
  end

  def load_task_status(task_name)
    file = status_file_for(task_name)
    return nil unless File.exist?(file)
    JSON.parse(File.read(file))
  rescue JSON::ParserError
    nil
  end


  # ========================================
  # サーバー情報検索タスク（統一命名パターン）
  # ========================================
  desc "IPアドレスでサーバーを検索"
  task :find_by_ip, [:ip] => [:check_api_credentials, :validate_env] do |t, args|
    ip = args[:ip] || ENV['IP_ADDRESS']

    unless ip
      abort "❌ エラー: IPアドレスが必要です\n" \
            "使い方: rake server:find_by_ip[192.168.1.1]\n" \
            "または: IP_ADDRESS=192.168.1.1 rake server:find_by_ip"
    end

    # IPアドレスの検証（SakuraServerUserAgentの共通メソッドを使用）
    require_relative 'scripts/sakura_server_user_agent'

    unless SakuraServerUserAgent.valid_ip_address?(ip)
      abort "❌ エラー: 無効なIPアドレス形式: #{ip}"
    end

    # IPアドレスを正規化
    validated_ip_str = SakuraServerUserAgent.normalize_ip_address(ip)

    puts "✅ 有効なIPアドレス: #{validated_ip_str}"
    puts "🔍 サーバー情報を検索中..."
    puts "-" * SEPARATOR_WIDTH

    # 検証済みIPでinitialize_server.rbスクリプトを実行（コマンドエコーを抑制）
    #
    # 失敗はブロックで受けて exit する。既定では rake が RuntimeError を投げ、
    # 「rake aborted!」とスタックトレースが出る。スクリプト自身が理由と対処法を
    # 出しているので、その後ろに CI のランナー上の絶対パスが並ぶと読む人が困る
    # （bot のコメントにもそのまま載る）
    cmd = ["ruby", "scripts/initialize_server.rb", "--find", validated_ip_str]
    sh(*cmd, verbose: false) do |ok, _res|
      exit 1 unless ok
    end
  end

  # ========================================
  # その他の検索タスク（統一命名パターン）
  # ========================================
  desc "Issue URLでサーバーを検索"
  task :find_by_issue, [:issue_url] => [:check_api_credentials, :validate_env] do |t, args|
    issue_url = args[:issue_url] || ENV['ISSUE_URL']

    unless issue_url
      abort "❌ エラー: Issue URLが必要です\n" \
            "使い方: rake server:find_by_issue[https://github.com/.../issues/XXX]"
    end

    # Issue URLフォーマットを検証
    unless issue_url =~ %r{^https://github\.com/coderdojo-japan/dojopaas/issues/\d+$}
      abort "❌ エラー: 無効なIssue URLフォーマット: #{issue_url}\n" \
            "期待される形式: https://github.com/coderdojo-japan/dojopaas/issues/XXX"
    end

    puts "📋 Issue処理中: #{issue_url}"
    puts "🔍 サーバー情報を抽出中..."
    puts "-" * SEPARATOR_WIDTH

    cmd = ["ruby", "scripts/initialize_server.rb", "--find", issue_url]
    sh(*cmd, verbose: false) { |ok, _res| exit 1 unless ok }
  end

  # ========================================
  # サーバー削除タスク（段階的実行）
  # ========================================
  desc "サーバー名でサーバーを検索"
  task :find_by_name, [:name] => [:check_api_credentials, :validate_env] do |t, args|
    name = args[:name] || ENV['SERVER_NAME']

    unless name
      abort "❌ エラー: サーバー名が必要です\n" \
            "使い方: rake server:find_by_name[coderdojo-japan]"
    end

    puts "🔍 サーバー名で検索: #{name}"
    puts "-" * SEPARATOR_WIDTH

    cmd = ["ruby", "scripts/initialize_server.rb", "--find", name]
    sh(*cmd, verbose: false) { |ok, _res| exit 1 unless ok }
  end

  # ========================================
  # サーバー削除タスク（段階的実行）
  # ========================================
  # 前回の削除結果を引き継がない。残っていると、削除せずに
  # create_empty_commit が通り、Issue だけが閉じる
  def clear_execute_deletion_status
    file = status_file_for('execute_deletion')
    File.delete(file) if File.exist?(file)
  end

  desc "サーバー削除の準備（情報確認のみ）"
  task :prepare_deletion, [:ip] => [:check_api_credentials, :validate_env] do |t, args|
    clear_execute_deletion_status
    ip = args[:ip] || ENV['IP_ADDRESS']

    unless ip
      abort "❌ エラー: IPアドレスが必要です"
    end

    # 削除フローの 1 歩目で、IP は Issue や bot のコメントからコピーした値が入る。
    # find_by_ip と同じ検証を通してから使う
    require_relative 'scripts/sakura_server_user_agent'

    unless SakuraServerUserAgent.valid_ip_address?(ip)
      abort "❌ エラー: 無効なIPアドレス形式: #{ip}"
    end

    ip = SakuraServerUserAgent.normalize_ip_address(ip)

    puts "🔍 削除対象サーバーの情報を確認中..."

    # 削除準備状態を保存（インクリメンタル実行用）
    # find_by_ipと同じロジックを使用しても、別途実行する
    # シェルを経由しないよう配列で渡す（capture2e は標準エラーも一緒に受け取る）
    result, status = Open3.capture2e('ruby', 'scripts/initialize_server.rb', '--find', ip)
    if status.success?
      save_task_status('prepare_deletion', {
        success: true,
        ip: ip,
        output: result
      })
      puts result
      puts "\n✅ 削除準備が完了しました"
      puts %(次のステップ: rake "server:execute_deletion[#{ip},<サーバー名>]")
      puts "サーバー名は上の表示を Issue の道場名と見比べて入力してください"
    else
      abort "❌ サーバー情報の取得に失敗しました\n#{result}"
    end
  end

  desc "サーバーを削除（危険・要確認）"
  task :execute_deletion, [:ip, :name] => :prepare_deletion do |t, args|
    ip   = args[:ip] || ENV['IP_ADDRESS']
    name = args[:name]

    # サーバー名を人が書くことで、IP の取り違えをここで止める
    # （prepare_deletion の出力と Issue を見比べて書く。Bot は名前を埋めない）
    if name.to_s.strip.empty?
      abort "❌ エラー: 削除するサーバー名が必要です\n" \
            "使い方: rake \"server:execute_deletion[#{ip},サーバー名]\"\n" \
            "サーバー名は prepare_deletion の出力に表示されます"
    end

    # 前のタスクの結果を確認
    prep_status = load_task_status('prepare_deletion')
    if prep_status.nil? || prep_status['status'].nil? || prep_status['status']['ip'] != ip
      abort "❌ エラー: 先に prepare_deletion を実行してください"
    end

    # 削除実行（確認の打鍵は省くが、名前の一致は必ず確認される）
    cmd = ['ruby', 'scripts/initialize_server.rb', '--delete', ip, '--name', name, '--force']

    puts "⚠️  サーバー削除を実行します: #{ip}"
    sh(*cmd) do |ok, res|
      if ok
        save_task_status('execute_deletion', {
          success: true,
          ip: ip,
          deleted_at: Time.now.iso8601
        })
        puts "✅ サーバー削除が完了しました"
      else
        abort "❌ サーバー削除に失敗しました"
      end
    end
  end

  desc "削除後の空コミット作成"
  task :create_empty_commit, [:issue_number] do |t, args|
    issue_number = args[:issue_number] || ENV['ISSUE_NUMBER']

    unless issue_number
      abort "❌ エラー: Issue番号が必要です"
    end

    # 削除状態を確認
    del_status = load_task_status('execute_deletion')
    if del_status.nil? || !del_status['status'] || !del_status['status']['success']
      abort "❌ エラー: サーバー削除が完了していません"
    end

    deleted_at = del_status['status']['deleted_at'] || Time.now.iso8601
    message = "Fix ##{issue_number}: Initialize server (deleted at #{deleted_at})"
    # Issue 番号は引数で渡ってくる。シェル文字列に埋めるとクォートを抜けられるので配列で渡す
    cmd = ['git', 'commit', '--allow-empty', '-m', message]
    sh(*cmd) do |ok, res|
      if ok
        puts "✅ 空コミットを作成しました"
        puts "次のステップ: git push でCI/CDを実行"
      else
        abort "❌ コミット作成に失敗しました"
      end
    end
  end

  # ========================================
  # 完全な初期化フロー（依存関係チェーン）
  # ========================================
  desc "サーバー初期化の手順を表示（削除は3ステップを個別に実行する）"
  task :initialize, [:ip, :issue_number] do |t, args|
    ip           = args[:ip]           || ENV['IP_ADDRESS'] || '<IPアドレス>'
    issue_number = args[:issue_number] || ENV['ISSUE_NUMBER'] || '<Issue番号>'

    # 一括実行はやめた: 確認を飛ばして削除まで走るため、取り違えたときに止まらない
    # 各ステップの出力を読みながら進める（サーバー名は prepare の出力を見て書く）
    puts "サーバー初期化は、次の3ステップを順に実行します。"
    puts ""
    puts %(  bundle exec rake "server:prepare_deletion[#{ip}]")
    puts %(  bundle exec rake "server:execute_deletion[#{ip},<サーバー名>]")
    puts %(  bundle exec rake "server:create_empty_commit[#{issue_number}]")
    puts ""
    puts "最後に gpush すると、CI がサーバーを作り直します。"
    puts "サーバー名は prepare_deletion の出力に表示されます。Issue の道場名と見比べて入力してください。"
  end

  # 検証ヘルパータスク（改善版）
  task :validate_env do
    if ENV['CI'] == 'true'
      # CI環境では必要なシークレットをチェック
      required_vars = %w[SACLOUD_ACCESS_TOKEN SACLOUD_ACCESS_TOKEN_SECRET]
      missing_vars = required_vars.reject { |var| ENV[var] }

      unless missing_vars.empty?
        abort "❌ エラー: CI環境で必要な環境変数が不足: #{missing_vars.join(', ')}\n" \
              "GitHub Secretsとして設定してください"
      end
    end
  end

  # ========================================
  # サーバー一覧参照タスク
  # ========================================
  desc "現在稼働中のサーバー一覧を表示"
  task :list do
    require_relative 'scripts/sakura_server_user_agent'
    require 'dotenv/load'

    puts "📋 サーバー一覧を取得中..."
    puts "データソース: #{SakuraServerUserAgent::INSTANCES_CSV_URL}"
    puts "-" * SEPARATOR_WIDTH

    begin
      uri = URI(SakuraServerUserAgent::INSTANCES_CSV_URL)
      response = Net::HTTP.get_response(uri)

      if response.code == '200'
        # エンコーディングを明示的に設定してCSVを解析（無効な文字を安全に処理）
        response.body.force_encoding('UTF-8').scrub('?')
        csv_data = CSV.parse(response.body, headers: true)

        # APIクライアントを初期化（ステータス確認用）
        server_statuses = {}
        if ENV['SACLOUD_ACCESS_TOKEN'] && ENV['SACLOUD_ACCESS_TOKEN_SECRET']
          begin
            # デフォルトパラメータ（石狩第二）が自動的に使用される
            client = SakuraServerUserAgent.new
            servers_data = client.get_servers()
            if servers_data && servers_data['Servers']
              servers_data['Servers'].each do |server|
                server_statuses[server['Name']] = server['Instance']['Status']
              end
            end
          rescue
            # エラーは無視してステータスなしで続行
          end
        end

        puts "📊 サーバー一覧（#{csv_data.length}台）:"
        puts ""

        csv_data.each do |row|
          server_name = row['Name']
          status = server_statuses[server_name]

          # ステータスに応じた絵文字と表示を設定
          status_display = if status
            case status
            when 'up'
              " (✅ up)"
            when 'down'
              " (⏸️  down)"
            when 'cleaning'
              " (🧹 cleaning)"
            else
              " (❓ #{status})"  # 予期しないステータスの場合
            end
          else
            ""  # APIが利用できない場合は何も表示しない
          end

          puts "  🖥️  #{server_name}#{status_display}"
          puts "      IPアドレス: #{row['IP Address']}"  # スペースを追加
          puts "      説明: #{row['Description']}" if row['Description']
          puts ""
        end

        # テスト用サーバーのチェック
        require_relative 'scripts/initialize_server'
        test_servers = csv_data.select do |row|
          ServerInitializer.safe_test_server?(row['Name'])
        end

        puts "🧪 テスト用サーバー（#{test_servers.length}台）:"
        if test_servers.any?
          test_servers.each do |server|
            puts "  ✅ #{server['Name']} - #{server['IP Address']}"  # スペースを追加
          end
        else
          puts "  （テスト用サーバーがありません）"
        end
        puts ""

        # ステータス表示についての注記
        if !ENV['SACLOUD_ACCESS_TOKEN'] || !ENV['SACLOUD_ACCESS_TOKEN_SECRET']
          puts "ℹ️  注: API認証情報が設定されていないため、サーバーステータス(up/down)は表示されていません"
          puts "     ステータスを表示するには、SACLOUD_ACCESS_TOKEN と SACLOUD_ACCESS_TOKEN_SECRET を設定してください"
        elsif server_statuses.empty?
          puts "ℹ️  注: API接続エラーのため、サーバーステータス(up/down)を取得できませんでした"
        end
        puts ""

      else
        abort "❌ エラー: サーバー一覧の取得に失敗しました (HTTP #{response.code})"
      end

    rescue => e
      abort "❌ エラー: #{e.message}"
    end
  end

  # ========================================
  # サーバー状態確認タスク
  # ========================================
  desc "サーバーの詳細状態を確認"
  task :status, [:server_name] => [:check_api_credentials] do |t, args|
    server_name = args[:server_name]

    unless server_name
      abort "❌ エラー: サーバー名が必要です\n" \
            "使い方: rake server:status[coderdojo-japan]"
    end

    puts "🔍 サーバー状態を確認中: #{server_name}"
    cmd = ["ruby", "scripts/utils/check_server_status.rb", server_name]
    sh(*cmd, verbose: false) { |ok, _res| exit 1 unless ok }
  end

  # ========================================
  # 個別サーバー作成タスク（テスト用）
  # ========================================
  desc "指定したサーバーを個別に作成（テスト用）"
  task :create, [:server_name] => [:check_api_credentials] do |t, args|
    server_name = args[:server_name]

    unless server_name
      abort "❌ エラー: サーバー名が必要です\n" \
            "使い方: rake server:create[coderdojo-japan]\n" \
            "注意: servers.csvに登録されているサーバー名を指定してください"
    end

    puts "="*SEPARATOR_WIDTH
    puts "🚀 DojoPaaS 個別サーバー作成"
    puts "="*SEPARATOR_WIDTH
    puts ""
    puts "サーバー名: #{server_name}"
    puts ""

    # deploy.rbのCoderDojoSakuraCLIクラスを使用（DRY原則）
    require_relative 'scripts/deploy'

    cli = CoderDojoSakuraCLI.new([])
    success = cli.create_single_server(server_name)

    if success
      puts ""
      puts "="*SEPARATOR_WIDTH
      puts "✅ サーバー作成プロセス完了"
      puts "="*SEPARATOR_WIDTH
      puts ""
      puts "【次のステップ】"
      puts "1. SSHで接続確認:"
      puts "   ssh ubuntu@<IPアドレス>"
      puts ""
      puts "2. スタートアップスクリプトの実行状況確認:"
      puts "   ssh ubuntu@<IPアドレス> 'sudo tail -f /var/log/cloud-init-output.log'"
      puts ""
    else
      puts ""
      puts "="*SEPARATOR_WIDTH
      puts "❌ サーバー作成に失敗しました"
      puts "="*SEPARATOR_WIDTH
      exit 1
    end
  end

end

# ヘルパーメソッド（将来の拡張用に保持）
# 注: 現在は使用されていません（YAGNI原則により簡素化）
# def in_sakura_cloud_range?(ip_addr)
#   sakura_ranges = [
#     IPAddr.new("153.127.0.0/16"),  # 石狩第二ゾーン
#     IPAddr.new("163.43.0.0/16"),   # 東京ゾーン
#     IPAddr.new("133.242.0.0/16"),  # 大阪ゾーン
#   ]
#   sakura_ranges.any? { |range| range.include?(ip_addr) }
# end

# ================================================================
# 並列実行タスク（将来の実装用にコメントアウト）
# ================================================================
# YAGNI原則により、実際に必要になるまでコメントアウト
# 注意: 200サーバーの並列チェックはAPI制限のリスクあり
#
# namespace :parallel do
#   desc "複数サーバーの状態を並列チェック"
#   multitask :check_all => ['server:validate_env'] do
#     # servers.csvから全サーバーをチェック
#     servers = CSV.read('servers.csv', headers: true)
#
#     # 並列でステータスチェックを実行
#     threads = servers.map do |server|
#       Thread.new do
#         begin
#           result = `ruby scripts/initialize_server.rb --find #{server['Name']} 2>&1`
#           { name: server['Name'], status: $?.success? ? 'OK' : 'ERROR', details: result }
#         rescue => e
#           { name: server['Name'], status: 'ERROR', details: e.message }
#         end
#       end
#     end
#
#     results = threads.map(&:value)
#
#     # 結果をサマリー表示
#     puts "\n" + "=" * 50
#     puts "サーバーステータスサマリー"
#     puts "=" * 50
#     results.each do |r|
#       status_icon = r[:status] == 'OK' ? '✅' : '❌'
#       puts "#{status_icon} #{r[:name]}: #{r[:status]}"
#     end
#   end
# end

# ================================================================
# クリーンタスク（Rake標準機能の活用）
# ================================================================
require 'rake/clean'

CLEAN.include('tmp/rake_status/*.json')
CLOBBER.include('tmp/rake_status')

desc "Rakeタスクのステータスファイルをクリア"
task :clear_status do
  rm_rf 'tmp/rake_status'
  puts "✅ ステータスファイルをクリアしました"
end

# ================================================================
# 将来のタスク（フェーズ2以降）
# ================================================================
#
# フェーズ2: 高度な自動化
# - rake server:batch_initialize    # 複数サーバーの一括初期化
# - rake server:health_check        # ヘルスチェック実行
# - rake deploy:canary             # カナリアデプロイ
#
# フェーズ3: 完全統合
# - rake maintenance:scheduled      # スケジュールメンテナンス
# - rake report:weekly             # 週次レポート生成
# - rake backup:all                # 全サーバーバックアップ
#
# 詳細なロードマップは docs/plan_rakefile_migration.md を参照
# ================================================================

namespace :workshop do
  desc "servers.csv のワークショップ用の行（branch の隠しコマンド）を確認"
  task :check do
    require_relative "scripts/workshop_check"

    result = WorkshopCheck.report(File.read("servers.csv"))

    if result[:status] == :none
      puts "ワークショップ用の行はありません"
    else
      body = result[:markdown].strip
      puts body

      # CI では PR の Checks から読めるようにサマリーへ書く
      summary = ENV["GITHUB_STEP_SUMMARY"]
      File.write(summary, body + "\n", mode: "a") if summary && !summary.to_s.empty?

      # 該当行にインラインで出す（read-only のまま。追加の権限は不要）
      # 成功時も notice を出す。Checks を開かなくても PR の該当行で分かる
      if ENV["GITHUB_ACTIONS"]
        result[:notices].to_a.each do |notice|
          text = notice[:message].delete("`").gsub("%", "%25").gsub("\r", "%0D").gsub("\n", "%0A")
          puts "::notice file=servers.csv,line=#{notice[:line]},title=ワークショップ用サーバー::#{text}"
        end

        result[:problems].each do |problem|
          # 注釈は Markdown を描画しないのでバッククォートを落とす
          # エスケープの順序は % → \r → \n（actions/toolkit と同じ）
          text = problem[:message].delete("`")
                                  .gsub("%", "%25")
                                  .gsub("\r", "%0D")
                                  .gsub("\n", "%0A")
          puts "::error file=servers.csv,line=#{problem[:line]},title=ワークショップ用の指定::#{text}"
        end
      end
    end

    abort "ワークショップ用の指定に問題があります" if [:problem, :broken].include?(result[:status])
  end
end