エピローグ — パターンを組み合わせる力

# Before: 800行のファットコントローラー
class OrdersController < ApplicationController
  def create
    # バリデーション、在庫チェック、合計計算、クーポン、保存、
    # メール、ポイント、Slack...全部ここに（800行）
  end
end
 
# After: 各パターンが適切な場所に
class OrdersController < ApplicationController
  before_action :authenticate_user!
  before_action :check_rate_limit, only: [:create]
 
  # Query Side（CQRSパターン）
  def index
    @order_summaries = OrderListQuery.new.call(
      user_id: current_user.id,
      page: params[:page]&.to_i || 1,
      status: params[:status]
    )
  end
 
  def show
    @order = OrderDetailQuery.new.call(
      order_id: params[:id].to_i,
      user_id: current_user.id
    )
  rescue OrderNotFoundError
    redirect_to orders_path, alert: "注文が見つかりません"
  end
 
  # Command Side（CQRSパターン + バックプレッシャー + サーキットブレーカー）
  def create
    result = OrderQueueService.new.enqueue(
      user_id: current_user.id,
      items: order_params[:items],
      priority: current_user.vip? ? :vip : :normal
    )
 
    render json: {
      message: "注文を受け付けました",
      job_id: result[:job_id],
      status_url: order_status_path(result[:job_id])
    }, status: :accepted
 
  rescue QueueFullError
    render json: { error: "只今注文が集中しています。しばらくお待ちください。" },
           status: :service_unavailable
  rescue RateLimiter::ExceededError
    render json: { error: "注文は1分に5件まで" },
           status: :too_many_requests
  end
 
  def status
    result = OrderQueueService.new.status(params[:job_id])
    render json: result
  end
 
  private
 
  def check_rate_limit
    limiter = RateLimiter.new(key: "orders:#{current_user.id}", limit: 5, window: 60)
    raise RateLimiter::ExceededError unless limiter.allowed?
  end
 
  def order_params
    params.require(:order).permit(:coupon_code, items: [:product_id, :quantity])
  end
end

# アンチパターン1: パターンの過剰適用
# 3行で済む処理にリポジトリ・サービス・コマンドを作る
class GetUserNameService
  def initialize(user_repository)
    @user_repository = user_repository
  end
 
  def call(user_id)
    @user_repository.find(user_id).name  # User.find(id).name でいい
  end
end
 
# アンチパターン2: レイヤーを飛び越える
class OrdersController
  def create
    # コントローラーがDBに直接書く
    Order.create!(params)        # NG: サービス層を飛ばしている
    Product.decrement!(:stock)   # NG: ビジネスロジックがコントローラーに
  end
end
 
# アンチパターン3: 間違ったパターン選択
# 小さなアプリにサーガパターン
class UserRegistrationSaga  # 1サービスの処理にサーガは不要
  # マイクロサービス間でないなら単なるトランザクションでよい
end
 
# アンチパターン4: パターン名の乱用
class UserService  # 何でもServiceと名付ける
  def create_user; end
  def send_email; end
  def calculate_discount; end
  def generate_report; end
  # 何をするクラスかわからない
end
 
# 正しい命名（責任が明確）
class UserCreationService; end      # ユースケース
class EmailNotificationService; end # インフラ
class DiscountCalculator; end       # ドメイン
class SalesReportQuery; end         # クエリ

# lib/tasks/code_health.rake
namespace :code_health do
  desc "コントローラーの行数チェック"
  task controller_size: :environment do
    fat_controllers = []
 
    Dir.glob("app/controllers/**/*.rb").each do |path|
      lines = File.readlines(path).count
      if lines > 100
        fat_controllers << { path: path, lines: lines }
      end
    end
 
    if fat_controllers.any?
      puts "警告: ファットコントローラーが検出されました"
      fat_controllers.each { |c| puts "  #{c[:path]}: #{c[:lines]}行" }
    else
      puts "OK: 全コントローラーが100行以下です"
    end
  end
 
  desc "循環参照チェック"
  task circular_deps: :environment do
    # 上位レイヤーが下位レイヤーを参照していないか確認
    violations = []
 
    Dir.glob("app/models/**/*.rb").each do |path|
      content = File.read(path)
      if content.match?(/require.*controllers|include.*Controller/)
        violations << "#{path}: モデルがコントローラーを参照"
      end
    end
 
    violations.empty? ? puts("OK: 循環参照なし") : violations.each { |v| puts "警告: #{v}" }
  end
