A 弱点補強 — typing.Protocol × @runtime_checkable × Structural Subtyping × NotificationResult Value Object（MOps 通知システム Bad→Good Ch2/Ch4/Ch5/Ch10）

📋 コピー"""MOps 通知システム — Protocol + Structural Subtyping による型安全通知.

適用パターン:
    Strategy   (Ch4): 振る舞いを Protocol で抽象化
    Value Object (Ch2): NotificationResult
    Protocol / Structural Subtyping (Ch10)
"""
from __future__ import annotations

import logging
import smtplib
from dataclasses import dataclass
from email.mime.text import MIMEText
from typing import Final, Protocol, runtime_checkable

logger = logging.getLogger(__name__)

# ── 定数（マジックストリング廃絶）────────────────────
DEFAULT_SUBJECT: Final[str] = "MOps キャンペーン通知"
EMAIL_ENCODING: Final[str] = "utf-8"

# ── Value Object ─────────────────────────────────────
@dataclass(frozen=True, slots=True)
class NotificationResult:
    """通知結果 Value Object（不変・ハッシュ可能）.

    Attributes:
        success:   通知が成功したか
        channel:   チャンネル名（"EmailNotifier" 等）
        recipient: 送信先識別子
        error:     失敗時エラーメッセージ（成功時 None）
    """
    success: bool
    channel: str
    recipient: str
    error: str | None = None

# ── Notifier Protocol ────────────────────────────────
@runtime_checkable  # isinstance(x, Notifier) を有効化
class Notifier(Protocol):
    """マルチチャンネル通知インターフェース.

    Structural Subtyping: このクラスを継承しなくても
    ``send()`` シグネチャが一致すれば型互換とみなされる。
    """
    def send(self, recipient: str, message: str) -> None:
        """通知を送信する.

        Args:
            recipient: 送信先識別子
            message:   通知本文
        """
        ...

# ── 各実装（Protocol を継承しない — 構造的互換）────────
class EmailNotifier:
    """SMTP メール通知チャンネル."""

    def __init__(
        self, smtp_host: str, port: int,
        user: str, password: str,
        subject: str = DEFAULT_SUBJECT,
    ) -> None:
        self._smtp_host = smtp_host
        self._port = port
        self._user = user
        self._password = password
        self._subject = subject  # 名前付き定数をデフォルト値に

    def send(self, recipient: str, message: str) -> None:
        """メールを送信する.

        Args:
            recipient: 送信先メールアドレス
            message:   メール本文

        Raises:
            smtplib.SMTPException: SMTP 接続失敗
        """
        msg = MIMEText(message, "plain", EMAIL_ENCODING)
        msg["From"] = self._user
        msg["To"] = recipient
        msg["Subject"] = self._subject
        with smtplib.SMTP(self._smtp_host, self._port) as server:
            server.login(self._user, self._password)
            server.sendmail(self._user, recipient, msg.as_string())
        logger.info("email sent", extra={"to": recipient})

class SmsNotifier:
    """SMS 通知チャンネル（Twilio 等）.

    Bad: send_sms() → Good: send() に統一
    """

    def __init__(self, api_key: str, from_number: str) -> None:
        self._api_key = api_key
        self._from_number = from_number

    def send(self, recipient: str, message: str) -> None:
        """SMS を送信する.

        Args:
            recipient: 電話番号（E.164形式）
            message:   SMS 本文
        """
        # 実際は Twilio SDK: client.messages.create(...)
        logger.info("sms sent", extra={"to": recipient})

class SlackNotifier:
    """Slack 通知チャンネル.

    Bad: notify() → Good: send() に統一
    """

    def __init__(self, webhook_url: str) -> None:
        self._webhook_url = webhook_url

    def send(self, recipient: str, message: str) -> None:
        """Slack チャンネルに通知する.

        Args:
            recipient: チャンネル名（例: "#mops-alert"）
            message:   通知本文
        """
        # 実際は requests.post(self._webhook_url, ...)
        logger.info("slack sent", extra={"channel": recipient})

# ── エントリーポイント ────────────────────────────────
def send_campaign_notifications(
    notifiers: list[Notifier],     # 型安全な引数
    recipients: list[str],
    message: str,
) -> list[NotificationResult]:     # 情報豊富な戻り値
    """複数チャンネル × 複数受信者へキャンペーン通知を送信する.

    dispatch_notification は不要: 全 Notifier が send() を持つため
    直接呼び出せる（ポリモーフィズム）。

    Args:
        notifiers:  通知チャンネルリスト（Notifier 互換）
        recipients: 送信先リスト
        message:    通知本文

    Returns:
        各 (notifier × recipient) の NotificationResult

    Raises:
        TypeError: Notifier 非互換オブジェクトが含まれる場合（Fail-Fast）
    """
    # Fail-Fast: ループ前に全 Notifier の互換性を一括検証
    for notifier in notifiers:
        if not isinstance(notifier, Notifier):
            raise TypeError(
                f"{type(notifier).__name__} は Notifier Protocol に非互換。"
                f"send(recipient: str, message: str) -> None を実装してください。"
            )

    results: list[NotificationResult] = []
    for notifier in notifiers:
        channel_name = type(notifier).__name__
        for recipient in recipients:
            try:
                notifier.send(recipient, message)  # dispatch 不要！
                results.append(NotificationResult(
                    success=True,
                    channel=channel_name,
                    recipient=recipient,
                ))
            except Exception as exc:
                # エラーを握りつぶさず logging で記録する
                logger.error(
                    "notification failed",
                    extra={
                        "channel": channel_name,
                        "recipient": recipient,
                        "error": str(exc),
                    },
                    exc_info=True,  # スタックトレースも記録
                )
                results.append(NotificationResult(
                    success=False,
                    channel=channel_name,
                    recipient=recipient,
                    error=str(exc),  # Result に格納して呼び出し元へ
                ))

    return results

# ── 実行例 ────────────────────────────────────────────
if __name__ == "__main__":
    logging.basicConfig(
        level=logging.INFO,
        format="%(levelname)s %(message)s",
    )

    notifiers: list[Notifier] = [
        SmsNotifier(api_key="dummy_key", from_number="+810000000000"),
        SlackNotifier(webhook_url="https://hooks.slack.com/dummy"),
    ]

    results = send_campaign_notifications(
        notifiers=notifiers,
        recipients=["#mops-alert", "+818012345678"],
        message="【キャンペーン】今週末限定セール開催中！",
    )

    for r in results:
        status = "✅" if r.success else "❌"
        print(f"{status} [{r.channel}] → {r.recipient}")
        if r.error:
            print(f"   エラー: {r.error}")