/jBSSKJr SSKrSSKrSSKrSSKrSSKrSSKJrJ r J r SSK J r J r SSKJrJr SSKrSSKJr SSKJr SS KJr SS KJrJr SS KJrJr SS KJ r SS K!J"r" SSK#J$r$ SSK%J&r& \RN"5r(\RR"\(RT5 "SS\RV5r,\ \RZ\.-\,-r/"SS\5r0Sr1"SS5r2"SS5r3SSjr4g)) 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:\rSrSrSrSrSrSrSrSr Sr S S jr S r g ) BuiltinAudioClipzcity-ambience.oggzforest-ambience.oggzoffice-ambience.oggzcrowded-room.oggzkeyboard-typing.oggzkeyboard-typing2.oggzhold_music.oggc[S5UR- n[[R [ U555$)Nzlivekit.agents.resources)rvaluestr_resource_stack enter_contextr)self file_paths V/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/voice/background_audio.pypathBuiltinAudioClip.path&s145 B ?001CDEEN)returnr) __name__ __module__ __qualname____firstlineno__ CITY_AMBIENCEFOREST_AMBIENCEOFFICE_AMBIENCE CROWDED_ROOMKEYBOARD_TYPINGKEYBOARD_TYPING2 HOLD_MUSICr%__static_attributes__r(r'r$rrs,'M+O+O%L+O-!JFr'rc@\rSrSr%SrS\S'SrS\S'SrS\S'S rg ) AudioConfig.z 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 probabilityr(N) r*r+r,r-__doc____annotations__r=r>r5r(r'r$r7r7.s# FEKr'r7ic,\rSrSr\\SS.SSjjrSSjrSSjrSSjrSS .SS jjr \\S .SS jjr SS jr SSjr SSjr \"\S9SSj5r\"\S9SSj5rSSjr\"\S9SSj5rSrg) BackgroundAudioPlayerD) ambient_soundthinking_soundstream_timeout_msch[U5(aUOSUl[U5(aUOSUl[R"SS[ S9Ul[R"SSSSUS9UlSUl [R"5Ul SUl SUl/UlSUlSUlg)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). Nir) queue_size_msi) blocksizecapacityrG)r_ambient_sound_thinking_soundr r9_AUDIO_SOURCE_BUFFER_MS _audio_source AudioMixer _audio_mixer publicationasyncioLock_lock_republish_task _mixer_atask _play_tasks_ambient_handle_thinking_handle)r"rErFrGs r$__init__BackgroundAudioPlayer.__init__EsB08 /F/FmD19.1I1I~t __UAE\]NN 1qDU >B\\^ :>7;572637r'cH[SU55nUS::agUS:a[R"5U:agUS::aSOUn[R"5[US5-nSnUH1nURS::aMURU- nXW- nXE::dM/Us $ US$)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# UHoRv M g7fN)r>).0sounds r$ @BackgroundAudioPlayer._select_sound_from_list..}sFve 1 1vsrNr;g)sumrandomminr>)r"soundstotal_probabilitynormalize_factorr cumulativera 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%)),< f. / /008#= =  % %33F;H??HOO3 3  , ,00?N Ns{r'cP[U[5(aUR5$U$r_)rqrr%)r"r:s r$rr.BackgroundAudioPlayer._normalize_builtin_audios! f. / /;;= Mr'Floopc^^^TR(d [S5eTRU5nUc[5mTR 5 T$UupEU(a [ U[ 5(a [S5e[5m[R"TRTXEU55mTRUU4Sj5 TRU4Sj5 TRRT5 T$)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:>TRRT5$r_)rXremove)_r"tasks r$,BackgroundAudioPlayer.play..s)9)9)@)@)Fr'c$>TR5$r_)_mark_playout_done)r~ play_handles r$rrs)G)G)Ir')rW RuntimeErrorru PlayHandlerrqr ValueErrorrS create_task _play_taskadd_done_callbackrXappend)r"audiorz normalized sound_sourcer=rrs` @@r$playBackgroundAudioPlayer.plays8  ?@ @11%8  $,K  * * , ) J|];;P !l ""4??; VZ#[\ FG IJ %r') agent_sessiontrack_publish_optionsc# URIShvN XlU=(d SUlU=(d SUl[ 5nUR 5(a[ R"S5 UR5IShvN [R"UR55Ul URRSUR5 UR(a&URRSUR 5 UR"(arUR%UR"5nU(aPUupg['Xg5n[)U[*5(aUR-USS9UlOUR-U5UlSSS5IShvN gGN![a GNBf=fGN3N!,IShvN (df  g=f7f)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. reconnectedagent_state_changedTry)rU_room_agent_session_track_publish_optionsr is_fake_jobrwarningr_publish_trackrSr_run_mixer_taskrWon_on_reconnected_agent_state_changedrLrur7rqrrrY) r"roomrrjob_ctxrrr=selected_sounds r$startBackgroundAudioPlayer.starts\2:::J"/"74D *?*G4D ' )+&&((NNf %%' ' ' ' 3 3D4H4H4J KD  JJMM-)=)= >""##&&'W>WX""!99$:M:MN +5(L%0%FN!,44/3yydy/S,/3yy/H,=::    (:::stGF&G'F?5F)4F?F:D F? G F=!G) F73F?6F77F?=G?GG  GGc# URIShvN UR(dSSS5IShvN g[UR6IShvN UR(a[UR5IShvN [UR5IShvN SUlUR R 5IShvN URR 5IShvN UR(a&URRSUR5 URRSUR5 [R"[5 UR bAURR"R%UR R&5IShvN SSS5 SSS5IShvN gGNGNGNGNUGN;GNNN1!,(df  N5=fN,!,IShvN (df  g=f7f)zw Gracefully closes the background audio system, canceling all ongoing playback tasks and unpublishing the audio track. Nrr)rUrWrrXrVrQacloserOroffrrr contextlibsuppress ExceptionrRlocal_participantunpublish_tracksidr"s r$rBackgroundAudioPlayer.aclosesc :::$$::"4#3#34 4 4##%d&:&:;;;!$"3"34 4 4 $D ##**, , ,$$++- - -""##''(=t?X?XY JJNN=$*>*> ?$$Y/##/**66FFtGWGWG[G[\\\0):: 5< 4 - -]0/):::sH G H G3 H G H G3G-G3>G?G3G(G3G!G3&G'A;G3"A G ,G-G 1G39 H G1H  H G3G3G3G3G3G  G. *G31H 3H 9G< : H H cUR(aURR5 SUl[R"UR 55Ulgr_)rVcancelrRrSr_republish_track_taskrs r$r%BackgroundAudioPlayer._on_reconnected5sA     ' ' )&2243M3M3OPr'cbUR(dgURS:XaaUR(a URR5(dgURceUR UR5UlgUR(aURR 5 gg)Nthinking)rM new_staterZdonerstop)r"evs r$r*BackgroundAudioPlayer._agent_state_changed<s##  <<: %$$T-B-B-G-G-I-I''3 33$(IId.B.B$CD !  " "  ! ! & & (#r'rcJ^^^^# [T[5(aTR5m[T[5(aU(a [ T5mO [ T5mSmSUUUU4SjjnU"5nUR RU5 TR5IShvN UR RU5 TR5 [R"S5IShvN TRR5(a>Sm[R "["5 UR%5IShvN SSS5 ggNNdN!,(df  g=f!UR RU5 TR5 [R"S5IShvN TRR5(aPSm[R "["5 UR%5IShvN SSS5 f!,(df  f=ff=f7f)NFcl># TShvN nT(a OTS:wa[R"UR[RS9R [R 5nUS[R "T5--n[R"USSUS9 [R"UR [R5R5URURURS97v MU7v GMTR5 gGN N!TR5 f=f7f)Nr;)dtype ii)out)data sample_rate num_channelssamples_per_channel)np frombufferrint16astypefloat32log10clipr AudioFrametobytesrrrr)framerrrastoppedr=s r$ _gen_wrapper6BackgroundAudioPlayer._play_task.._gen_wrapperYs 1#($%}!}}UZZrxxHOOPRPZPZ[rxx'7 88fe>!nn!%RXX!6!>!>!@(-(9(9).););050I0I $ ..0)$5(..0s=D4DDDDC:D D4DDD11D4rT)r)$AsyncGenerator[rtc.AudioFrame, None])rqrr%r_loop_audio_framesrrQ add_streamwait_for_playout remove_streamrrSsleep _stop_futrrrrr)r"rrar=rzrgenrs ``` @r$r BackgroundAudioPlayer._play_taskJs e- . .JJLE eS ! !*51.u5 1 10n '    ( ( -..0 0 0    + +C 0  * * ,--" " "$$))++((6**,&&76, 1 # '76    + +C 0  * * ,--" " "$$))++((6**,&&766,sA-H#4.E%"E#E%'AH#+E,?H#+E?EE H#E%H#E E"H#%AH *F-+AH +H?H H H  H H  H#c# URShvN nURRU5IShvN M.N)N g7fr_)rQrO capture_frame)r"rs r$r%BackgroundAudioPlayer._run_mixer_tasks<,, :%$$2259 9 9 : 9-s1 AA=AA?AAAAc0# URbg[RRSUR5nUR R RXR=(d [R"55IShvN UlgN 7f)Nbackground_audio) rRr LocalAudioTrackcreate_audio_trackrOrr publish_trackrTrackPublishOptions)r"tracks r$r$BackgroundAudioPlayer._publish_tracksq    ' ##667I4K]K]^!%!=!=!K!K ..K#2I2I2K"   sBB B Bc# URIShvN UR5IShvN SSS5IShvN gN-NN !,IShvN (df  g=f7fr_)rUrrs r$r+BackgroundAudioPlayer._republish_track_tasks9:::%%' ' ':: ':::sQA!AA!AAA A!AA!AA!A A  AA!)rrYrLrQrOrUrWrXrVrrZrMrrRN)rE@NotGivenOr[AudioSource | AudioConfig | list[AudioConfig] | None]rFrrGintr)None)rhzlist[AudioConfig]r)zAudioConfig | None)r:z4AudioSource | AudioConfig | list[AudioConfig] | Noner)z tuple[AudioSource, float] | None)r:r9r)z#AsyncIterator[rtc.AudioFrame] | str)rz-AudioSource | AudioConfig | list[AudioConfig]rzboolr)r)rzrtc.RoomrzNotGivenOr[AgentSession]rz#NotGivenOr[rtc.TrackPublishOptions]r)rr)r)rrr)r) rrrar9r=r<rzrr)r)r*r+r,r-rr[rnrurrrrrrrrrrrrrr5r(r'r$rBrBDsL[d !$18X18 1818 18f8J )$ 1<1 1  1n3c`# [R"UR5IShvN gN7f)z( Waits for the sound to finish playing. N)rSshieldrrs r$rPlayHandle.wait_for_playoutsnnT^^,,,s $.,.c>^SU4SjjnU"5R5$)NcD># TR5IShvN T$N7fr_)rrsr$ _await_impl)PlayHandle.__await__.._await_impls"'') ) )K *s   )r)r) __await__)r"rs` r$rPlayHandle.__await__s }&&((r'c[R"[R5 URR S5 SSS5 g!,(df  g=fr_)rrrSrrrrs r$rPlayHandle._mark_playout_dones4  !:!: ; NN % %d +< ; ;s A  A)rrNr)r)r)r)z Generator[Any, None, PlayHandle]) r*r+r,r-r[rrrrrr5r(r'r$rrs 0% &- ),r'rcL# [U5ShvN nU7v MN M 7fr_r)r#rs r$rrs) 1)< %K < s $!!$!$)r#rr)r)5 __future__rrSatexitrenumrfcollections.abcrrrimportlib.resourcesrrtypingr r numpyrlivekitr jobr logrtypesrrutilsrr utils.aior utils.audiorrreventsr ExitStackr registercloseEnumrrrr9r7rNrBrrr(r'r$rs"  DD."!),'0'*&&(%%& Ftyy FCNN+c14DD  * &N(N(b %,%,Pr'