U ¬9%e39ã @s¤dZddlZe dd¡ddlmZmZddlZddlZddlZddl Z ddl m Z ddl m Z dd lmZd Zd Zd ZGd d „d e ƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZdae ¡Ze d¡dd„ZGdd„dejƒZGdd„deƒZ e!dkr ej"dd…D]nZ#ej# $ej# %e#¡¡Z#e e#ƒFZ&e'e&j(ƒe'e&j)ƒe'e&j*ƒe&D]Z+e'e,e+ƒe-e+dƒƒqtW5QRXq0dS)aYUse Gstreamer to decode audio files. To read an audio file, pass it to the constructor for GstAudioFile() and then iterate over the contents: >>> f = GstAudioFile('something.mp3') >>> try: >>> for block in f: >>> ... >>> finally: >>> f.close() Note that there are a few complications caused by Gstreamer's asynchronous architecture. This module spawns its own Gobject main- loop thread; I'm not sure how that will interact with other main loops if your program has them. Also, in order to stop the thread and terminate your program normally, you need to call the close() method on every GstAudioFile you create. Conveniently, the file can be used as a context manager to make this simpler: >>> with GstAudioFile('something.mp3') as f: >>> for block in f: >>> ... Iterating a GstAudioFile yields strings containing short integer PCM data. You can also read the sample rate and channel count from the file: >>> with GstAudioFile('something.mp3') as f: >>> print f.samplerate >>> print f.channels >>> print f.duration éNÚGstz1.0)ÚGLibr)Úquoteé)Ú DecodeError)Ú AudioFileé Z__GSTDEC_SENTINEL__c@s eZdZdS)ÚGStreamerErrorN)Ú__name__Ú __module__Ú __qualname__©r r úO/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/audioread/gstdec.pyr Esr cs eZdZdZ‡fdd„Z‡ZS)ÚUnknownTypeErrorz7Raised when Gstreamer can't decode the given file type.cstƒ d|¡||_dS)Nzcan't decode stream: )ÚsuperÚ__init__Ú streaminfo)Úselfr©Ú __class__r rrKsÿzUnknownTypeError.__init__©r r r Ú__doc__rÚ __classcell__r r rrrIsrc@seZdZdZdS)Ú FileReadErrorz*Raised when the file can't be read at all.N©r r r rr r r rrRsrcs eZdZdZ‡fdd„Z‡ZS)Ú NoStreamErrorzTRaised when the file was read successfully but no audio streams were found. cstƒ d¡dS)Nzno audio streams found©rr©rrr rr[szNoStreamError.__init__rr r rrrWsrc@seZdZdZdS)ÚMetadataMissingErrorzdRaised when GStreamer fails to report stream metadata (duration, channels, or sample rate). Nrr r r rr_srcs eZdZdZ‡fdd„Z‡ZS)ÚIncompleteGStreamerErrorzkRaised when necessary components of GStreamer (namely, the principal plugin packages) are missing. cstƒ d¡dS)Nzmissing GStreamer base pluginsrrrr rrjsÿz!IncompleteGStreamerError.__init__rr r rrrfsrc Cs2t$tstƒat ¡tW5QR£SQRXdS)z%Get the shared main-loop thread. N)Ú_loop_thread_lockÚ_shared_loop_threadÚMainLoopThreadÚstartr r r rÚget_loop_threadws r$cs(eZdZdZ‡fdd„Zdd„Z‡ZS)r"z7A daemon thread encapsulating a Gobject main loop. cs$tƒ ¡tj dd¡|_d|_dS)NFT)rrrZMainLoopÚnewÚloopÚdaemonrrr rr†s zMainLoopThread.__init__cCs|j ¡dS©N)r&Úrunrr r rr)‹szMainLoopThread.run)r r r rrr)rr r rrr"ƒs r"c@s~eZdZdZdd„Zdd„ZdZdd„Zd d „Zd d „Z d d„Z dd„Z dd„Z dd„Z ddd„Zdd„Zdd„Zdd„ZdS)Ú GstAudioFileaäReads raw audio data from any audio file that Gstreamer knows how to decode. >>> with GstAudioFile('something.mp3') as f: >>> print f.samplerate >>> print f.channels >>> print f.duration >>> for block in f: >>> do_something(block) Iterating the object yields blocks of 16-bit PCM data. Three pieces of stream information are also available: samplerate (in Hz), number of channels, and duration (in seconds). It's very important that the client call close() when it's done with the object. Otherwise, the program is likely to hang on exit. Alternatively, of course, one can just use the file as a context manager, as shown above. cCsd|_d|_t ¡|_tj dd¡|_tj dd¡|_tj dd¡|_ |jdksd|jdksd|j dkrjt ƒ‚|j  ¡}|  ¡|  d|j¡|  d|j¡dttj |¡ƒ}|j d|¡|j  d |j¡|j  d |j¡|j  d |j¡|j  d tj d ¡¡|j  dd¡|j  dt¡|j  dd¡|j  dd¡|j   d|j¡t d¡|_|j  d¡  d|j¡|_ |j !|j¡|j !|j¡|j !|j ¡|j "|j ¡t# $t%¡|_#t&ƒ|_'d|_(d|_d|_)|j *tj+j,¡|j -¡|j(rü| .d¡|j(‚dS)NFÚ uridecodebinZ audioconvertZappsinkz message::eoszmessage::errorzfile://Úuriz pad-addedz no-more-padsz unknown-typeÚcapsz!audio/x-raw, format=(string)S16LEZdropz max-buffersÚsyncz emit-signalsTz new-samplerÚsinkz notify::caps)/ÚrunningÚfinishedrZPipelineÚpipelineZElementFactoryÚmakeÚdecÚconvr/rÚget_busZadd_signal_watchÚconnectÚ_messagerÚosÚpathÚabspathÚ set_propertyÚ _pad_addedÚ _no_more_padsÚ _unkown_typeZCapsZ from_stringÚ BUFFER_SIZEÚ _new_sampleÚ threadingÚ SemaphoreÚ ready_semÚget_static_padÚ _notify_capsÚ caps_handlerÚaddÚlinkÚqueueÚQueueÚ QUEUE_SIZEr$ÚthreadÚread_excÚgot_capsÚ set_stateÚStateZPLAYINGÚacquireÚclose)rr:Úbusr,r r rr¥sZ   þ   ÿ   zGstAudioFile.__init__cCsrd|_| ¡ d¡}| d¡d|_| d¡d|_| ¡ tj j ¡\}}|rZ|d|_ n t dƒ|_ |j ¡dS) z>The callback for the sinkpad's "notify::caps" signal. TrÚchannelsrZrateiÊš;zduration not availableN)rOZget_current_capsZ get_structureZget_intrUÚ samplerateZget_peerZquery_durationrZFormatZTIMEÚdurationrrNrDÚrelease)rÚpadÚargsÚinfoÚsuccessÚlengthr r rrFüs  zGstAudioFile._notify_capsFcCs@| d¡ ¡}| d¡r<|j d¡}| ¡s szGstAudioFile._no_more_padscCsx|jrp| d¡ ¡}| ¡}| tjj¡\}}|rht|j t ƒrJt |j ƒ}n|j }|  |¡|j  |¡ntdƒ‚tjjS)z8The callback for appsink's "new-sample" signal. z pull-samplez3Unable to map buffer memory while reading the file.)r0ÚemitÚ get_bufferZget_all_memoryÚmaprZMapFlagsÚREADÚ isinstanceÚdataÚ memoryviewÚbytesZunmaprJÚputr Z FlowReturnÚOK)rr/ÚbufZmemr\r[rhr r rrA*s   zGstAudioFile._new_samplecCs.| ¡}| d¡sdSt|ƒ|_|j ¡dS)zrAr?r8rwrxrSr}r~r‚r r r rr*‘sW    r*Ú__main__).rÚgiZrequire_versionZ gi.repositoryrrÚsysrBr9rJÚ urllib.parserÚ exceptionsrÚbaserrLr@ror rrrrrr!ÚRLockr Úinitr$ÚThreadr"r*r Úargvr:r;Ú expanduserÚfÚprintrUrVrWÚsÚlenÚordr r r rÚsH"