Update scraper5.py
Browse files- scraper5.py +33 -3
scraper5.py
CHANGED
|
@@ -25,15 +25,32 @@ class XrayBrowserManager:
|
|
| 25 |
async with self._lock:
|
| 26 |
if self._setup_done: return
|
| 27 |
setup_and_start_xray()
|
|
|
|
| 28 |
self.playwright = await async_playwright().start()
|
| 29 |
self.context = await self.playwright.chromium.launch_persistent_context(
|
| 30 |
"/tmp/xray_profile",
|
| 31 |
headless=True,
|
| 32 |
proxy={"server": "socks5://127.0.0.1:10808"},
|
| 33 |
-
|
| 34 |
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 35 |
self._setup_done = True
|
| 36 |
|
|
|
|
|
|
|
| 37 |
async def get_page(self):
|
| 38 |
if not self._setup_done: await self.start()
|
| 39 |
return await self.context.new_page()
|
|
@@ -45,12 +62,25 @@ async def search_movies(query):
|
|
| 45 |
try:
|
| 46 |
url = f"{DOMENA}/se/j/json?q={urllib.parse.quote(query)}"
|
| 47 |
print(f"[TUNNEL] Vyhľadávam: {query}")
|
| 48 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 49 |
content = await page.evaluate("() => document.body.innerText")
|
| 50 |
return json.loads(content)
|
| 51 |
-
except
|
|
|
|
|
|
|
| 52 |
finally: await page.close()
|
| 53 |
|
|
|
|
| 54 |
async def get_details(slug, media_type):
|
| 55 |
page = await manager.get_page()
|
| 56 |
url = f"{DOMENA}/p/{slug}" if media_type in ["movie", "film"] else f"{DOMENA}/tv/{slug}/S01E01"
|
|
|
|
| 25 |
async with self._lock:
|
| 26 |
if self._setup_done: return
|
| 27 |
setup_and_start_xray()
|
| 28 |
+
|
| 29 |
self.playwright = await async_playwright().start()
|
| 30 |
self.context = await self.playwright.chromium.launch_persistent_context(
|
| 31 |
"/tmp/xray_profile",
|
| 32 |
headless=True,
|
| 33 |
proxy={"server": "socks5://127.0.0.1:10808"},
|
| 34 |
+
user_agent="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36"
|
| 35 |
)
|
| 36 |
+
|
| 37 |
+
# --- OVERENIE IP ADRESY ---
|
| 38 |
+
test_page = await self.context.new_page()
|
| 39 |
+
try:
|
| 40 |
+
print("[DEBUG] Overujem IP cez tunel...")
|
| 41 |
+
await test_page.goto("https://api.ipify.org", timeout=15000)
|
| 42 |
+
ip = await test_page.inner_text("body")
|
| 43 |
+
print(f"[DEBUG] Tvoja IP v tuneli je: {ip}")
|
| 44 |
+
except Exception as e:
|
| 45 |
+
print(f"[DEBUG ERROR] Tunel nefunguje: {e}")
|
| 46 |
+
finally:
|
| 47 |
+
await test_page.close()
|
| 48 |
+
# ---------------------------
|
| 49 |
+
|
| 50 |
self._setup_done = True
|
| 51 |
|
| 52 |
+
|
| 53 |
+
|
| 54 |
async def get_page(self):
|
| 55 |
if not self._setup_done: await self.start()
|
| 56 |
return await self.context.new_page()
|
|
|
|
| 62 |
try:
|
| 63 |
url = f"{DOMENA}/se/j/json?q={urllib.parse.quote(query)}"
|
| 64 |
print(f"[TUNNEL] Vyhľadávam: {query}")
|
| 65 |
+
|
| 66 |
+
# Otestujeme aj klasickú HTML stránku, či nás pustí
|
| 67 |
+
await page.goto(url, wait_until="networkidle", timeout=30000)
|
| 68 |
+
|
| 69 |
+
# Získame surový obsah
|
| 70 |
+
raw_content = await page.content()
|
| 71 |
+
print(f"[DEBUG] Surová dĺžka obsahu: {len(raw_content)}")
|
| 72 |
+
|
| 73 |
+
if len(raw_content) < 200:
|
| 74 |
+
print(f"[DEBUG] POZOR! Web vrátil podozrivo málo dát: {raw_content}")
|
| 75 |
+
|
| 76 |
content = await page.evaluate("() => document.body.innerText")
|
| 77 |
return json.loads(content)
|
| 78 |
+
except Exception as e:
|
| 79 |
+
print(f"[SEARCH ERROR] {e}")
|
| 80 |
+
return []
|
| 81 |
finally: await page.close()
|
| 82 |
|
| 83 |
+
|
| 84 |
async def get_details(slug, media_type):
|
| 85 |
page = await manager.get_page()
|
| 86 |
url = f"{DOMENA}/p/{slug}" if media_type in ["movie", "film"] else f"{DOMENA}/tv/{slug}/S01E01"
|