diff --git a/Src/API/webru.py b/Src/API/webru.py index 8c5d5dd..29f289c 100644 --- a/Src/API/webru.py +++ b/Src/API/webru.py @@ -55,23 +55,21 @@ async def get_stream_link(id,site,client): print("No .m3u8 URL found.") ''' stream_url = f"https://{server_key}new.iosplayer.ru/{server_key}/{dlhd_id}" + "/mono.m3u8" + return stream_url,Referer,Origin 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) - soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('iframe')) - iframe = soup.find('iframe', class_='embed-responsive-item') - real_link = iframe.get('src') - response = await client.get(real_link, allow_redirects = False) - pattern = r"source:\s*'([^']*\.m3u8)'" - match = re.search(pattern, response.text) - if match: - m3u8_url = match.group(1) # The URL is captured in the first capturing group - parsed_url = urlparse(m3u8_url) - domain = parsed_url.netloc - - else: - print("No .m3u8 URL found.") - stream_url = f"https://{domain}/lb/"+ webru_vary[id] + "/index.m3u8" - return stream_url,Referer,Origin + response = await client.get("https://calcio.monster/streaming-gratis-calcio-1.php") + soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('div', class_='ticket_btn')) + href = soup.find('a').get('href') + response = await client.get(href) + soup = BeautifulSoup(response.text, 'lxml', parse_only=SoupStrainer('button')) + webru_iframe = soup.find('button', {"data-type": "embed"}).get('data-url') + webru_iframe = "https://" + webru_iframe.split("/")[2] + vary_id = webru_vary[id] + vary_link = f"{webru_iframe}/server_lookup.php?channel_id={vary_id}" + response = await client.get(vary_link, headers=headers, allow_redirects=True, impersonate = "chrome124") + server_key = response.json()['server_key'] + stream_url = f"https://{server_key}new.iosplayer.ru/{server_key}/{vary_id}" + "/mono.m3u8" + return stream_url,Referer,Origin except Exception as e: return None async def webru(id,site,client): @@ -80,7 +78,7 @@ async def webru(id,site,client): return new_stream_url,Referer,Origin except Exception as e: print("WebRu failed",e) - return None + return None,None,None @@ -97,7 +95,7 @@ async def get_skystreaming(id,client): return m3u8_url,Host,Origin except Exception as e: print("SkyStreaming failed",e) - return None,None + return None,None,None @@ -164,4 +162,15 @@ async def webru2(id,site,client): url,Host = await get_skystreaming(id,client) streams['streams'].append({'title': f'{HF}Server {i}', 'url': url, "behaviorHints": {"notWebReady": True, "proxyHeaders": {"request": {"User-Agent": "Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:127.0) Gecko/20100101 Firefox/127.0", "Accept": "*/*", "Accept-Language": "en-US,en;q=0.5", "Origin": "https://skystreaming.guru", "DNT": "1", "Sec-GPC": "1", "Connection": "keep-alive", "Referer": "https://skystreaming.guru/", "Sec-Fetch-Dest": "empty", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Site": "cross-site", "Pragma": "no-cache", "Cache-Control": "no-cache", "TE": "trailers","Host": Host}}}}) - ''' \ No newline at end of file + ''' +async def test_webru(): + from curl_cffi.requests import AsyncSession + async with AsyncSession() as client: + # Replace with actual id, for example 'anime_id:episode' format + test_id = "sky-sport-uno" # This is an example ID format + results = await get_skystreaming(test_id,client) + print(results) + +if __name__ == "__main__": + import asyncio + asyncio.run(test_webru()) \ No newline at end of file diff --git a/run.py b/run.py index 7745638..106ae4b 100644 --- a/run.py +++ b/run.py @@ -251,20 +251,24 @@ async def addon_stream(request: Request,config, type, id,): i = i+1 if url: streams['streams'].append({'title': f'{Icon}Server S {i}' + channel['title'], 'url': url, "behaviorHints": {"notWebReady": True, "proxyHeaders": {"request": {"User-Agent": "Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:127.0) Gecko/20100101 Firefox/127.0", "Accept": "*/*", "Accept-Language": "en-US,en;q=0.5", "Origin": Sky_Origin, "DNT": "1", "Sec-GPC": "1", "Connection": "keep-alive", "Referer": f"{Sky_Origin}/", "Sec-Fetch-Dest": "empty", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Site": "cross-site", "Pragma": "no-cache", "Cache-Control": "no-cache", "TE": "trailers","Host": Host}}}}) - if MFP == "1": - if id in webru_vary: + if id in webru_vary: + i = i+1 + webru_url, Referer_webru_url,Origin_webru_url = await webru(id,"vary",client) + if MFP== "1": + webru_url = f'{MFP_url}/proxy/hls/manifest.m3u8?api_password={MFP_password}&d={webru_url}&h_Referer={Referer_webru_url}&h_Origin={Origin_webru_url}&h_User-Agent=Mozilla%2F5.0%20(Windows%20NT%2010.0%3B%20Win64%3B%20x64)%20AppleWebKit%2F537.36%20(KHTML%2C%20like%20Gecko)%20Chrome%2F58.0.3029.110%20Safari%2F537.3' + streams['streams'].append({'title': f"{Icon}Proxied Server X-{i} " + channel['title'],'url': webru_url}) + else: + streams['streams'].append({'title': f'{Icon}Server X-{i}' + channel['title'], 'url': webru_url, "behaviorHints": {"notWebReady": True, "proxyHeaders": {"request": {"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3", "Accept": "*/*", "Accept-Language": "en-US,en;q=0.5", "Origin": Origin_webru_url, "DNT": "1", "Sec-GPC": "1", "Connection": "keep-alive", "Referer": Referer_webru_url, "Sec-Fetch-Dest": "empty", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Site": "cross-site", "Pragma": "no-cache", "Cache-Control": "no-cache", "TE": "trailers"}}}}) + + if id in webru_dlhd: + if DLHD == "1": i = i+1 - webru_url = await webru(id,"vary",client) - streams['streams'].append({'title': f"{Icon}Server X-{i} " + channel['title'],'url': webru_url}) - if id in webru_dlhd: - if DLHD == "1": - i = i+1 - webru_url_2,Referer_webru_url_2,Origin_webru_url_2 = await webru(id,"dlhd",client) - if MFP== "1": - webru_url_2 = f'{MFP_url}/proxy/hls/manifest.m3u8?api_password={MFP_password}&d={webru_url_2}&h_Referer={Referer_webru_url_2}&h_Origin={Origin_webru_url_2}&h_User-Agent=Mozilla%2F5.0%20(Windows%20NT%2010.0%3B%20Win64%3B%20x64)%20AppleWebKit%2F537.36%20(KHTML%2C%20like%20Gecko)%20Chrome%2F58.0.3029.110%20Safari%2F537.3' - streams['streams'].append({'title': f"{Icon}Proxied Server D-{i} " + channel['title'],'url': webru_url_2}) - else: - streams['streams'].append({'title': f'{Icon}Server D-{i}' + channel['title'], 'url': webru_url_2, "behaviorHints": {"notWebReady": True, "proxyHeaders": {"request": {"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3", "Accept": "*/*", "Accept-Language": "en-US,en;q=0.5", "Origin": Origin_webru_url_2, "DNT": "1", "Sec-GPC": "1", "Connection": "keep-alive", "Referer": Referer_webru_url_2, "Sec-Fetch-Dest": "empty", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Site": "cross-site", "Pragma": "no-cache", "Cache-Control": "no-cache", "TE": "trailers"}}}}) + webru_url_2,Referer_webru_url_2,Origin_webru_url_2 = await webru(id,"dlhd",client) + if MFP== "1": + webru_url_2 = f'{MFP_url}/proxy/hls/manifest.m3u8?api_password={MFP_password}&d={webru_url_2}&h_Referer={Referer_webru_url_2}&h_Origin={Origin_webru_url_2}&h_User-Agent=Mozilla%2F5.0%20(Windows%20NT%2010.0%3B%20Win64%3B%20x64)%20AppleWebKit%2F537.36%20(KHTML%2C%20like%20Gecko)%20Chrome%2F58.0.3029.110%20Safari%2F537.3' + streams['streams'].append({'title': f"{Icon}Proxied Server D-{i} " + channel['title'],'url': webru_url_2}) + else: + streams['streams'].append({'title': f'{Icon}Server D-{i}' + channel['title'], 'url': webru_url_2, "behaviorHints": {"notWebReady": True, "proxyHeaders": {"request": {"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3", "Accept": "*/*", "Accept-Language": "en-US,en;q=0.5", "Origin": Origin_webru_url_2, "DNT": "1", "Sec-GPC": "1", "Connection": "keep-alive", "Referer": Referer_webru_url_2, "Sec-Fetch-Dest": "empty", "Sec-Fetch-Mode": "cors", "Sec-Fetch-Site": "cross-site", "Pragma": "no-cache", "Cache-Control": "no-cache", "TE": "trailers"}}}}) @@ -306,7 +310,7 @@ async def addon_stream(request: Request,config, type, id,): streams['streams'].append({"name":f'{Name}\n{quality_sc} Max', 'title': f'{Icon}StreamingCommunity\n {slug_sc.replace("-"," ").capitalize()}','url': url_streaming_community,'behaviorHints':{'notWebReady': False, 'bingeGroup': f'streamingcommunity{quality_sc}'}}) else: - streams['streams'].append({"name":f'{Name}\n{quality_sc}p Max\n This will work only on a local instance', 'title': f'{Icon}StreamingCommunity\n {slug_sc.replace("-"," ").capitalize()}','url': url_streaming_community,'behaviorHints': {'proxyHeaders': {"request": {"user-agent": User_Agent}}, 'notWebReady': True, 'bingeGroup': f'streamingcommunity{quality_sc}'}}) + streams['streams'].append({"name":f'{Name}\n{quality_sc}p Max', 'title': f'{Icon}StreamingCommunity\n {slug_sc.replace("-"," ").capitalize()}\n This will work only on a local instance','url': url_streaming_community,'behaviorHints': {'proxyHeaders': {"request": {"user-agent": User_Agent}}, 'notWebReady': True, 'bingeGroup': f'streamingcommunity{quality_sc}'}}) if provider_maps['LORDCHANNEL'] == "1" and LC == "1": url_lordchannel,quality_lordchannel = await lordchannel(id,client)