A 弱点補強 — asyncio.TaskGroup × ExceptionGroup（except*）× Pydantic v2 BaseSettings × TypeVar[bound] × frozen dataclass slots=True（型安全並列バッチ Bad→Good Ch2/Ch4/Ch7/Ch10/Ch11）

📋 コピー"""campaign_fetcher.py — 並列キャンペーン取得バッチ（型安全版）

Ch2:  StrEnum / Pydantic v2 BaseSettings / CampaignResponse バリデーション
Ch4:  frozen dataclass slots=True CampaignResult（値オブジェクト）
Ch7:  名前付き定数（Settings クラスで管理・ハードコード排除）
Ch10: ExceptionGroup × except* × asyncio.timeout（例外の部分回収）
Ch11: asyncio.TaskGroup × Semaphore（構造化並行性・並列数制限）
"""
from __future__ import annotations

import asyncio, logging
from dataclasses import dataclass
from datetime import UTC, datetime
from decimal import Decimal, ROUND_HALF_UP
from enum import StrEnum
from typing import Final

import aiohttp
from pydantic import BaseModel, Field
from pydantic_settings import BaseSettings, SettingsConfigDict

logger = logging.getLogger(__name__)

# ── 定数（Ch7）
MONEY_PLACES: Final[Decimal] = Decimal("1")

# ── 環境変数から型安全に読み込み（Pydantic v2 BaseSettings）
class Settings(BaseSettings):
    """API 設定。環境変数 or .env ファイルから自動読み込み。"""
    model_config = SettingsConfigDict(env_file=".env", extra="ignore")

    api_base_url: str                                      # 必須（デフォルトなし）
    api_timeout_seconds: float = Field(default=30.0, gt=0) # gt=0: ゼロ以下を拒否
    api_max_concurrent: int = Field(default=10, ge=1, le=50)

# ── StrEnum（Ch2）
class CampaignStatus(StrEnum):
    ACTIVE   = "active"
    PAUSED   = "paused"
    ARCHIVED = "archived"

# ── API レスポンスのバリデーション（Pydantic v2）
class CampaignResponse(BaseModel):
    model_config = {"extra": "ignore"}  # 未知フィールド無視
    campaign_id: str
    budget: Decimal        # str → Decimal に自動変換
    status: CampaignStatus # 未知ステータス → ValidationError

# ── 値オブジェクト（Ch4）
@dataclass(frozen=True, slots=True)  # slots: __dict__ なし → 軽量
class CampaignResult:
    """キャンペーン取得結果のイミュータブル値オブジェクト。"""
    campaign_id: str
    budget: Decimal
    status: CampaignStatus
    fetched_at: datetime

    @property
    def budget_jpy(self) -> str:
        """予算を '¥1,234' 形式で返す（@property は frozen でも可能）。"""
        return f"¥{self.budget:,.0f}"

# ── 1件取得コア
async def _fetch_one(
    session: aiohttp.ClientSession,
    semaphore: asyncio.Semaphore,
    campaign_id: str,
    settings: Settings,
) -> CampaignResult:
    """1件のキャンペーンを取得し CampaignResult で返す。

    Raises:
        aiohttp.ClientError: HTTP エラー（4xx/5xx）。
        asyncio.TimeoutError: タイムアウト超過。
        pydantic.ValidationError: レスポンスが期待スキーマと不一致。
    """
    async with semaphore:  # 最大 api_max_concurrent 件を同時実行に制限
        # asyncio.timeout で宣言的タイムアウト（Python 3.11+ 推奨 Ch10）
        async with asyncio.timeout(settings.api_timeout_seconds):
            async with session.get(
                f"{settings.api_base_url}/campaigns/{campaign_id}",
                headers={"Accept": "application/json"},
            ) as resp:
                resp.raise_for_status()   # 4xx/5xx → ClientResponseError
                raw = await resp.json()

    # Pydantic v2 バリデーション（未知フィールド・型エラーを即排除）
    validated = CampaignResponse.model_validate(raw)
    budget_rounded = validated.budget.quantize(
        MONEY_PLACES, rounding=ROUND_HALF_UP
    )
    return CampaignResult(
        campaign_id=validated.campaign_id,
        budget=budget_rounded,
        status=validated.status,
        fetched_at=datetime.now(UTC),
    )

# ── 並列取得メイン
async def fetch_all(
    campaign_ids: list[str],
    settings: Settings | None = None,
) -> tuple[list[CampaignResult], list[BaseException]]:
    """複数キャンペーンを並列取得し (成功リスト, 失敗リスト) を返す。

    asyncio.TaskGroup で全タスクを管理し、
    except* で ExceptionGroup から部分的に例外を回収する。
    成功リストは campaign_id 昇順にソート済み。
    """
    settings = settings or Settings()
    if not campaign_ids:
        return [], []

    semaphore = asyncio.Semaphore(settings.api_max_concurrent)
    errors: list[BaseException] = []
    completed_tasks: list[asyncio.Task[CampaignResult]] = []

    async with aiohttp.ClientSession() as session:
        try:
            # TaskGroup: Python 3.11+ の構造化並行性（Ch11）
            # 全タスクが完了 or 例外発生で ExceptionGroup を raise
            async with asyncio.TaskGroup() as tg:
                for cid in campaign_ids:
                    t = tg.create_task(
                        _fetch_one(session, semaphore, cid, settings),
                        name=f"fetch-{cid}",  # デバッグ用タスク名
                    )
                    completed_tasks.append(t)

        except* aiohttp.ClientError as eg:
            # HTTP エラーのみを抽出（4xx/5xx/接続エラー）
            logger.warning("%d 件の HTTP エラーを回収", len(eg.exceptions))
            errors.extend(eg.exceptions)

        except* asyncio.TimeoutError as eg:
            # タイムアウトエラーのみを抽出
            logger.warning("%d 件のタイムアウトを回収", len(eg.exceptions))
            errors.extend(eg.exceptions)

        except* Exception as eg:
            # Pydantic ValidationError などの予期せぬエラー
            logger.error("%d 件の予期せぬエラーを回収", len(eg.exceptions))
            errors.extend(eg.exceptions)

    # 成功タスクのみ result() を収集
    results: list[CampaignResult] = [
        t.result()
        for t in completed_tasks
        if not t.cancelled() and t.exception() is None
    ]
    # campaign_id 昇順でソート（決定的な順序を保証）
    return sorted(results, key=lambda r: r.campaign_id), errors