U Eh\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}q q|S)NFT) isinstance)objtypesZvalidZ stream_typer >/var/www/html/venv/lib/python3.8/site-packages/ffmpeg/nodes.py _is_of_types s  rcCsddd|DS)Nz, cSsg|]}d|j|jqS)z{}.{})format __module____name__.0xr r r sz"_get_types_str..)join)r r r r _get_types_strsrc@sReZdZdZdddZddZddZd 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||s"tdt|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}|jr$d|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__cCsD|jdk rtd|nt|ts2td||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__cCs|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 audioIsz Stream.audiocCs|dS)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 videobsz Stream.video)N) rr __qualname____doc__r"r&r(r+r0propertyr2r4r r r r rs   rcCsP|dkri}n>t|tr"d|i}n*t|ttfr>tt|}nt|trL|}|Sr#)r rlisttupledict enumerate stream_spec stream_mapr r r get_stream_map|s   r?cCsBg}t|D],}t|ts0tdt|||jq|S)NzExpected Stream; got {}) r8valuesr rrrrappendr)r>Znodesr.r r r get_stream_map_nodess  rBcCst|}t|Sr#)r?rBr<r r r get_stream_spec_nodessrCcs\eZdZdZeddZeddZeddZgiffdd Zdd d Z d dZ Z S)Nodez Node basecCsV|dk r*t||kr*td|t|n(|dk rRt||krRtd|t|dS)Nz,Expected at least {} input stream(s); got {}z+Expected at most {} input stream(s); got {})lenr-r)clsr> min_inputs max_inputsr r r Z__check_input_lenszNode.__check_input_lencCs8t|D]&}t||s tdt|t|q dS)NzKExpected incoming stream(s) to be of one of the following types: {}; got {})r8r@rrrrr)rFr>incoming_stream_typesr.r r r Z__check_input_typess zNode.__check_input_typescCs2i}t|D]\}}|j|j|jf||<q|Sr#)r8itemsrrr)rFr>incoming_edge_mapZdownstream_labelZupstreamr r r Z__get_incoming_edge_maps zNode.__get_incoming_edge_mapc sRt|} || |||| ||| } tt|| |||||_||_dSr#) r?_Node__check_input_len_Node__check_input_types_Node__get_incoming_edge_mapsuperrDr"_Node__outgoing_stream_typeZ_Node__incoming_stream_types) rr=namerIoutgoing_stream_typerGrHargskwargsr>rK __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!)rP)rrrr r r r.sz Node.streamcCs,t|tr|j|j|jdS|j|dSdS)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,)rN)r slicer.startstop)ritemr r r r0s zNode.__getitem__)NN) rrr5r6 classmethodrLrMrNr"r.r0 __classcell__r r rUr rDs    rDcseZdZdfdd ZZS)FilterableStreamNcstt|||tth|dSr#)rOr^r" InputNode FilterNoderrr r!rUr r r"s  zFilterableStream.__init__)Nrrr5r"r]r r rUr r^sr^cs2eZdZdZgiffdd ZeddZZS)r_zInputNode typec s$tt|jd|itdd||ddS)Nrr=rQrIrRrGrHrSrT)rOr_r"r^)rrQrSrTrUr r r"s zInputNode.__init__cCstj|jdSNfilenameospathbasenamerTr%r r r short_reprszInputNode.short_repr)rrr5r6r"r7rjr]r r rUr r_s r_cs,eZdZdgiffdd ZddZZS)r`rc s&tt|j||thtd|||ddSNrrc)rOr`r"r^)rr=rQrHrSrTrUr r r" s zFilterNode.__init__c s|j}|j}|jdkr t|g}dd|D}it|D]$\}}t|d}t|d}||<q>dd|D}fddtD}||} t|jd} | r| dd | 7} t| d S) N)splitZasplitcSsg|]}t|dqS\'=:rrr r r rsz*FilterNode._get_filter..rncSsg|]}t|dqSrmro)rr3r r r r$scsg|]}d||qS)z{}={})r)rkZ out_kwargsr r r%sz={}:z\'[],;) rSrTrQrEr8rJrsortedrr) rZoutgoing_edgesrSrTZout_argsrpr3Z arg_paramsZ kwarg_paramsparamsZ params_textr rqr _get_filters"      zFilterNode._get_filter)rrr5r"rur]r r rUr r`sr`cs.eZdZgiffdd ZeddZZS) OutputNodec s&tt|j||thtdd||ddSrk)rOrvr"r^ OutputStreamrr.rQrSrTrUr r r"1s zOutputNode.__init__cCstj|jdSrdrfr%r r r rj=szOutputNode.short_repr)rrr5r"r7rjr]r r rUr rv0s rvcseZdZdfdd ZZS)rwNcs"tt|j||ttth|ddS)NrW)rOrwr"rv GlobalNodeMergeOutputsNoderarUr r r"Cs  zOutputStream.__init__)Nrbr r rUr rwBsrwcseZdZfddZZS)rzcs"tt|j||thtddddS)Nr)r=rQrIrRrGrH)rOrzr"rw)rstreamsrQrUr r r"Ns zMergeOutputsNode.__init__rbr r rUr rzMsrzcs"eZdZgiffdd ZZS)ryc s&tt|j||thtdd||ddSrk)rOryr"rwrxrUr r r"[s zGlobalNode.__init__rbr r rUr ryZsrycsfdd}|S)Ncs"pjfddDS)Ncsg|]}t|qSr )setattr)rZ stream_classfunc func_namer r rksz6stream_operator..decorator..)r)r~rQstream_classesr}r decoratoris z"stream_operator..decoratorr )rrQrr rr stream_operatorhsrcCstth|dSN)rrQ)rr^rQr r r filter_operatorqsrcCstth|dSr)rrwrr r r output_operatorusr)N)N) __future__rZ past.builtinsrZdagrZ_utilsrrbuiltinsrrgrrrr?rBrCrDr^r_r`rvrwrzryrrr__all__r r r r s.     e  U(