Bj UdZddlmZddlZddlZddlZddlmZddlm Z ddl Z ddZ eGddZ dd Zdd Zdd Zej"d Zdd ZddZiZded<ddZddZy)z`ffmpeg/ffprobe helpers: stream selection, audio extraction, subtitle extraction, frame sampling.) annotationsN) dataclass)PathcFtj|ddjS)NT)checkcapture_output) subprocessrunstdout)cmds 1/root/repos/pocs/video-evals/src/dubeval/media.py_runr s >>#T$ ? F FFcTeZdZUded<ded<ded<ded<ded<d ed <d ed <y ) Proberpathfloatdurationintwidthheightfps list[dict]audio subtitlesN)__name__ __module__ __qualname____annotations__rr rrs' JO J K J rrcjtjtdddddddt|g}t d|d D}d |d j d D\}}gg}}|d D]}|d |j dij d|j dd}|ddk(r!|ji|d t|ic|ddk(sl|ji|d t|it|t|ddt|dt|d||z ||S)Nffprobe-verrorz -show_formatz -show_streamsz-ofjsonc32K|]}|ddk(s |yw) codec_typevideoNr ).0ss r zprobe..sJqq'/IJs streamsc32K|]}t|ywN)r)r)xs r r+zprobe..sA1AAs r_frame_rate/indextagslanguage codec_name) stream_indexlangcodecr'rsubtitleformatrrr) r%loadsrstrnextsplitgetappendlenrrr) rinfor(numdenrsubsr*entrys r proberGsG ::dItWnoW\^dfijnfopq rD JDOJ JEAn 5 ; ;C @AHCb4E )_7!"7QUU625F5J5J:5Vabafafgsatu \?g % LL7E77CJ7 8 |_ * KK555'3t95 6 7 uT(^J78#eGn:MsSXYaSbOcsE4 ))rc|js6tdddddt|dd|dd d t|t|g |S) Nffmpegr#r$-y-i-mapz0:a:z-ac1z-arexistsrr<)src audio_indexdstsrs r extract_audiorT+sK ::< hgtT3s8VtK=EYS%R#c(4 5 Jrc x|js)tdddddt|dd|t|g |S)NrIr#r$rJrKrLz0:s:rN)rP sub_indexrRs r extract_subtitlesrW2s= ::< hgtT3s8VtI;EWY\]`Ya bc Jrz=(\d+):(\d+):(\d+)[,.](\d+)\s*-->\s*(\d+):(\d+):(\d+)[,.](\d+)c Xg}tjd|jddjD]}|jj }t |D]\}}t j|}|s|jDcgc] }t|}}|ddz|ddzz|d z|d d z z} |d dz|d dzz|dz|dd z z} |j| | dj||dzdjd|Scc}w)Nz\n\s*\nzutf-8replace)encodingerrorsri< )startendtext) rer> read_textstrip splitlines enumerate_TCsearchgroupsrr@join) rcuesblocklinesilinemr/grfrgs r parse_srtry;s3 D*dnngin&X&^&^&`a  ((* ' GAt 4 A%&XXZ0SV00!t adRi/!A$61DdTkAaD2I-!4qtd{B eC%PQTUPUPV-AXA^A^A`ab   K 1sD'c|t|}tt|j|z|jz dz dz}t ddddt d|ddt|d t d ||z dd d |d |d|dddddg}tj|tjjd||dS)zKRGB frames [N, H, W, 3] decoded with ffmpeg (fast seek), scaled to `width`.r^rIr#r$z-ssz.3frKz-tg?z-vfzfps=z,scale=:z-frawvideoz-pix_fmtrgb24-r_) probe_cachedrroundrrrmaxr<np frombufferuint8reshape)rPrfrgrrprraws r sample_framesrJsSA qxx%'!''1A56: ;F $3sE?32G$PSTWPXT3;/4uSEQVPWWXY_X`>aj*gs< =C ==bhh ' / /FE1 EErzdict[Path, Probe]_PROBEScH|tvrt|t|<t|Sr.)rrG)rs r rrWs! 7d  4=rctttd|dz}t|d\}}t|d\}}t|d\}}|dd|dd|dd|dS) Nr{r`i6i`02dr|.03d)rrrdivmod)secondsmshrwr*s r tcr]sr U3sG$t+ , -B 2y !EAr 2v EAr 2t EArWAaWAaWAbX ..r)r z list[str]returnbytes)rrrr) rPrrQrrRrrSrrr)rPrrVrrRrrr)rrrr) rPrrfrrgrrrrrrz np.ndarray)rrrr<)__doc__ __future__rr%rir dataclassesrpathlibrnumpyrrrrGrTrWcompilernryrrrrrr rr rsf" !G   ) bjjQR F   /r