Fixes: legacy DB NOT NULL, SEO httpx compat, single README screenshot, repo-name dedup, post-TOTP recovery verification

.gitignore

@@ -0,0 +1,14 @@
+__pycache__/
+*.pyc
+*.pyo
+logs/
+*.log
+.venv/
+venv/
+.env
+data/*.db
+data/*.db-journal
+cookies/
+screenshots/validator/
+.DS_Store
+.bot.pid

account_aging_worker.py

@@ -0,0 +1,344 @@
+"""Account aging — превращает «холодный» GitHub-аккаунт в активного юзера.
+
+Свежесозданный аккаунт, который только постит свои репо и больше нигде
+не появляется — самый простой паттерн для anti-spam GitHub: ноль
+star'ов на чужие репо, ноль follow'ов, ноль реакций. Этот воркер
+прогоняет аккаунт через имитацию реального поведения **через REST
+API** (без браузера — быстро и без палевных camoufox-сессий):
+
+  1. Найти 10-15 популярных репо в его теме (search API,
+     ``stars:>500`` фильтр).
+  2. ⭐ Звездануть 5-10 случайных из них (``PUT /user/starred/...``).
+  3. 👤 Зафолловить 3-5 владельцев этих репо
+     (``PUT /user/following/...``).
+  4. 👍 Поставить thumbsup-реакцию на 2-3 популярных открытых issue
+     в одном из этих репо (``POST /issues/<n>/reactions``). Текст
+     **не пишем** — это самый низко-рискованный вариант engagement'а.
+
+После прогона аккаунт выглядит как dev который что-то скрейпил,
+интересовался темой, наблюдает за проектами. Его собственные репо
+ранжируются ощутимо выше — GitHub Search учитывает «соц.граф» в
+своих сигналах.
+
+Интерфейс:
+
+    age_account(token, themes, db_log, intensity='normal') -> dict
+
+Возвращает ``{ok, starred, followed, reactions, error?}``.
+
+Интенсивности:
+  * ``'light'`` — 3 stars / 1 follow / 1 reaction (для уже обкатанных
+    акков)
+  * ``'normal'`` — 7 stars / 4 follows / 2 reactions
+  * ``'heavy'`` — 12 stars / 6 follows / 3 reactions (новые акки)
+
+Все ошибки тихие — возвращаем ``ok: False`` с причиной.
+"""
+from __future__ import annotations
+
+import asyncio
+import random
+from typing import Optional
+
+import httpx
+
+from logger_setup import get_logger
+
+log = get_logger(__name__)
+
+
+REST_BASE = "https://api.github.com"
+
+
+_INTENSITY_PROFILES = {
+    "light":  {"stars": 3,  "follows": 1, "reactions": 1, "delay_min": 5,  "delay_max": 12},
+    "normal": {"stars": 7,  "follows": 4, "reactions": 2, "delay_min": 8,  "delay_max": 20},
+    "heavy":  {"stars": 12, "follows": 6, "reactions": 3, "delay_min": 12, "delay_max": 30},
+}
+
+
+# Пул трендовых тем — поиск ведём по этим. Если тема нашего акка не
+# попадает в whitelist, всё равно используем её прямо как `q=...`.
+_THEME_TO_QUERY = {
+    "windows":   "topic:windows topic:utility stars:>500",
+    "gaming":    "topic:gaming stars:>500",
+    "overlay":   "topic:overlay stars:>200",
+    "automation": "topic:automation stars:>500",
+    "cli":       "topic:cli-tool stars:>500",
+    "python":    "language:python topic:utility stars:>1000",
+    "javascript": "language:javascript topic:tool stars:>1000",
+    "rust":      "language:rust topic:cli stars:>500",
+    "go":        "language:go topic:devops stars:>500",
+}
+
+
+_REACTIONS = ("+1", "heart", "rocket", "hooray")
+
+
+def _build_query(themes: list[str]) -> str:
+    """Собрать GitHub-search query из тем аккаунта.
+
+    Если тема прямой match'ит наш whitelist — берём подготовленный
+    шаблон. Иначе — используем тему как ключевое слово плюс
+    ``stars:>200`` чтобы отсечь мёртвые проекты.
+    """
+    if not themes:
+        return "stars:>1000 topic:tool"
+    chunks: list[str] = []
+    for t in themes:
+        t = (t or "").strip().lower()
+        if not t:
+            continue
+        if t in _THEME_TO_QUERY:
+            chunks.append(_THEME_TO_QUERY[t])
+        else:
+            chunks.append(f"{t} stars:>200")
+    return " ".join(chunks[:3]) if chunks else "stars:>1000 topic:tool"
+
+
+async def _search_popular_repos(
+    client: httpx.AsyncClient,
+    token: str,
+    themes: list[str],
+    limit: int = 25,
+) -> list[dict]:
+    """``GET /search/repositories?q=<theme>&sort=stars`` — топ репо.
+
+    Возвращает список словарей с ``full_name``, ``owner.login``,
+    ``open_issues_count``. Логин для follow'ов берётся из ``owner``.
+    """
+    q = _build_query(themes)
+    try:
+        r = await client.get(
+            f"{REST_BASE}/search/repositories",
+            params={
+                "q": q, "sort": "stars", "order": "desc",
+                "per_page": min(int(limit), 50),
+            },
+            headers={
+                "Authorization": f"Bearer {token}",
+                "Accept": "application/vnd.github+json",
+                "X-GitHub-Api-Version": "2022-11-28",
+            },
+        )
+        if r.status_code != 200:
+            log.warning(
+                "[AGING] search_repos HTTP %s for q=%r: %s",
+                r.status_code, q, r.text[:200],
+            )
+            return []
+        items = r.json().get("items", [])
+        # Защита от пустого ответа.
+        return [it for it in items if it.get("full_name")]
+    except Exception as e:
+        log.warning("[AGING] search_repos crash: %s", e)
+        return []
+
+
+async def _star_repo(
+    client: httpx.AsyncClient, token: str, full_name: str,
+) -> bool:
+    """``PUT /user/starred/{owner}/{repo}`` — 204 No Content при успехе."""
+    try:
+        r = await client.put(
+            f"{REST_BASE}/user/starred/{full_name}",
+            headers={
+                "Authorization": f"Bearer {token}",
+                "Accept": "application/vnd.github+json",
+                "Content-Length": "0",
+            },
+        )
+        return r.status_code in (204, 304)  # 304 если уже звезда
+    except Exception as e:
+        log.warning("[AGING] star %s failed: %s", full_name, e)
+        return False
+
+
+async def _follow_user(
+    client: httpx.AsyncClient, token: str, login: str,
+) -> bool:
+    """``PUT /user/following/{login}`` — 204 при успехе."""
+    try:
+        r = await client.put(
+            f"{REST_BASE}/user/following/{login}",
+            headers={
+                "Authorization": f"Bearer {token}",
+                "Accept": "application/vnd.github+json",
+                "Content-Length": "0",
+            },
+        )
+        return r.status_code in (204, 304)
+    except Exception as e:
+        log.warning("[AGING] follow %s failed: %s", login, e)
+        return False
+
+
+async def _list_open_issues(
+    client: httpx.AsyncClient, token: str, full_name: str, limit: int = 5,
+) -> list[int]:
+    """Список номеров популярных open-issues для целевого репо."""
+    try:
+        r = await client.get(
+            f"{REST_BASE}/repos/{full_name}/issues",
+            params={
+                "state": "open", "sort": "comments", "direction": "desc",
+                "per_page": min(int(limit), 30),
+            },
+            headers={
+                "Authorization": f"Bearer {token}",
+                "Accept": "application/vnd.github+json",
+            },
+        )
+        if r.status_code != 200:
+            return []
+        items = r.json() or []
+        # Отсеиваем pull request (REST issues возвращает PR'ы тоже).
+        return [
+            it["number"] for it in items
+            if it.get("number") and not it.get("pull_request")
+        ]
+    except Exception as e:
+        log.warning("[AGING] list_issues %s: %s", full_name, e)
+        return []
+
+
+async def _react_to_issue(
+    client: httpx.AsyncClient, token: str, full_name: str,
+    issue_number: int, content: str = "+1",
+) -> bool:
+    """``POST /repos/{owner}/{repo}/issues/{n}/reactions`` — 200/201 при успехе."""
+    try:
+        r = await client.post(
+            f"{REST_BASE}/repos/{full_name}/issues/{issue_number}/reactions",
+            json={"content": content},
+            headers={
+                "Authorization": f"Bearer {token}",
+                "Accept": "application/vnd.github+json",
+            },
+        )
+        return r.status_code in (200, 201)
+    except Exception as e:
+        log.warning(
+            "[AGING] react %s#%d failed: %s", full_name, issue_number, e,
+        )
+        return False
+
+
+async def age_account(
+    *,
+    token: str,
+    themes: Optional[list[str]] = None,
+    intensity: str = "normal",
+    db_log=None,
+) -> dict:
+    """Прогнать аккаунт через серию «реалистичных» действий.
+
+    :param token: PAT владельца аккаунта (нужен scope ``user:follow``,
+        ``public_repo`` для star/reactions).
+    :param themes: список тем-ключевых слов (обычно из репо аккаунта
+        или из выбранной темы при создании).
+    :param intensity: light / normal / heavy (см. _INTENSITY_PROFILES).
+    :param db_log: optional callable ``(level, message)`` для записи
+        в БД. Без него только в stdout-лог.
+
+    Возвращает ``{ok, starred, followed, reactions, error?}``.
+    """
+    if not token:
+        return {
+            "ok": False, "starred": 0, "followed": 0, "reactions": 0,
+            "error": "no_token",
+        }
+    profile = _INTENSITY_PROFILES.get(intensity, _INTENSITY_PROFILES["normal"])
+    themes = themes or []
+    delay_min = profile["delay_min"]
+    delay_max = profile["delay_max"]
+
+    starred = followed = reactions = 0
+
+    async with httpx.AsyncClient(
+        timeout=30, follow_redirects=True,
+    ) as client:
+        repos = await _search_popular_repos(
+            client, token, themes,
+            limit=max(profile["stars"] * 2, 20),
+        )
+        if not repos:
+            return {
+                "ok": False, "starred": 0, "followed": 0, "reactions": 0,
+                "error": "no_search_results",
+            }
+
+        random.shuffle(repos)
+
+        # 1) Звёзды.
+        star_targets = repos[: profile["stars"]]
+        for repo in star_targets:
+            ok = await _star_repo(client, token, repo["full_name"])
+            if ok:
+                starred += 1
+                log.info("[AGING] ⭐ %s", repo["full_name"])
+            await asyncio.sleep(
+                random.uniform(delay_min, delay_max),
+            )
+
+        # 2) Follow'ы — берём владельцев части начвёзженных репо
+        # (рандомизация, чтобы не было паттерна «фолловлю всех кого
+        # звезданул»).
+        follow_pool = list({
+            (r.get("owner") or {}).get("login")
+            for r in star_targets
+            if (r.get("owner") or {}).get("login")
+            and (r.get("owner") or {}).get("type") != "Organization"
+        })
+        random.shuffle(follow_pool)
+        for login in follow_pool[: profile["follows"]]:
+            ok = await _follow_user(client, token, login)
+            if ok:
+                followed += 1
+                log.info("[AGING] 👤 follow %s", login)
+            await asyncio.sleep(
+                random.uniform(delay_min, delay_max),
+            )
+
+        # 3) Реакции на популярные open-issues. Берём первый из
+        # звёзданутого пула, чьи issues есть.
+        for repo in star_targets:
+            if reactions >= profile["reactions"]:
+                break
+            issue_numbers = await _list_open_issues(
+                client, token, repo["full_name"], limit=5,
+            )
+            if not issue_numbers:
+                continue
+            chosen_issue = random.choice(issue_numbers)
+            content = random.choice(_REACTIONS)
+            ok = await _react_to_issue(
+                client, token, repo["full_name"], chosen_issue, content,
+            )
+            if ok:
+                reactions += 1
+                log.info(
+                    "[AGING] %s on %s#%d",
+                    content, repo["full_name"], chosen_issue,
+                )
+            await asyncio.sleep(
+                random.uniform(delay_min, delay_max),
+            )
+
+    summary = (
+        f"aged: starred={starred}/{profile['stars']}, "
+        f"followed={followed}/{profile['follows']}, "
+        f"reactions={reactions}/{profile['reactions']}"
+    )
+    log.info("[AGING] %s", summary)
+    if db_log is not None:
+        try:
+            await db_log("INFO", summary)
+        except Exception:
+            pass
+    return {
+        "ok": (starred + followed + reactions) > 0,
+        "starred": starred,
+        "followed": followed,
+        "reactions": reactions,
+    }