Add encoding to urls
This commit is contained in:
@@ -7,6 +7,7 @@ from Src.Utilities.loadenv import load_env
|
|||||||
import json, random
|
import json, random
|
||||||
from Src.Utilities.info import get_info_imdb,get_info_tmdb
|
from Src.Utilities.info import get_info_imdb,get_info_tmdb
|
||||||
from Src.Utilities.eval import eval_solver
|
from Src.Utilities.eval import eval_solver
|
||||||
|
import urllib.parse
|
||||||
env_vars = load_env()
|
env_vars = load_env()
|
||||||
GS_PROXY = config.GS_PROXY
|
GS_PROXY = config.GS_PROXY
|
||||||
proxies = {}
|
proxies = {}
|
||||||
@@ -70,6 +71,7 @@ async def get_supervideo_link(link,client):
|
|||||||
async def search(showname,date,client):
|
async def search(showname,date,client):
|
||||||
try:
|
try:
|
||||||
headers = random_headers.generate()
|
headers = random_headers.generate()
|
||||||
|
showname = urllib.parse.quote(showname)
|
||||||
response = await client.get(ForwardProxy + f'{GS_DOMAIN}/?story={showname}&do=search&subaction=search', allow_redirects=True, impersonate = "chrome124", headers = headers, proxies = proxies)
|
response = await client.get(ForwardProxy + f'{GS_DOMAIN}/?story={showname}&do=search&subaction=search', allow_redirects=True, impersonate = "chrome124", headers = headers, proxies = proxies)
|
||||||
if response.status_code != 200:
|
if response.status_code != 200:
|
||||||
print(f"Guardaserie Failed to fetch search results: {response.status_code}")
|
print(f"Guardaserie Failed to fetch search results: {response.status_code}")
|
||||||
@@ -120,8 +122,12 @@ async def guardaserie(id,client):
|
|||||||
return None
|
return None
|
||||||
page_url = await search(showname,date,client)
|
page_url = await search(showname,date,client)
|
||||||
supervideo_link =await player_url(page_url,season,episode,client)
|
supervideo_link =await player_url(page_url,season,episode,client)
|
||||||
final_url = await eval_solver(supervideo_link,proxies, ForwardProxy, client)
|
if supervideo_link:
|
||||||
return final_url
|
final_url = await eval_solver(supervideo_link,proxies, ForwardProxy, client)
|
||||||
|
return final_url
|
||||||
|
else:
|
||||||
|
print("Couldn't find iframe source")
|
||||||
|
return None
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print("MammaMia: Guardaserie Failed",e)
|
print("MammaMia: Guardaserie Failed",e)
|
||||||
return None
|
return None
|
||||||
@@ -132,7 +138,7 @@ async def test_script():
|
|||||||
from curl_cffi.requests import AsyncSession
|
from curl_cffi.requests import AsyncSession
|
||||||
async with AsyncSession() as client:
|
async with AsyncSession() as client:
|
||||||
# Replace with actual id, for example 'anime_id:episode' format
|
# Replace with actual id, for example 'anime_id:episode' format
|
||||||
test_id = "tt0460649:1:1" # This is an example ID format
|
test_id = "tt0157246:1:1" # This is an example ID format tt0460649
|
||||||
results = await guardaserie(test_id, client)
|
results = await guardaserie(test_id, client)
|
||||||
print(results)
|
print(results)
|
||||||
|
|
||||||
|
|||||||
@@ -142,6 +142,7 @@ async def eval_solver(stream_link,proxies, ForwardProxy, client):
|
|||||||
headers["user-agent"] = "Mozilla/5.0 (Linux; Android 12) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.5060.71 Mobile Safari/537.36"
|
headers["user-agent"] = "Mozilla/5.0 (Linux; Android 12) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.5060.71 Mobile Safari/537.36"
|
||||||
headers["User-Agent"] = "Mozilla/5.0 (Linux; Android 12) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.5060.71 Mobile Safari/537.36"
|
headers["User-Agent"] = "Mozilla/5.0 (Linux; Android 12) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.5060.71 Mobile Safari/537.36"
|
||||||
response = await client.get( ForwardProxy + stream_link, allow_redirects=True, timeout=30, headers = headers, proxies = proxies, impersonate = "chrome124")
|
response = await client.get( ForwardProxy + stream_link, allow_redirects=True, timeout=30, headers = headers, proxies = proxies, impersonate = "chrome124")
|
||||||
|
print("Eval:",response.status_code)
|
||||||
soup = BeautifulSoup(response.text, "lxml",parse_only=SoupStrainer("script"))
|
soup = BeautifulSoup(response.text, "lxml",parse_only=SoupStrainer("script"))
|
||||||
script_all = soup.find_all("script")
|
script_all = soup.find_all("script")
|
||||||
for i in script_all:
|
for i in script_all:
|
||||||
|
|||||||
Reference in New Issue
Block a user