/cj,dZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl Z ddl Z e j e jjddlmZmZmZddlmZ ddlZn #e$rdZYnwxYwdadadadadadadadada da!da"dZ#Gdde Z$d Z%dS) z HTTP REST API handler for the Qwen Pipeline. Serves static files + REST APIs for profiles, conversations, recordings, ACRS proxy, TTS test, translation, and tool generation. N)SimpleHTTPRequestHandler)QwenTtsRealtimeQwenTtsRealtimeCallback AudioFormat)OpenAIc 2|a|a|a|a|a|a|a|a|a| a | a dS)zBInitialize module-level references. Called once at server startup.N) HTTP_DIRRECORDINGS_DIRPROFILES_COLLECTIONCONVERSATIONS_COLLECTIONAPI_KEYLLM_BASE LLM_MODEL TTS_MODEL TTS_VC_MODEL LANG_NAMES_cloned_voices_ref) http_dirrecordings_dirprofiles_collectionconversations_collectionapi_keyllm_base llm_model tts_model tts_vc_model lang_namescloned_voices_refs I/home/m1-ai/DEPLOYMENTS/AI-PHONE/ZACK-UPDATE/fixing_leaked/http_routes.pyinit_http_routesr /sDH#N-7GHIILJ*ceZdZdZfdZfdZfdZdZdZddZ d Z d Z d Z d Z d ZdZedZdZdZdZdZdZdZdZdZdZdZdZdZdZdZxZ S)PipelineHTTPHandlerz>## # ;* * *??$$ $ ;/ / /&&(( ( ;7 7 7))++ + ;3 3 3%%'' ' ;2 2 2$$&& & ;0 0 0((** * ; ! !"4 5 5 -,&&v{37I3J3J3K3K'LMMC'',, , r!ctj|j}|jdrNtj|jt dd}||S|jdrNtj|jt dd}||S| ddS)Nz/api/profiles/r3rE) r5r6r7r-r.r:r;_delete_profile_delete_conversationrQ)r(rBnamerCs r do_DELETEzPipelineHTTPHandler.do_DELETE~s&&ty11 ; ! !"2 3 3 .<'' C8H4I4I4J4J(KLLD''-- - ; ! !"7 8 8 2,&&v{37L3M3M3N3N'OPPC,,S11 1 r!cLtj|d}|||dd|dt |||j|dS)Nutf-8 Content-Typeapplication/jsonContent-Length) jsondumpsencode send_response send_headerr; end_headerswfilewrite)r(datastatusbodys r_json_responsez"PipelineHTTPHandler._json_responsesz$&&w// 6""" );<<< )3t99555  r!cts|ddidS t}i}t|dD]E\}} t j|d|||<*#tjtf$rYBwxYw||dS#t$r0}|dt|idYd}~dSd}~wwxYw)NerrorChromaDB not availableids documents) r riget enumerater^loadsJSONDecodeError IndexError Exceptionstr)r(resultprofilesipides rr8z"PipelineHTTPHandler._list_profiless" Q&&1I'JCPP P 8(,,..FH#F5M22  3$(Jvk/B1/E$F$FHSMM,j9D    ) ) ) ) ) 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8s;5B.#A;:B.;BB.BB.. C(8%C##C(cdts|ddidS t|jdd}t j|j|}|d}|d}t |gt j |gdgg td ||d d idS#t$rB}td ||dt|idYd}~dSd}~wwxYw)Nrkrlrmr]rrVrfg)rnro embeddingsz[Profiles] Saved: okTz[Profiles] Save error: rp)r riintheadersrqr^rsrfilereadupsertr_printrvrw)r(lengthrhrVrfr|s rrFz!PipelineHTTPHandler._save_profilesT" Q&&1I'JCPP P 8))*:A>>??F:djoof5566Dz9PipelineHTTPHandler._list_conversations..s QtWr!T)keyreverserp)r rirqrrr^rs_recording_pathreplace isinstancedictappendosr-isfilertrusortrvrw) r(rx conversationsrzrCdocrec_file caller_file_fa _fa_summaryr|s rr9z'PipelineHTTPHandler._list_conversationssd' Q&&1I'JCPP P 8-1133FM#F5M22  3*VK%8%;<>!$$!IaLLL   t - - - - - 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8sBB;; C5%C00C5c~tjdd|}tjt |dzS)z,Return safe filesystem path for a recording.z[^\w\-]_r)resubrr-joinr )rCsafes rrz#PipelineHTTPHandler._recording_paths1vj#s++w||ND7N;;;r!c t|jdd}|dkr|ddidS|j|}||}t|d5}||dddn #1swxYwYtdtj |d t|d |d d idS#t$r0}|dt|id Yd}~dSd}~wwxYw)z1Save uploaded audio recording for a conversation.r]rrkzNo datawbNz[Recording] Saved:  (z bytes)rTrp)rrrqrirrropenrerrr-basenamer;rvrw)r(rCrrffilepathrr|s rrPz#PipelineHTTPHandler._save_recordings 8))*:A>>??F{{**GY+?EEE:??6**D++C00Hh%%                  X(8(8(B(BXXc$iiXXX Y Y Y   t - - - - - 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8sCAD ?D B) D )B--D 0B-1AD E%EEc|drD|dtd }||dd}d}n||}d}tj|s|dS tj|}t|d5}| }dddn #1swxYwY| d | d || d t|| d d |d| |j|dS#t $r0}|dt%|idYd}~dSd}~wwxYw)z6Serve a recording file (browser .webm or caller .wav)._callerNrrz audio/wavz audio/webmrErbrXr[r]zContent-Dispositionzattachment; filename=""rkrp)endswithr;rrrr-rrQrrrrarbrcrdrervrirw) r(rCreal_cidr content_typefilenamerrfr|s rr=z"PipelineHTTPHandler._get_recordings << " " (+S^^O+,H++H55==g}UUH&LL++C00H'Lw~~h'' (??3'' ' 8w''11Hh%% vvxx                 s # # #   ^\ : : :   -s4yy 9 9 9   2AhAAA C C C       J  T " " " " " 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8s=&/FC6* F6C::F=C:>BF G#%GGcddl}t|di}tdt||gd|ddS)z;Return last-seen config vars per profile for the dashboard.rN_LAST_CONFIG_VARSu7[ConfigVars] GET /api/config-vars — profiles stored: ) CURRENTTIME CURRENTDATE CALLERPHONE AGENTDATA EXTENSIONSOUTGOING)builtins lastConfig)__main__getattrrlistkeysri)r(rrs rr>z$PipelineHTTPHandler._get_config_vars2s#H.A2FF hM^McMcMeMeHfHfhhiii lll+       r!c ts|ddidS |tjdS#t$r0}|dt |idYd}~dSd}~wwxYw)zFSummary of recorded calls: recv (from cloud) vs send (to bridge) gaps.rktracer unavailablermrpN)audio_timing_traceri get_callsrvrw)r(r|s rr?z&PipelineHTTPHandler._audio_timing_list>s! M&&1E'FLL L 8    2 < > > ? ? ? ? ? 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8s&A B%A>>BcFts|ddidS tj|}||ddidS||dS#t$r0}|dt |idYd}~dSd}~wwxYw)z%Full per-piece timeline for one call.rkrrmNz not foundrErp)rri get_seriesrvrw)r(rCrfr|s rr@z(PipelineHTTPHandler._audio_timing_seriesGs! M&&1E'FLL L 8%055D|**G[+A3GGG    % % % % % 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8s-A&A&& B 0%BB c2 t|jdd}tj|j|}|dd}|dd}|r|s|ddidS|d d d}|d d }i}d D]} tj|d||dd} | j dkr| ng|| dd<Y#t$rg|| dd<Y~wxYw||dS#t$r0} |dt| idYd} ~ dSd} ~ wwxYw)z5Proxy: fetch all ACRS entities and return to browser.r]rapi_urlrrrkzapi_url and api_key requiredr /dispatchesr\) X-API-KEYAccept) departments categoriestypeszsub-categoriesratings/ F)rtimeoutverifyrX-rrpN)rrrqr^rsrrrirsplitrequests status_coderrvrw) r(rrhrrbaserrxentityrespr|s rrGzPipelineHTTPHandler._acrs_syncUs 8))*:A>>??F:djoof5566Dhhy"--Ghhy"--G [' [**G5S+TVYZZZ>>-33A6D$+7IJJGF] : ::#<4(:(:&(:(:GUW`efffDFJFVZ]F]F]tyy{{{ceF6>>#s3344 :::79F6>>#s33444:    ' ' ' ' ' 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8sCBE'EADE#E?EEE F&%FFc t|jdd}tj|j|}|dd}|dd}|dd}|di}|r|r|s|dd id S|d d d}|d d}tj |d|||dd} i} | } n!#t$rd| j ddi} YnwxYw| j dvr|| dS|d| i| j dS#t$r0} |dt| idYd} ~ dSd} ~ wwxYw)z Proxy: create an entity in ACRS.r]rrrrrrfrkz!api_url, api_key, entity requiredrrrr\)rr[rrF)r^rrrrawNrp)rX)rrrqr^rsrrrirrpostrvtextrrw) r(rrhrr entity_typerfrrr resp_datar|s rrHz PipelineHTTPHandler._acrs_createks 8))*:A>>??F:djoof5566Dhhy"--Ghhy"--G((8R00K88FB''D `' ` `**G5X+Y[^___>>-33A6D$+=OPPG=D!8!8;!8!8t)0"ULLLDI 5 IIKK  5 5 5"DIdsdO4  5:--##I.....##Wi$8$:JKKKKK 8 8 8   #a&& 13 7 7 7 7 7 7 7 7 7 8sIC F AFD#"F#E>FE!F$F F= %F88F=c t|jdd}tj|j|}|dd}|dd}t|dd}t|d d}t|d d }|s| d d idSgtj Gfddt}|} t} tD]+} | d|kr| dt} n,t!| | d} | | |t&jd|||d} t+dt-|| D]6}| |||| zt1jd7| dd}D]}|t9j|z }t9j|d}| d|id S#t@$rB}tCd|| d tE|idYd }~d Sd }~wwxYw)!z,Synthesize text and return base64 PCM audio.r]rrrvoiceEthan speech_rateg? pitch_ratevolume2rkztext is requiredrc,eZdZdZfdZfdZdS)8PipelineHTTPHandler._tts_test..CollectorCallbackcdSNr)r(s ron_openz@PipelineHTTPHandler._tts_test..CollectorCallback.on_opensr!c0dSr)set)r(r) done_events ron_closezAPipelineHTTPHandler._tts_test..CollectorCallback.on_closes:>>+;+;+;+;+;r!c |dd}|dkr1|dd}|r|dSdS|dkrdSdS#t$rYdSwxYw)Ntyperzresponse.audio.deltadeltazsession.finished)rqrrrv)r(responseetypeaudio audio_chunksrs ron_eventzAPipelineHTTPHandler._tts_test..CollectorCallback.on_events  ( VR 8 8 $:::$,LL"$=$=E$; , 3 3E : : : : :;;"&888&NN,,,,,98$sA A.A.. A<;A<N)__name__ __module__ __qualname__rrr )r rsrCollectorCallbackrsK''';;;;;        r!rr target_modelz4wss://dashscope-intl.aliyuncs.com/api-ws/v1/realtime)modelcallbackurl server_commit)rresponse_formatmoderrrPgQ?)rr!asciir z[TTS Test] Error: rpN)#rrrqr^rsrrstripfloatri threadingEventrrrrrconnectupdate_sessionrPCM_24000HZ_MONO_16BITranger; append_texttimesleepfinishwaitbase64 b64decode b64encodedecodervrrw)r(rrhrrrrrrrrcvtts chunk_sizerz all_audiochunk combined_b64r|r rs @@rrIzPipelineHTTPHandler._tts_tests9B 8))*:A>>??F:djoof5566D88FB''--//DHHWg..E < <==Ktxx c::;;J(B//00F O**G5G+H#NNNL"**J        $;   )(**H!I(  d8u$$ "~| D DIE%"(JC KKMMM    + B$'%    J1c$ii44 ! !Qq:~%5 6777 4    JJLLL OOBO ' ' 'I% 5 5V-e444 !+I66==gFFL   , 7 8 8 8 8 8 8 8 8 *q** + + +   #a&& 13 7 7 7 7 7 7 7 7 7 8sDJ2FJ22 K><7K99K>c x t|jdd}tj|j|}|dd}|dpd}|dpd}|r|r|s|ddid S||kr|d |iStt}d |d <|||}|||}d |d|d|} ttt} | jjt"d| dgdddi} | jdjjpd} t+| dkrL| ddkr | ddks| ddkr(| ddkr| dd} t-d|d|dt+|d|d | id"S#t.$rB} t-d | |dt1| id!Yd"} ~ d"Sd"} ~ wwxYw)#z:Translate text from one language to another using the LLM.r]rrr source_lang target_langrkz'text, source_lang, target_lang requiredr translationzChinese (Simplified)zhz;You are a professional translator. Translate the following z text into a~. Rules: - Preserve the original formatting, line breaks, bullet points, and section headings exactly. - Keep placeholders, variable names, code, URLs, and identifiers unchanged (e.g. {name}, $var, REFERENCE DATA, TRANSFER CAPABILITY). - Translate only natural-language content. - Output ONLY the translated text. No preamble, no explanations, no surrounding quotes. Source text: rbase_urluserrolecontent皙?enable_thinkingFrmessages temperature extra_bodyr'rz [Translate] z -> rz chars)z[Translate] Error: rpN)rrrqr^rsrrrrirrrr rchat completionscreaterchoicesmessager=r;rrvrw)r(rrhrsourcetargetrsrc_nametgt_namepromptllmr r6r|s rrJzPipelineHTTPHandler._translates1 8))*:A>>??F:djoof5566D88FB''--//Dhh}--3::<-u5 3H $+A.6>D"KKMMK;1$$Q3&&;r?c+A+AQ3&&;r?c+A+A)!B$/5577 IIIVIIs4yyIII J J J    < = = = = = 8 8 8 +++ , , ,   #a&& 13 7 7 7 7 7 7 7 7 7 8s%C+I-.I- E I-- J977J44J9c nd} t|jdd}tj|j|}|dd}|ddpt}|s| ddidSd |}ttt }|j j|d |d gd ddi}|jdjjpd}|dr@t)jdd|}t)jdd|}|}tj|} t-d| dddt/| dgd|d| | dS#tj$rP} t-d| d|dd| ddt3| id Yd} ~ dSd} ~ wt4$rB} t-d!| | dt3| idYd} ~ dSd} ~ wwxYw)"zGUse LLM to generate a structured tool definition from natural language.rr]r descriptionrrkzdescription is requiredrafYou are a tool definition generator for an OpenAI-compatible function calling system. The user will describe an API tool in natural language. Your job is to extract structured information and return ONLY a JSON object (no markdown, no explanation, no code fences) with exactly these fields: { "name": "snake_case_function_name", "description": "Clear description of what this tool does", "parameters": [ { "name": "param_name", "type": "string", "description": "What this parameter is for", "required": true } ], "endpoint": "https://api.example.com/path", "headers": {} } Rules: - name MUST be snake_case (lowercase, underscores only, no spaces) - type must be one of: string, number, integer, boolean - Extract the API endpoint URL if mentioned; leave as empty string if not mentioned - Extract any custom headers if mentioned (e.g. Authorization); default to empty object - Infer reasonable parameter names, types, and descriptions from context - Mark parameters as required=true unless they are clearly optional - Output ONLY the JSON object, nothing else User description: r8r:r;r>r?Fr@```z^```(?:json)?\s*\n? \n?```\s*$z[ToolGen] Generated: rV?r parametersz params, model=)z[ToolGen] JSON parse error: z Raw: NrpzLLM returned invalid JSON: iz[ToolGen] Error: )rrrqr^rsrrrrrirr rrGrHrIrJrKr=r.rrrr;rtrwrv) r(rrrhrSrrPrQr rxr|s rrKz"PipelineHTTPHandler._generate_tools,@ 8))*:A>>??F:djoof5566D((="55;;==KHHWb))//11>YE ?**78#???44'2544 <8<<-u5 3H #A&.6<"CCEEC~~e$$ "f3R==f]B44iikkZ__F Q&**VS*A*AQQ&**\26677QQHMQQQ R R R    ' ' ' ' '# H H H FFF3tt9FF G G G   @A@@A3 H H H H H H H H H 8 8 8 )a)) * * *   #a&& 13 7 7 7 7 7 7 7 7 7 8s,CH EH J4AI%% J427J//J4c Nd} t|jdd}tj|j|}|dd}|dd}|dg}|dd}|ddpt}|r|s| d d id Sd d |Dpd} d|d|d|d| d|d } ttt} | jj|d| dgdddi} | jdjjpd}|dr@t+jdd|}t+jdd|}|}t/d|d |d!| ||d"d%S#t0$rB} t/d#| | d t3| id$Yd%} ~ d%Sd%} ~ wwxYw)&z9Use LLM to generate a Python handler function for a tool.rr]r tool_namerSrWhandler_descriptionrrkz.tool_name and handler_description are requiredr c 3K|]=}d|dd|ddd|ddV>dS) z - rVrrstring): rSrN)rq).0ps r z8PipelineHTTPHandler._generate_handler..Xsp$$[qyZZAEE&($;$;ZZmUW@X@XZZ$$$$$$r!z (none)zYou are a Python code generator for a phone system's tool handler. Generate a handler function that will be registered with @register_handler. SIGNATURE (must be exactly this): @register_handler('z') def handle_an(args, tool_def=None): AVAILABLE (already imported, do NOT add import statements): - requests (for HTTP calls) - json (for JSON handling) - re (for regex) HANDLER RULES: - args is a dict containing the tool parameters - Must return a string (the result sent back to the AI) - Use args.get('param_name', '') to safely get parameters - For API calls, use requests.post/get with timeout=15, verify=False - Handle errors with try/except and return error messages as strings - Do NOT use: import, os, subprocess, exec, eval, open, __import__, sys - Do NOT include any import statements TOOL DESCRIPTION: z PARAMETERS: z HANDLER LOGIC: z Output ONLY the Python function code (with the @register_handler decorator line). No markdown code fences, no explanation, no imports.r8r:r;r>r?Fr@rTz^```(?:python)?\s*\n?rUz$[HandlerGen] Generated handler for: z (model=rX)rZ handler_codez[HandlerGen] Error: rpN)rrrqr^rsrrrrrirrr rrGrHrIrJrKr=r.rrrrvrw)r(rrrhrZrSrWr[r params_textrPrQr r|s rrLz%PipelineHTTPHandler._generate_handlerHs(> 8))*:A>>??F:djoof5566Db117799I((="55;;==K,33J"&((+@""E"E"K"K"M"M HHWb))//11>YE V$7 V**NOQTVVV))$$#$$$  G'0GG( GG"&1#GG$!,%GG&#6'GGG 28<<-u5 3H #A&.6<"CCEEC~~e$$ "f5r3??f]B44iikk TTTETTT U U U   i M M N N N N N 8 8 8 ,,, - - -   #a&& 13 7 7 7 7 7 7 7 7 7 8sD,I1D%I J$"7JJ$c  t|jdd}tj|j|}|dd}|dg}|ddpd}|ddpt}|s|s| d d id Sd}|rg}|D]} | d i} | d d} | dd} | ry| dkrs| didi} | r'd | nd}| d| d|d| |rdd |z}d}|rd|}d|d||d}ttt}|jj|d|dgdd d!i"}|jdjjpd}|d#r@t/jd$d|}t/jd%d|}|}t3d&|d't5|d(|d)| d*|id-S#t6$rB}t3d+|| d t9|id,Yd-}~d-Sd-}~wwxYw).z9Use LLM to generate a system prompt for a transfer agent.r]rrSrtools agent_namezTransfer Agentrrkz%Provide a description, tools, or bothrfunctionrV transfer_backrW propertiesz, nonez- (r_z! TOOLS AVAILABLE TO THIS AGENT: r\z AGENT PURPOSE (from user): zxYou are a system prompt writer for a phone call AI agent. Generate a concise system prompt for a transfer agent named "zY". This agent handles live phone calls after being transferred from a main receptionist. u RULES FOR THE GENERATED PROMPT: - Write in second person ("You are...") - Keep it concise but comprehensive (a few paragraphs max) - Mention this is a live phone call — responses must be brief (2-3 sentences per turn) - If tools are provided, explain WHEN to use each one (not the parameter details — the agent already has tool definitions) - Include a transfer_back instruction: tell the agent to transfer back to the main receptionist if the caller's request is outside this agent's scope - Do NOT include greetings or opening lines — those are handled separately - Output ONLY the system prompt text, no markdown formatting, no code fences, no explanation r8r:r;g?r?Fr@rTz^```(?:\w+)?\s*\n?rUz"[PromptGen] Generated prompt for: rz chars, model=rXrPz[PromptGen] Error: rpN)rrrqr^rsrrrrrirrrrr rrGrHrIrJrKr=r.rrrr;rvrw)r(rrhrSrfrgr tools_context tool_linestfnfn_namefn_descparams param_names desc_contextrPrQr rr|s rrOz$PipelineHTTPHandler._generate_promptsN 8))*:A>>??F:djoof5566D((="55;;==KHHWb))E,3399;;O?OJHHWb))//11>YE Mu M**EFMMMM  FFAz2..B ffVR00G ff]B77GF7o#=#=!# b!9!9!=!=lB!O!OBH&Tdii &>&>&>f "))DDD;DD7DDFFF>))J//0" L PO+OO 333 3 ! 333 .8<<-u5 3H #A&.6<"CCEEC~~e$$ "f2B<<f]B44iikk 7z77#hh77.3777 8 8 8   3 0 0 0 0 0 8 8 8 +++ , , ,   #a&& 13 7 7 7 7 7 7 7 7 7 8sDL G7L M 7M  Mc t|jdd}tj|j|}|dd}ddl}| |dd}|r|s| ddid Sgd }|D]#}||vr| dd |id cS$ t|d d n2#t$r%}| dd|id cYd}~Sd}~wwxYwd|d|vr| dd|did Sddl m } tjtjt$d} | d} t+| ||| ddlm} m} idddddddtdt2dt4dt6dt8d t:d!t<d"t>d#t@d$tBd%tDd&tFd'tHd(tJtLtNtPtRtTtVtXtZt\t^t`tbd) }|| | tdttfd*}ti||tId+|| d|d,dS#tb$rB}tId-|| dt5|id.Yd}~dSd}~wwxYw)/z1Validate, save, and activate a generated handler.r]rrZrNrcrkz'tool_name and handler_code are requiredr)zimport __import__zexec(zeval(zcompile(zopen(zos.zsys. subprocessshutilzglobals(zlocals(zsetattr(zgetattr(zdelattr( __builtins__zForbidden pattern detected: z execzSyntax error: z@register_handler('z')z$Handler must use @register_handler(')datetimezgenerated_handlers.pyz%Y-%m-%d %H:%M:%S)register_handlerCUSTOM_HANDLERSTrueTFalseFNonerrrwboolrrtuplerr;r#rrrrmin) maxabsroundsortedreversedzipmapfilter ValueError TypeErrorKeyErrorrv)rzr}r~rr^rz*[HandlerGen] Saved and activated handler: )rrZz[HandlerGen] Save error: rp)5rrrqr^rsrrrtextwrapdedentricompile SyntaxErrorr|rr-rdirname__file__nowstrftime_replace_or_append_handler tool_handlersr}r~rrwrrrrrr;r#rrrrrrrrrrrrrrrrrvrrr{)r(rrhrZrrc forbiddenpatternr|r|gen_file timestampr}r~ safe_builtinsexec_nss rrMz!PipelineHTTPHandler._save_handlersOE 8))*:A>>??F:djoof5566Db117799I OOO#??488NB+G+GHHNNPPL OL O**GH#OOOI % R Rl**.. "J"J"JKSRRRRR+  : mV<<<< : : :**2q223S:::::::: : 3Y222,FF**RYRRRSUXZZZ * ) ) ) ) )w||BGOOH$=$=?VWWH //0CDDI &xL) T T T H G G G G G G G  %u .4d s #U ,13 8>  %d -4U =B3 s $U -8  j  +25  s  $'sU h3&(y$9   M!.$4#2$ G w ' ' ' JyJJ K K K   t) D D E E E E E 8 8 8 1a11 2 2 2   #a&& 13 7 7 7 7 7 7 7 7 7 8s[CL(LLDL E E:E;LE&L,F!L M7MMc, t|jdd}tj|j|}|dd}|s|ddidSttt}|j j |d d d gdd d di}|jdjjpd}t'd|d|d|d|dddS#t($r<}t'd|d|d|dd|dYd}~dSd}~wwxYw)z2Test if a model exists and can generate responses.r]rrrrkzModel name is requiredrr8r:zReply with only the word "ok".r;r?F)rrArB max_tokensrCz [ModelCheck] z : ok (reply=rXTz is available)rrKz : failed (zModel not available: )rrkN)rrrqr^rsrrrrirr rrGrHrIrJrKr=lowerrrv)r(rrhrrQr replyr|s rrNz PipelineHTTPHandler._check_model&s U))*:A>>??F:djoof5566DHHWb))//11E U**G5M+NPSTTT8<<BEEGGMMOOE =%==U=== > > >   t58O8O8O P P Q Q Q Q Q U U U 7%771777 8 8 8   u7Rq7R7R S S T T T T T T T T T UsBE B3E F1FF)rX)!rrr__doc__r'r/rArRrWrir8rFrTr9r<rU staticmethodrrPr=r>r?r@rGrHrIrJrKrLrOrMrN __classcell__)r+s@rr#r#CsFF>>>>>/////     *6 8 8 8888& 8 8 8#8#8#8J 8 8 8 8 8 8<<\< 8 8 8888:   888 8 8 8888,888:D8D8D8L383838jC8C8C8JA8A8A8FP8P8P8dG8G8G8RUUUUUUUr!r#cd|d}d|d|d|d}tj|rt|dd 5}|}d d d n #1swxYwY||vrQt j|d z}t j|d |t j }| |z}n| |z}t|dd 5}| |d d d d S#1swxYwYd Sd} t|dd 5}| | |zd d d d S#1swxYwYd S)zKReplace existing handler for tool_name in generated_handlers.py, or append.z# --- Generated:  z rlz) --- r\rrZ)encodingNz)\(.*?\) ---\n.*?(?=\n# --- Generated:|\Z)r)flagswaG""" Auto-generated tool handlers. Managed by AI Tool Builder. Each handler below was generated by the LLM and reviewed by the user before activation. """ import json import re import requests from tool_handlers import register_handler # Generated handlers below # ============================================================ ) rr-rrrrescaperDOTALLrstripre) rrZcodermarker new_blockrr=rheaders rrr?sC - - - -F:v:: ::$:::I w~~h( (C' 2 2 2 affhhG                W  i''*VVGfWb'CCCGnn&&2GGnn&&2G (C' 2 2 2 a GGG                      # (C' 2 2 2 (a GGFY& ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s6A%%A),A).DDD2EEE)&rr^rrr%rr) urllib.parser5 http.serverrrurllib3disable_warnings exceptionsInsecureRequestWarning!dashscope.audio.qwen_tts_realtimerrropenairrrvr r r r r rrrrrrr r#rrr!rrs  000000+BCCC        +++(y Uy Uy Uy Uy U2y Uy Uy Ux"("("("("(sAA'&A'