o i\1@s.ddlmZddlmZddlmZddlmZmZddl m Z ddl Z dd Z d d Z Gd d d e ZddZddZddZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGd d!d!eZGd"d#d#eZehdfd$d%Zd*d&d'Zd*d(d)Zd gZdS)+)unicode_literals) basestring) KwargReprNode) escape_chars get_hash_int)objectNcCs&d}|D] }t||rd}|Sq|S)NFT) isinstance)objtypesZvalidZ stream_typer [/var/www/html/eduruby.in/lip-sync/lip-sync-env/lib/python3.10/site-packages/ffmpeg/nodes.py _is_of_types s rcCsddd|DS)Nz, cSsg|] }d|j|jqS)z{}.{})format __module____name__.0xr r r z"_get_types_str..)join)r r r r _get_types_strsrc@sTeZdZdZ dddZddZddZd d Zd d Ze d dZ e ddZ dS)Streamz^Represents the outgoing edge of an upstream node; may be used to create more downstream nodes.NcCs8t||stdt|t|||_||_||_dS)NzHExpected upstream node to be of one of the following type(s): {}; got {})r TypeErrorrrtypenodelabelselector)self upstream_nodeupstream_labelZ node_typesupstream_selectorr r r __init__s   zStream.__init__cCstt|jt|jgSN)rhashrrrr r r __hash__'szStream.__hash__cCst|t|kSr$)r%)rotherr r r __eq__*sz Stream.__eq__cCs>|jjdd}d}|jrd|j}d||j||jj}|S)NF)Z include_hashz:{}z{}[{!r}{}] <{}>)rZ long_reprrrrZ short_hash)rZ node_reprroutr r r __repr__-s zStream.__repr__cCsB|jdur td|t|tstd||jj|j|dS)a Select a component (audio, video) of the stream. Example: Process the audio and video portions of a stream independently:: input = ffmpeg.input('in.mp4') audio = input['a'].filter("aecho", 0.8, 0.9, 1000, 0.3) video = input['v'].hflip() out = ffmpeg.output(audio, video, 'out.mp4') Nz!Stream already has a selector: {}z*Expected string index (e.g. 'a'); got {!r}rr) r ValueErrorrr rrrstreamr)rindexr r r __getitem__7s  zStream.__getitem__cC|dS)aSelect the audio-portion of a stream. Some ffmpeg filters drop audio streams, and care must be taken to preserve the audio in the final output. The ``.audio`` and ``.video`` operators can be used to reference the audio/video portions of a stream so that they can be processed separately and then re-combined later in the pipeline. This dilemma is intrinsic to ffmpeg, and ffmpeg-python tries to stay out of the way while users may refer to the official ffmpeg documentation as to why certain filters drop audio. ``stream.audio`` is a shorthand for ``stream['a']``. Example: Process the audio and video portions of a stream independently:: input = ffmpeg.input('in.mp4') audio = input.audio.filter("aecho", 0.8, 0.9, 1000, 0.3) video = input.video.hflip() out = ffmpeg.output(audio, video, 'out.mp4') ar r&r r r audioIz Stream.audiocCr2)aSelect the video-portion of a stream. Some ffmpeg filters drop audio streams, and care must be taken to preserve the audio in the final output. The ``.audio`` and ``.video`` operators can be used to reference the audio/video portions of a stream so that they can be processed separately and then re-combined later in the pipeline. This dilemma is intrinsic to ffmpeg, and ffmpeg-python tries to stay out of the way while users may refer to the official ffmpeg documentation as to why certain filters drop audio. ``stream.video`` is a shorthand for ``stream['v']``. Example: Process the audio and video portions of a stream independently:: input = ffmpeg.input('in.mp4') audio = input.audio.filter("aecho", 0.8, 0.9, 1000, 0.3) video = input.video.hflip() out = ffmpeg.output(audio, video, 'out.mp4') vr r&r r r videobr5z Stream.videor$) rr __qualname____doc__r#r'r)r,r1propertyr4r7r r r r rs    rcCsV|duri}|St|trd|i}|St|ttfr"tt|}|St|tr)|}|Sr$)r rlisttupledict enumerate stream_spec stream_mapr r r get_stream_map|s   rBcCsBg}t|D]}t|tstdt|||jq|S)NzExpected Stream; got {}) r;valuesr rrrrappendr)rAnodesr/r r r get_stream_map_nodess  rFcCst|}t|Sr$)rBrFr?r r r get_stream_spec_nodessrGcs\eZdZdZeddZeddZeddZgiffdd Zdd d Z d dZ Z S)Nodez Node basecCsX|durt||krtd|t||dur(t||kr*td|t|dSdS)Nz,Expected at least {} input stream(s); got {}z+Expected at most {} input stream(s); got {})lenr.r)clsrA min_inputs max_inputsr r r Z__check_input_lenszNode.__check_input_lencCs8t|D]}t||stdt|t|qdS)NzKExpected incoming stream(s) to be of one of the following types: {}; got {})r;rCrrrrr)rJrAincoming_stream_typesr/r r r Z__check_input_typess  zNode.__check_input_typescCs2i}t|D]\}}|j|j|jf||<q|Sr$)r;itemsrrr)rJrAincoming_edge_mapZdownstream_labelZupstreamr r r Z__get_incoming_edge_maps zNode.__get_incoming_edge_mapc sRt|} || |||| ||| } tt|| |||||_||_dSr$) rB_Node__check_input_len_Node__check_input_types_Node__get_incoming_edge_mapsuperrHr#_Node__outgoing_stream_typeZ_Node__incoming_stream_types) rr@namerMoutgoing_stream_typerKrLargskwargsrArO __class__r r r#s    z Node.__init__NcCs|j|||dS)z|Create an outgoing stream originating from this node. More nodes may be attached onto the outgoing stream. r")rT)rrrr r r r/sz Node.streamcCs(t|tr|j|j|jdS|j|dS)ajCreate an outgoing stream originating from this node; syntactic sugar for ``self.stream(label)``. It can also be used to apply a selector: e.g. ``node[0:'a']`` returns a stream with label 0 and selector ``'a'``, which is the same as ``node.stream(label=0, selector='a')``. Example: Process the audio and video portions of a stream independently:: input = ffmpeg.input('in.mp4') audio = input[:'a'].filter("aecho", 0.8, 0.9, 1000, 0.3) video = input[:'v'].hflip() out = ffmpeg.output(audio, video, 'out.mp4') r-)r)r slicer/startstop)ritemr r r r1s  zNode.__getitem__)NN) rrr8r9 classmethodrPrQrRr#r/r1 __classcell__r r rYr rHs    rHceZdZdfdd ZZS)FilterableStreamNcstt|||tth|dSr$)rSrcr# InputNode FilterNoderr r!r"rYr r r#s  zFilterableStream.__init__r$rrr8r#rar r rYr rcrccs2eZdZdZgiffdd ZeddZZS)rdzInputNode typec s$tt|jd|itdd||ddS)Nrr@rUrMrVrKrLrWrX)rSrdr#rc)rrUrWrXrYr r r#s  zInputNode.__init__cCtj|jdSNfilenameospathbasenamerXr&r r r short_reprzInputNode.short_repr)rrr8r9r#r:rqrar r rYr rds  rdcs.eZdZdgiffdd Z ddZZS)rerc s&tt|j||thtd|||ddSNrri)rSrer#rc)rr@rUrLrWrXrYr r r#   zFilterNode.__init__c s|j}|j}|jdvrt|g}dd|D}it|D]\}}t|d}t|d}||<qdd|D}fddtD}||} t|jd} | rZ| dd | 7} t| d S) N)splitZasplitcSg|]}t|dqS\'=:rrr r r rz*FilterNode._get_filter..rxcSrvrwry)rr6r r r r$rzcsg|] }d||qS)z{}={})r)rkZ out_kwargsr r r%rz={}:z\'[],;) rWrXrUrIr;rNrsortedrr) rZoutgoing_edgesrWrXZout_argsr{r6Z arg_paramsZ kwarg_paramsparamsZ params_textr r|r _get_filters"       zFilterNode._get_filter)rrr8r#rrar r rYr res recs.eZdZgiffdd ZeddZZS) OutputNodec s&tt|j||thtdd||ddSrs)rSrr#rc OutputStreamrr/rUrWrXrYr r r#1rtzOutputNode.__init__cCrjrkrmr&r r r rq=rrzOutputNode.short_repr)rrr8r#r:rqrar r rYr r0s rcrb)rNcs"tt|j||ttth|ddS)Nr[)rSrr#r GlobalNodeMergeOutputsNoderfrYr r r#Cs  zOutputStream.__init__r$rgr r rYr rBrhrcseZdZfddZZS)rcs"tt|j||thtddddS)Nr)r@rUrMrVrKrL)rSrr#r)rstreamsrUrYr r r#Ns  zMergeOutputsNode.__init__rgr r rYr rMsrcs"eZdZgiffdd ZZS)rc s&tt|j||thtdd||ddSrs)rSrr#rrrYr r r#[rtzGlobalNode.__init__rgr r rYr rZsrcsfdd}|S)Ncs"pjfddDS)Ncsg|]}t|qSr )setattr)rZ stream_classfunc func_namer r rksz6stream_operator..decorator..)r)rrUstream_classesrr decoratoris z"stream_operator..decoratorr )rrUrr rr stream_operatorhsrcCtth|dSN)rrU)rrcrUr r r filter_operatorqrcCrr)rrrr r r output_operatorurrr$) __future__rZ past.builtinsrZdagr_utilsrrbuiltinsrrnrrrrBrFrGrHrcrdrerrrrrrr__all__r r r r s0    e  U(