OJni4ddlZddlZddlmZGddZy)N) async_reqc0eZdZdZddedzdedzfdZdefdZdefdZe dd ee zdzde fd Z e d edefd Z e d ed ededzfdZ ddededededee zdzdee zdzdedzdefdZe ddededzdedzdeefdZy)BaseLiveStreamz. Base class for live stream fetchers. N proxy_addrcookiesc ||_||_y)a Initializes a new instance of BaseLiveStream. Args: proxy_addr (str | None): The proxy address to use for requests. Defaults to None. cookies (str | None): The cookies to include in requests. Defaults to None. N)rr)selfrrs I/home/uftp/myenv/lib/python3.12/site-packages/streamget/platforms/base.py__init__zBaseLiveStream.__init__ s% returnc*dd|jxsddS)z~ Returns headers for mobile requests. Returns: dict: Mobile headers with default values. zMozilla/5.0 (Linux; Android 11; SAMSUNG SM-G973U) AppleWebKit/537.36 (KHTML, like Gecko) SamsungBrowser/14.2 Chrome/87.0.4280.141 Mobile Safari/537.36;zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2z user-agentzaccept-languagecookierr s r _get_mobile_headersz"BaseLiveStream._get_mobile_headerss!Z\ll(b   r c*dd|jxsddS)zv Returns headers for PC requests. Returns: dict: PC headers with default values. z}Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/121.0.0.0 Safari/537.36 Edg/121.0.0.0rrrrrs r _get_pc_headerszBaseLiveStream._get_pc_headers$s!I\ll(b   r qualitycdddddd}|st|jdSt|j}|j r%t|j t |}||j|dfS)z Maps a quality string to its corresponding index. Args: quality (str | int): The quality string (e.g., 'OD', 'HD') or index. Returns: tuple: A tuple containing the quality string and its index. rr)ODUHDHDSDLD)listitemsstrupperisdigitkeysintget)rQUALITY_MAPPING quality_strs r get_quality_indexz BaseLiveStream.get_quality_index2s"#1AQaH--/03 3'l((*    3356s;7GHKO// Q???r urlctjj|}tjj|j}|S)z Parses a URL and extracts query parameters. Args: url (str): The URL to parse. Returns: dict: A dictionary of query parameters. urllibparseurlparseparse_qsquery)r. parsed_url query_paramss r parse_urlzBaseLiveStream.parse_urlGs8\\**3/ ||,,Z-=-=> r paramsctjj|}tjj|j}||vr||dSy)a Extracts a specific query parameter from a URL. Args: url (str): The URL to parse. params (str): The parameter name to extract. Returns: str | None: The value of the specified parameter, or None if not found. rNr0)r.r9r6r7s r get_paramszBaseLiveStream.get_paramsVsO\\**3/ ||,,Z-=-=> \ !'* * "r m3u8 json_data video_qualityurl_typespec hls_extra_key flv_extra_keyplatformc K|ds |d|iz}|S|d t dkr# j dt dkr#|j|\} ||ddd} fd } |d k(r(| |} | |} ||r|d n| |r|d n| | d z}n-|dk(r| |} ||r|d n| | dz}n| |} || | dz}|jd|d<||d<|Sw)z Fetches the stream URL based on the provided data and quality. Returns: dict: A dictionary containing the stream URL and other relevant information. is_liverC play_url_list anchor_nameT)rCrIrEc }|r||S|SN)keyplay_urlrFselected_qualitys r get_urlz.BaseLiveStream.get_stream_url..get_urls$%56H$'8C= 5X 5r allm3u8_urlflv_url)rRrS record_urlr<)rRrT)rSrTtitler)lenappendr-r*)r r=r>r?r@rArBrCdatarPrRrSrFrOs @@r get_stream_urlzBaseLiveStream.get_stream_urlhs?# *h/ /I !/2 - 1$  r!2 3- 1$+/*@*@*O' ' $]3   6 u }-Hm,G 59Ij1x379Y/W& D  }-H $:!6H\de eDm,G w? ?D! g.W 'Y s AC! BC!proxyheaderscN Kt|||d{}g}|jdD]3}|jds|j|j 5|sU|jdD]A}|j j ds#|j|j Ct jd}|j|}t||D cic]\}} | t|c} } t| fdd }|S7cc} }ww) a Fetches a list of play URLs from an M3U8 file. Args: m3u8 (str): The URL of the M3U8 file. proxy (str | None): The proxy address to use. Defaults to None. headers (dict | None): Custom headers for the request. Defaults to None. Returns: List[str]: A list of play URLs sorted by bandwidth (highest first). )rr[N zhttps://r<zBANDWIDTH=(\d+)c|SrKrL)r.url_to_bandwidths r z2BaseLiveStream.get_play_url_list..s >Ns>Sr T)rMreverse) rsplit startswithrWstripendswithrecompilefindallzipr)sorted) r<rZr[resprFibandwidth_patternbandwidth_list bandwidthr.r_s @r get_play_url_listz BaseLiveStream.get_play_url_liststwGG D! 0A||J'$$QWWY/ 0ZZ% 4779%%f-!((3 4JJ'9:*2248FI.ZgFhiNIsCY/i}2S]ab Hjs/D%D+D%AD%AD%/DD%D%)NNrK)r<FNNN)__name__ __module__ __qualname____doc__r%r dictrr staticmethodr)tupler-r8r;boolrYr#rprLr r rrsb 3: sTz   T      @39t#3@u@@( s t  ++S+S4Z++"nsgk48,d,3,RU,fj,,/#I,<,TWZ]T]`dTd,'*Tz,=A,\c#*dUYkeijmenr r)rf urllib.parser1requests.async_httprrrLr r r{s +iir