U m5hX@s\ddlmZddlmZddlmZddlmZddlZddl Z ddl Z ddl m Z m Z mZmZddlmmZddZGd d d Zd d ZGd ddZGdddZGdddZd-ddZddlmZmZGdddZddZddZd d!Ze ee d"d#d$Z!e eej"d%d&d'Z#d.ej"e e e e fee e e fd(d)d*Z$d+d,Z%dS)/wraps)HttpResponseForbidden)redirect)FTPN)DictAnyOptionalListc Cs:t|d|d}|D]}||qW5QRXdS)N/zwb+)openchunkswrite)filepathfilename destinationchunkr*/var/www/html/Focus/src/apps/core/utils.pyhandle_uploaded_file s rc@seZdZdddZddZdS) TelegramLog.6723497869:AAEKCB3YJUGnUFeMihLlr-FHblTuvtoVUZA -4155125438cCs||_||_dSN) BOT_TOKENGROUP_ID)selfrrrrr__init__szTelegramLog.__init__cCst|j}||j|dSr)telebotZTeleBotr send_messager)rmessagebotrrrsend_telegram_logs zTelegramLog.send_telegram_logN)rr)__name__ __module__ __qualname__rr#rrrrrs rcstfdd}|S)Ncs>d|jkr2|jdr2|jddkr2|f||StdSdS)Nid_userz auth:login)sessionr)requestargskwargsfuncrrwrappers"zcheck_user..wrapperr)r-r.rr,r check_usersr/c@seZdZddZdS) NoVastResultcCs||_||_t||_dSr id_campaign total_adsinttotal_impressionsrr2r3r5rrrr*szNoVastResult.__init__Nr$r%r&rrrrrr0)sr0c@seZdZddZdS) VastResultcCs||_||_t||_dSrr1r6rrrr0szVastResult.__init__Nr7rrrrr8/sr8c@s6eZdZd ddZddZddZd d Zd d ZdS) FTPClientNcCs&||_||_||_||_||_dSr) ftp_serverportusernamepassword _setup_loggerlogger)rr;r<r=r>rrrr7s zFTPClient.__init__cCs@tt}|tjtd}t}|||||S)Nz)%(asctime)s - %(levelname)s - %(message)s) logging getLoggerr$setLevelINFO Formatter StreamHandler setFormatter addHandler)rr@ formatterchrrrr?>s     zFTPClient._setup_loggercCs0t|_|j|j|j|j|j|jdSr)rftpconnectr;r<loginr=r>rrrrrLGszFTPClient.connectcCst|dr|jdS)NrK)hasattrrKquitrNrrr disconnectLs zFTPClient.disconnectc Cszzp||j||dd}t|d}|jd||W5QRX|jd|d|dWWFdSt k r}z |j d |WYWd Sd}~XYnXW5|XdS) Nr rbSTOR zFile 'z' uploaded successfully to ''TzFailed to upload file: F) rQrLrKcwdsplitr storbinaryr@info Exceptionerror)rlocal_file_path remote_dirr local_fileerrr upload_filePs    zFTPClient.upload_file)r:NN)r$r%r&rr?rLrQr`rrrrr95s   r9皙?皙?333333?皙?cCs$|||d|||||S)a Calculate the priority score for a campaign. Args: - TSA (float): Target Show Alignment value (between 0 and 1). - ARF (float): Airing Requirement Fulfillment value (between 0 and 1). - U (float): Urgency value (between 0 and 1). - P (float): Position value (between 0 and 1). - W_TSA (float): Weight for Target Show Alignment (default is 0.4). - W_ARF (float): Weight for Airing Requirement Fulfillment (default is 0.2). - W_U (float): Weight for Urgency (default is 0.3). - W_P (float): Weight for Position (default is 0.1). Returns: - float: Priority score for the campaign. r)ZTSAZARFUPZW_TSAZW_ARFZW_UZW_Prrrcalculate_priority_score`srh)r error_permc@sbeZdZdZdddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ dS) FTPConnectoraf A class to manage FTP connections and operations. Attributes: host (str): The FTP server hostname. port (int): The port number of the FTP server. username (str): The username for authentication. password (str): The password for authentication. ftp (FTP): An instance of the FTP class for FTP operations. NcCs"||_||_||_||_d|_dS)a Initializes the FTPConnector with server details. Args: host (str): The FTP server hostname. port (int, optional): The port number of the FTP server. Defaults to None. username (str, optional): The username for authentication. Defaults to None. password (str, optional): The password for authentication. Defaults to None. N)hostr<r=r>rK)rrkr<r=r>rrrrs zFTPConnector.__init__c CszL|jr$t|_|j|j|jn t|j|_|j|j|jtdWn0t k r|}ztd|W5d}~XYnXdS)zj Connects to the FTP server. Raises: Exception: If connection fails. zConnected to FTP server.z Error connecting to FTP server: N) r<rrKrLrkrMr=r>printrZrr_rrrrLs  zFTPConnector.connectc CsRz|jr|jtdWn0tk rL}ztd|W5d}~XYnXdS)zr Disconnects from the FTP server. Raises: Exception: If disconnection fails. zDisconnected from FTP server.z%Error disconnecting from FTP server: N)rKrPrlrZrmrrrrQs   zFTPConnector.disconnectc Cszvz@||jr8|j}td|D] }t|q(ntdWn0tk rr}ztd|W5d}~XYnXW5|XdS)z0 Lists files on the FTP server. zList of files on server:Not connected to FTP server.zError listing files: N)rQrLrKnlstrlrZ)rfilesrr_rrr list_filess   $zFTPConnector.list_filesc Cszzv||jrnt|d4}|dd}|j||jd||W5QRXtd|d|dntdWn0tk r}ztd |W5d }~XYnXW5|Xd S) a Uploads a file to the FTP server. Args: local_path (str): The local path of the file to upload. remote_path (str): The remote path where the file will be uploaded. Raises: Exception: If file upload fails. rSr rRrTz Uploaded  to .rnzError uploading file: N) rQrLrKr rWrVrXrlrZ)r local_path remote_pathr^Zremote_filenamer_rrrr`s    $zFTPConnector.upload_filec Cszz^||jrVt|d}|jd||jW5QRXtd|d|dntdWn0tk r}ztd|W5d}~XYnXW5|XdS) a0 Downloads a file from the FTP server to the local machine. Args: remote_path (str): The remote path of the file on the server. local_path (str): The local path where the file will be saved. Raises: Exception: If file download fails. wbzRETR z Downloaded rrrsrnzError downloading file: N)rQrLrKr retrbinaryrrlrZ)rrurtrr_rrr download_files    $zFTPConnector.download_filec Cs~znz8||jr0|j|td|dntdWn0tk rj}ztd|W5d}~XYnXW5|XdS)z Creates a directory on the FTP server. Args: directory (str): The directory path to be created. Raises: Exception: If directory creation fails. zCreated directory: rsrnzError creating directory: N)rQrLrKmkdrlrZr directoryr_rrrcreate_directorys   $zFTPConnector.create_directoryc Cs~znz8||jr0|j|td|dntdWn0tk rj}ztd|W5d}~XYnXW5|XdS)z Deletes a file from the FTP server. Args: remote_path (str): The remote path of the file to be deleted. Raises: Exception: If file deletion fails. zDeleted file: rsrnzError deleting file: N)rQrLrKdeleterlrZ)rrur_rrr delete_files   $zFTPConnector.delete_filec Cs~znz8||jr0|j|td|dntdWn0tk rj}ztd|W5d}~XYnXW5|XdS)z Deletes a directory from the FTP server. Args: directory (str): The directory path to be deleted. Raises: Exception: If directory deletion fails. zDeleted directory: rsrnzError deleting directory: N)rQrLrKrmdrlrZrzrrrdelete_directory&s   $zFTPConnector.delete_directoryc Cszvz@||jr8|j||td|d|dntdWn0tk rr}ztd|W5d}~XYnXW5|XdS)z Renames a file on the FTP server. Args: from_name (str): The current name of the file. to_name (str): The new name for the file. Raises: Exception: If file renaming fails. zRenamed file from rrrsrnzError renaming file: N)rQrLrKrenamerlrZ)r from_nameZto_namer_rrr rename_file<s  $zFTPConnector.rename_file)NNN)r$r%r&__doc__rrLrQrqr`rxr|r~rrrrrrrjvs rjcCs8tt|d\}}}}|d|d||d}|S)N:i<i@B)mapr4rW)time_strhoursminutesseconds microseconds total_secondsrrrhhmmssf_to_secondsUsrc Cs4ddlm}m}||}ddi}||j}tj||d}|jdkr0t|j|d}d|krr|j|_| nd|kr|j|_ | nd |kr|j|_ | nd |kr|j|_ | nld |kr|j|_ | nRd |kr|j|_| n8d |krtd|j|j|_| n|j|_| |SdS)Nr)urlparseparse_qs User-AgenteMozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.36)urlheaderseventZjs_startZjs_first_quartileZ js_midpointZjs_third_quartileZvast_impressionZ doubleclickZ js_completezCheck: ) urllib.parserrqueryrequestsgettextrltracking_start_statussavetracking_firstquartile_statustracking_midpoint_statustracking_thirdquartile_statusimpression_sprintserve_statusimpression_double_click_statustracking_completed_status) rreplyrr parsed_urlr query_paramsresponseZ event_valuerrrvast_update_requests`sF             rcCs^ddlm}m}d}t|}|jdkrV|d}|dd}dd|D}|SdSdS)Nr)datetime timedeltazqhttps://almatv-stor.vizionr.fr/synthesia/almatv/playlist/manager/php/_getPlaylist.php?fields=title,isPub,durationdatacSs&g|]}d|kr|ddkr|qS)isPub1r).0itemrrr s z%visioner_playlist..)rrrr status_codejson)rrrr head_data playlist_dataprocessed_datarrrvisioner_playlists   r)rreturnc CszJtj|dd}||jr4td||jWStd|WdSWnDtjjk r}z"td|dt|WYdSd}~XYnXdS)z Fetch XML content from a URL and check status code. Args: url: The URL to send the request to Returns: The XML content as string if successful, None otherwise )timeoutz"Successfully fetched content from zNo content received from NzError fetching URL z: ) rrraise_for_statuscontentrlr exceptionsRequestExceptionstr)rrr_rrrfetch_xml_from_urls  r) xml_contentrc CsZzt|}td|WStjk rT}ztdt|WYdSd}~XYnXdS)z Parse XML content into an ElementTree. Args: xml_content: String containing XML data Returns: The root element of the parsed XML, or None if parsing failed zSuccessfully parsed XML contentzFailed to parse XML: N)ET fromstringrl ParseErrorr)rrootr_rrrparse_xml_contents  r)rtag_name attributesrc Csg}g}|d|}tdt|d|d|D]}d}|rj|D]\}} ||| krJd}qjqJ|r6|jdd|jDgd } |D]2} | j| jd d| jDd } | d | q|| ||q6|rtd t|dntd t|d|d||fS)a Extract data from XML elements based on tag name and optional attributes. Args: root: The root XML element tag_name: The tag to search for attributes: Optional dictionary of attribute names and values to match If None, all elements with the tag_name will be returned Returns: List of dictionaries containing the matched elements' data z.//zFound z elements with tag 'rUTFcSsi|]\}}||qSrrrkvrrr sz.extract_data_by_attributes..)rrchildrencSsi|]\}}||qSrrrrrrrs)tagrrrz Extracted z% elements matching attribute criteria) findallrllenitemsrrattribrappend) rrrresultsZ elements_rootelementselementZmatches_criteria attr_nameZ attr_valueZ element_datachildZ child_datarrrextract_data_by_attributess8   rcCs<ddlm}ddl}ddlm}ddlm}ddlm}ddl }ddl }ddl }ddl m m}ddddddd d d d dd d d dd dddddddd} ddddddddd} d} d} ddi} |j| | | d }d!|d"d#d$d%|d"d#d$d&|d"d#d$d'|d"d#d$d(|d"d#d$g}d)d*id)d+id)d,id)d-id)d.ig}dS)/Nre) call_vastr) HTTPProxyAuth)ThreadPoolExecutor) parse_urli!i%i+i-i$i#i(i"i&i'i,i.)Z FeuilletonZMagazineu Mini-Sériez Magazine z Mini-SerieZSerieZ InformationzMagazine Sportif Dessin AnimezMagazine Sportif ZTelefilmZ DocumentaireZ ReligieuxZSportz Long MetrageZNewsz Long-MetragezDes Histoires Et Des HommesuSérieZMusiqueZTheatreZ SpectacleZJeuxZ720Z567rz Abtal albiharzar-MAZ2M_TVFrance)whZ content_genreZ content_titlelanguageZ pod_max_dur channel_namecountryahttps://tv.springserve.com/vast/850576?w=1920&h=1080&cb={{CACHEBUSTER}}&ip={{IP}}&ua={{USER_AGENT}}&pod_max_dur={{POD_MAX_DUR}}&pod_ad_slots={{POD_AD_SLOTS}}&app_bundle={{APP_BUNDLE}}&app_name={{APP_NAME}}&app_store_url={{APP_STORE_URL}}&did={{DEVICE_ID}}&us_privacy={{US_PRIVACY}}rr)r num_requestsparamsz185.124.241.179:12323Z 14a2f5dfde475Z 51ae51af21)httpauthz89.116.242.185:12323z45.140.244.198:12323z193.106.198.128:12323z136.175.224.210:12323rz5http://14a2f5dfde475:51ae51af21@185.124.241.179:12323z4http://14a2f5dfde475:51ae51af21@89.116.242.185:12323z4http://14a2f5dfde475:51ae51af21@45.140.244.198:12323z5http://14a2f5dfde475:51ae51af21@193.106.198.128:12323z5http://14a2f5dfde475:51ae51af21@136.175.224.210:12323)tasksrrZ requests.authrconcurrent.futuresrZ urllib3.utilrrandomrosxml.etree.ElementTreeetree ElementTreedelay)rrrrrrrrrZiab_catrrrrvastZ proxy_listZproxies0rrr call_vast_api sx       r)rarbrcrd)N)& functoolsr django.httprdjango.shortcutsrftplibrrArrtypingrrr r rrrrrrr/r0r8r9rhrirjrrrrrElementrrrrrrrs2      + ` /,<