OJni3 JddlZddlmZmZddlmZddlmZGddeZy) N) StreamData wrap_stream) async_req)BaseLiveStreamceZdZdZddedzdedzffd ZdefdZdded edefd Z e dd ed ee zdzde fd Z xZS)PiaopaioLiveStreamzO A class for fetching and processing Piaopiao live stream information. N proxy_addrcookiescPt||||j|_yN)super__init___get_pc_headers pc_headers)selfr r __class__s Y/home/uftp/myenv/lib/python3.12/site-packages/streamget/platforms/piaopiao/live_stream.pyrzPiaopaioLiveStream.__init__ s" W-..0returnc.dddd|jxsddS)Nzapplication/jsonzhttps://m.pp.weimipopo.comzhttps://m.pp.weimipopo.com/z;ios/7.830 (ios 17.0; ; iPhone 15 (A2846/A3089/A3090/A3092)))z content-typeoriginrefererz user-agentcookie)r )rs rrz"PiaopaioLiveStream._get_pc_headerss$.24Wll(b   rurl process_datac^K|j|d}d|d}d|vr!d}d|jd<d|jd<nd }t|||j|j d {}t j |}|s|S|d }|d }|d} |dd} | r|d} | d| | dz} | S7Cw)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. anchorUidr) inviteUuid anchorUuidcatshowz'https://api.catshow168.com/live/previewzhttps://h.catshow168.comOriginRefererz)https://api.pp.weimipopo.com/live/preview) json_datar headersNdatanamelivingF) anchor_nameis_livepullUrlT)r,m3u8_url record_url) get_paramsrrr jsonloads) rrrroom_idr&apijson_str live_infor+ live_statusresultr.s rfetch_web_stream_dataz(PiaopaioLiveStream.fetch_web_stream_datas//#{3!  ;C(BDOOH %)CDOOI &=C"3)aeapapqqJJx(  f% ' ) !,?  +H $HHU UF rsA%B-'B+(AB-r& video_qualityc.K|ddiz}t|Sw)z_ Fetches the stream URL for a live room and wraps it into a StreamData object. platformu 飘飘直播)r)r&r:s rfetch_stream_urlz#PiaopaioLiveStream.fetch_stream_url=s" j.11 9%%s)NN)Tr)__name__ __module__ __qualname____doc__strrdictrboolr9 staticmethodintrr= __classcell__)rs@rr r s~13:1sTz1  "s"$"RV"H&$&sSy4?O&[e&&rr ) r1r(rrrequests.async_httprbaserr rrrKs +,!;&;&r