U[iG ddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZmZddlmZddlmZddlZddlmZddlmZmZdd lmZmZdd l m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4mZddl5m6Z6ddl7m8Z8ddl9m:Z:er ddl;mZ>ddl?m@Z@ddl5mAZAmBZBddl7mCZCejjdxs eFe ejdz ZHGddZI d'deFdeFdzd eFdzfd!ZJd'd"eFdzdeFdzfd#ZK d(d"eFdzdeFdzd$eLd%eMeFefdzfd&ZNy))N) AsyncIteratorSequence)BytesIO)Path) TYPE_CHECKINGAnyOptionalcast)unquote)run_sync)Client handle_file)Status StatusUpdate)Image)AnyUrl) Starlette)Request) JSONResponseResponse)MountRoute)ReceiveScopeSend)processing_utils route_utilsutils) BlockFunction)State)HeadertypesServerReadResourceContents) BlockContextBlocks) ComponentGRADIO_TEMP_DIRgradioc eZdZdZ ddlmZddlmZddlm Z ddl m Z ddl m Z dBdZed ed zfd Zd ed efd Zd eed zfdZededeed efdZd eeeffdZdCdZd efdZdedeeefd e eeeeeefdffdZ!ded eefdZ"ede#d ed zfdZ$deded eeeffdZ%dDdZ&d e'd!ed"ed d fd#Z(d$ed d%fd&Z)ed efd'Z*d(dded e eeeefffd)Z+ed*e,d+d,ed efd-Z-ed.e,d+d,ed efd/Z. dEded0eeefd zd e eeefeeee/zffd1Z0d e1fd2Z2d3eeefd e eeefeeee/zffd4Z3d5ed6eeee/zd efd7Z4ed8ed e5jjd zfd9Z6ed:ed e7d zfd;Z8edZ9d,ed?ed ed@fdAZ:y #e$rYwxYw)FGradioMCPServerz A class for creating an MCP server around a Gradio app. This class requires `mcp` to be installed. Args: blocks: The Blocks app to create the MCP server for. rr"r$r&)SseServerTransport)StreamableHTTPSessionManagerc ddl}||_|jj|_|j |_d|_tj}|r|jdddznd|_ |j|_ |jd|_d|_|j#|j dd d t$d t&d t(d dffd }t*j,dt.d t0dffd }||_|_||_y#t$r}td|d}~wwxYw)NrzThe `mcp` package is required to use the Gradio MCP integration. Please install it with the `mcp` extra: `pip install gradio[mcp]`./_FT)app json_response statelessscopereceivesendreturncK|jdd}|jds$td|dd}||||d{yj|||d{y7!7w)Npathr2)/gradio_api/mcpz/gradio_api/mcp/z/gradio_api/mcp/httpz/gradio_api/mcp/http/zPath 'zD' not found. The MCP HTTP transport is available at /gradio_api/mcp.i)content status_code)getendswithrhandle_request)r9r:r;r>responsemanagers X/var/www/html/chatbot/Makanify-Chatbot-3/venv/lib/python3.12/site-packages/gradio/mcp.pyhandle_streamable_httpz8GradioMCPServer.__init__..handle_streamable_httpZs99VR(D==$$TF*no #ugt444((> > >5 ?s$AA+A'A+!A)"A+)A+r6cKj4d{ d dddd{y7#wxYw7 #1d{7swYyxYww)z7Context manager for managing session manager lifecycle.N)run)r6rFs rGlifespanz*GradioMCPServer.__init__..lifespanosR{{}           sLA5A>7> A<A9>AAA A A)mcp ImportErrorblocks get_api_infoapi_infocreate_mcp_server mcp_server root_pathr get_spacesplit tool_prefixget_tool_to_endpointtool_to_endpointwarn_about_state_inputs _local_url_client_instancer0rrr contextlibasynccontextmanagerrrrKrFrH)selfrNrLespace_idrHrKrFs @rG__init__zGradioMCPServer.__init__CsI     002 002??$>#.r2S8" $ 9 9 ; $$&&*/333u4  ? ?#* ?26 ?  ?*  ' '   mD.A  ( !  &<#i V  sD&& E/ D;;Er<Nc|jSN)rZr^s rG local_urlzGradioMCPServer.local_url|s requestctjt|j}|j d}t|j d}|j dryy)z Gets the route path of the MCP server based on the incoming request. Can be different depending on whether the request is coming from the MCP SSE transport or the HTTP transport. N)queryr3z/gradio_api/mcp/messagesr?)httpxURLstrurl copy_withrstriprC)r^rgrms rGget_route_pathzGradioMCPServer.get_route_pathsP iiGKK()mm$m'#hooc" <<2 3-$rfc|jjj}|ytt |di}d|vr2|dj d}|Dcgc]}|j |z}}|Sycc}w)z Extract the selected tools from the request query parameters and return the full tool names (with the tool prefix). Returns None if no tools parameter is specified (meaning all tools are available). N query_paramstools,)rRrequest_contextrgdictgetattrrUrV)r^context_requestrrrstoolfull_tool_namess rGget_selected_tools_from_requestz/GradioMCPServer.get_selected_tools_from_requests +///*I*I*Q*Q  "GO^RHI l " )//4ECHI4t//$6IOI" "JsA1 tool_nameexisting_tool_namescrtjdd|}|dd}|}d}||vr|d|z}|dz }||vr|S)z Sanitizes a tool name to make it a valid MCP tool name (only alphanumeric characters, underscores, <= 128 characters) and is unique among the existing tool names. z [^a-zA-Z0-9]r5Nx)resub)r|r}tool_name_basesuffixs rGvalid_and_unique_tool_namez*GradioMCPServer.valid_and_unique_tool_names`FF?C; dsO "..&1VH5I aKF..rfci}|jdD]}|j|}| |j#t|jddxsLt |jdxr!t|jj ddxs|j d}|j|z}|j|t|j}|||<|S)z Gets all of the tools that are exposed by the Gradio app and also creates a mapping from the tool names to the endpoint names in the API docs. named_endpointsN__name__ __class__r3) rPget_block_fn_from_endpoint_namefnrwhasattrrlstriprVrsetkeys)r^rX endpoint_nameblock_fnfn_namer|s rGrWz$GradioMCPServer.get_tool_to_endpoints !]]+<= 8M;;MJH8;;#6 Z6-HKK5I 5 5z4H- !'', ((72I773/4467I+8 Y '! 8" rfc|jjD]K\}}|j|}|std|jDs7t j dMy)z= Warn about tools that have gr.State inputs. c3<K|]}t|tywrc) isinstancer ).0inputs rG z:GradioMCPServer.warn_about_state_inputs..sVU 5% 8VszThis MCP server includes a tool that has a gr.State input, which will not be updated between tool calls. The original, default value of the State will be used each time.N)rXitemsranyinputswarningswarn)r^r5rrs rGrYz'GradioMCPServer.warn_about_state_inputss\!% 5 5 ; ; =  A};;MJHCVhooVV & rfc @|j|jjj}| t d|j |}t j|||j}t|jxs|dddddddi|_|jS)NCould not find the request object in the MCP server context. This is not expected to happen. Please raise an issue: https://github.com/gradio-app/gradio.rg route_pathrSF x-gradio-userrL)download_filesverboseanalytics_enabled ssl_verify_skip_componentsheaders) r[rRrurg ValueErrorrpr get_root_urlrSr re)r^rxrroot_urls rG_get_or_create_clientz%GradioMCPServer._get_or_create_clients  (.2oo.M.M.U.UO& p,,_=J"//'%..H %+*($"' !&(%0%D !$$$rfname argumentsrc|j}|j|\}}|j||}|jj |}|t d||||vrt d|d|j |}|J||jdvr-|jd|d} tj| d|} ng} |jjj} | t dt| jj} | j!d d| j!d d|| | |fS) z Prepare and validate arguments for a tool call. Returns: A tuple of (endpoint_name, processed_args, request_headers, block_fn) N"Unknown tool for this Gradio app: zTool 'z#' is not in the selected tools listr parametersrzcontent-lengthr)r{get_input_schemaconvert_strings_to_filedatarXrBrrrP client_utilsconstruct_argsrRrurgrvrrpop) r^rrselected_toolsr5filedata_positionsprocessed_kwargsrrparameters_infoprocessed_argsrxrequest_headerss rG_prepare_tool_call_argsz'GradioMCPServer._prepare_tool_call_argssw==? $ 5 5d ; ;; ) --11$7  A$HI I  %$n*DvdV+NOP P77 F### DMM*;< <"mm,=>}MO*88 N  N*.//*I*I*Q*Q  "l 66<<>?,d3OT2noxGGrfjobcNKt|jd{}|gS7w)z Execute a tool call without progress tracking (fast path). Calls job.result() to get the final output without processing intermediate status updates. Returns: The output data as a list. N)r result)r^rrs rG_execute_tool_without_progressz.GradioMCPServer._execute_tool_without_progresss%  ++x,s %#%updatec|jtjtjfvry|jtjfvr>d|j d|j d}|j|d|jdz }|S|jtjfvr|jxsgD]}|jdnd |j}|j,|j |d |jd |jcS|je|jr|d |jcSy|jtjtjfvry y) z Format a status update into a human-readable progress message. Returns: A formatted message string, or None if no message should be shown. zJoined server queue.zIn queue. Position z out of .Nz Estimated time remaining: z seconds.Progressz Progress z: Step z of Processing)coder JOINING_QUEUESTARTINGIN_QUEUErank queue_sizeetaPROGRESS progress_datadescindexlength PROCESSING ITERATING)rmessage progress_unittitles rG_format_progress_messagez(GradioMCPServer._format_progress_message(so ;;6//A A) [[V__- -+FKK=ARAR@SSTUGzz%8 INNN [[V__- -!'!5!5!; B %))1$]%7%7$89 !&&2}7K7K7W ')<)<(=T-BVBVAWX#((49M9M9U#WGM,?,?+@AA B[[V..0@0@A Arfprogress_tokenc Kd}|23d{}|jdk(rtt|}|j|}|jj j j|||t|jj jd{|dz }|jdk(s|js|j}|jr|jd}|jd}|r|r|d |} t| |r |} t| |r |} t| d } t| 7676|jr|jd Sw) z Execute a tool call with progress tracking (streaming path). Iterates through job updates to send progress notifications to the client. Returns: The output data as a list. rNstatus)rprogressrrelated_request_idroutputrerrorz: zError!data)typer rrrRrusessionsend_progress_notificationrl request_idfinaloutputssuccessrB RuntimeError exception) r^rrsteprrr error_title error_messagemsgs rG_execute_tool_with_progressz+GradioMCPServer._execute_tool_with_progressHsu , ,&{{h&lF377?OO33;;VV'5!% '+. OO;;FF, W   (V\\~~"(**W"5K$*JJw$7M"}!, R ?'s++ '+ 's++ %)'s++'&s++; ,   < ==?--/ !f~sKE,EEEBE,EE,8 E,E,A#E,EE,&E,cjtjjxsd}|j dtdt tt fdjjffd }|jdtjjffd }|jdtjjffd }|jdtjjffd }|j!d t"tzdtj$ffd }|j'dtjj(ffd }|j+ ddtdt tt fd zdjj,ffd }|S)z Create an MCP server for the given Gradio Blocks app. Parameters: blocks: The Blocks app to create the MCP server for. Returns: The MCP server. z Gradio Apprrr<c Kd}jjj*jjjj}t j d{}j ||\}}}}j|j|}|j|||d}| |jsj|d{} nj||d{} j|j| } jjj} j!| } t#j$| | j&} j)| | } t+|j,ddrd| i}nd}j.j1| |t+|j,ddS7_77ۭw) z Call a tool on the Gradio app. Args: name: The name of the tool to call. arguments: The arguments to pass to the tool. N)api_namerr_mcp_structured_outputFr _mcp_meta)r@structuredContent_meta)rRrumeta progressTokenr rrinsert_empty_statersubmitqueuerrpop_returned_staterrgrprrrSpostprocess_output_datarwrr#CallToolResult)rrrclientrrrrr output_datarxrrr@structured_contentr^s rG call_toolz4GradioMCPServer.create_mcp_server..call_tools"N..33?!%!@!@!E!E!S!S#D$>$>??F,,T9= EM>?H"44X__nUN&---C%X^^$($G$G$LL $($D$D"% 11(2B2BKPK.2oo.M.M.U.UO,,_=J"//'%..H 22;IGx{{$.list_toolss "AACNE,0,A,A,G,G,I ( =!-)>2Q?? N${{* [9$KK11V;*.*A*A(I*V' Z 11)ZH #HKKdC  JJOO&$/$*' $' 6LsC.list_resourcess I!AACN,0,A,A,G,G,I ( =!-)>2Q?? N  [9 --;#+;;#@#@L!#NL!IJ161O1O 2.KQ&!(( JJ//$0%-[[%9%9,7)1)C)C 0# 2 &AD= D=D=6D=AD="AD=c ~Kg} j} jjD]\}}|||vr j|}|s"|js/t |jdsF|jj dk(s`|jj}tjd|}tj|j\}}}|s|j jj||jj||jj  |Sw)z@ List all available resource templates. rrr) uriTemplaterrr)r{rXrrrrrrrrrrrr#ResourceTemplaterr) templatesrr|rrrrrr5r^s rGlist_resource_templateszBGradioMCPServer.create_mcp_server..list_resource_templatess I!AACN,0,A,A,G,G,I ( =!-)>2Q?? N  [9 --;#+;;#@#@L!#NL!IJ161O1O 2.KQ"!(( JJ77,8%-[[%9%9,7)1)C)C 8# 2 rrcKt|}tjd{}jj D]}j |}|s|j s%t|j ds<|j jdk(sV|j j}tjd|}i}d}|retj|}|D]} |jd| dd| d }tjd |d |} | r| j}d }n||k(rd }|s|j d vr-j d |d} t#j$| d|} nt'|j } |j(| d|i23d{} | j*dk(s| j,s&| j.}|dd}|j j0}|r5|j3ds$t5j6j9d}j;|gcSt=d|7,76yw)z: Read a specific resource by URI. NrrrFz\{z\}z(?P[^/]+)^$Trrrrrrrztext/ascii)r@ mime_typezResource not found: )rlr rrXvaluesrrrrrrrescapereplacematch groupdictrPrrlistrrrrr startswithbase64 b64decodeencoder'r)rrrrrrkwargsmatchedpatternparamr(rrrrrr$r^s rG read_resourcez8GradioMCPServer.create_mcp_server..read_resource sa c(C#D$>$>??F!%!6!6!=!=!?8  ?? N  [9 --;#+;;#@#@L!#NL!IJF#G!"$))L"9%/E&-oo"&ugT 2d5'4I'G!#1WIQ = %*__%6F&*G%,"&(DMM:K,LL.2mm$> $Y-A-A'-J%+%5%5fmmG6L%MF 55(.)6 i8 t3C59: :w@T&-s`$II5I I+IIB I=A)I&I*I+I.I? I BIIIc Kg} j} jjD]\}}|||vr j|}|s"|js/t |jdsF|jj dk(s`tj|j\}}}tj|j}|D cgc]6\} } }} jj| |j| d| 8} } } }|j jj||| |Scc}} } ww)z5 List all available prompts. rpromptr2)rrrequired)rrr)r{rXrrrrrrrget_function_paramsr#PromptArgumentrBrPrompt) promptsrr|rrrrr5function_params param_name has_defaultrr^s rG list_promptsz7GradioMCPServer.create_mcp_server..list_promptscsP G!AACN,0,A,A,G,G,I ( =!-)>2Q?? N  [9 --9161O1O 2.KQ',&?&? &LO>M !! :J Q  11!+(2z2(F)4_2!I!NN ))!*(3&/*/ <N!s+AE EE6EAE;E =ENc Kt jd{}d} jjD]o} j |}|s|j s$t |j ds;|j jdk(sU|j j|k(son|std||xsi} j |}|J| jdvr- jd|d}tj|d|}nt|j}|j|d|i23d{}|jd k(s|j s&|j"}|d d }  j$j' j$j)d j$j+d t- gS776cw)zI Get a specific prompt with filled-in arguments. Nrr5zPrompt not found: rrrrrrrusertextrrA)roler@)messages)r rrXr%rrrr _mcp_namerrPrrr*rrrrr#GetPromptResult PromptMessage TextContentrl) rrrrrrrrrrr^s rG get_promptz5GradioMCPServer.create_mcp_server..get_prompts$D$>$>??F M!%!6!6!=!=!?  ?? N  [9 --9 --5 ! #5dV!<==!RI;;MJH' '' .? @@"&--0A"B="Q #".!r9rIrF) r^serverrr rrr3r>rIs ` rGrQz!GradioMCPServer.create_mcp_servervsS!2!2!BlCD    1 1 "&sCx.1  ZZ & &1  1 f    " $tzz"7"  " H     d4::+>+>&?  ! D  ' ' ) tDJJ4O4O/P  * B    @ ;Vc\@ ;d4;T;T6U@ ; @ ;D    $ D):):$;$  $ L    :>5 5 "&sCx.4"75  ZZ ' '5  5 n rfr6subpathrSc d}j||_fd}|j|tt dj t d|t djt djgy ) a! Launch the MCP server on the SSE transport. Parameters: app: The Gradio app to mount the MCP server on. subpath: The subpath to mount the MCP server on. E.g. "/gradio_api/mcp" root_path: The root path of the Gradio Blocks app. z /messages/cK j|j|j|j4d{}jj |d|djj d{dddd{tS7a7 7#1d{7swYtSxYw#t$r}tdt|d}~wwxYww)NrrzMCP SSE connection error: ) connect_sser9r:_sendrRrJcreate_initialization_optionsr Exceptionprintrl)rgstreamsr_r^sses rG handle_ssez5GradioMCPServer.launch_mcp_on_sse..handle_sses ??MM7??GMM//--  EEG z! z! 23q6(;< sC)5CBC?B"=B>B" C B  CC)CB" C"B=(B+ )B=0 C<C)=C C& C!!C&&C)z/schema)endpointz/sse)r6r3)routesN) r/rSmountrrget_complete_schemarhandle_post_messagerH)r^r6rKrS messages_pathrUrTs` @rGlaunch_mcp_on_ssez!GradioMCPServer.launch_mcp_on_sses% %%m4"   !!%!9!9&:6,C,C,CD#4#>#>?  rfrzBlockFunction | Nonecvtfd|jjjDd}|S)a$ Get the BlockFunction for a given endpoint name (e.g. "/predict"). Parameters: endpoint_name: The name of the endpoint to get the BlockFunction for. Returns: The BlockFunction for the given endpoint name, or None if it is not found. c3^K|]$}|jjdk(r|&yw)r3N)rr)rrrs rGrzBGradioMCPServer.get_block_fn_from_endpoint_name..s0 ;;-"6"6s";; s*-N)nextrNfnsr%)r^rrs ` rGrz/GradioMCPServer.get_block_fn_from_endpoint_names9 ++//002    rfcy)zu Sentence prompting the agent to use the upload_file_to_gradio tool if a file is passed as an input. z If a user passes a file as an input, use the upload_file_to_gradio tool, if present, to upload the file to the gradio app and create a Gradio File Input. Then use the returned path as the input to the toolrrds rG_file_data_tool_descriptionz+GradioMCPServer._file_data_tool_descriptions `rfrctj|j\}}}|j||\}}|jdurd}n|jMt |dkDr||j z }|rW||jdrdnddzdj|zz }n)|j}t |dkDr||j z }t|tsJ||fS)z Get the description of a function, which is used to describe the tool in the MCP server. Also returns the description of each parameter of the function as a dictionary. Fr2rrz Returns: z, ) rrrrapi_descriptionlenrbrCjoinrrl)r^rr|rrreturnsr5rs rGrz"GradioMCPServer.get_fn_description s,1+I+I(+++V( Z $ 5 5i L   # #u ,K  % % -%&*t??? &//4R#"#ii() #22K%&*t??? +s+++J&&rfrzComponent | BlockContextrcrt|D](\}}t|ts|j|d*|S)z Insert None placeholder values for any State input components, as State inputs are not included in the endpoint schema. N) enumeraterr insert)rriinput_component_types rGrz"GradioMCPServer.insert_empty_state's>(1'8 % #A#.6 At$ % rf componentscpt|D]'\}}t|ts|j|)|S)z Remove any values corresponding to State output components from the data as State outputs are not included in the endpoint schema. )rirr r)rmrrkcomponent_types rGrz"GradioMCPServer.pop_returned_state4s9"+:!6  A~.%0   rfrc X|jj|}|td||jd}|j|}|Jd|dDcic]4}|di|d|r|d|vr d||dinid|vr |drd |dini6c}d }|j |Scc}w) a Get the input schema of the Gradio app API, appropriately formatted for MCP. Parameters: tool_name: The name of the tool to get the schema for, e.g. "predict" parameters: The description and parameters of the tool to get the schema for. Returns: - The input schema of the Gradio app API. - A list of positions of FileData objects in the input schema. rrobjectrparameter_namerrparameter_defaultdefault)r properties)rXrBrrPsimplify_filedata_schema)r^r|rrr endpoint_infopr s rGrz GradioMCPServer.get_input_schemaAs--11)<  A)MN N--(9:'++M: ((('|4"# &i &&!,<*=*K' 15E3F(GH &/!3:M8N#A&9$:; &  &,,V44#s9B'cK|js tiStt|di}d}d|vr|dj d}t |}d}g}|j jD]I\}}|||vr|j|} | | jJ|j| |\} } |j|| \} } t| dkDr|sd}tj| j}g}|jD]N\}}|tus|t tus|j#dd j%}|j'|Pd }t)| jd r| jj*}||| j,d }|r||d <|| | |d}|j'|Lt|Sw)a Get the complete schema of the Gradio app API. For debugging purposes, also used by the Hugging Face MCP server to get the schema for MCP Spaces without needing to establish an SSE connection. Parameters: request: The Starlette request object. Returns: A JSONResponse containing a dictionary mapping tool names to their input schemas. rrNrsrtFrTr5-ryr)file_data_presentmcp_typerr)rrrr)rPrrvrwrUrrXrrrrrrerget_type_hintsr!r r'lowerrrrr)r^rgrrrrsr{schemasr|rrrrr r type_hintsrequired_headersr< type_hint header_namer|rinfos rGrYz#GradioMCPServer.get_complete_schemals}}# #GG^R@A  l " )//4E ZN!(,(=(=(C(C(E$ ! $I})i~.M;;MJH'HKK,C CC&*&=&=h &R #K)-)>)>y*)U &F&%&*3D$(!--hkk:J! )3)9)9); 9% I&)x7G*G","4"4S#">"D"D"FK$++K8 9 Hx{{K0#;;00&7$!)!2!2D  "2Y"*% D NN4 I$ !LG$$s D*G -BG r c dtdtttfdtfd d dtdttt zdzdtttfdzdtffd g|}|fS) a Parses a schema of a Gradio app API to identify positions of FileData objects. Replaces them with base64 strings while keeping track of their positions so that they can be converted back to FileData objects later. Parameters: schema: The original schema of the Gradio app API. Returns: A tuple containing the simplified schema and the positions of the FileData objects. objdefsr<c0t|tsyd|vr>|d}|jdr'|jdd}|j |i}ny|j di}|j di}d|vr>|d}|jdr'|jdd}|j |i}ny|j dij di}|j d ij d}|j d d k(xs|d k(S) NFz$refz#/$defs/r3r4rur_typertconstzgradio.FileData)rrvr+rUrB)rrrefkeypropsr type_field default_types rGis_gradio_filedatazDGradioMCPServer.simplify_filedata_schema..is_gradio_filedatasc4(}&k>>*-))C.,C((3+C GGL"-E99VR(D~6l>>*-))C.,C88C,D ,377DJ88Ir266w?Lw'+<<5#44 rfNnoder>c|g}|i}tj|}t|trd|vr|j |d ||rB j |jdD]}|j |dd|d<d|d<i}d|vxrd|v}|jD]H\}}|r|dk(r |||||<|j | |||||<|j J|St|trQg}t|D]?\}}|j ||j  ||||j A|S|S)N$defs)ruadditional_descriptionrstringrz1Gradio File Input - a http or https url to a fileformatru) copydeepcopyrrvrrrrr*ri) rr>rrris_schema_rootvaluerkitemrrtraverses rGrz:GradioMCPServer.simplify_filedata_schema..traversesk ||==&D$%d?KKW .%dD1&--diik:P,d+,#+DL%XDN!'4!HLD4H"&**,#JC%#*=&.udD&As  C(&.udD&As  # D$'(GAtKKNMM(4t"<=HHJ KrfNN)rrvrlboolr*int)r^r simplified_schemarrrs @@@rGrvz(GradioMCPServer.simplify_filedata_schemas C tCH~ $ @,0*.* * sSy/D(* sCx.4'*  * X57$V, "444rfrrclddtdtttzdzdtffd |S)a' Convert specific string values back to FileData objects based on their positions. This is used to convert string values (as base64 encoded strings) to FileData dictionaries so that they can be passed into .preprocess() logic of a Gradio app. Parameters: value: The input data to process, which can be an arbitrary nested data structure that may or may not contain strings that should be converted to FileData objects. filedata_positions: List of paths to positions in the input data that should be converted to FileData objects. Returns: The processed data with strings converted to FileData objects where appropriate. Base64 encoded strings are first saved to a temporary file and then converted to a FileData object. Example: >>> convert_strings_to_filedata( {"image": "data:image/jpeg;base64,..."}, [["image"]] ) >>> {'image': FileData(path='')}, Nrr>r<c |g}t|tr/|jDcic]\}}||||gzc}}St|tr)t |Dcgc]\}}|||gzc}}St|t rb|vr^|j dr#ttj|tS|j dr t|Std||Scc}}wcc}}w)Nzdata:)zhttp://zhttps://zSInvalid file data format, provide a url ('http://...' or 'https://...'). Received: ) rrvrr*rirlr+rrsave_base64_to_cacheDEFAULT_TEMP_DIRr)rr>rrrkrrrs rGrz=GradioMCPServer.convert_strings_to_filedata..traverse"s|$%IM;E3C%66D$'BKD/Rwq$tqcz2RRD#&43E+E??7+'(==dDTU__%<=&t,,$mnrmstK%Ss C2#C8rc)rr*rlr)r^rrrs `@rGrz+GradioMCPServer.convert_strings_to_filedata s62 3 d39o&<  2rf file_pathctjj|sytjj|j d}|t j vry t j|S#t$rYywxYw)ze If a filepath is a valid image, returns a PIL Image object. Otherwise returns None. Nr) osr>existssplitextr~rregistered_extensionsopenrQ)rexts rG get_imagezGradioMCPServer.get_image=sq ww~~i(ggy01!4 e113 3 ::i( (  s)A>> B  B  file_datact|tra|jdx}rNt|tr=|j dr,t |j dddjSyy)z If a file_data is a valid FileDataDict with a url that is a data:image/svg+xml, returns bytes of the svg. Otherwise returns None. rmzdata:image/svgrtrN)rrvrBrlr+r rUr.)rrms rGget_svgzGradioMCPServer.get_svgLsa i &9==3G,GC,G#s#7G(Hsyya034;;==rfimagerct}|j||tj|j j dS)z? Returns a base64 encoded string of the image. )rutf-8)rsaver, b64encodegetvaluedecode)rrbuffers rGget_base64_datazGradioMCPServer.get_base64_dataYs>  6& ) 1299'BBrfrz&types.TextContent | types.ImageContentcg}tj||d}|D]}|j|x}rtj|j d}d}tj ||dt}|d|} |jjd|||jjdd |  g} ntj|r|j|d x} r~| jxsd } |j| | }d | j!}|jjd|||jjdd|dxs|d  g} nY|jjdt#|dxs|d  g} n'|jjdt#| g} |j%| |S)z Postprocess the output data from the Gradio app to convert FileData objects back to base64 encoded strings. Parameters: data: The output data to postprocess. Nrz image/svg+xml orig_namez/gradio_api/file=r)rrrrAzSVG Image URL: rBr>pngzimage/z Image URL: rm)r add_root_urlrr,rrsave_bytes_to_cacherr# ImageContentrHris_file_obj_with_metarrrr~rlextend) r^rr return_valuesr svg_bytes base64_datamimetypesvg_pathsvg_url return_valuer image_formats rGrz'GradioMCPServer.postprocess_output_databs ,,T8TB' /F LL00y0$..y9@@I *+??&"5!69I&J&7zBJJ++$;,JJ**#.wi8+   33F; NN6&>::5:#(<<#85L"&"6"6ul"KK!' (:(:(<'=>H //!({X0 ..!'#.ve}/Nv.O!P/ $L ..!'c&-2Q6&>.R/$L !% 6 6FV 6 UV   .O' /Prf)rNr))r<N)r<r%rc);r __module__ __qualname____doc__rLr# mcp.serverr% mcp.server.lowlevel.helper_typesr'mcp.server.sser/"mcp.server.streamable_http_managerr0rMrapropertyrlrerrpr*r{ staticmethodrrrvrWrYr rrtuplerrrrrrQrr\rrbrrrrrrrrYrvrrrbytesrrrrrfrGr.r..s %I5S7=r3: %g %# % cT1A -0X " d38n 2 %v%0-H-H$(cN-H sDItCH~> ?-H^  S #*>,,(+, c3h,\L\ ) Y) ) ) QU) V  ,`S`` '''47' sDcN" #'6 34 <@     78 @C    -1)5)5cNT))5 tCH~tDsO44 5 )5V>%L>%@[538n[5 tCH~tDsO44 5[5z22.24c ?.C2 2h S U[[4%7   3 54<  Cu{{CCCCCC33#&3 6 73E!    sGGGr.rrr$cfd}|S)z0Decorator to mark a function as an MCP resource.cHd|_|_|_xsd|_|S)Nrz text/plain)rr_mcp_descriptionr)rrr$rs rG decoratorzresource..decorators,! +)%5 rfr)rrr$rs``` rGrrs  rfrcfd}|S)z.Decorator to mark a function as an MCP prompt.cNd|_xs |j|_|_|S)Nr5)rrrEr)rrrs rGrzprompt..decorators' *r{{ ) rfr)rrrs`` rGr5r5s rfstructured_outputrcfd}|S)a  Decorator to mark a function as an MCP tool (optional, since functions are registered as tools by default). Can be used to configure various aspects of the tool. Parameters: name: The name of the tool. Overrides the default name of the function. description: The description of the tool. Overrides the default description from the function's docstring. structured_output: Whether the tool should return structured output (implementation is quite limited at the moment). If True, the output will be wrapped in a dictionary with the key "result" and the value being the output of the function. Recommended to keep this False unless you have a specific reason to need the structured output. _meta: Additional metadata for the tool. cNd|_|_|_|_|_|S)Nry)rrErrr)rrrrrs rGrztool..decorators-  $5!)  rfr)rrrrrs```` rGryrys" rfr)NNFN)Or,r\rrrtempfilercollections.abcrriorpathlibrtypingrrr r urllib.parser gradio_client.utilsrrrjanyio.to_threadr gradio_clientr rrrPILrpydanticrstarlette.applicationsrstarlette.requestsrstarlette.responsesrrstarlette.routingrrstarlette.typesrrrr,rr gradio.blocksrgradio.componentsr gradio.route_utilsr!rLr#rr%rr'r(r)r*environrBrl gettempdirrr.rr5rrvryrrfrGrsO  355 * $-4,&6*0077'#%!E2+::>>"34    (*9 gg`#PT  $'$J BE*  t t "##'  *t S>D rf