+ ~jA^RIHt^RIt^RIt^RIt^RIt^RIt^RIHtH t H t ^RI H t H t ^RIHtHt^RIt^RIHt^RIHt^RIHt^R IHtHt^R IHtHt^R IH t ^R I!H"t"^R I#H$t$^RI%H&t&]PN!4t(]PR!](PT4!RR]PV4t,] ]PZ,].,],,t/!RR]4t0Rt1Rt2!RR4t3!RR4t4RRlt5R#)) annotationsN)AsyncGenerator AsyncIterator Generator)as_filefiles)Any NamedTuple)rtc)get_job_contextlogger) NOT_GIVEN NotGivenOr)is_givenlog_exceptions)cancel_and_waitaudio_frames_from_file) AgentSession)AgentStateChangedEventc>]tRt^tRtRtRtRtRtRt Rt RR lt R t R #) BuiltinAudioClipzcity-ambience.oggzforest-ambience.oggzoffice-ambience.oggzcrowded-room.oggzkeyboard-typing.oggzkeyboard-typing2.oggzhold_music.oggcV^8dQhRR/#)returnstr)formats"z/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/voice/background_audio.py __annotate__BuiltinAudioClip.__annotate__&sFFcFc \R4VP, p\\P \ V444#)zlivekit.agents.resources)rvaluer_resource_stack enter_contextr)self file_paths& r pathBuiltinAudioClip.path&s145 B ?001CDEEr#rN) __name__ __module__ __qualname____firstlineno__ CITY_AMBIENCEFOREST_AMBIENCEOFFICE_AMBIENCE CROWDED_ROOMKEYBOARD_TYPINGKEYBOARD_TYPING2 HOLD_MUSICr*__static_attributes__rr#r rrs2'M+O+O%L+O-!JFFr#rcB]tRt^.t$RtR]R&RtR]R&RtR]R&RtR #) AudioConfigz Definition for the audio to be played in the background Args: volume: The volume of the audio (0.0-1.0) probability: The probability of the audio being played, when multiple AudioConfigs are provided (0.0-1.0) AudioSourcesource?floatvolume probabilityrN) r,r-r.r/__doc____annotations__r>r?r7rr#r r9r9.s# FEKr#r9ibackground_audioc]tRt^EtR]R]R^/RRlltRRltRR ltR R ltR R /RRllt R]R]/RRllt RRlt RRlt RRlt ]!]R7RRl4t]!]R7RRl4tRR ltR!tR"#)#BackgroundAudioPlayer ambient_soundthinking_soundstream_timeout_msc(V^8dQhRRRRRRRR/#)rrEz@NotGivenOr[AudioSource | AudioConfig | list[AudioConfig] | None]rFrGintrNoner)rs"r r!"BackgroundAudioPlayer.__annotate__Fs50808X08 0808 08r#c l\V4'dTMRVn\V4'dTMRVn\P!R^\ R7Vn\P!R^R^VR7VnRVn \P!4Vn RVn .VnRVnRVnR#)uk Initializes the BackgroundAudio component with optional ambient and thinking sounds. This component creates and publishes a continuous audio track to a LiveKit room while managing the playback of ambient and agent “thinking” sounds. It supports three types of audio sources: - A BuiltinAudioClip enum value, which will use a pre-defined sound from the package resources - A file path (string) pointing to an audio file, which can be looped. - An AsyncIterator that yields rtc.AudioFrame When a list (or AudioConfig) is supplied, the component considers each sound’s volume and probability: - The probability value determines the chance that a particular sound is selected for playback. - A total probability below 1.0 means there is a chance no sound will be selected (resulting in silence). Args: ambient_sound (NotGivenOr[Union[AudioSource, AudioConfig, List[AudioConfig], None]], optional): The ambient sound to be played continuously. For file paths, the sound will be looped. For AsyncIterator sources, ensure the iterator is infinite or looped. thinking_sound (NotGivenOr[Union[AudioSource, AudioConfig, List[AudioConfig], None]], optional): The sound to be played when the associated agent enters a “thinking” state. This can be a single sound source or a list of AudioConfig objects (with volume and probability settings). Ni) queue_size_msi) blocksizecapacityrG)r_ambient_sound_thinking_soundr r:_AUDIO_SOURCE_BUFFER_MS _audio_source AudioMixer _audio_mixer publicationasyncioLock_lock _mixer_atask _play_tasks_ambient_handle_thinking_handle)r(rErFrGs&$$$r __init__BackgroundAudioPlayer.__init__FsB08 /F/FmD19.1I1I~t __UAE\]NN 1qDU >B\\^ 7;572637r#c V^8dQhRRRR/#)rsoundszlist[AudioConfig]rzAudioConfig | Noner)rs"r r!rKxs.?DVr#c x\RV44pV^8:dR#VR8d\P!4V8dR#VR8:dRMTp\P!4\VR4,pRpVF;pVP^8:dKVPV, pWW, pWE8:gK9Vu# VR,#)z Selects a sound from a list of BackgroundSound based on their probabilities. Returns None if no sound is selected (when sum of probabilities < 1.0). c38"TFqPxK R#5iN)r?).0sounds& r @BackgroundAudioPlayer._select_sound_from_list..}sFve 1 1vsNr<g)sumrandomminr?)r(ratotal_probabilitynormalize_factorr cumulativerf norm_probs&& r _select_sound_from_list-BackgroundAudioPlayer._select_sound_from_listxs  FvFF  ! s "v}}9J'J"3s":3@Q MMOc"3S9 9 E  A%)),<r9)r(r;selecteds&& r _normalize_sound_source-BackgroundAudioPlayer._normalize_sound_sources > f. / /008#= =  % %33F;H??HOO3 3  , ,00?N Ns{r#c V^8dQhRRRR/#)rr;r:rz#AsyncIterator[rtc.AudioFrame] | strr)rs"r r!rKs{?br#c R\V\4'dVP4#V#rd)rvrr*)r(r;s&&r rw.BackgroundAudioPlayer._normalize_builtin_audios! f. / /;;= Mr#loopFc$V^8dQhRRRRRR/#)raudioz-AudioSource | AudioConfig | list[AudioConfig]rboolr PlayHandler)rs"r r!rKs(11<1 1  1r#c aaaSP'g \R4hSPV4pVf\4oSP 4S#VwrEV'd"\ V\ 4'd \R4h\4o\P!SPSWEV44oSPVV3Rl4SPV3Rl4SPPS4S#)aQ Plays an audio once or in a loop. Args: audio (Union[AudioSource, AudioConfig, List[AudioConfig]]): The audio to play. Can be: - A string pointing to a file path - An AsyncIterator that yields `rtc.AudioFrame` - An AudioConfig object with volume and probability - A list of AudioConfig objects, where one will be selected based on probability If a string is provided and `loop` is True, the sound will be looped. If an AsyncIterator is provided, it is played until exhaustion (and cannot be looped automatically). loop (bool, optional): Whether to loop the audio. Only applicable if `audio` is a string or contains strings. Defaults to False. Returns: PlayHandle: An object representing the playback handle. This can be awaited or stopped manually. zBackgroundAudio is not startedz}Looping sound via AsyncIterator is not supported. Use a string file path or your own 'infinite' AsyncIterator with loop=Falsec:<SPPS4#rd)r[remove)_r(tasks&r ,BackgroundAudioPlayer.play..s)9)9)@)@)Fr#c$<SP4#rd)_mark_playout_done)r play_handles&r rrs)G)G)Ir#)rZ RuntimeErrorrzrrrvr ValueErrorrW create_task _play_taskadd_done_callbackr[append)r(rr normalized sound_sourcer>rrsf&$ @@r playBackgroundAudioPlayer.plays8   ?@ @11%8  $,K  * * , ) J|];;P !l ""4??; VZ#[\ FG IJ %r# agent_sessiontrack_publish_optionsc(V^8dQhRRRRRRRR/#) rroomzrtc.RoomrzNotGivenOr[AgentSession]rz#NotGivenOr[rtc.TrackPublishOptions]rrJr)rs"r r!rKs;6I6I6I0 6I C 6I  6Ir#c "VP;_uu_4GRjxL WnT;'gRVnT;'gRVn\ 4pVP 4'd\ P!R4TP4GRjxL \P!TP44Tn TP'd'TPPRTP4TP 'dxTP#TP 4pT'dUTwrg\%Yg4p\'T\(4'dTP+TRR7TnMTP+T4TnRRR4GRjxL R#ELx \dEL%i;iELL +GRjxL 'giR#;i5i)a Starts the background audio system, publishing the audio track and beginning playback of any configured ambient sound. If `ambient_sound` is provided (and contains file paths), they will loop automatically. If `ambient_sound` contains AsyncIterators, they are assumed to be already infinite or looped. Args: room (rtc.Room): The LiveKit Room object where the audio track will be published. agent_session (NotGivenOr[AgentSession], optional): The session object used to track the agent's state (e.g., "thinking"). Required if `thinking_sound` is provided. track_publish_options (NotGivenOr[rtc.TrackPublishOptions], optional): Options used when publishing the audio track. If not given, defaults will be used. NzLBackground audio is not supported in console mode. Audio will not be played.agent_state_changedT)r)rY_room_agent_session_track_publish_optionsr is_fake_jobrwarningr_publish_trackrWr_run_mixer_taskrZon_agent_state_changedrPrzr9rvrrr\) r(rrrjob_ctxrrr>selected_sounds &$$$ r startBackgroundAudioPlayer.startsR2::::J"/"7"74D *?*G*G4D ' )+&&((NNf %%' ' ' ' 3 3D4H4H4J KD """##&&'W>WX"""!99$:M:MN +5(L%0%FN!,44/3yydy/S,/3yy/H,;::    (:::sG FG  F-F- 6F?F-F(>F-7F- "F--AF- G  F+ G  F%!F-$F%%F-+G -G 3F64 G ?G  G cV^8dQhRR/#rrrJr)rs"r r!rKsTTdTr#c "VP;_uu_4GRjxL VP'gRRR4GRjxL R#\VP!GRjxL \VP4GRjxL RVnVPP 4GRjxL VP P 4GRjxL VP'd'VPPRVP4\P!\4;_uu_4VP\4pVe8VPP P#VP$4GRjxL RRR4RRR4GRjxL R#ELrELREL8ELLLL. +'giL4;iL+ +GRjxL 'giR#;i5i)zw Gracefully closes the background audio system, canceling all ongoing playback tasks and unpublishing the audio track. Nr)rYrZrr[rUacloserSroffr contextlibsuppress Exception_find_publication_by_name _TRACK_NAMErlocal_participantunpublish_tracksid)r(currents& r rBackgroundAudioPlayer.acloses8 ::::$$$::"4#3#34 4 4!$"3"34 4 4 $D ##**, , ,$$++- - -"""##''(=t?X?XY$$Y//88E&**66FFw{{SSS 0:: 5 4 - -T 0/:::sGF GF4 GFGF4FF48F9(F4!F"!F4FF4AF4"A F .F /F 3F4; GF2GGF4F4F4F4F  F/ *F42G4G :F=; G G  Gc V^8dQhRRRR/#)rnamerrz rtc.LocalTrackPublication | Noner)rs"r r!rK3sc6Vr#c VPPPP4FpVPV8XgKVu# R#rd)rrtrack_publicationsvaluesr)r(rpubs&& r r/BackgroundAudioPlayer._find_publication_by_name3s<:://BBIIKCxx4 Lr#c V^8dQhRRRR/#)revrrrJr)rs"r r!rK9s ) )'= )$ )r#c xVP'gR#VPR8XdgVP'd#VPP4'gR#VPfQhVP VP4VnR#VP'dVPP 4R#R#)Nthinking)rQ new_stater]donerstop)r(rs&&r r*BackgroundAudioPlayer._agent_state_changed9s###  <<: %$$$T-B-B-G-G-I-I''3 33$(IId.B.B$CD !  " " "  ! ! & & (#r#r c ,V^8dQhRRRRRRRRR R /#) rrrrfr:r>r=rrrrJr)rs"r r!rKHs43'3'%3'.93'CH3'PT3' 3'r#c aaaa"\S\4'dSP4o\S\4'd V'd \ S4oM \ S4oRoRVVVV3RllpV!4pVP PV4SP4GRjxL VP PV4SP4\P!^4GRjxL SPP4'dHRo\P !\"4;_uu_4VP%4GRjxL RRR4R#R#LLoL +'giR#;i TP PT4SP4\P!^4GRjxL SPP4'd[Ro\P !\"4;_uu_4TP%4GRjxL RRR4i +'gii;ii;i5i)FcV^8dQhRR/#)rr$AsyncGenerator[rtc.AudioFrame, None]r)rs"r r!6BackgroundAudioPlayer._play_task..__annotate__Vs 1 1$H 1r#c<"SRjxL pS'dEMSR8wd\P!VP\PR7P \P 4pV^ \P !S4,,p\P!VRRVR7\P!VP \P4P4VPVPVPR75xEKV5xEKSP4R#EL&ED(L SP4i;i5i)Nr<)dtypei)out)data sample_rate num_channelssamples_per_channeli)np frombufferrint16astypefloat32log10clipr AudioFrametobytesrrrr)framerrrfstoppedr>s r _gen_wrapper6BackgroundAudioPlayer._play_task.._gen_wrapperVs 1#($$%}!}}UZZrxxHOOPRPZPZ[rxx'7 88fe>!nn!%RXX!6!>!>!@(-(9(9).););050I0I $ ..0)$5(..0s=E D7D4D1D4DD7E 1D44D77E  E NT)rvrr*r_loop_audio_framesrrU add_streamwait_for_playout remove_streamrrWsleep _stop_futrrrrr)r(rrfr>rrgenrs&fff& @r r BackgroundAudioPlayer._play_taskGs e- . .JJLE eS ! !*51.u5 1 10n '    ( ( -..0 0 0    + +C 0  * * ,--" " "$$))++((66**,&&76, 1 # '766    + +C 0  * * ,--" " "$$))++((66**,&&7666,sAI ,I8.E7&E'E7+AI/E0#I$I8E# E! E# IE7I!E## E4 . I7AH=<F?=$H="$H=H) H H) H=) H9 4 H==IcV^8dQhRR/#rr)rs"r r!rK~s::t:r#c "VPRjxL pVPPV4GRjxL K/L*LD-R#5ird)rUrS capture_frame)r(rs& r r%BackgroundAudioPlayer._run_mixer_task}sA,, : :%$$2259 9 9 : 9-s3 AA>A AAAAAAcV^8dQhRR/#rr)rs"r r!rKs  d r#c @"VPeR#\PP\VP 4pVP PPYP;'g\P!44GRjxL VnR#L 5ird) rVr LocalAudioTrackcreate_audio_trackrrSrr publish_trackrTrackPublishOptions)r(tracks& r r$BackgroundAudioPlayer._publish_trackss    ' ##66{DDVDVW!%!=!=!K!K ..KK#2I2I2K"   sA0B3BB B) rr\rPrUrSrYrZr[rr]rQrrVN)r,r-r.r/rr^rrrzrwrrrrrrrrrrr7rr#r rDrDEs08[d08  08"%08d8$ 1 1f6I3< 6I FO 6IpT8 )6"3'#3'j6":#:  r#rDc^]tRtRtRRltRRltRRltRR ltR R ltR R lt Rt R#)ricV^8dQhRR/#rr)rs"r r!PlayHandle.__annotate__s00$0r#c \PR,!4Vn\PR,!4VnR#rd)rWFuture _done_futrr(s&r r^PlayHandle.__init__s( -/ -/r#cV^8dQhRR/#)rrrr)rs"r r!rs%%d%r#c 6VPP4#)z1 Returns True if the sound has finished playing. )rrrs&r rPlayHandle.dones~~""$$r#cV^8dQhRR/#rr)rs"r r!rs & &d &r#c VP4'dR#\P!\P4;_uu_4VP P R4VP4RRR4R# +'giR#;i)z Stops the sound from playing. N)rrrrWInvalidStateErrorr set_resultrrs&r rPlayHandle.stopsV 99;;   !:!: ; ; NN % %d +  # # %< ; ; ;s ,A;; B cV^8dQhRR/#rr)rs"r r!rs---r#c b"\P!VP4GRjxL R#L5i)z( Waits for the sound to finish playing. N)rWshieldrrs&r rPlayHandle.wait_for_playoutsnnT^^,,,s $/-/cV^8dQhRR/#)rrz Generator[Any, None, PlayHandle]r)rs"r r!rs));)r#c @aRV3RllpV!4P4#)cV^8dQhRR/#)rrrr)rs"r r!*PlayHandle.__await__..__annotate__s  : r#cD<"SP4GRjxL S#L5ird)rrsr _await_impl)PlayHandle.__await__.._await_impls"'') ) )K *s   ) __await__)r(rsf r rPlayHandle.__await__s   }&&((r#cV^8dQhRR/#rr)rs"r r!rs,,D,r#c \P!\P4;_uu_4VPP R4RRR4R# +'giR#;ird)rrrWrrrrs&r rPlayHandle._mark_playout_dones:  !:!: ; ; NN % %d +< ; ; ;s A A$ )rrN) r,r-r.r/r^rrrrrr7rr#r rrs%0% &- ),,r#rc V^8dQhRRRR/#)rr)rrrr)rs"r r!r!s0Tr#cN"\V4RjxL pV5xKL D K"5i)TNr)r)rs& r rrs) 1)<  %K r+s"  DD."!),'0'*&&(%%& Ftyy FCNN+c14DD  * & D D N %,%,Pr#