Cj SSKJr SSKrSSKrSSKrSSKrSSKJr SSKJ r SSK J r J r Sr \ SS4SS jjr\"S S 55r"S S 5rg)) annotationsN) dataclass) UserError)npnpti]cbUR[R:Xa;[R"USS5nUS-R [R 5nO)UR[R :wa [ S5e[R"5n[R"US5nURU5 URU5 URU5 URUR55 UR!S5 SSS5 SUS4$!,(df  N=f) N?0Buffer must be a numpy array of int16 or float32wrz audio.wavz audio/wav)dtyperfloat32clipastypeint16rioBytesIOwaveopen setnchannels setsampwidth setframerate writeframestobytesseek)buffer frame_rate sample_widthchannels audio_filewav_files d/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/agents/voice/input.py_buffer_to_audio_filer&s ||rzz!s+5.((2  !JKKJ :s #xh'l+j)V^^-. $ [ 11 $ #s /A$D  D.cj\rSrSr%SrS\S'\rS\S'SrS\S'S r S\S 'SS jr SS jr S r g) AudioInput(z7Static audio to be used as input for the VoicePipeline.z"npt.NDArray[np.int16 | np.float32]rintr rr!rr"cn[URURURUR5$)z2Returns a tuple of (filename, bytes, content_type))r&rr r!r"selfs r% to_audio_fileAudioInput.to_audio_file:s($T[[$//4CTCTVZVcVcddcURR[R:XaY[R"URSS5UlURS-R [R 5UlO3URR[R :wa [S5e[R"URR55RS5$)z2Returns the audio data as a base64 encoded string.r r r rzutf-8) rrrrrrrrbase64 b64encoderdecoder,s r% to_base64AudioInput.to_base64>s ;;   *''$++tS9DK;;.66rxx@DK [[  "(( *NO O 3 3 56==gFFr0)rN)returntuple[str, io.BytesIO, str])r7str) __name__ __module__ __qualname____firstlineno____doc____annotations__DEFAULT_SAMPLE_RATEr r!r"r.r5__static_attributes__r0r%r(r((sEA ..*J)?L#<HcBe Gr0r(c(\rSrSrSrSrSSjrSrg)StreamedAudioInputJzAudio 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. c8[R"5Ulg)N)asyncioQueuequeuer,s r%__init__StreamedAudioInput.__init__OsOV}} r0cV# URRU5IShvN gN7f)zAdds more audio data to the stream. Args: audio: The audio data to add. Must be a numpy array of int16 or float32 or None. If None passed, it indicates the end of the stream. N)rIput)r-audios r% add_audioStreamedAudioInput.add_audioRsjjnnU###s )'))rIN)rNz)npt.NDArray[np.int16 | np.float32] | None)r:r;r<r=r>rJrOrArBr0r%rDrDJs_$r0rD) rz/npt.NDArray[np.int16 | np.float32 | np.float64]r r*r!r*r"r*r7r8) __future__rrGr2rr dataclassesr exceptionsrimportsrr r@r&r(rDrBr0r%rUs" !" * 2 ;222 2 ! 22 GG GB$$r0