"""ESM(G마켓·옥션) 검색 어댑터 — 네이버 폴백용(네이버에 해당 몰이 없을 때만 크롤).

두 사이트는 eBay Korea 백엔드 공유 + '잠시만 기다리십시오…' JS 챌린지(수 초 후 자동 통과)가
동일해, BrowserSearchAdapter 위에 site 파라미터 하나로 커버한다(카드/셀렉터만 분기).
챌린지는 ready_selector(카드) 가 렌더될 때까지 대기하면 자연히 통과한다.
"""

import time
from urllib.parse import quote

from common.logger import LOG
from services.search.browser_base import BrowserSearchAdapter
from services.search.contract import NormalizedProduct
from services.search.card_parser import parse_cards
from services.search.esm.selectors import SITES

# ESM 차단 마커. '잠시만 기다리십시오' 챌린지는 렌더 완료 후에도(parse=0) 남아 있으면 = 이 IP 가
# 챌린지를 못 푼 것 → 차단으로 간주해 IP 회전 재시도를 유도한다(정상 시엔 카드가 떠 parse>0 이라 여기 안 옴).
_BLOCK_MARKERS = ("errors.edgesuite.net", "You don't have permission to access", "비정상적인 접근", "잠시만 기다리")


# Cloudflare Turnstile('사람인지 확인' 체크박스) 위젯 iframe.
_CF_IFRAME = 'iframe[src*="challenges.cloudflare.com"]'


class EsmAdapter(BrowserSearchAdapter):
    block_markers = _BLOCK_MARKERS
    min_result_html = 8000              # 챌린지 페이지(~21KB)는 크므로 short 폴백은 명백한 에러만
    # G마켓/옥션은 Cloudflare Turnstile. patchright 가 콜드 ~12초에 자동 통과하고, 통과하면 cf_clearance
    # 쿠키로 이후 요청은 ~5초(웜). 콜드 자동통과 여유로 25초까지 대기(잡은 폴백 데드라인 15s 가 상한).
    ready_timeout_ms = 25000
    # Cloudflare Turnstile 은 리소스 로딩 패턴까지 지문검사 → 챌린지 solving 중 차단하면 봇 판정(이미지만 막아도 실패).
    # 하지만 **cf_clearance 확보(웜) 후엔 차단해도 재챌린지 없음**(실측) → 동적 차단: 콜드=허용, 웜=차단.
    block_resources_default = True
    blocked_resource_types = {"image", "media", "font"}

    def __init__(self, site: str, **kwargs):
        if site not in SITES:
            raise ValueError(f"unknown ESM site: {site}")
        self._site = SITES[site]
        self.source = site              # base __init__ 의 user_data_dir 기본값에 쓰임
        self.ready_selector = self._site.ready_selector
        super().__init__(**kwargs)

    def _search_url(self, query: str, limit: int) -> str:
        return self._site.search_url.format(q=quote(query))

    def _parse(self, html: str) -> list[NormalizedProduct]:
        return parse_cards(html, self._site.cards)

    async def _blocking_now(self) -> bool:
        """Turnstile 챌린지를 이미 통과(cf_clearance 쿠키 있음)했을 때만 리소스 차단.
        콜드(쿠키 없음)엔 차단하면 Turnstile 지문검사에 걸리므로 허용."""
        if not self._block_resources or self._ctx is None:
            return False
        try:
            cookies = await self._ctx.cookies(self._site.search_url)
            return any(c.get("name") == "cf_clearance" for c in cookies)
        except Exception:
            return False

    async def _wait_ready(self, page):
        """Turnstile 대응 렌더 대기: 카드가 뜰 때까지 폴링하되, 매 회 인터랙티브 체크박스면 클릭 시도.
        대부분은 patchright 가 자동 통과(클릭 무해). cf_clearance 웜 상태면 카드가 곧바로 뜬다."""
        deadline = time.monotonic() + self.ready_timeout_ms / 1000
        while time.monotonic() < deadline:
            try:
                if await page.query_selector(self.ready_selector):
                    return
            except Exception:
                pass
            await self._try_pass_turnstile(page)
            await page.wait_for_timeout(1000)

    async def _try_pass_turnstile(self, page):
        """Turnstile 인터랙티브 체크박스(나쁜 IP 에스컬레이션)면 클릭. best-effort — 없거나 실패해도 무시.
        위젯은 challenges.cloudflare.com cross-origin iframe 안에 있다."""
        try:
            fl = page.frame_locator(_CF_IFRAME)
            for sel in ('input[type="checkbox"]', 'label'):
                loc = fl.locator(sel)
                if await loc.count():
                    await loc.first.click(timeout=1200)
                    LOG.d(f"[{self.source}] Turnstile 체크박스 클릭 시도")
                    return
        except Exception:
            pass