OJni? b d dl Z d dlZd dlZd dlZddlmZmZ ddlm Z ddl
m Z G d de Z y) N )
StreamData wrap_stream) async_req )BaseLiveStreamc e Zd ZdZddedz dedz f fd
ZdefdZdededz fd Z dededz fd
Z
dededz fd Z dded e defd
Z
eddedeez dz defd Z xZS )HuajiaoLiveStreamzN
A class for fetching and processing Huajiao live stream information.
N
proxy_addrcookiesc P t | || | j | _ y N)super__init___get_pc_headers
pc_headers)selfr r __class__s X/home/uftp/myenv/lib/python3.12/site-packages/streamget/platforms/huajiao/live_stream.pyr zHuajiaoLiveStream.__init__ s"
W- ..0 returnc , ddd| j xs ddS )Nz/zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6zhttps://www.huajiao.com/zPMozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/115.0 )accept-languagerefererz
user-agentcookie)r )r s r r z!HuajiaoLiveStream._get_pc_headers s! P1lll(b
r urlc K |j d d j dd d }d| } t || j | j d { }t j d| j d }t j | }|d d
}|d d }|d d
} |j d d j dd d }| |||fS 7 # t $ r t d w xY ww)N?r / maxsplitzhttps://www.huajiao.com/l/r r headerszvar feed = (.*?});feedsnauthoruidnicknamezFailed to retrieve live room data, the Huajiao live room address is not fixed, please use the anchor's homepage address for recording.) splitrsplitr r r researchgroupjsonloads Exception RuntimeError)
r r live_idapihtml_strjson_str json_datar' r) r* s
r get_huajiao_snz HuajiaoLiveStream.get_huajiao_sn s ))C.#**3*;A>*7)4 @ &34??TXTcTc ddHyy!5x@FFqIH
8,I6"4(BH%e,C *:6HiinQ'..sQ.?BGRg- - e @ ?@
@ @s/ .C5%C CBC C5C C22C5c K d|v r@|j d d j d d }|dt t t j dz d}d t j
j
| }t || j | j
d { }t j | }t d | | j | j
d { }t j d | j d }|d
r0d|d
d d d v r |d
d d d } || d d| d | d |dS |ddS y 7 7 fw)Nuserr r user/r! r0 )r) fmt_z+https://webh.huajiao.com/User/getUserFeeds?r$ z https://www.huajiao.com/user/u (.*?)的主页.*datar' feedsr& titleTrelateid anchor_namerB is_liver' liveidr) FrE rF )r+ strinttimeurllibparse urlencoder r r r0 r1 r- r. r/ )
r r r) paramsr5 r7 r8 r6 rE r& s
r get_huajiao_user_infoz'HuajiaoLiveStream.get_huajiao_user_info- sj S=))C.#))'215C TYY[4 /01F @ @V@VW]@^?_`C &34??TXTcTc ddH
8,I &-J3%+P]a]l]l/3 @ @H ))$ExPVVWXYK TYv->w-G-J6-R%R (1!4V<#. !'] # t* ": .
(3uEE5 e@s& B E
"E #AE
$E %A%E
E
c x K ddd| j xs dd}|j dd d }d | }t || j |
d { }t j
| }|d s|d j
d
s t d |d }|d d |d d d|d d |d d |d d dS 7 iw)NzPliving/9.4.0 (com.huajiao.seeding; build:2410231746; iOS 17.0.0) Alamofire/9.4.0zzh-Hans-US;q=1.01r )z
User-Agentr sdk_versionr r r! r" z3https://live.huajiao.com/feed/getFeedInfo?relateid=)r r% errmsgr@ creatimeFailed to retrieve live room data, the Huajiao live room address is not fixed, please manually change the address for recording.r( r* r& rB Tr' rC r) rD )r r, r r r0 r1 getr2 )r r r% room_idr5 r7 r8 r@ s r get_huajiao_stream_url_appz,HuajiaoLiveStream.get_huajiao_stream_url_appK s l 1 ll(b
**S1*-a0CG9M"34??GTTJJx( X i&7&;&;J&G-.
. >*5&\'*v,t$6l:.>%(
Us A B:B8A*B: process_datac K ddd}d|v r(| j s|S | j | d{ }nqt |j | j | j
d d{ }|j
d d k( r t d
| j | d{ }|r|j d |d < |j d }|r|j d
|d
< t t j dz dd|ddi}dt j j | }t || j | j
d{ }t j | } |d| d d | d d dz }|S 7 U7 7 7 8w)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.
r FrH r< NT)r r% redirect_urlr zhttps://www.huajiao.comrV rE rF rB r= z1.0.0)rK versionencodeh265z(https://live.huajiao.com/live/substream?r$ r@ h264_url)rF flv_url
record_url)r rP r stripr r rstripr2 rY poprJ rK rL rM rN r0 r1 )
r r rZ result room_data live_statusrO r5 r7 r8 s
r fetch_web_stream_dataz'HuajiaoLiveStream.fetch_web_stream_datag s "$6 c><<
" 8 8 ==I!#))+$//SWSbSbquvvCzz#";; 89 9 # = =c BBI $-MM-$@F= !#-- 2K"+--"8w d 2 3 & f A AWAWX^A_@`a!*stX\XgXg!hh JJx 0 # ( 0 <"+F"3J"?
= >v
C isF ,F
F9F
(F)7F
F !B1F
F 1F
F
F
F
r8
video_qualityc . K | ddiz } t | S w)za
Fetches the stream URL for a live room and wraps it into a StreamData object.
platformu 花椒直播)r )r8 rj s r fetch_stream_urlz"HuajiaoLiveStream.fetch_stream_url s"
j.11 9%%s )NN)Tr )__name__
__module__ __qualname____doc__rI r dictr tupler9 rP rY boolri staticmethodrJ r rm
__classcell__)r s @r r
r
s 13: 1sTz 1
@ @ @$ Fs Ftd{ F<
C
D4K
8.s .$ .RV .` &$ &sSy4?O &[e & &r r
)
r0 r- rK urllib.parserL r@ r r requests.async_httpr baser r
r r r{ s( + , !R& R&r