reloia/MammaMia
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed dlhd scraping

Browse Source
This commit is contained in:
UrloMythus
2025-02-11 21:32:36 +01:00 Unverified
parent 731896527e
commit c68a50ddb0
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Src/API/webru.py
+9 -2
View File
@@ -32,11 +32,18 @@ headers = {
async def get_stream_link(id,site,MFP_CREDENTIALS,client): async def get_stream_link(id,site,MFP_CREDENTIALS,client):
try: try:
if site == "dlhd": if site == "dlhd":
dlhd_id = webru_dlhd[id]
response = await client.get(f"https://thedaddy.{DLHD_DOMAIN}/embed/stream-853.php", impersonate = "chrome124", headers = headers) response = await client.get(f"https://thedaddy.{DLHD_DOMAIN}/embed/stream-853.php", impersonate = "chrome124", headers = headers)
soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('iframe')) soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('iframe'))
iframe = soup.find('iframe', id='thatframe') iframe = soup.find('iframe', id='thatframe')
real_link = iframe.get('src') real_link = iframe.get('src')
parent_site_domain = real_link.split('/premiumtv')[0]
server_key_link = (f'{parent_site_domain}/server_lookup.php?channel_id={dlhd_id}')
response = await client.get(server_key_link, allow_redirects = False)
server_key = response.json()['server_key']
'''
response = await client.get(real_link, allow_redirects = False) response = await client.get(real_link, allow_redirects = False)
print(response.text)
pattern = r"source:\s*'([^']*\.m3u8)'" pattern = r"source:\s*'([^']*\.m3u8)'"
match = re.search(pattern, response.text) match = re.search(pattern, response.text)
if match: if match:
@@ -46,7 +53,8 @@ async def get_stream_link(id,site,MFP_CREDENTIALS,client):
else: else:
print("No .m3u8 URL found.") print("No .m3u8 URL found.")
stream_url = f"https://{domain}/lb/" + webru_dlhd[id] + "/index.m3u8" '''
stream_url = f"https://{server_key}new.iosplayer.ru/{server_key}/{dlhd_id}" + "/mono.m3u8"
elif site == "vary": elif site == "vary":
response = await client.get(f"https://www.tanti.{TF_DOMAIN}/tv-channel/sky-cinema-action-2", impersonate = "chrome124", headers = headers, timeout = 10) response = await client.get(f"https://www.tanti.{TF_DOMAIN}/tv-channel/sky-cinema-action-2", impersonate = "chrome124", headers = headers, timeout = 10)
soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('iframe')) soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('iframe'))
@@ -72,7 +80,6 @@ async def get_stream_link(id,site,MFP_CREDENTIALS,client):
async def webru(id,site,client,MFP_CREDENTIALS): async def webru(id,site,client,MFP_CREDENTIALS):
try: try:
new_stream_url = await get_stream_link(id,site,MFP_CREDENTIALS,client) new_stream_url = await get_stream_link(id,site,MFP_CREDENTIALS,client)
return new_stream_url return new_stream_url
except Exception as e: except Exception as e:
print("WebRu failed",e) print("WebRu failed",e)