ja!UddlZddlZddlmZmZddlmZddlZddlm Z m Z m Z m Z m Z hdZdZGddeZGd d Zdaedzed <d efd Zdejd efdZ d(deeeefdedzdedededeeeefdzdeeeefzdzd eeefeeeefddfzfdZ d)deeeefdeededzdeded eeefeeeefddfzf dZ d*deeezdedzd ed eeefd!Z d+d#ed$eededzd%ed eeeeff d&Z!d eeeeffd'Z"dS),N) GeneratorIterable)Any)RUIZHI_API_KEYRUIZHI_BASE_URLRUIZHI_EMBEDDING_MODELRUIZHI_RERANK_MODELRUIZHI_TEXT_MODEL>c >eZdZddededzdedzddffd ZxZS)RuizhiApiErrorNmessage status_code response_textreturncft|||_||_dSN)super__init__rr)selfrrr __class__s 9/home/longshao/multi-rider-rag/shared/ai/ruizhi_client.pyrzRuizhiApiError.__init__s1 !!!&*)NN)__name__ __module__ __qualname__strintr __classcell__)rs@rrrsj+++#*+TWZ^T^+jn++++++++++r rc eZdZddZdedededefdZdedeeefdeeeefddffd Z e d e edeeeefddffd Z e d e jddfd Ze deddfdZdS) _RuizhiClientrNcddd}tr dt|d<tjtjd|tjdd d |_dS) Nzapplication/jsonz gzip, deflate)z Content-TypezAccept-EncodingzBearer Authorization/gN@gr@)readF)base_urlheaderstimeoutverify)rhttpxClientrrstripTimeout_client)rr.s rrz_RuizhiClient.__init__su. /    B'A'A'AGO $|$+C00M$U333     r methodpathkwargsc FttdzD]} |jj||fi|}|jt vr!|tkr||F|||cS#tj tj tj f$r=}|tkrtd||||Yd}~d}~wtj$r}td||d}~wwxYwtd)NzRuizhi API request failed: z'Ruizhi API request failed after retries)range _MAX_RETRIESr5requestr_TRANSIENT_STATUS_CODES_sleep_raise_for_statusjsonr1TimeoutException NetworkErrorRemoteProtocolErrorr HTTPError)rr6r7r8attemptresponseexcs rr=z_RuizhiClient.request0sV\A-.. S SG S/4</GGGG'+BBBwQ]G]G]KK(((&&x000}}&&&*E,>@YZ % % %l**()Ls)L)LMMSVV G$$$$$$$$? S S S$%H3%H%HIIsR SFGGGs*AB (B  &D/3C''D9D  D json_payloadc#Kd}ttdzD]I} |jd||5}|jt vr-|tkr"|| ddd]|||| D]}d}|V ddddS#1swxYwY#tj tj tj f$r@}|s |tkrtd||||Yd}~d}~wtj$r}td||d}~wwxYwdS)NFr:POSTrATzRuizhi API stream failed: )r;r<r5streamrr>r?r@_iter_sse_chunks iter_linesr1rBrCrDrrE)rr7rIyieldedrFrGchunkrHs rrMz_RuizhiClient.streamBs\A-.. R RG R\((L(IIX+/FFF7UaKaKa G,,, **8444!%!6!6x7J7J7L7L!M!M$$"&# *E,>@YZ % % %Vg55()Kc)K)KLLRUU G$$$$$$$$? R R R$%G#%G%GHHcQ R R RsSC0C - C9AC ? C C CC C&E$?5D::E$ EE$linesc#hK|D]}|}|s|dr|dd}|dkrdS tj|}n*#tj$r}t d||d}~wwxYwt |tr|VdS)Nzdata:z[DONE]zInvalid Ruizhi stream chunk: )strip startswithrAloadsJSONDecodeErrorr isinstancedict)rRraw_linelinerQrHs rrNz_RuizhiClient._iter_sse_chunksVs  H>>##D w'' (ABBx~~''x V 4((' V V V$%KT%K%KLLRUU V%&&    sA..B=BBrGc|jrdS|t|}td|jd||j|j)NzRuizhi API returned HTTP z: )rr) is_successr,_response_error_detailrrtext)rGdetails rr@z_RuizhiClient._raise_for_statusgsd    F '11 H(< H H H H ,"-    r rFc:tjdd|zzdS)Ng?r)timesleep)rFs rr?z_RuizhiClient._sleepss! 3!W*%&&&&&r )rN)r!r"r#rr$rr=rZrrM staticmethodrrNr1Responser@r%r?r rr(r(sV    &HcHHHHHHH$R3Rd38nR4PSUXPX>[_aeKeAfRRRR( )DcNDRV>&"5G> D DDr kb_namescxdd|D}g|d|d}t||||S)N c3 K|] }d|V dS)@Nrg).0names r zchat_with_kb..s(::*d**::::::r run)rolecontent)rrrMrs)joinry)rqr{rrrMrs kb_content rag_messagess r chat_with_kbrsR:::::::JFXF*EEFL  E&Z P P PPr texts dimensionsc |pt||d}tdd|}t|tr|dgng}t|t stdt|d}g}|D]i}t|tr(t|d t std | |d j|S) N)rrinputrrKz /embeddingsrLdataz,Ruizhi embeddings response missing data listc\t|tr|ddndS)Nindexr)rYrZrm)items rzembedding..s*JtUYDZDZ,aDHHWa,@,@,@`ar )key embeddingz3Ruizhi embeddings response contains an invalid item) rrir=rYrZrmlistrsortedappend) rrrrrnrGrorderedvectorsrs rrrs 00 G }}$$V]$IIH'1(D'A'A I8<< # # #rD dD ! !MKLLLTaabbbG!#G**$%% XZ8M8Mt-T-T X !VWW WtK()))) Nr rTquery documentstop_kcr|pt|||d}tdd|}t|tr|St|t rK|d|dg}t|tr d|DStd) N)rrrrrrKz/rerankrLresultsrc<g|]}t|t|SrgrYrZrrs r zrerank..s'GGGT 40F0FGDGGGr z+Ruizhi rerank response missing results list)r rir=rYrrZrmr)rrrrrrnrGrs rrerankrs-- G }}$$VYW$EEH(D!!(D!!H,,y(,,vr*B*BCC gt $ $ HGGWGGG G F G GGr ctdd}t|tr7|dg}t|t r d|DSt d)NGETz/modelsrc<g|]}t|t|Srgrrs rrzlist_models..s'DDDTZd-C-CDDDDDr z(Ruizhi models response missing data list)rir=rYrZrmrr)rGrs r list_modelsrsw}}$$UI66H(D!!E||FB'' dD ! ! EDDTDDD D C D DDr )NFrorpNN)NFrz)Nr)NrT)#rArccollections.abcrrtypingrr1shared.config.configrrrr r r>r< RuntimeErrorrr(r5__annotations__rirfr$r_rrZboolr%floatryrrrrrgr rrs //////// >== +++++\+++Y'Y'Y'Y'Y'Y'Y'Y'x!% $$$]U^,)-/3EE4S>"E :E E E  E S#X $ & EtCH~%,E #s(^iS#Xd :;;EEEE< Q Q4S>" Q3i Q : Q  Q  Q  #s(^iS#Xd :;; Q Q Q Q c? : $u+ 6 HH HCyH :H  H  $sCx. HHHH,ET$sCx.)EEEEEEr