# Decision tree (from Full Merged §3 + Combo HAR)
# Q1 strong bot detection? YES → Patchright/Cloak + residential
# Q2 NL multi-step adaptive? YES → browser-use on stealth engine
# Q3 multi-account live? YES → Hybrid 4.7 ServerRouter

cd "/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid/omni-hybrid-merged"
python3 omni_cli.py boot
# Path A live only after routing sticky account→VPS
# Path C: cd social-autopilot && python3 run.py once   # if configured

# Install (engine layer — Ultimate + Full Merged §3)
pip install browser-use patchright playwright cryptography pyyaml
patchright install chromium

# Minimal Path B sketch (same session contract as Ultimate doc)
# Prefer official browser-use BrowserSession + patchright executable_path when versions update.
# Never use vanilla Playwright chromium for live social.
#
# from browser_use import Agent, BrowserSession
# browser_session = BrowserSession(
#     executable_path="<patchright chromium>",
#     user_data_dir="~/.config/browseruse/profiles/{ACCOUNT}",
#     headless=False,
# )
# # deterministic work on same profile, then:
# agent = Agent(task="...", llm=..., browser_session=browser_session)
# await agent.run()

MERGED_ROOT="/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid"
OMNI_MERGED="/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid/omni-hybrid-merged"
OMNI_ROOT="/Users/khaledahmedmohamed/designs-content/vip/social media agent/social media omni credentials/media omni agents"
# https://media.addict.best/
cd "$OMNI_MERGED" && python3 check_merge.py && python3 omni_cli.py boot
python3 omni_cli.py prompt

# Sequential order — never reverse
cd "/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid/omni-hybrid-merged"
python3 omni_cli.py boot
# then: cookies inject → warm → gated publish/grow
# python3 omni_cli.py publish --account {ACCOUNT} --platform {PLATFORM} --now

import time

def is_expired(exp, now=None):
    now = now if now is not None else time.time()
    return exp is not None and isinstance(exp, (int, float)) and exp > 0 and exp <= now

def normalize_cookie(c):
    now = time.time()
    exp = c.get("expires", c.get("expirationDate"))
    if is_expired(exp, now):
        return None
    out = {
        "name": c.get("name"), "value": c.get("value"),
        "domain": c.get("domain"), "path": c.get("path", "/"),
    }
    # KEEP session cookies: expires=-1 or missing → do not drop
    if exp is not None and exp > 0:
        out["expires"] = exp
    else:
        out["expires"] = -1
    ss = (c.get("sameSite") or c.get("same_site") or "Lax")
    # Titlecase: Lax|Strict|None
    out["sameSite"] = str(ss).strip().title().replace("Lax", "Lax").replace("Strict", "Strict").replace("None", "None")
    if out["sameSite"].lower() == "lax": out["sameSite"] = "Lax"
    if out["sameSite"].lower() == "strict": out["sameSite"] = "Strict"
    if out["sameSite"].lower() == "none": out["sameSite"] = "None"
    return out

# chmod 600 vault; inject cookies before page.goto

export OMNI_ROOT="/Users/khaledahmedmohamed/designs-content/vip/social media agent/social media omni credentials/media omni agents"
python3 "$OMNI_ROOT/local_auto_login.py" --platform all
python3 "$OMNI_ROOT/dashboard_launcher.py"
# After success: scp cookies to pinned VPS only (Mode C)

export OMNI_ROOT="/Users/khaledahmedmohamed/designs-content/vip/social media agent/social media omni credentials/media omni agents"
python3 "$OMNI_ROOT/session_sync_keep_alive.py"
# clear Chromium Singleton locks if profile stuck:
# rm -f "$PROFILE/Singleton*" 

# After live publish success:
# await first_60_minutes(page, platform, post_url, human, ch)
# Always: smart_click only; Poisson delays; log proofs/
from pathlib import Path
print("log first_60 actions to proofs/ and incidents.jsonl if blocked")

export OMNI_ROOT="/Users/khaledahmedmohamed/designs-content/vip/social media agent/social media omni credentials/media omni agents"
cd "/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid/omni-hybrid-merged"
python3 omni_cli.py grow --account acc1 --platform twitter
# or:
python3 "$OMNI_ROOT/engage_growth_overgrowth.py" --platform twitter --account acc1

def classify(trigger: str) -> str:
    t = trigger.lower()
    if any(x in t for x in ("shadowban", "locked", "banned", "suspended")):
        return "L3"  # 310 → 48h
    if any(x in t for x in ("checkpoint", "session_expired", "captcha", "challenge")):
        return "L2"  # 308 → re-export cookies, quarantine
    return "L1"  # 301 → reduce rate

# append incidents.jsonl · never ban-loop captcha

"""
Cubic Bezier smart_click — UNIFIED stealth law.
Drop-in for Playwright Page when patching Omni scripts.

Usage:
    from smart_click import smart_click
    await smart_click(page, selector)
    # or
    await smart_click(page, element_handle=handle)
"""
from __future__ import annotations

import asyncio
import math
import random
from typing import Optional, Tuple, List

# Optional playwright types — no hard import at module level for gate-only hosts


