OJniJddlZddlmZmZddlmZddlmZGddeZy) N) StreamData wrap_stream) async_req)BaseLiveStreamc|eZdZdZd dedzdedzffd Zddededefd Ze dd ed ee zdzde fd Z xZ S)LianJieLiveStreamzL A class for fetching and processing Yinbo live stream information. N proxy_addrcookiescPt||||j|_yN)super__init___get_pc_headers pc_headers)selfr r __class__s X/home/uftp/myenv/lib/python3.12/site-packages/streamget/platforms/lianjie/live_stream.pyrzLianJieLiveStream.__init__ s" W-..0url process_datareturncK|jddjddd}d|}t||j|jd {}t j |}|s|S|d }|d }|d } |d d} | dk(rP|d} |d} d| jddz} | jdd}| jdd}| d| |||dz} | S7w)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. ?rzlailianjie.com/)maxsplitzXhttps://api.lailianjie.com/ApiServices/service/live/getRoomInfo?&_$t=&_sign=&roomNumber=)r headersNdatanicknameisonlineF) anchor_nameis_livedefaultRoomTitlevideoUrlzhttps://z webrtc://z.flv?z.m3u8?T)r$titlem3u8_urlflv_url record_url)splitrsplitrr rjsonloadsreplace)rrrroom_idplay_apijson_str json_data room_datar# live_statusresultr' webrtc_url https_urlr)r(s rfetch_web_stream_dataz'LianJieLiveStream.fetch_web_stream_datas))C.#**+&$&sSy4?O&[e&&rr ) r-r rrrequests.async_httprbaserr rrrKs +,!-&-&r