.h^ ddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z dZ e ddfddZeGddZGddZdS)) annotationsN) dataclass) UserError)npnpti]buffer"npt.NDArray[np.int16 | np.float32] frame_rateint sample_widthchannelsreturntuple[str, io.BytesIO, str]cf|jtjkr9tj|dd}|dztj}n$|jtjkrt dtj}tj |d5}| || || ||||ddddn #1swxYwYd|dfS) N?0Buffer must be a numpy array of int16 or float32wrz audio.wavz audio/wav)dtyperfloat32clipastypeint16rioBytesIOwaveopen setnchannels setsampwidth setframerate writeframestobytesseek)r r rr audio_filewav_files O/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/agents/voice/input.py_buffer_to_audio_filer*sI |rz!!s++5.((22  ! !JKKKJ :s # #xh'''l+++j)))V^^--...  [ 11sAs ;  * *'$+tS99DK;.66rx@@DKK [ "( * *NOO O 3 3 5 566==gFFFr1N)rr)rr2) __name__ __module__ __qualname____doc____annotations__DEFAULT_SAMPLE_RATEr rrr0r7r1r)r,r,(sAA....*J))))?L<HBeeee G G G G G Gr1r,c eZdZdZdZddZdS)StreamedAudioInputzAudio input represented as a stream of audio data. You can pass this to the `VoicePipeline` and then push audio data into the queue using the `add_audio` method. c6tj|_dS)N)asyncioQueuequeuer.s r)__init__zStreamedAudioInput.__init__OsHO  r1audior cJK|j|d{VdS)zAdds more audio data to the stream. Args: audio: The audio data to add. Must be a numpy array of int16 or float32. N)rDput)r/rFs r) add_audiozStreamedAudioInput.add_audioRs4 jnnU###########r1N)rFr )r8r9r:r;rErIr>r1r)r@r@JsDXXX$$$$$$r1r@) r r r r rr rr rr) __future__rrBr4rr dataclassesr exceptionsrimportsrr r=r*r,r@r>r1r)rNs"""""" !!!!!!"""""" * 222222 GGGGGGG GB$$$$$$$$$$r1