Fix for Animeworld
This commit is contained in:
UrloMythus
+99
-64
@@ -44,16 +44,32 @@ showname_replace = {
|
||||
"Shippuuden": "Shippuden",
|
||||
" ": "+",
|
||||
}
|
||||
|
||||
async def security_cookie (response):
|
||||
if "SecurityAW-gl" in response.text:
|
||||
match = re.search(r'SecurityAW-gl=([^;]+)', response.text)
|
||||
characters = "gl"
|
||||
elif "SecurityAW-Ec" in response.text:
|
||||
match = re.search(r'SecurityAW-Ec=([^;]+)', response.text)
|
||||
characters = "Ec"
|
||||
if match:
|
||||
Security_Cookie = match.group(1).strip()
|
||||
cookies = {
|
||||
f"SecurityAW-{characters}": Security_Cookie
|
||||
}
|
||||
return cookies
|
||||
async def get_mp4(anime_url,ismovie,episode,client):
|
||||
response = await client.get(ForwardProxy + anime_url,allow_redirects=True, impersonate = "chrome124",proxies=proxies)
|
||||
cookies = {}
|
||||
response = await client.get(ForwardProxy + anime_url,allow_redirects=True, cookies = cookies,impersonate = "chrome124",proxies=proxies)
|
||||
soup = BeautifulSoup(response.text,'lxml')
|
||||
if ismovie == 0:
|
||||
episode_page = soup.find('a', {'data-episode-num':episode })
|
||||
if episode_page is None:
|
||||
return None
|
||||
episode_page = f'https://animeworld.{AW_DOMAIN}{episode_page["href"]}'
|
||||
response = await client.get(ForwardProxy + episode_page,allow_redirects=True, impersonate = "chrome124", proxies=proxies)
|
||||
response = await client.get(ForwardProxy + episode_page,allow_redirects=True, cookies = cookies,impersonate = "chrome124", proxies=proxies)
|
||||
if response.status_code == 202:
|
||||
cookies = await security_cookie(response)
|
||||
response = await client.get(ForwardProxy + episode_page,allow_redirects=True, cookies = cookies,impersonate = "chrome124", proxies=proxies)
|
||||
soup = BeautifulSoup(response.text,'lxml')
|
||||
|
||||
a_tag = soup.find('a', {'id': 'alternativeDownloadLink', 'class': 'm-1 btn btn-sm btn-primary'})
|
||||
@@ -66,6 +82,84 @@ async def get_mp4(anime_url,ismovie,episode,client):
|
||||
|
||||
|
||||
|
||||
async def search(showname,date,ismovie,episode,client):
|
||||
search_year = date[:4]
|
||||
headers = random_headers.generate()
|
||||
link = f'https://www.animeworld.so/filter?year={search_year}&sort=2&keyword={showname}'
|
||||
response = await client.get(ForwardProxy + link,allow_redirects=True, impersonate = "chrome124", headers = headers, proxies = proxies)
|
||||
if response.status_code == 202:
|
||||
cookies = await security_cookie(response)
|
||||
response = await client.get(ForwardProxy + link,allow_redirects=True, impersonate = "chrome124", proxies = proxies, headers = headers, cookies = cookies)
|
||||
else:
|
||||
cookies = {}
|
||||
soup = BeautifulSoup(response.text,'lxml')
|
||||
anime_list = soup.find_all('a', class_=['poster', 'tooltipstered'])
|
||||
final_urls = []
|
||||
for anime in anime_list:
|
||||
anime_info_url = f'https://www.animeworld.{AW_DOMAIN}/{anime["data-tip"]}'
|
||||
response = await client.get(ForwardProxy + anime_info_url,allow_redirects=True, impersonate = "chrome124", cookies = cookies, proxies = proxies)
|
||||
if response.status_code == 202:
|
||||
cookies = await security_cookie(response)
|
||||
response = await client.get(ForwardProxy + anime_info_url,allow_redirects=True, impersonate = "chrome124", cookies = cookies, proxies = proxies)
|
||||
pattern = r'<label>Data di uscita:</label>\s*<span>\s*(.*?)\s*</span>'
|
||||
match = re.search(pattern, response.text, re.S)
|
||||
release_date = match.group(1).strip()
|
||||
for ita, eng in months.items():
|
||||
release_date = release_date.replace(ita, eng)
|
||||
release_date = datetime.datetime.strptime(release_date, "%d %B %Y")
|
||||
date_object = datetime.datetime.strptime(date, "%Y-%m-%d")
|
||||
release_date = release_date.strftime("%Y-%m-%d")
|
||||
if (release_date == date or
|
||||
release_date == date_object + datetime.timedelta(days=1) or
|
||||
release_date == date_object - datetime.timedelta(days=1)):
|
||||
anime_url = f'https://www.animeworld.{AW_DOMAIN}{anime["href"]}'
|
||||
final_url = await get_mp4(anime_url,ismovie,episode,client)
|
||||
if final_url:
|
||||
final_urls.append(final_url)
|
||||
|
||||
return final_urls
|
||||
|
||||
async def animeworld(id,client):
|
||||
try:
|
||||
kitsu_id = id.split(":")[1]
|
||||
ismovie = 1 if len(id.split(":")) == 2 else 0
|
||||
if ismovie == 1:
|
||||
episode = None
|
||||
else:
|
||||
episode = id.split(":")[2]
|
||||
showname,date = await get_info_kitsu(kitsu_id,client)
|
||||
for key in showname_replace:
|
||||
if key in showname: # Check if the key is a substring of showname
|
||||
showname = showname.replace(key, showname_replace[key])
|
||||
if "Naruto:" in showname:
|
||||
showname = showname.replace(":", "")
|
||||
final_urls = await search(showname,date,ismovie,episode,client)
|
||||
return final_urls
|
||||
except:
|
||||
print("Animeworld failed")
|
||||
return None
|
||||
|
||||
async def test_animeworld():
|
||||
async with AsyncSession() as client:
|
||||
# Replace with actual id, for example 'anime_id:episode' format
|
||||
test_id = "kitsu:11:3" # This is an example ID format
|
||||
results = await animeworld(test_id, client)
|
||||
print(results)
|
||||
|
||||
if __name__ == "__main__":
|
||||
from curl_cffi.requests import AsyncSession
|
||||
import asyncio
|
||||
asyncio.run(test_animeworld())
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -97,7 +191,7 @@ async def old_search(showname,date,ismovie,episode,client):
|
||||
'keyword': showname,
|
||||
}
|
||||
|
||||
response = await client.post(f'https://www.animeworld.{AW_DOMAIN}/api/search/v2', params=params, cookies=cookies, headers=headers,allow_redirects=True, impersonate = "chrome120")
|
||||
response = await client.post(f'https://www.animeworld.{AW_DOMAIN}/api/search/v2', params=params, cookies=cookies, headers=headers,allow_redirects=True, impersonate = "chrome124")
|
||||
|
||||
data = json.loads(response.text)
|
||||
final_urls = []
|
||||
@@ -133,63 +227,4 @@ async def old_search(showname,date,ismovie,episode,client):
|
||||
final_url = await get_mp4(anime_url,ismovie,episode,client)
|
||||
final_urls.append(final_url)
|
||||
break
|
||||
return final_urls
|
||||
|
||||
async def search(showname,date,ismovie,episode,client):
|
||||
search_year = date[:4]
|
||||
headers = random_headers.generate()
|
||||
|
||||
response = await client.get(ForwardProxy + f'https://www.animeworld.so/filter?year={search_year}&sort=2&keyword={showname}',allow_redirects=True, impersonate = "chrome124", headers = headers, proxies = proxies)
|
||||
soup = BeautifulSoup(response.text,'lxml')
|
||||
anime_list = soup.find_all('a', class_=['poster', 'tooltipstered'])
|
||||
final_urls = []
|
||||
for anime in anime_list:
|
||||
anime_info_url = f'https://www.animeworld.{AW_DOMAIN}/{anime["data-tip"]}'
|
||||
response = await client.get(ForwardProxy + anime_info_url,allow_redirects=True, impersonate = "chrome124", proxies = proxies)
|
||||
pattern = r'<label>Data di uscita:</label>\s*<span>\s*(.*?)\s*</span>'
|
||||
match = re.search(pattern, response.text, re.S)
|
||||
release_date = match.group(1).strip()
|
||||
for ita, eng in months.items():
|
||||
release_date = release_date.replace(ita, eng)
|
||||
release_date = datetime.datetime.strptime(release_date, "%d %B %Y")
|
||||
release_date = release_date.strftime("%Y-%m-%d")
|
||||
if release_date == date:
|
||||
anime_url = f'https://www.animeworld.{AW_DOMAIN}{anime["href"]}'
|
||||
final_url = await get_mp4(anime_url,ismovie,episode,client)
|
||||
if final_url:
|
||||
final_urls.append(final_url)
|
||||
|
||||
return final_urls
|
||||
|
||||
async def animeworld(id,client):
|
||||
try:
|
||||
print(id)
|
||||
kitsu_id = id.split(":")[1]
|
||||
ismovie = 1 if len(id.split(":")) == 2 else 0
|
||||
if ismovie == 1:
|
||||
episode = None
|
||||
else:
|
||||
episode = id.split(":")[2]
|
||||
showname,date = await get_info_kitsu(kitsu_id,client)
|
||||
for key in showname_replace:
|
||||
if key in showname: # Check if the key is a substring of showname
|
||||
showname = showname.replace(key, showname_replace[key])
|
||||
if "Naruto:" in showname:
|
||||
showname = showname.replace(":", "")
|
||||
final_urls = await search(showname,date,ismovie,episode,client)
|
||||
return final_urls
|
||||
except:
|
||||
print("Animeworld failed")
|
||||
return None
|
||||
|
||||
async def test_animeworld():
|
||||
async with AsyncSession() as client:
|
||||
# Replace with actual id, for example 'anime_id:episode' format
|
||||
test_id = "kitsu:11407" # This is an example ID format
|
||||
results = await animeworld(test_id, client)
|
||||
print(results)
|
||||
|
||||
if __name__ == "__main__":
|
||||
from curl_cffi.requests import AsyncSession
|
||||
import asyncio
|
||||
asyncio.run(test_animeworld())
|
||||
return final_urls
|
||||
Reference in New Issue
Block a user