OJni{ ^ddlZddlZddlmZmZddlmZddlmZddl m Z Gd d eZ y) N) StreamData wrap_stream) async_req)BaseLiveStream)calculate_signceZdZdZddedzdedzffd ZdZddeded efd Z e dd ed ee zdzd e fd Z xZS)LaixiuLiveStreamzM A class for fetching and processing Laixiu live stream information. N proxy_addrcookiescPt||||j|_yN)super__init___get_pc_headers pc_headers)selfr r __class__s W/home/uftp/myenv/lib/python3.12/site-packages/streamget/platforms/laixiu/live_stream.pyrzLaixiuLiveStream.__init__s" W-..0cdtd}ddt|ddd|d|d d d dd d ddd}|S)Npc)ua_typez}Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36 Edg/138.0.0.0web timestamp210003imei requestId9z1.0.0WEBzhttps://www.imkktv.comzhttps://www.imkktv.com/z/zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6)z User-Agent mobileModelr loginType versionCoder r!channelversionosplatformOriginRefererzAccept-Language)r str)r sign_dataheaderss rrz LaixiuLiveStream._get_pc_headerss["40 I Y{34"f%";/.0P "rurl process_datareturncJKd}tj||}|r|jdnd}d|}t||j|j d{}t j|}|s|S|d} | d} | d d k(} | d d } | r| d } | d| | dz} | S7Fw)a) Fetches web stream data for a live room. Args: url (str): The room URL. process_data (bool): Whether to process the data. Defaults to True. Returns: dict: A dictionary containing anchor name, live status, room URL, and title. z (?:roomId|anchorId)=(.*?)(?=&|$)r z9https://api.imkktv.com/liveroom/getShareLiveVideo?roomId=)r r/Ndatanickname playStatusrF) anchor_nameis_liveplayUrlT)r9flv_url record_url)researchgrouprr rjsonloads)rr0r1patternmatchroom_idplay_apijson_str json_data room_datar8 live_statusresultr;s rfetch_web_stream_dataz&LaixiuLiveStream.fetch_web_stream_data's6 '3'$)%++a.rNwiX"8QUQ`Q`aaJJx(  f%  +  -2 !,?  *G $7'R RF bsAB#B!AB#rG video_qualityc.K|ddiz}t|Sw)z_ Fetches the stream URL for a live room and wraps it into a StreamData object. r*u 来秀直播)r)rGrLs rfetch_stream_urlz!LaixiuLiveStream.fetch_stream_urlDs" j.11 9%%s)NN)Tr)__name__ __module__ __qualname____doc__r-rrbooldictrK staticmethodintrrN __classcell__)rs@rr r sv13:1sTz1*s$RV:&$&sSy4?O&[e&&rr ) r@r=r5rrrequests.async_httprbaserutilsr r rrr\s% +,!!@&~@&r