j dZddlmZddlmZmZmZddlmZddl m Z m Z  ddede defd Z d eedeefd Zd ed e defd Zd eed e deefdZy)zUtilities for chat loaders.)deepcopy)IterableIteratorList) ChatSession) AIMessage BaseMessage chat_session delimiterreturnc g}|dD]}t|jtrId}|jD]1}t|tr||j ddxsdz }-||z }3||_t|jt st d|j|s|jt|t|t|dr|djj d|djd|jj dk(rt|djt st d|dj|dj|z|jzj|d_|djj dgj|jj dxsg|jt|t|S) zMerge chat runs together in a chat session. A chat run is a sequence of messages from the same sender. Args: chat_session: A chat session. Returns: A chat session with merged chat runs. messagestextzAChat Loaders only support messages with content type string, got sendereventsr) isinstancecontentlistdictgetstr ValueErrorappendrtypeadditional_kwargsstripextendr)r r rmessagerrs p/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langchain_community/chat_loaders/utils.pymerge_chat_runs_in_sessionr# s#%H + goot ,D"??gt,GKK39r9DGOD + #GO'//3/')  OOHW- . wXb\ 2 3 ..228<H ..x8((,,X67hrl22C8 #B<//02  $$y07??Beg RL  RL * * . .x < C C))--h7=2  OOHW- .E,F  )) chat_sessionsc#4K|D]}t|yw)zMerge chat runs together. A chat run is a sequence of messages from the same sender. Args: chat_sessions: A list of chat sessions. Returns: A list of chat sessions with merged chat runs. N)r#)r%r s r"merge_chat_runsr'>s& (66&src g}d}|dD]q}|jjd|k(r@t|j|jj t |dd}|dz }|j |st|S) Convert messages from the specified 'sender' to AI messages. This is useful for fine-tuning the AI to adapt to your voice. rrrexampleN)rrr*r)rrrrcopygetattrrr)r%rr num_convertedr!s r"map_ai_messages_in_sessionr/Ms HM ,  $ $ ( ( 2f <")";";"@"@"BD9G Q M -  ))r$c#6K|D]}t||yw)r)N)r/)r%rr s r"map_ai_messagesr1`s& (v>>&sN)z )__doc__r,rtypingrrrlangchain_core.chat_sessionsrlangchain_core.messagesrr rr#r'r/r1r$r"r7s!++4:171*1**-1*1*h 78K#8 7Xk=R 7*k*3*;*&?K(?25? k?r$