o lWi@sddlmZmZddlZddlZddlmZddlmZddl Z ddl Z ddl Z ddl m Z mZmZmZmZmZmZmZmZddlZddlZddlmZddlmZmZdd lmZdd l m!Z!e "e#Z$Gd d d e%eZ&Gd dde%eZ'GdddZ(GdddZ)GdddZ*GdddeZ+GdddeZ,GdddZ-GdddZ.GdddZ/Gdd d Z0Gd!d"d"e0Z1Gd#d$d$e0Z2dS)%)ABCabstractmethodN)ThreadPoolExecutor)Enum) Any AwaitableCallableDictListLiteralOptionalTupleUnion)ConnectionClosedOK) Connectionconnect)BaseElevenLabs) __version__c@s,eZdZdZdZdZdZdZdZdZ dZ d S) ClientToOrchestratorEventz9Event types that can be sent from client to orchestrator.pongclient_tool_result#conversation_initiation_client_datafeedbackcontextual_update user_message user_activityN) __name__ __module__ __qualname____doc__PONGCLIENT_TOOL_RESULT#CONVERSATION_INITIATION_CLIENT_DATAFEEDBACKCONTEXTUAL_UPDATE USER_MESSAGE USER_ACTIVITYr(r(m/var/www/html/asistente-voz-ia/venv/lib/python3.10/site-packages/elevenlabs/conversational_ai/conversation.pyrsrc@seZdZdZdZdZdS)AgentChatResponsePartTypestartdeltastopN)rrrSTARTDELTASTOPr(r(r(r)r*&sr*c@s2eZdZdZd deefddZdefddZdS) $UserMessageClientToOrchestratorEventz%Event for sending user text messages.NtextcCtj|_||_dSN)rr&typer2selfr2r(r(r)__init__/ z-UserMessageClientToOrchestratorEvent.__init__returncC|j|jdSNr5r2r=r7r(r(r)to_dict3z,UserMessageClientToOrchestratorEvent.to_dictr4) rrrr r strr8dictr?r(r(r(r)r1,sr1c@s(eZdZdZdddZdefddZdS) %UserActivityClientToOrchestratorEventz>Event for registering user activity (ping to prevent timeout).r:NcCs tj|_dSr4)rr'r5r>r(r(r)r8:s z.UserActivityClientToOrchestratorEvent.__init__cCs d|jiS)Nr5)r5r>r(r(r)r?=s z-UserActivityClientToOrchestratorEvent.to_dict)r:N)rrrr r8rBr?r(r(r(r)rC7s rCc@s,eZdZdZdefddZdefddZdS) )ContextualUpdateClientToOrchestratorEventzPEvent for sending non-interrupting contextual updates to the conversation state.r2cCr3r4)rr%r5r2r6r(r(r)r8Dr9z2ContextualUpdateClientToOrchestratorEvent.__init__r:cCr;r<r=r>r(r(r)r?Hr@z1ContextualUpdateClientToOrchestratorEvent.to_dictN)rrrr rAr8rBr?r(r(r(r)rDAsrDc@sVeZdZdZedeegdffddZeddZedefd d Z ed d Z dS) AudioInterfacezKAudioInterface provides an abstraction for handling audio input and output.input_callbackNcCdSa?Starts the audio interface. Called one time before the conversation starts. The `input_callback` should be called regularly with input audio chunks from the user. The audio should be in 16-bit PCM mono format at 16kHz. Recommended chunk size is 4000 samples (250 milliseconds). Nr(r7rFr(r(r)r+Os zAudioInterface.startcCrGa Stops the audio interface. Called one time after the conversation ends. Should clean up any resources used by the audio interface and stop any audio streams. Do not call the `input_callback` from `start` after this method is called. Nr(r>r(r(r)r-ZzAudioInterface.stopaudiocCrGzOutput audio to the user. The `audio` input is in 16-bit PCM mono format at 16kHz. Implementations can choose to do additional buffering. This method should return quickly and not block the calling thread. Nr(r7rLr(r(r)outputdrKzAudioInterface.outputcCrGzInterruption signal to stop any audio output. User has interrupted the agent and all previosly buffered audio output should be stopped. Nr(r>r(r(r) interruptnszAudioInterface.interrupt) rrrr rrbytesr+r-rOrQr(r(r(r)rELs   rEc@sZeZdZdZedeegedffddZeddZ edefd d Z ed d Z dS) AsyncAudioInterfacezVAsyncAudioInterface provides an async abstraction for handling audio input and output.rFNcdSrHr(rIr(r(r)r+{s zAsyncAudioInterface.startcrTrJr(r>r(r(r)r-zAsyncAudioInterface.stoprLcrTrMr(rNr(r(r)rOrUzAsyncAudioInterface.outputcrTrPr(r>r(r(r)rQszAsyncAudioInterface.interrupt) rrrr rrrRrr+r-rOrQr(r(r(r)rSxs   rSc @seZdZdZddeejddfddZddZd d Z dd e d e e e gefe e geeffdeddfddZd e de defddZd e de de e gdffddZddZdS) ClientToolsaRHandles registration and execution of client-side tools that can be called by the agent. Supports both synchronous and asynchronous tools running in a dedicated event loop, ensuring non-blocking operation of the main conversation thread. Args: loop: Optional custom asyncio event loop to use for tool execution. If not provided, a new event loop will be created and run in a separate thread. Using a custom loop prevents "different event loop" runtime errors and allows for better context propagation and resource management. Nloopr:cCs8i|_t|_||_d|_d|_t|_t |_ dSr4) tools threadingLocklock _custom_loop_loop_threadEvent_runningr thread_pool)r7rWr(r(r)r8s   zClientTools.__init__csdjrdSjdurj_jdSfdd}tj|ddd_jj dS)zHStart the event loop in a separate thread for handling async operations.Ncsht_tjjzjWjjd_dSjjd_wr4) asyncionew_event_loopr]set_event_loopr`set run_foreverclearcloser(r>r(r)run_event_loops        z)ClientTools.start..run_event_loopTzClientTools-EventLoop)targetdaemonname) r`is_setr\r]rerYThreadr^r+wait)r7rir(r>r)r+s    zClientTools.startcCs`|jr,|jr.|jdur|jn|j|jj|jr#|j|j j dddSdSdS)z6Gracefully stop the event loop and clean up resources.NF)ro) r]r`rmr\rgcall_soon_threadsafer-r^joinrashutdownr>r(r(r)r-s   zClientTools.stopF tool_namehandleris_asynccCsd|j%t|s td||jvrtd|d||f|j|<WddS1s+wYdS)aRegister a new tool that can be called by the AI agent. Args: tool_name: Unique identifier for the tool handler: Function that implements the tool's logic is_async: Whether the handler is an async function zHandler must be callableTool 'z' is already registeredN)r[callable ValueErrorrX)r7rsrtrur(r(r)registers  "zClientTools.register parameterscs||j||jvrtd|d|j|\}}Wdn1s#wY|r1||IdHSt|j||IdHS)zpExecute a registered tool with the given parameters. Returns the result of the tool execution. rvz' is not registeredN)r[rXrxrbget_event_looprun_in_executorra)r7rsrzrtrur(r(r)handles zClientTools.handlecallbackcsFjs tdjdurtdfdd}|dS)zExecute a tool and send its result via the provided callback. This method is non-blocking and handles both sync and async tools. z%ClientTools event loop is not runningNzEvent loop is not availablec szIdH}dd|pdddd}Wnty:}zddt|dd}WYd}~nd}~ww|dS)Nr tool_call_idz Client tool: z called successfully.F)r5rresultis_errorT)r}get ExceptionrA)rresponseer~rzr7rsr(r)_execute_and_callbacks"  z7ClientTools.execute_tool.._execute_and_callback)r`rm RuntimeErrorr]_schedule_coroutine)r7rsrzr~rr(rr) execute_tools  zClientTools.execute_toolcCs$|jdur |j|St||jS)z3Schedule a coroutine on the appropriate event loop.N)r\r] create_taskrbrun_coroutine_threadsafe)r7coror(r(r)r$s  zClientTools._schedule_coroutiner4)F)rrrr r rbAbstractEventLoopr8r+r-rArrrBrrboolryr}rrr(r(r(r)rVs$  "   rVc @sDeZdZdZ    d deedeedeedeefddZdS) ConversationInitiationDataz+Configuration options for the Conversation.N extra_bodyconversation_config_overridedynamic_variablesuser_idcCs(|pi|_|pi|_|p i|_||_dSr4)rrrr)r7rrrrr(r(r)r8/s    z#ConversationInitiationData.__init__)NNNN)rrrr r rBrAr8r(r(r(r)r,src@sheZdZdZ      d dedeedeedeedeeedeeed eeefd d ZdS) OnPremInitiationDataz;Configuration options for the Conversation in on-prem mode.Non_prem_conversation_url#post_call_transcription_webhook_urlpost_call_audio_webhook_urlagent_config_dictoverride_agent_config_listtools_config_listprompt_knowledge_basecCs.||_||_||_||_||_||_||_dSr4)rrrrrrr)r7rrrrrrrr(r(r)r8?s  zOnPremInitiationData.__init__)NNNNNN) rrrr rAr rBr r8r(r(r(r)r<s.   rc@seZdZdZ ddddddededeededeed ee d ee fd d Z d dZ ddZ ddZddZddZddZdS)BaseConversationzMBase class for conversation implementations with shared parameters and logic.N)config client_toolson_prem_configclientagent_idr requires_authrrrcCsP||_||_||_||_|pt|_|pt|_||_|j d|_ d|_ dS)Nr) rrrrrrrVrrr+_conversation_id_last_interrupt_id)r7rrrrrrrr(r(r)r8Ts     zBaseConversation.__init__cCsh|jr|jjS|jj}tj|j| drdndd }| ds)|d7}|d|j dt S)Nhttpswssws)scheme/z v1/convai/conversation?agent_id=z&source=python_sdk&version=)rrr_client_wrapper get_base_urlurllibparseurlparse_replace startswithgeturlendswithrr)r7 base_http_url base_ws_urlr(r(r) _get_wss_urlls & zBaseConversation._get_wss_urlcCs<|jjjj|jd}|j}d|vrdnd}||dtS)N)r?&zsource=python_sdk&version=)rconversational_ai conversationsget_signed_urlr signed_urlr)r7rr separatorr(r(r)_get_signed_urlwsz BaseConversation._get_signed_urlc Cs2td|jj|jj|jj|jj|jj|jjdS)Nenclave_setup_config)r5rrrrrr) jsondumpsrrrrrrrr>r(r(r)"_create_on_prem_initiation_message~sz3BaseConversation._create_on_prem_initiation_messagec CsDtd|jj|jj|jjdtdd|jjrd|jjiSiS)Nr python_sdk)sourceversion)r5custom_llm_extra_bodyrr source_infor)rrrrrrrrr>r(r(r)_create_initiation_messages  z+BaseConversation._create_initiation_messagec Cs\|ddkr|d}|jdusJ|d|_dS|ddkr;|d}t|d|jkr-dSt|d }||dS|dd krU|jrS|d }||d dSdS|dd kr|j r| d i}| dd}| dd}zt |}Wn t yt j }Ynw|||dSdS|ddkr|jr|d}||d|ddSdS|ddkr|jr|d}||ddSdS|ddkr|d}t|d|_|dS|ddkr|d}|||jr|dr|t|ddSdSdS|ddkr+| di}| d} d|di| di} || | dS dS) zCore message handling logic shared between sync and async implementations. Args: message: The parsed message dictionary message_handler: Handler object with methods for different operations r5 conversation_initiation_metadata&conversation_initiation_metadata_eventNconversation_idrL audio_eventevent_id audio_base_64agent_responseagent_response_eventagent_chat_response_parttext_response_partr2r,agent_response_correctionagent_response_correction_eventoriginal_agent_responsecorrected_agent_responseuser_transcriptuser_transcription_event interruptioninterruption_eventping ping_eventping_msclient_tool_callrsrrzrintrbase64 b64decodehandle_audio_outputcallback_agent_responsehandle_agent_responsestrip!callback_agent_chat_response_partrr*rxr/handle_agent_chat_response_part"callback_agent_response_correction handle_agent_response_correctioncallback_user_transcripthandle_user_transcripthandle_interruption handle_pingcallback_latency_measurementhandle_latency_measurementhandle_client_tool_call r7messagemessage_handlereventrLr2 part_type_str part_type tool_callrsrzr(r(r)_handle_message_coresp                   z%BaseConversation._handle_message_corec s|ddkr|d}|jdusJ|d|_dS|ddkr?|d}t|d|jkr.dSt|d }||IdHdS|dd kr\|jrZ|d }||d IdHdSdS|dd kr|j r| d i}| dd}| dd}zt |}Wn t yt j }Ynw|||IdHdSdS|ddkr|jr|d}||d|dIdHdSdS|ddkr|jr|d}||dIdHdSdS|ddkr|d}t|d|_|IdHdS|ddkr|d}||IdH|jr|dr|t|dIdHdSdSdS|ddkrD| di}| d} d|di| di} || | dS dS) z.Async wrapper for core message handling logic.r5rrNrrLrrrrrrrr2rr,rrrrrrrrrrrrrsrrzrrr(r(r)_handle_message_core_asyncsr                 z+BaseConversation._handle_message_core_asyncr4)rrrr rrAr rrrVrr8rrrrrrr(r(r(r)rQs8    CrcseZdZUeed<eeegdfed<eeeegdfed<eeeegdfed<eeegdfed<eee gdfed<eeed<ee j ed <e j ed <ee ed < d)dddddddddd d ededeedededeedeedeeegdfdeeeegdfdeeeegdfdeeegdfdeee gdfdeedeeffddZddZddZdeefddZdefddZd d!Zdefd"d#Zd$efd%d&Zd'd(ZZS)* Conversationaudio_interfaceNrrrrrcallback_end_sessionr^ _should_stop_ws rrrrrrrrrrrrrrrrc  ^tj|||||||d||_||_| |_| |_| |_| |_| |_d|_ d|_ t |_ dS)aConversational AI session. BETA: This API is subject to change without regard to backwards compatibility. Args: client: The ElevenLabs client to use for the conversation. agent_id: The ID of the agent to converse with. user_id: The ID of the user conversing with the agent. requires_auth: Whether the agent requires authentication. audio_interface: The audio interface to use for input and output. client_tools: The client tools to use for the conversation. callback_agent_response: Callback for agent responses. callback_agent_response_correction: Callback for agent response corrections. First argument is the original response (previously given to callback_agent_response), second argument is the corrected response. callback_agent_chat_response_part: Callback for streaming text response chunks. First argument is the text chunk, second argument is the type (START, DELTA, STOP). callback_user_transcript: Callback for user transcripts. callback_latency_measurement: Callback for latency measurements (in milliseconds). rrrrrrrN)superr8rrrrrrrr^rrYr_rr7rrrrrrrrrrrrrr __class__r(r)r8)s&' zConversation.__init__cCs8|jr|n|}tj|j|fd|_|jdS)zoStarts the conversation session. Will run in background thread until `end_session` is called. )rjargsN)rrrrYrn_runr^r+r7ws_urlr(r(r) start_sessionfszConversation.start_sessioncCs:|j|jd|_|j|jr|dSdSz6Ends the conversation session and cleans up resources.Nrr-rrrrerr>r(r(r) end_sessionos    zConversation.end_sessionr:cCs|jstd|j|jS)Waits for the conversation session to end. You must call `end_session` before calling this method, otherwise it will block. Returns the conversation ID, if available. Session not started.)r^rrqrr>r(r(r)wait_for_session_endys z!Conversation.wait_for_session_endr2c C`|jstdt|d}z|jt|WdSty/}z t d|d}~ww)Send a text message from the user to the agent. Args: text: The text message to send to the agent. Raises: RuntimeError: If the session is not active or websocket is not connected. /Session not started or websocket not connected.r2Error sending user message: N rrr1sendrrr?rloggererrorr7r2rrr(r(r)send_user_messages  zConversation.send_user_messagec Cs\|jstdt}z|jt|WdSty-}z t d|d}~ww)Register user activity to prevent session timeout. This sends a ping to the orchestrator to reset the timeout timer. Raises: RuntimeError: If the session is not active or websocket is not connected. r!Error registering user activity: N rrrCrrrr?rrrr7rrr(r(r)register_user_activitysz#Conversation.register_user_activityc Cr)aSend a contextual update to the conversation. Contextual updates are non-interrupting content that is sent to the server to update the conversation state without directly prompting the agent. Args: content: The contextual information to send to the conversation. Raises: RuntimeError: If the session is not active or websocket is not connected. rr!Error sending contextual update: N rrrDrrrr?rrrrr(r(r)send_contextual_updates  z#Conversation.send_contextual_updater c sJt|dd_jr_fdd}j|j szt j dd}j rHWWddS |Wn;tye}z WYd}~n*d}~wtymYnty}ztd|WYd}~nd}~wwj r0d_WddS1swYdS)Nmax_sizec s~ztdt|iWdSty YdSty>}zt d|WYd}~dSd}~wwNuser_audio_chunkz Error sending user audio chunk: rrrr b64encodedecoderrrrrrLrr7rr(r)rFs z)Conversation._run..input_callback?timeoutError receiving message: )rrrrrrrr+rrmrloadsrecv_handle_messagerr TimeoutErrorrrr)r7r rFrrr(r/r)r s8     "zConversation._runcCs(Gddd}|||}|||dS)Nc@\eZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ dS)z8Conversation._handle_message..SyncMessageHandlercS8||_||_|j|_|j|_|j|_|j|_|j|_dSr4 conversationrrrrrrr7r;rr(r(r)r8 zAConversation._handle_message..SyncMessageHandler.__init__cSs|jj|dSr4r;rrOrNr(r(r)rzLConversation._handle_message..SyncMessageHandler.handle_audio_outputcS|j|dSr4r;rr7rr(r(r)rzNConversation._handle_message..SyncMessageHandler.handle_agent_responsecS|j||dSr4r;rr7original correctedr(r(r)rr?zYConversation._handle_message..SyncMessageHandler.handle_agent_response_correctioncSrDr4r;rr7r2rr(r(r)rr?zXConversation._handle_message..SyncMessageHandler.handle_agent_chat_response_partcSr@r4r;rr7 transcriptr(r(r)rrCzOConversation._handle_message..SyncMessageHandler.handle_user_transcriptcSs|jjdSr4r;rrQr>r(r(r)rrCzLConversation._handle_message..SyncMessageHandler.handle_interruptioncSs |jtd|dddSNrr)r5rrrrrr7rr(r(r)rszDConversation._handle_message..SyncMessageHandler.handle_pingcSr@r4r;rr7latencyr(r(r)rrCzSConversation._handle_message..SyncMessageHandler.handle_latency_measurementc"fdd}jj|||dS)Ncs&jjsjt|dSdSr4)r;rrmrrrrrr>r(r) send_responses zgConversation._handle_message..SyncMessageHandler.handle_client_tool_call..send_responser;rrr7rsrzrWr(r>r)r zPConversation._handle_message..SyncMessageHandler.handle_client_tool_callN rrrr8rrrrrrrrrr(r(r(r)SyncMessageHandler  r\)r)r7rrr\rtr(r(r)r6s 0zConversation._handle_messager4)rrrrE__annotations__r rrAr*rrYrnr_rrrrrVrr8r rrrr"r%r r6 __classcell__r(r(rr)rsv         =   (rc seZdZUeed<eeegedfed<eeeegedfed<eeee gedfed<eeegedfed<eee gedfed<eegedfed<ee j ed <e j ed <eejed < d)dddddddddd d ededeedededeedeedeeegedfdeeeegedfdeeee gedfdeeegedfdeee gedfdeegedfdeeffddZddZddZdeefddZdefddZd d!Zdefd"d#Zd$efd%d&Zd'd(ZZS)*AsyncConversationrNrrrrrr_taskrrrrrrrrrrc  r)a@Async Conversational AI session. BETA: This API is subject to change without regard to backwards compatibility. Args: client: The ElevenLabs client to use for the conversation. agent_id: The ID of the agent to converse with. user_id: The ID of the user conversing with the agent. requires_auth: Whether the agent requires authentication. audio_interface: The async audio interface to use for input and output. client_tools: The client tools to use for the conversation. callback_agent_response: Async callback for agent responses. callback_agent_response_correction: Async callback for agent response corrections. First argument is the original response (previously given to callback_agent_response), second argument is the corrected response. callback_agent_chat_response_part: Async callback for streaming text response chunks. First argument is the text chunk, second argument is the type (START, DELTA, STOP). callback_user_transcript: Async callback for user transcripts. callback_latency_measurement: Async callback for latency measurements (in milliseconds). callback_end_session: Async callback for when session ends. rN)rr8rrrrrrrrarrbr_rrrr(r)r8*s&( zAsyncConversation.__init__cs.|jr|n|}t|||_dS)zmStarts the conversation session. Will run in background task until `end_session` is called. N)rrrrbrr rar r(r(r)r hszAsyncConversation.start_sessioncsH|jIdH|jd|_|j|jr"|IdHdSdSr rr>r(r(r)rps  zAsyncConversation.end_sessionr:cs"|jstd|jIdH|jS)rrN)rarrr>r(r(r)rzs  z&AsyncConversation.wait_for_session_endr2c h|jstdt|d}z|jt|IdHWdSty3}z t d|d}~ww)rrrNrrrr(r(r)rs  "z#AsyncConversation.send_user_messagec sd|jstdt}z|jt|IdHWdSty1}z t d|d}~ww)rrNrr r!r(r(r)r"s"z(AsyncConversation.register_user_activityc rb)aSend a contextual update to the conversation. Contextual updates are non-interrupting content that is sent to the server to update the conversation state without directly prompting the agent. Args: text: The contextual information to send to the conversation. Raises: RuntimeError: If the session is not active or websocket is not connected. rrNr#r$rr(r(r)r%s  "z(AsyncConversation.send_contextual_updater c stj|dd4IdH_jrIdHIdHfdd}j|IdHzzj sz1t j  ddIdH}j r_WWd_WdIdHdSt|}|IdHWn9t jyxYn0tyIdHYn&ty}ztd|IdHWYd}~n d}~wwj r=Wd_nd_wWdIdHdS1IdHswYdS)Nr&r'c sztdt|iIdHWdSty'IdHYdStyH}zt d|IdHWYd}~dSd}~wwr)r+r.r/r(r)rFs z.AsyncConversation._run..input_callbackr0r1r3) websocketsrrrrrrrr+rrmrbwait_forr5rr4r6r7rrrrr)r7r rF message_strrrr(r/r)r sB       .zAsyncConversation._runcs0Gddd}|||}|||IdHdS)Nc@r8)z>AsyncConversation._handle_message..AsyncMessageHandlercSr9r4r:r<r(r(r)r8r=zGAsyncConversation._handle_message..AsyncMessageHandler.__init__cs|jj|IdHdSr4r>rNr(r(r)rzRAsyncConversation._handle_message..AsyncMessageHandler.handle_audio_outputc|j|IdHdSr4rArBr(r(r)rzTAsyncConversation._handle_message..AsyncMessageHandler.handle_agent_responsec|j||IdHdSr4rErFr(r(r)rrfz_AsyncConversation._handle_message..AsyncMessageHandler.handle_agent_response_correctioncrir4rIrJr(r(r)rrfz^AsyncConversation._handle_message..AsyncMessageHandler.handle_agent_chat_response_partcrgr4rKrLr(r(r)rrhzUAsyncConversation._handle_message..AsyncMessageHandler.handle_user_transcriptcs|jjIdHdSr4rNr>r(r(r)rrhzRAsyncConversation._handle_message..AsyncMessageHandler.handle_interruptioncs(|jtd|ddIdHdSrOrPrQr(r(r)r szJAsyncConversation._handle_message..AsyncMessageHandler.handle_pingcrgr4rRrSr(r(r)rrhzYAsyncConversation._handle_message..AsyncMessageHandler.handle_latency_measurementcrU)Ncs,jjstjt|dSdSr4) r;rrmrbrrrrrrVr>r(r)rWs zmAsyncConversation._handle_message..AsyncMessageHandler.handle_client_tool_call..send_responserXrYr(r>r)rrZzVAsyncConversation._handle_message..AsyncMessageHandler.handle_client_tool_callNr[r(r(r(r)AsyncMessageHandlerr]rj)r)r7rrrjrtr(r(r)r6s 0z!AsyncConversation._handle_messager4)rrrrSr^r rrArr*rrbTaskr_rcWebSocketClientProtocolrrrrVrr8r rrrr"r%r r6r_r(r(rr)r`sv       >  ,r`)3abcrrrbrconcurrent.futuresrenumrrloggingrYtypingrrrr r r r r r urllib.parserrcwebsockets.exceptionsrwebsockets.sync.clientrr base_clientrrr getLoggerrrrArr*r1rCrDrErSrVrrrrr`r(r(r(r)sB  ,       ,, L