from Src.Utilities.info import get_info_tmdb, is_movie, get_info_imdb import Src.Utilities.config as config from fake_headers import Headers from urllib.parse import quote from Src.Utilities.loadenv import load_env from Src.API.extractors.mixdrop import mixdrop from Src.API.extractors.deltabit import deltabit import re import logging from Src.Utilities.config import setup_logging level = config.LEVEL logger = setup_logging(level) from bs4 import BeautifulSoup,SoupStrainer env_vars = load_env() random_headers = Headers() try: import pytesseract from PIL import Image except Exception as e: print("You can not use ES") import base64 from io import BytesIO import time import os import json import difflib import random from Src.Utilities.mfp import build_mfp ES_DOMAIN = config.ES_DOMAIN ES_PROXY = config.ES_PROXY proxies = {} if ES_PROXY == "1": PROXY_CREDENTIALS = env_vars.get('PROXY_CREDENTIALS') proxy_list = json.loads(PROXY_CREDENTIALS) proxy = random.choice(proxy_list) if proxy == "": proxies = {} else: proxies = { "http": proxy, "https": proxy } ES_ForwardProxy = config.ES_ForwardProxy if ES_ForwardProxy == "1": ForwardProxy = env_vars.get('ForwardProxy') else: ForwardProxy = "" def convert_numbers(base64_data): image_data = base64.b64decode(base64_data) image = Image.open(BytesIO(image_data)) custom_config = r'--oem 3 --psm 6 outputbase digits' number_string = pytesseract.image_to_string(image, config=custom_config) return number_string.strip() async def get_numbers(safego_url,client): headers = random_headers.generate() headers['User-Agent'] = 'Mozilla/5.0 (X11; Linux x86_64; rv:138.0) Gecko/20100101 Firefox/138.0' response = await client.get(ForwardProxy + safego_url,headers = headers, proxies = proxies) cookies = (response.cookies.get_dict()) soup = BeautifulSoup(response.text,'lxml',parse_only=SoupStrainer('img')) numbers = soup.img['src'].split(',')[1] return numbers,cookies async def real_page(safego_url,client): try: current_directory = os.path.dirname(os.path.abspath(__file__)) file_path = os.path.join(current_directory, 'cookie.txt') headers = random_headers.generate() headers['Origin'] = 'https://safego.cc' headers['Referer'] = safego_url headers['User-Agent'] = 'Mozilla/5.0 (X11; Linux x86_64; rv:138.0) Gecko/20100101 Firefox/138.0' with open(file_path, 'r') as file: cookies = file.read() cookies = json.loads(cookies.replace("'", '"')) response = await client.post(ForwardProxy + safego_url,headers=headers, cookies = cookies, proxies = proxies) soup = BeautifulSoup(response.text,'lxml', parse_only=SoupStrainer('a')) if len(soup)>= 1: return soup.a['href'] else: logger.info("Getting numbers") numbers,cookies = await get_numbers(safego_url,client) numbers = convert_numbers(numbers) data = {'captch4': numbers} response = await client.post(ForwardProxy + safego_url,headers=headers, data=data, cookies = cookies, proxies = proxies) cap4 = response.headers.get('set-cookie').split(';')[0] cookies[cap4.split('=')[0]] = cap4.split('=')[1] with open(file_path, 'w') as file: file.write(str(cookies)) soup = BeautifulSoup(response.text,'lxml', parse_only=SoupStrainer('a')) return soup.a['href'] except Exception as e: logger.info(f"ES{e}") async def get_host_link(pattern,atag,client): match = re.search(pattern, atag) headers = random_headers.generate() if match: href_value = match.group(1) response = await client.head(ForwardProxy + href_value, headers={**headers, 'Range': 'bytes=0-0'}, proxies = proxies) href_value = response.url href = await real_page(href_value,client) return href async def scraping_links(atag,MFP,MFP_CREDENTIALS,client,streams,language): #Check which hosts are avaiable and extract the links from one of them. Turbovid uses Cloudflare therefore is not avaiable. Maxstream has a captcha. if "MixDrop" in atag and "DeltaBit" in atag: pattern = r']*rel="noopener"[^>]*>DeltaBit' href = await get_host_link(pattern,atag,client) try: streams = await deltabit(href,client,streams,"Eurostreaming",proxies,ForwardProxy,language) except Exception as e: pattern = r']*rel="noopener"[^>]*>MixDrop' href = await get_host_link(pattern,atag,client) streams = await mixdrop(href,client,MFP,MFP_CREDENTIALS,streams,"Eurostreaming",proxies,ForwardProxy,language) return streams if "MixDrop" in atag and "DeltaBit" not in atag: try: pattern = r']*rel="noopener"[^>]*>MixDrop' href = await get_host_link(pattern,atag,client) streams = await mixdrop(href,client,MFP,MFP_CREDENTIALS,streams,"Eurostreaming",proxies,ForwardProxy,language) return streams except Exception as e: return streams if 'DeltaBit' in atag and "MixDrop" not in atag: try: pattern = r']*rel="noopener"[^>]*>DeltaBit' href = await get_host_link(pattern,atag,client) streams = await deltabit(href,client,streams,"Eurostreaming",proxies,ForwardProxy,language) return streams except Exception as e: return streams if 'DeltaBit' not in atag and 'MixDrop' not in atag: logger.info("Just give up") return streams async def episodes_find(description,season,episode,MFP,MFP_CREDENTIALS,client,streams): t = 0 episode = episode.zfill(2) pattern = rf'{season}×{episode}\s*(.*?)(?=)' match = re.findall(pattern, description) if match: for episode_details in match: if "href" in episode_details: if t == 0: language = "\nITA" elif t == 1: language = "\nSUB-ITA" t +=1 streams = await scraping_links(episode_details.split(' – ', 1)[1],MFP,MFP_CREDENTIALS,client,streams,language) return streams async def search(showname,date,season,episode,MFP,MFP_CREDENTIALS,client,streams): headers = random_headers.generate() response = await client.get(ForwardProxy + f"{ES_DOMAIN}/wp-json/wp/v2/search?search={quote(showname)}&_fields=id", proxies = proxies, headers = headers) results = response.json() for i in results: response = await client.get(ForwardProxy + f"{ES_DOMAIN}/wp-json/wp/v2/posts/{i['id']}?_fields=content,title", proxies = proxies, headers = headers) if f'ID articolo non valido' in response.text: continue description = response.json() title = description['title']['rendered'] description = description['content']['rendered'] ratio = difflib.SequenceMatcher(None, title, showname).ratio() if ratio >=0.96: streams = await episodes_find(description,season,episode,MFP,MFP_CREDENTIALS,client,streams) return streams else: year_pattern = re.compile(r'(?]*>Continua a leggere' match = re.search(pattern, description) if match: href_value = match.group(1) response_2 = await client.get(ForwardProxy + href_value, proxies = proxies, headers = headers) match = year_pattern.search(response_2.text) if match: year = match.group(0) if abs(int(year) - int(date)) <=1: streams = await episodes_find(description,season,episode,MFP,MFP_CREDENTIALS,client,streams) return streams return streams async def eurostreaming(streams,id,client,MFP,MFP_CREDENTIALS): try: general = await is_movie(id) ismovie = general[0] clean_id = general[1] type = "Eurostreaming" if ismovie == 0 : season = str(general[2]) episode = str(general[3]) elif ismovie == 1: return streams if "tmdb" in id: showname,date = get_info_tmdb(clean_id,ismovie,type) else: showname,date = await get_info_imdb(clean_id,ismovie,type,client) logger.info(f"ES {showname}") streams = await search(showname,date, season,episode,MFP,MFP_CREDENTIALS,client,streams) return streams except Exception as e: logger.warning(f"ES {e}") return streams async def test_euro(): from curl_cffi.requests import AsyncSession async with AsyncSession() as client: results = await eurostreaming({'streams': []},"tt6156584:4:1",client,"0",['test','test']) print(results) async def test_deltabit(): from curl_cffi.requests import AsyncSession async with AsyncSession() as client: results = await deltabit("https://deltabit.co/fgeki2456ab1",client) print(results) if __name__ == "__main__": import asyncio asyncio.run(test_euro()) #python3 -m Src.API.eurostreaming '''tt11950864 '''