end

# これからユウキが学ぶこと
next_steps = {
  architecture: [
    "ヘキサゴナルアーキテクチャ（ポートとアダプター）",
    "クリーンアーキテクチャ",
    "ドメイン駆動設計（DDD）"  # 本サイトに別トピックあり
  ],
  aws: [
    "EKS（Kubernetes on AWS）",
    "AWS CDK でインフラをコードで管理",
    "OpenTelemetry による分散トレーシング",
    "AWS AppMesh / Service Mesh"
  ],
  rails: [
    "Hotwire / Turbo でリアルタイム更新",
    "Action Cable WebSocket",
    "Rails Engine でのモジュール分割",
    "Zeitwerk オートローディング"
  ],
  golang: [
    "Go でのマイクロサービス実装",
    "gRPC によるサービス間通信",
    "Go の並行処理パターン"
  ]
}

# 新しいプロジェクト参画時のチェックリスト（Rakeタスク形式）
namespace :architecture do
  desc "プロジェクト健康診断"
  task :health_check do
    puts "=== アーキテクチャ健康診断 ===\n\n"
 
    checks = {
      "MVCの責任分離"        => -> { check_fat_controllers },
      "レイヤー構造の存在"    => -> { check_service_layer },
      "リポジトリパターン"    => -> { check_repository_usage },
      "イベントの疎結合"      => -> { check_event_driven },
      "CQRSの適用箇所"       => -> { check_cqrs_pattern },
      "障害対応の仕組み"      => -> { check_circuit_breaker },
    }
 
    checks.each do |name, check|
      result = check.call
      status = result[:ok] ? "✓" : "!"
      puts "  #{status} #{name}: #{result[:message]}"
    end
  end
 
  private
 
  def check_fat_controllers
    fat = Dir.glob("app/controllers/**/*.rb").select { |f| File.readlines(f).count > 100 }
    fat.empty? ? { ok: true, message: "全コントローラー100行以下" }
               : { ok: false, message: "ファット: #{fat.map { |f| File.basename(f) }.join(', ')}" }
  end
 
  def check_service_layer
    has_services = Dir.exist?("app/services") && Dir.glob("app/services/**/*.rb").any?
    has_services ? { ok: true, message: "app/services/ あり" }
                 : { ok: false, message: "サービス層なし — レイヤードアーキテクチャを検討" }
  end
 
  def check_repository_usage
    has_repos = Dir.glob("app/repositories/**/*.rb").any?
    has_repos ? { ok: true, message: "リポジトリパターン採用済み" }
              : { ok: false, message: "リポジトリなし — クエリがモデルに散在していないか確認" }
  end
 
  def check_event_driven
    has_events = Dir.glob("app/events/**/*.rb").any? || defined?(ActiveSupport::Notifications)
    has_events ? { ok: true, message: "イベント機構あり" }
               : { ok: false, message: "イベント駆動なし — 後処理が密結合になっていないか確認" }
  end
 
  def check_cqrs_pattern
    has_queries = Dir.glob("app/queries/**/*.rb").any?
    has_queries ? { ok: true, message: "Queryオブジェクトあり" }
                : { ok: false, message: "Queryオブジェクトなし — 重い読み取りクエリがサービスに埋まっていないか確認" }
  end
 
  def check_circuit_breaker
    has_cb = Gem.loaded_specs.key?("circuitbox") || Gem.loaded_specs.key?("resilient")
    has_cb ? { ok: true, message: "サーキットブレーカーライブラリあり" }
           : { ok: false, message: "障害対応なし — 外部API呼び出しがある場合は要検討" }
  end
end

// パターンの対応関係
 
// Rails: app/services/order_creation_service.rb
// Go:    internal/usecase/order_usecase.go
 
package usecase
 
type OrderUseCase struct {
    repo      repository.OrderRepository   // リポジトリパターン
    publisher event.Publisher              // イベント駆動
    cb        circuitbreaker.CircuitBreaker // サーキットブレーカー
}
 
func (u *OrderUseCase) CreateOrder(cmd CreateOrderCommand) (*Order, error) {
    // Application Service と同じ責任
    if err := cmd.Validate(); err != nil {
        return nil, err
    }
 
    order, err := u.repo.Save(NewOrder(cmd))
    if err != nil {
        return nil, err
    }
 
    // イベント発行（疎結合）
    u.publisher.Publish(OrderCreatedEvent{OrderID: order.ID})
 
    return order, nil
}