qidZddlmZmZddlmZddlmZmZm Z m Z m Z ddl m Z ddlmZmZ ddlmZddlmZGd d eZy #e$r"Zej.d ed ed Z[wwxYw)z,Langchain integration processor for Pipecat.)OptionalUnion)logger)FrameLLMContextFrameLLMFullResponseEndFrameLLMFullResponseStartFrame TextFrame)OpenAILLMContextFrame)FrameDirectionFrameProcessor)AIMessageChunk)RunnablezLIn order to use Langchain, you need to `pip install pipecat-ai[langchain]`. zMissing module: Nc~eZdZdZddedeffd ZdefdZdede ffd Z e d e ee fd efd Zd efd ZxZS)LangchainProcessora.Processor that integrates Langchain runnables with Pipecat's frame pipeline. This processor takes LLM message frames, extracts the latest user message, and processes it through a Langchain runnable chain. The response is streamed back as text frames with appropriate response markers. chaintranscript_keycLt|||_||_d|_y)zInitialize the Langchain processor. Args: chain: The Langchain runnable to use for processing messages. transcript_key: The key to use when passing input to the chain. N)super__init___chain_transcript_key_participant_id)selfrr __class__s Y/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/processors/frameworks/langchain.pyrzLangchainProcessor.__init__'s'  -.2participant_idc||_y)zSet the participant ID for session tracking. Args: participant_id: The participant ID to use for session configuration. N)r)rrs rset_participant_idz%LangchainProcessor.set_participant_id3s .rframe directioncKt|||d{t|ttfrt j d|t|tr|jjn|jj}|dd}|j|jd{y|j||d{y77"7 w)zProcess incoming frames and handle LLM message frames. Args: frame: The incoming frame to process. direction: The direction of frame flow in the pipeline. NzGot transcription frame content) r process_frame isinstancerr rdebugcontextmessages get_messages_ainvokestrip push_frame)rr!r"r*textrs rr&z LangchainProcessor.process_frame;sg#E9555 eo/DE F LL3E7; <e%:; &&]]//1  ! Y/D-- - - -//%3 3 3 6 . 3s4CCBC4C5CCCCCr/returncX|xtdx\|Stdx\|jS y)zExtract token value from various text types. Args: text: The text or message chunk to extract value from. Returns: The extracted string value. )strrr%)r/s r__get_token_valuez$LangchainProcessor.__get_token_valueSs3 !||#"rcKtjd||jtd{ |jj |j |idd|jii23d{}t|j|}d|_ |j|d{D77A7 6nW#t$rtj|dYn4t$r)}|jd|| d{7Yd}~nd}~wwxYw|jtd{7y#|jtd{7wxYww) z5Invoke the Langchain runnable with the provided text.zInvoking chain with N configurable session_id)configTz! generator was closed prematurelyzUnknown error occurred: ) error_msg exception)rr(r.r rastreamrrr $_LangchainProcessor__get_token_valueincludes_inter_frame_spaces GeneratorExitwarning Exception push_errorr)rr/tokenr!es rr,zLangchainProcessor._ainvokees? +D623oo79::: =#{{22%%t,&t7K7K(LM 3  - -e"$"8"8"?@481ooe,,, ; - -   G NNdV#DE F Y//.Fqc,JVW/X X X Y//"9";< < <$//"9";< < 8B:9B><6C2B<3C8E!:B><C>C?D:!D!D:#D+DDD D:DD:E!3D64E!:EEEE!)input)__name__ __module__ __qualname____doc__rr4rr rr r& staticmethodrrr=r, __classcell__)rs@rrrsr 3h 3 3..44>40c>&9 :s"=3=rr)rItypingrrlogururpipecat.frames.framesrrrr r 1pipecat.processors.aggregators.openai_llm_contextr "pipecat.processors.frame_processorr r langchain_core.messagesrlangchain_core.runnablesrModuleNotFoundErrorrDerrorrArr2rrrUsp3"TM,61 W=W= ,FLL_` &qc* ++,s AA- A((A-