---

import os
import re
import json
import time
import requests
from bs4 import BeautifulSoup
from playwright.sync_api import sync_playwright

# ==================== НАСТРОЙКИ TELEGRAM ====================
TELEGRAM_BOT_TOKEN = "ВАШ_ТОКЕН_ОТ_BOTFATHER"
TELEGRAM_CHAT_ID = "ВАШ_CHAT_ID"

# Если доступ к api.telegram.org блокируется, укажите прокси (например, "http://127.0.0.1:1080")
TG_PROXY = None

# ==================== НАСТРОЙКИ ПОИСКА И ЦЕН ====================
MAX_PRICE = 3000

# Твоя ссылка на выдачу Авито (сортировка "По дате"):
AVITO_URL = "https://www.avito.ru/rossiya/odezhda_obuv_aksessuary/aksessuary/golovnye_ubory-ASgBAgICAUT8AtgM?q=gutta&s=104"

# Варианты бренда
BRAND_VARIANTS = ["gutta", "гутта", "gatta", "гатта"]

# Ключевые слова кепок
CAP_KEYWORDS = ["кепк", "бейсболк", "снепбек", "snapback", "тракер", "trucker", "cap"]

# Маркеры договорной цены / цены в ЛС
NEGOTIABLE_MARKERS = ["в лс", "в личк", "договорн", "предлож", "обмен"]

# Минус-слова (отсекаем реплики "type" и одежду)
STOP_WORDS = ["type", "тайп", "колготк", "чулк", "носк", "лосин", "белье", "трусы"]

CHECK_INTERVAL = 60
SEEN_FILE = "seen_items.json"


def send_telegram_photo(caption: str, photo_bytes: bytes):
    """Отправка фото товара со ссылкой и ценой."""
    url = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/sendPhoto"
    data = {
        "chat_id": TELEGRAM_CHAT_ID,
        "caption": caption,
        "parse_mode": "HTML"
    }
    files = {"photo": ("cap.png", photo_bytes, "image/png")}
    proxies = {"http": TG_PROXY, "https": TG_PROXY} if TG_PROXY else None
    try:
        requests.post(url, data=data, files=files, timeout=25, proxies=proxies)
    except Exception as e:
        print(f"[TG ERROR] Сбой отправки фото: {e}")


def send_telegram_text(text: str):
    """Отправка текстового сообщения (запасной канал)."""
    url = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
    payload = {
        "chat_id": TELEGRAM_CHAT_ID,
        "text": text,
        "parse_mode": "HTML",
        "disable_web_page_preview": False
    }
    proxies = {"http": TG_PROXY, "https": TG_PROXY} if TG_PROXY else None
    try:
        requests.post(url, json=payload, timeout=12, proxies=proxies)
    except Exception as e:
        print(f"[TG ERROR] Сбой отправки текста: {e}")


def load_seen() -> set:
    if os.path.exists(SEEN_FILE):
        try:
            with open(SEEN_FILE, "r", encoding="utf-8") as f:
                return set(json.load(f))
        except Exception:
            return set()
    return set()


def save_seen(seen_ids: set):
    with open(SEEN_FILE, "w", encoding="utf-8") as f:
        json.dump(list(seen_ids), f, ensure_ascii=False, indent=2)


def extract_price(text: str) -> int:
    clean = re.sub(r"[^\d]", "", text)
    return int(clean) if clean else 0


def parse_page(page, seen_ids: set):
    html_content = page.content()
    soup = BeautifulSoup(html_content, "html.parser")
    items = soup.find_all("div", {"data-marker": "item"})

    print(f"\n[ИНФО] Найдено объявлений на странице: {len(items)}")

    for item in items:
        item_id = item.get("data-item-id")
        if not item_id or item_id in seen_ids:
            continue

        title_el = item.find("a", {"data-marker": "item-title"})
        if not title_el:
            continue

        title = title_el.get_text(strip=True)
        link = "https://www.avito.ru" + title_el.get("href", "")
        item_full_text = item.get_text(" ", strip=True).lower()

        # Парсим цену
        price_meta = item.find("meta", {"itemprop": "price"})
        if price_meta and price_meta.get("content"):
            price = int(price_meta["content"])
        else:
            price_box = item.find("strong")
            price = extract_price(price_box.get_text()) if price_box else 0

        # 1. Проверяем бренд
        has_brand = any(b in item_full_text for b in BRAND_VARIANTS)

        # 2. Проверяем, что это головной убор / кепка
        is_cap = any(kw in item_full_text for kw in CAP_KEYWORDS)

        # 3. Проверяем стоп-слова
        has_stop_word = any(sw in item_full_text for sw in STOP_WORDS)

        # 4. Проверяем условие «в ЛС / договорная»
        is_negotiable = (
            any(marker in item_full_text for marker in NEGOTIABLE_MARKERS) or
            (0 <= price <= 50)  # Заглушки вида 1 ₽ или 10 ₽
        )

        # 5. Проверяем обычную цену
        is_regular_valid_price = (50 < price <= MAX_PRICE)

        # Если бренд совпал, это кепка, нет стоп-слов, и либо цена до 3000, либо договорная:
        if has_brand and is_cap and not has_stop_word and (is_regular_valid_price or is_negotiable):
            if is_negotiable and price <= 50:
                price_str = f"💬 Договорная / Цена в ЛС ({price} ₽)"
            else:
                price_str = f"{price} ₽"

            caption = (
                f"🧢 <b>Найдена кепка Gutta!</b>\n\n"
                f"📌 <b>Товар:</b> {title}\n"
                f"💵 <b>Цена:</b> {price_str}\n"
                f"🔗 <a href='{link}'>Открыть на Авито</a>"
            )

            print(f"[УСПЕХ] Найдено: {title} | {price_str}")

            try:
                card_locator = page.locator(f'div[data-marker="item"][data-item-id="{item_id}"]').first
                card_locator.scroll_into_view_if_needed()
                page.wait_for_timeout(600)
                photo_bytes = card_locator.screenshot()
                send_telegram_photo(caption, photo_bytes)
            except Exception as e:
                print(f"[SCREENSHOT ERROR] {e}")
                send_telegram_text(caption)

        seen_ids.add(item_id)

    save_seen(seen_ids)


def run_bot():
    seen_ids = load_seen()
    print("Запуск мониторинга кепок Gutta...")
    send_telegram_text("🚀 <i>Бот запущен. Мониторинг кепок Gutta (до 3 000 ₽ + договорные) активен!</i>")

    with sync_playwright() as p:
        browser = p.chromium.launch(
            headless=False,
            args=["--disable-blink-features=AutomationControlled"]
        )
        context = browser.new_context(
            user_agent="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36",
            viewport={"width": 1366, "height": 768}
        )
        page = context.new_page()

        print("Загружаем страницу поиска Авито...")
        page.goto(AVITO_URL, wait_until="domcontentloaded", timeout=45000)
        page.wait_for_timeout(4000)

        while True:
            try:
                page.reload(wait_until="domcontentloaded", timeout=45000)
                page.wait_for_timeout(3500)

                parse_page(page, seen_ids)
                print(f"[OK] Проверка завершена. Ждем {CHECK_INTERVAL} сек...")
            except Exception as err:
                print(f"[ОШИБКА ЦИКЛА] {err}")

            time.sleep(CHECK_INTERVAL)


if __name__ == "__main__":
    run_bot()