def _bezier(
    start: Tuple[float, float],
    end: Tuple[float, float],
    points: int = 22,
) -> List[Tuple[float, float]]:
    x0, y0 = start
    x3, y3 = end
    # control points with human-ish offset
    cp1 = (x0 + random.uniform(-80, 80), y0 + random.uniform(-40, 120))
    cp2 = (x3 + random.uniform(-80, 80), y3 + random.uniform(-120, 40))
    out = []
    for i in range(points):
        t = i / (points - 1)
        u = 1 - t
        x = u**3 * x0 + 3 * u**2 * t * cp1[0] + 3 * u * t**2 * cp2[0] + t**3 * x3
        y = u**3 * y0 + 3 * u**2 * t * cp1[1] + 3 * u * t**2 * cp2[1] + t**3 * y3
        out.append((x, y))
    return out


def _pad_box(box: dict, pad: float = 0.25) -> Tuple[float, float]:
    """Avoid exact centroid (bot signal)."""
    x = box["x"] + box["width"] * random.uniform(pad, 1 - pad)
    y = box["y"] + box["height"] * random.uniform(pad, 1 - pad)
    return x, y


async def smart_click(
    page,
    selector: Optional[str] = None,
    *,
    element_handle=None,
    timeout: float = 15000,
    steps: int = 22,
) -> None:
    """
    Move mouse along cubic Bezier then click with jitter delay.
    NEVER use page.click(selector) for social — call this instead.
    """
    if element_handle is None:
        if not selector:
            raise ValueError("selector or element_handle required")
        element_handle = await page.wait_for_selector(selector, timeout=timeout)
    if element_handle is None:
        raise RuntimeError(f"element not found: {selector}")

    box = await element_handle.bounding_box()
    if not box:
        # fallback: still better than silent pass
        await element_handle.click(timeout=timeout)
        return

    target = _pad_box(box)
    # current mouse (Playwright has no get; assume last or viewport center)
    vp = page.viewport_size or {"width": 1280, "height": 800}
    start = (random.uniform(0, vp["width"] * 0.3), random.uniform(0, vp["height"] * 0.3))

    path = _bezier(start, target, points=steps)
    for x, y in path:
        await page.mouse.move(x, y)
        await asyncio.sleep(random.uniform(0.004, 0.018))

    await asyncio.sleep(random.uniform(0.05, 0.18))
    await page.mouse.down()
    await asyncio.sleep(random.uniform(0.03, 0.09))
    await page.mouse.up()
    await asyncio.sleep(random.uniform(0.08, 0.25))


async def human_scroll(page, total_px: int = 800) -> None:
    """Poisson-ish stepped scroll (warm_up helper)."""
    left = total_px
    while left > 0:
        step = min(left, int(random.gauss(120, 40)))
        step = max(40, step)
        await page.mouse.wheel(0, step)
        left -= step
        await asyncio.sleep(random.uniform(0.15, 0.55))


def poisson_delay(avg_seconds: float = 2.0) -> float:
    u = max(1e-9, random.random())
    d = -math.log(u) * avg_seconds
    return max(0.4, min(d, avg_seconds * 4))

import math, random
def get_poisson_delay(rate=1.5):
    return -math.log(1.0 - random.random()) / rate

cd "/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid/omni-hybrid-merged"
python3 omni_cli.py boot
# score = min(100, sum(weights_passed))
# publish.py --dry-run
# reject if virality < 60 or media path invalid

# 1 hub → 8–12 shorts → 4–6 carousels → 2–3 threads
# hook first 3s; mute-test; platform-native length
import json
print(json.dumps({"hook":"", "caption":"", "cta":"", "hashtags":[], "on_screen_text":"", "virality_checklist":[]}, indent=2))

from urllib.parse import urlparse

def domain_of(s: str) -> str:
    return urlparse(s).netloc.lower() or s.lower()

# require ≥2 distinct domains; confidence ≥ 65 before factual publish
# search OFF unless --factual

# Meta: Ad Library → 3-3-3 creative test → scale ≤20%/72h
# High intent: review sites, communities — value-first only
# Never sell spam lists; ethics.yaml passive_only
print("weekly_plan: channels, messages, caps, review_gate")

# servers.json account_routing sticky
# Authorized examples (from Full Merged / AGENTS roster):
# ssh hostinger
# ssh -i ~/.ssh/contabo2_new1 root@149.102.150.185
# ssh -i ~/.ssh/hetzner_dokploy root@46.62.228.173
# ssh -i ~/.ssh/ai_developer_key root@213.199.36.17
curl -s https://ifconfig.me; echo
# never run two accounts on same IP

# proofs/{platform}_{ts}.png · logs/incidents.jsonl
# status in {{PASS,FAIL,INCONCLUSIVE}}
import json, time
print(json.dumps({
  "status": "INCONCLUSIVE",
  "proofs": [],
  "remaining": [],
  "ts": time.time(),
}, indent=2))

cd "/Users/khaledahmedmohamed/designs-content/vip/social media agent/the full merged manager hybrid/omni-hybrid-merged"
python3 omni_cli.py boot
# python publish.py publish --platform instagram --topic "..." --dry-run
echo "dry-run: no live upload; print gate results only"

# PhasedGrowth sketch (Full Merged / Hybrid 4.7)
# age 0–6d:  posts=0 follows=0 likes≤5
# age 7–13: posts≤1 follows≤5 likes≤20
# age 14–20: posts≤2 follows≤15 likes≤40
# age 21+: playbook ceilings (still pad 20–30%)
# never rigid cron — add jitter minutes
print("remaining = caps - used_today")