from asgiref.sync import async_to_sync
from channels.exceptions import InvalidChannelLayerError
from channels.layers import get_channel_layer

try:
    from redis.exceptions import ConnectionError as RedisConnectionError
except Exception:  # pragma: no cover - optional dependency in local/test runtimes
    RedisConnectionError = RuntimeError


async def broadcast_phase_event(session_code: str, event_type: str, payload: dict) -> None:
    """Send a phase event to all WebSocket clients connected to a game session."""
    try:
        channel_layer = get_channel_layer()
        if channel_layer is None:
            return
        group_name = f"game_{session_code.upper()}"
        await channel_layer.group_send(
            group_name,
            {
                "type": "phase.event",
                "event_type": event_type,
                "payload": payload,
            },
        )
    except (InvalidChannelLayerError, RedisConnectionError):
        return


def sync_broadcast_phase_event(session_code: str, event_type: str, payload: dict) -> None:
    """Sync wrapper for calling broadcast_phase_event from synchronous Django views."""
    try:
        async_to_sync(broadcast_phase_event)(session_code, event_type, payload)
    except (InvalidChannelLayerError, RedisConnectionError):
        return