Test for Tantifilm
This commit is contained in:
@@ -165,7 +165,6 @@ async def true_url(protect_link,client):
|
|||||||
response = await client.get(protect_link, proxies=proxies, allow_redirects=True, impersonate = "chrome120")
|
response = await client.get(protect_link, proxies=proxies, allow_redirects=True, impersonate = "chrome120")
|
||||||
else:
|
else:
|
||||||
response = await client.get(protect_link, allow_redirects=True, impersonate = "chrome120")
|
response = await client.get(protect_link, allow_redirects=True, impersonate = "chrome120")
|
||||||
link = response.url
|
|
||||||
|
|
||||||
|
|
||||||
if response.status_code == 200:
|
if response.status_code == 200:
|
||||||
@@ -182,7 +181,10 @@ async def true_url(protect_link,client):
|
|||||||
if match:
|
if match:
|
||||||
# Create real link (match[0] includes all matched elements)
|
# Create real link (match[0] includes all matched elements)
|
||||||
url =f'https://d000d.com{match[1]}'
|
url =f'https://d000d.com{match[1]}'
|
||||||
rebobo = await client.get(url, headers=headers, allow_redirects=True, impersonate = "chrome120")
|
if "HF" == "1" :
|
||||||
|
rebobo = await client.get(url, headers=headers, allow_redirects=True, impersonate = "chrome120",proxies= proxies)
|
||||||
|
else:
|
||||||
|
rebobo = await client.get(url, headers=headers, allow_redirects=True, impersonate = "chrome120")
|
||||||
real_url = f'{rebobo.text}123456789{match[2]}{real_time}'
|
real_url = f'{rebobo.text}123456789{match[2]}{real_time}'
|
||||||
print("MammaMia: Found results for Tantifilm")
|
print("MammaMia: Found results for Tantifilm")
|
||||||
return real_url
|
return real_url
|
||||||
@@ -266,7 +268,7 @@ async def tantifilm(imdb,client,TF_FAST_SEARCH):
|
|||||||
return None
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
'''
|
||||||
async def test_animeworld():
|
async def test_animeworld():
|
||||||
from curl_cffi.requests import AsyncSession
|
from curl_cffi.requests import AsyncSession
|
||||||
async with AsyncSession() as client:
|
async with AsyncSession() as client:
|
||||||
@@ -278,5 +280,5 @@ if __name__ == "__main__":
|
|||||||
import asyncio
|
import asyncio
|
||||||
asyncio.run(test_animeworld())
|
asyncio.run(test_animeworld())
|
||||||
|
|
||||||
|
'''
|
||||||
|
|
||||||
|
|||||||
@@ -224,8 +224,7 @@ async def addon_stream(request: Request,config, type, id,):
|
|||||||
SC_FAST_SEARCH = provider_maps['SC_FAST_SEARCH']
|
SC_FAST_SEARCH = provider_maps['SC_FAST_SEARCH']
|
||||||
url_streaming_community,url_720_streaming_community,quality_sc = await streaming_community(id,client,SC_FAST_SEARCH)
|
url_streaming_community,url_720_streaming_community,quality_sc = await streaming_community(id,client,SC_FAST_SEARCH)
|
||||||
if url_streaming_community is not None:
|
if url_streaming_community is not None:
|
||||||
response = await client.get("https://api.ipify.org?format=json")
|
print(f"StreamingCommunity Found Results for {id}")
|
||||||
print(f"StreamingCommunity Found Results for {id}",response.json())
|
|
||||||
if quality_sc == "1080":
|
if quality_sc == "1080":
|
||||||
streams['streams'].append({'title': f'{HF}StreamingCommunity 1080p Max', 'url': url_streaming_community})
|
streams['streams'].append({'title': f'{HF}StreamingCommunity 1080p Max', 'url': url_streaming_community})
|
||||||
streams['streams'].append({'title': f'{HF}StreamingCommunity 720p Max', 'url': url_720_streaming_community})
|
streams['streams'].append({'title': f'{HF}StreamingCommunity 720p Max', 'url': url_720_streaming_community})
|
||||||
|
|||||||
Reference in New Issue
Block a user