:Ъi>!,,ry~~a/@/@@ AArCtextreturnctjdd|}tjdd|}tjdd|tjtjz}|S)a" Clean and preprocess context text for LLM consumption This function removes unwanted formatting elements that might confuse the LLM. Args: text (str): Raw text content to be cleaned Returns: str: Cleaned text ready for LLM processing z\n?\s*\d+[\.]\)\s* u [•\-–▪]z\n\s*References?\s*:\s*$)flags)resub MULTILINE IGNORECASEstrip)r\s r) clean_contextrgs` 6'd 3 3D 6"C . .D 6-r4r|bm?[ \ \ \D ::<<rC) zph.dzm.sczd.sc naturopath disseminated coagulationdic pathology mechanism theoreticalrobertyoungc|tfddDr dStfddDr dS|S)a Sanitize answer based on question type This function applies specific response patterns for certain types of questions to ensure scientifically accurate and appropriately cautious responses. Args: text (str): Original answer text from LLM question (str): Original user question Returns: str: Potentially modified answer based on question type c3 K|]}|vV dSNrT.0kqs r) z"sanitize_answer..s' @ @a16 @ @ @ @ @ @rC)smallthreeprovestudyaTBased on the information provided in the blog context, the study is exploratory and limited by its very small sample size. It cannot establish proof that the intervention removes toxins from the human body. The findings provide only initial observations, and larger, well-controlled studies would be required to draw definitive conclusions.c3 K|]}|vV dSrsrTrts r)rxz"sanitize_answer..s' G Ga16 G G G G G GrC) differentcomparemarketothera8The blog context does not explicitly provide information about the study size, its stated purpose, or its methodological limitations in relation to this question. As a result, no conclusions can be drawn based on the available information. Further well-controlled studies would be required to address this topic.)lowerany)r\rDrws @r)sanitize_answerrs A @ @ @ @? @ @ @@@  &   G G G GF G G GGG  W   KrCr2c #K tjdd|ddddddd dd 5}|jd krNt|d r|jnd}t d|jd|d|jdV ddddSd}|D]}|s tj| d}d|vr|dr d}|dV| drn=]#tj $rYnt$r}dt|VYd}~nd}~wwxYw|sdVddddS#1swxYwYdS#tjj$rdVYdStjj$rdVYdSt$rh}t dt#|jdt|dt#|jdt|VYd}~dSd}~wwxYw)a Call locally running LLM via Ollama with streaming capability This function establishes a streaming connection to the Ollama service and yields response chunks as they become available, enabling real-time response delivery to the client. Args: prompt (str): Formatted prompt including context and question Yields: str: Response chunks from the LLM as they are generated Raises: Exception: If connection to Ollama fails or streaming encounters errors r.r/Tffffff??333333? temperaturetop_prepeat_penalty num_predictr1r2r3options,r5r3r6r7r\zNo error detailsz[OLLAMA ERROR] Status z: z$[LLM ERROR]: Ollama returned status z?. The model may be loading. Please wait a moment and try again.NFutf-8r;donez[PARSING ERROR]: zT[LLM ERROR]: No response received. The model may still be loading. Please try again.zZ[LLM ERROR]: Cannot connect to Ollama service. Is it running? Start it with 'ollama serve'za[LLM ERROR]: Ollama request timed out. The model may be loading or the prompt may be too complex.z[OLLAMA EXCEPTION]: [LLM ERROR]: z - )r8r9r:hasattrr\r iter_linesr5loadsdecodegetJSONDecodeErrorrrR exceptionsConnectionErrorTimeouttyperN)r2r& error_textreceived_responselinedatar(s r)call_llama2_streamrs"A< ] 1+ #& &)#&      6 m}# '.q&'9'9QQVV?Q Lq}LL LLMMMLQ]LLLLLL-6 m6 m6 m6 m6 m6 m6 m6 m2!&    :dkk'&:&:;;D"T)/d:.>/,0)":....xx''+H 6c!ff66666EEEEE % mllllm6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 m6 mp   .kkkjjjjjjj   &rrrqqqqqqq <<< AT!WW%5AAQAABBB;d1gg.;;3q66;;;;;;;;;;;rYiandoinisitmemyofortoandcanforhowthewhydoesfromgivethatthiswhatexampleexplaincBg|]}|vt|dk|S))r!)ruw skip_wordss r) zchat..s8hhh!QjEXh]`ab]c]cfg]ghAhhhrCc3PK|] }|dvV!dS)r N)r)ruwordarts r)rxzchat..s8IIts7|))+++IIIIIIrCg?g?c|dS)NrrT)xs r)zchat..s !A$rC)keyreverseNz[SEARCH] Top match: 'rr 2z' score=z.3fz#[SEARCH] No match above 0.45 for: ''z?[CASE 4] TRIGGERED: No DB match + No conversation history for 'a#I don't have reliable information about this specific topic in the available content. Could you please provide more details or rephrase your question? Alternatively, you might want to ask about related topics like general health principles, wellness practices, or preventive care approaches.rDr`rEr_g333333?c3 K|]}|vV dSrsrT)rurquestion_lowers r)rxzchat..s(,n,nT^-C,n,n,n,n,n,nrC z4[CASE 3] TRIGGERED: No DB match + Continuing topic (.2fz similarity) for 'z Matching against: Question='z ...' Answer='z...'rz Q: z A:c3Kd} t}|D]}|r ||z }|V d|}t jj|tjz }td|dddS#t$r}dt|VYd}~dSd}~wwxYw)Nr`r_z[TIMING] CASE 3 LLM: rsr) rrfjoinsplitrJr=rDrHrrrR) full_answer llm_functionchunk clean_answerllm_timer( llm_prompt llm_startrws r)stream_case3_responsez#chat..stream_case3_responses"$K7'@ %1\*%=%=,,E${{}}, +u 4 &+ (+xx 0A0A0C0C'D'D 3A4EqzS_```#'9;;#:EhEEEEFFFFF$7776c!ff666666666667sBB'' C1C  Cz text/plain) media_typez3[CASE 4] TRIGGERED: No DB match + Different topic (z Context: Question='c3KVdSrsrT)general_answersr)stream_general_responsez%chat..stream_general_response1s rCr)r rz7SELECT content FROM dr_young_all_articles WHERE id = %srcontentizCONTEXT LENGTH:z ic 3f Kd} t}|D]3}|r||z }|Vtjd4t jd }D]/}|dr%|d|vr||d0|rdV|D] }|dV dVtdD]\}}|d |d dVd | }tj j |tjz }tjz } td td dd ddddtd dd|dd| dddS#t$r} dt| VYd} ~ dSd} ~ wwxYw)Nr`g{Gz?zhttps?://[^\s\)]+rz See here for more info:  z References: rz. r r_z [TIMING]:z Embedding: rzs | DB: z s | Search: rz Context: z s | LLM: z s | Total: r)rrfrHsleeprbfindallr enumeraterrrJr=rDrrrR)rrr content_urlsrefrrrr total_timer(context context_timedb_time embed_timerr2rw references search_time start_times r)stream_responsezchat..stream_responseVs_ % +-L%f-- % %;;==%5(KKKKJt$$$:&:GDDL! 4 4u:4#e*L"@4 ''E 333 %5555'%%C ***$$$$$ # # ##J22 / /3..c'l.......88K$5$5$7$788L '(91:| T T Ty{{Y.Hz1J +    c ccccccQ\cccc d d d clccccccR\cccc d d d d d + + +*#a&&** * * * * * * * * * +sE>F F0F++F0)rHrBr=rr! embed_modelencoderDr rr r[rrrrsortedrset intersectionunionrrfetchonergr)*rwrI embed_start query_embdb_startr"r#scored search_startscoremeaningful_wordslast_interaction last_question last_answercombined_contextconversation_keywordscurrent_keywordsoverlap total_uniquesimilarity_ratiorr context_start context_parts_ content_rowcleanedrrrrrrrrrr2rrrrrs*` @@@@@@@@@@@@@@r)chatrsJ'q'899G 8Q%6 8 8999 :s7|| : : :;;;)++K"" #I {*Jy{{H   D +++ & &CikkH$GF9;;L ( (y#k"233LLL hhhhqz'7'7'9'9'?'?'A'Ahhh IIII8HIII I I  TME 4< ( MM5#, ' ' 'F = = =bqb AF)++ ,KC \fQil7&;CRC&@\\&QR)TU,\\\]]]] AAJAAABBB TU))++J  aTUT^aaa b b bE N@ /6=wr{{2 L\d,00R@@FFHHHbdMHX`*..x<<BBDDD^`K#0??+?? $'(8(>(>(@(@$A$A !">#7#7#9#9:: /<<=MNNOOG4::;KLLMML9E9IPw55q  #%. ,n,n,n,nP`PfPfPhPhiljlilPm,n,n,n)n)n. CM]CCCuvuCCCDDDo crc8JooYdehfhehYioooppp#.dsd"3J !IKK 7777777*))>)>)@)@\ZZZZBL\BBBtut~BBBCCCf}SbS/AffP[\_]_\_P`fffgggI ! ! ! ! !!!8!8!:!:|TTTTIKKMMJ * *3\u:     MPSTXPY|\\\llnn  *#K $:5D5$ABBG   ) ) ) S//000kk-((G9;;.L%4%.JF  I*+*+*+*+*+*+*+*+*+*+*+*+*+*+X    rC)=rQsysosrHrbrr5 subprocessnumpyr collectionsrasynciodotenvrfastapirfastapi.responsesrpydanticrr8sentence_transformersrGROQ_AVAILABLErpathdirnameabspath__file__ current_dir project_rootinsert database.dbr apptorchrr groq_clientrAr r* threadingThreadstartr<rRrBrJrLr[rgFORBIDDEN_TERMSrrrrrr9rrTrCr)r7s  //////555555JKKKgoobgooh7788 w{++ < &&&&&&g 0T  !!   ,--- 444: *4888>>@@@TTT4 ,T:::@@BBB0c0000 4 4 4S 4 4 4 4 % % % % %) % % % B B B2########LR