サービス境界の見つけ方 — ドメインで切る

# 商品サービスでの「商品」
module ProductContext
  class Product
    attr_accessor :id, :name, :description, :category
    attr_accessor :images, :specifications, :seo_keywords
    # 商品カタログ担当: 見た目・スペック・SEOが重要
  end
end
 
# 在庫サービスでの「商品」
module InventoryContext
  class StockItem
    attr_accessor :product_id, :quantity, :warehouse_location
    attr_accessor :reorder_threshold, :supplier_id
    # 在庫担当: 数量・場所・発注が重要
  end
end
 
# 注文サービスでの「商品」
module OrderContext
  class OrderLineItem
    attr_accessor :product_id, :product_name_snapshot  # 注文時点の名前を保存
    attr_accessor :unit_price_snapshot  # 注文時点の価格を保存
    attr_accessor :quantity
    # 注文担当: 注文時点の情報を不変に保つことが重要
  end
end

# コンテキスト定義
contexts:
  user:
    owns:
      - ユーザーアカウント
      - 認証・認可
      - プロフィール情報
      - ポイント残高
    does_not_own:
      - 注文履歴（注文コンテキストが所有）
 
  product:
    owns:
      - 商品カタログ
      - カテゴリ・タグ
      - 商品画像
      - SEOメタデータ
    does_not_own:
      - 在庫数（在庫コンテキストが所有）
 
  order:
    owns:
      - 注文ライフサイクル
      - 注文明細（価格・数量のスナップショット）
      - 配送先情報
    does_not_own:
      - 決済詳細（決済コンテキストが所有）

# 注文サービスはユーザーサービスの「下流」
# ユーザーサービスが変更されると、注文サービスが影響を受ける可能性がある
 
# 注文サービス側: ACL（腐敗防止層）で変換
module OrderContext
  class UserAdapter
    def self.from_user_service(response)
      # UserServiceのAPIレスポンスをOrderContextのモデルに変換
      {
        user_id: response['id'],
        display_name: response['full_name'] || response['username'],
        shipping_address: format_address(response['addresses']&.first)
      }
    end
 
    private
 
    def self.format_address(addr)
      return nil unless addr
      "#{addr['postal_code']} #{addr['prefecture']}#{addr['city']}#{addr['street']}"
    end
  end
end

# shared/money.rb — 共有カーネル: 金額の扱い
module Shared
  class Money
    attr_reader :amount, :currency
 
    def initialize(amount, currency: 'JPY')
      @amount = amount.round
      @currency = currency
    end
 
    def +(other)
      raise ArgumentError, "通貨が一致しません" unless currency == other.currency
      Money.new(amount + other.amount, currency: currency)
    end
 
    def to_h
      { amount: amount, currency: currency }
    end
  end
end

# サービス境界の決定基準チェックリスト
class ServiceBoundaryChecker
  CRITERIA = [
    "ビジネスドメインが独立している",
    "変更の頻度が他と大きく異なる",
    "スケール要件が他と大きく異なる",
    "データの所有権が明確",
    "チームの所有権が明確",
    "外部システムとの結合点になっている"
  ].freeze
end

# config/routes.rb — プロキシで段階的に移行
Rails.application.routes.draw do
  # 移行済み: 検索APIをSearchServiceに転送
  scope '/api/v1' do
    match '/search/*path', to: proc { |env|
      proxy_to('http://search-service', env)
    }, via: :all
 
    # まだモノリスで処理: 注文
    resources :orders
    resources :products
    resources :users
  end
end

# app/middleware/service_proxy.rb
class ServiceProxy
  def initialize(app, service_url:, path_prefix:)
    @app = app
    @service_url = service_url
    @path_prefix = path_prefix
  end
 
  def call(env)
    request = Rack::Request.new(env)
    if request.path.start_with?(@path_prefix)
      forward_to_service(request)
    else
      @app.call(env)
    end
  end
 
  private
 
  def forward_to_service(request)
    response = HTTP
      .headers(extract_headers(request))
      .public_send(request.request_method.downcase, "#{@service_url}#{request.path}")
    [response.status, response.headers.to_h, [response.body.to_s]]
  end
end

# app/services/product_context/
# └── product.rb
# └── product_repository.rb
# └── product_catalog_service.rb
 
# モノリス内でも「コンテキスト」を意識した構造にしておくと
# 後でサービスとして切り出しやすい
 
module ProductContext
  class ProductCatalogService
    def initialize(repository: ProductRepository.new)
      @repository = repository
    end
 
    def find_by_id(id)
      @repository.find(id)
    end
 
    def search(query, filters: {})
      @repository.search(query, filters)
    end
  end
 
  class ProductRepository
    def find(id)
      record = Product.find(id)
      to_domain(record)
    end
 
    private
 
    def to_domain(record)
      ProductContext::Product.new(
        id: record.id,
        name: record.name,
        price: Shared::Money.new(record.price_cents)
      )
    end
  end
end