kKjgldZddlmZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZmZmZddlZddlmZmZddlmZe r dd lmZdd lmZdd lmZdd lmZmZm Z dd l!m"Z"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-m.Z.ddl/m0Z0ddZ1ddZ2ddZ3ddZ4Gdde'ZGddeZ5y) z Resource template functionality.) annotationsN)Callable) TYPE_CHECKINGAnyClassVaroverload)parse_qsquoteunquote) AnnotationsIcon)SkipJsonSchema)Docket) Execution)ResourceTemplate)Fieldfield_validator validate_call)ResourceResourceResult) AuthCheck)FastMCPComponent)compress_schema)resolve_ui_mime_type) TaskConfigTaskMeta)get_cached_typeadapterctjd|}|r<|jdjdDchc]}|j c}St Scc}w)zFExtract query parameter names from RFC 6570 `{?param1,param2}` syntax. \{\?([^}]+)\},)researchgroupsplitstripset) uri_templatematchps k/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/fastmcp/resources/template.pyextract_query_paramsr,#sR II& 5E #(;;q>#7#7#<=#sActjdd|}tjd|}d}|D]}|jdrd|j drS|dd}|j dr!|d d}|j d d }|d |d z }\|j d d }|d |dz }x|tj |z } tjd|dS#tj$rYy wxYw)aBuild regex pattern for URI template, handling RFC 6570 syntax. Supports: - `{var}` - simple path parameter - `{var*}` - wildcard path parameter (captures multiple segments) - `{?var1,var2}` - query parameters (ignored in path matching) Hyphens in parameter names are normalized to underscores in regex group names so that matched groups are valid Python identifiers. Returns None if the template produces an invalid regex (e.g. parameter names with leading digits or duplicates from a remote server). z \{\?[^}]+\}z (\{[^}]+\}){}r *N-_z(?P.+)z>[^/]+)^$) r"subr% startswithendswithreplaceescapecompileerror)templatetemplate_without_querypartspatternpartnamer$s r+ build_regexrD+s VVNBA HH^%;  E %D|#ll3,f$".t"4Q"7F3K& M%CsB<c||}jD]\}}t|}t|d}t|d}|g}|jdd} | |k7r|j | |D].} |jd| d|}|jd| d|}0d fd } t j d | |}|S) uExpand a URI template with parameters — inverse of `match_uri_template`. Supports the same RFC 6570 subset: - Path params: `{var}`, `{var*}` - Query params: `{?var1,var2}` r.)safe/r4r3r/r0z*}c |jdjdDcgc]}|j}}g}|D]}|jdd}|vr5|j t |dt t |N|vsS|j t |dt t ||rddj|zSycc}w) Nr r!r3r4=rF&r.)r$r%r&r:appendr strjoin)r)nnamesr@rC underscoredrQs r+_expand_query_blockz0expand_uri_template.._expand_query_blocks$)KKN$8$8$=>$=q$=>D,,sC0Kv~ d }AeCt 4E.F-GHI& d }AeC{8K4L.M-NOP  %( (?sC!r)r)z re.Match[str]returnr])rJr]r r:r\r"r7) r(rQresultrTvalue value_strsimplewildcardforms hyphenatedformrbs ` r+expand_uri_templaterlwsFlln UJ yr*-[[c*   LL $D^^bbM6:F^^bcNH=F% VV$&96 BF Mc>eZdZUdZdZded<edZded<ed d Zded <ed Z ded<edd Z ded<edddZ ded<d,dZ e d- d.dZed ded/dZd0dZd1dZd2d Ze d3 d4d!Ze d5d"Z d3 d6d#Zd7d$Z d8d%Zed9d&Zed,d'Zd:d(Zddd) d;d*Zd<fd+ ZxZS)=r.A template for dynamically creating resources.r>z ClassVar[str] KEY_PREFIXzSubclasses must implement read() or override create_resource()NotImplementedError)r argumentss r+readzResourceTemplate.reads! L   c<t|tr|St|S)anConvert a raw result to ResourceResult. This is used in two contexts: 1. In _read() to convert user function return values to ResourceResult 2. In tasks_result_handler() to convert Docket task results to ResourceResult Handles ResourceResult passthrough and converts raw values using ResourceResult's normalization. ) isinstancer)r raw_values r+convert_resultzResourceTemplate.convert_results! i 0 i((rmc KywNrrrKrQ task_metas r+_readzResourceTemplate._read c Kywrrrs r+rzResourceTemplate._read &)rcKddlm}||d||d{}|r|S|j||d{}|jd{}|j |S7K7/7w)aServer entry point that handles task routing. This allows ANY ResourceTemplate subclass to support background execution by setting task_config.mode to "supported" or "required". The server calls this method instead of create_resource()/read() directly. Args: uri: The concrete URI being read params: Template parameters extracted from the URI task_meta: If provided, execute as a background task and return CreateTaskResult. If None (default), execute synchronously and return ResourceResult. Returns: ResourceResult when task_meta is None. CreateTaskResult when task_meta is provided. Subclasses can override this to customize task routing behavior. For example, FastMCPProviderResourceTemplate overrides to delegate to child middleware without submitting to Docket. rcheck_background_taskr> component task_typerrN)fastmcp.server.tasks.routingrcreate_resourcerr)rrKrQrr task_resultresourcerds r+rzResourceTemplate._read st0 G1jFi    --c6::}}&""6** ;&s1A*A$A*A&A*A(A*&A*(A*c Ktdw)zCreate a resource from the template with the given parameters. The base implementation does not support background tasks. Use FunctionResourceTemplate for task support. z[Subclasses must implement create_resource(). Use FunctionResourceTemplate for task support.r)rrKrQs r+rz ResourceTemplate.create_resource3s " =  rc t|jd|j|jd|j|jd|j|jd|j |jd|j |jd|j|jd|j|jd|j S) z8Convert the resource template to an SDKResourceTemplate.rC uriTemplaterqmimeTyperrr_meta)rCrrqrrrrr) SDKResourceTemplategetrCr(rqrtrrrget_meta)r overridess r+to_mcp_templatez ResourceTemplate.to_mcp_template>s #vtyy1! mT5F5FG! mT5E5EF]]:t~~>--4--4! mT5E5EF--  rmct||j|j|j|jxsdiS)zJCreates a FastMCP ResourceTemplate from a raw MCP ResourceTemplate object.rr)r(rCrqrtrv)rrCrqr)r mcp_templates r+from_mcp_templatez"ResourceTemplate.from_mcp_templateQs= %11""$00"++;|   rmcb|j|j}|d|jxsdS)z1The globally unique lookup key for this template.@r.)make_keyr(r)rbase_keys r+rTzResourceTemplate.key^s3==!2!231T\\/R011rmc|jjsy|j|j|jgyz[x01 : ) BF .;? )) .);C) #)) NR$+$+ .$+;J$+ 4$+L      &    22 5"# >>>  >  >> >.  rmrceZdZUdZded<e d ddZe ddZ d ddZddZdd Zdd Z ddd  dd Z e d dd Z y)rroz"SkipJsonSchema[Callable[..., Any]]rNc Kywrrrs r+rzFunctionResourceTemplate._readrrc Kywrrrs r+rzFunctionResourceTemplate._readrrcKddlm}||d||d{}|r|S|j|d{}|j|S737w)aOptimized server entry point that skips ephemeral resource creation. For FunctionResourceTemplate, we can call read() directly instead of creating a temporary resource, which is more efficient. Args: uri: The concrete URI being read params: Template parameters extracted from the URI task_meta: If provided, execute as a background task and return CreateTaskResult. If None (default), execute synchronously and return ResourceResult. Returns: ResourceResult when task_meta is None. CreateTaskResult when task_meta is provided. rrr>rNr)rrrr)rrKrQrrrrds r+rzFunctionResourceTemplate._reads`& G1jFi    yy6y22""6** 3sAA AAAAc&Kdfd }tj||jjjj j jjjjj Sw)z>Create a resource from the template with the given parameters.cHKjd{}|S7w)Nr)r)rdrQrs r+resource_read_fnzBFunctionResourceTemplate.create_resource..resource_read_fns$99v966FM7s " ") rrKrCrqrtr~rrrrrry)rcr) rrrCrqrtr~rrrrrry)rrKrQrs` ` r+rz(FunctionResourceTemplate.create_resourcess  %%((nn((****!!  sB BcK|j}tj|j}t |j D]\}}||j vst|ts&|j |}|j}|tjjus|turf |turt|||<nT|turt|||<n=|tur5|j}|dvrd||<n|dvrd||<nt!d|d||jdi|} tj$| r | d{} | S#t t"f$rwxYw7w) r)true1yesT)false0noFzInvalid boolean value for z: Nr)copyinspect signaturerlistrJrvrr] annotation Parameteremptyintfloatboollower ValueErrorAttributeError isawaitable) rrrsig param_name param_valueparamrr rds r+rzFunctionResourceTemplate.readsh!('+FLLN'; #J S^^+ ;0Lz2"-- !2!2!8!88J#z,You must provide a name for lambda functionszz9FunctionResourceTemplate.from_function..vs- 0 JJ'++77 70s13zURI parameters z- must be a subset of the function arguments: forbiddenrT) prune_titlesrr)r(rCrrrqrrtrrvr~rrrry),getattrr|r}r rrrvvaluesrrVAR_POSITIONALr'r"findallr,sortedr:fastmcp.server.dependenciesrrkeysrsrrissubsetanygetdocrrr from_boolvalidate_function isroutine functoolspartial__call__r__func__r json_schemarrrr])'rrr(rCrrrqrrtr~rrrry func_namer rraw_path_paramsraw_query_paramsall_rawseenraw_name normalizedr* path_params query_paramsall_uri_paramsrr wrapper_fnuser_sig func_paramsrequired_paramsoptional_paramsinvalid_query_paramsr type_adapterrv resolved_mimes' r+rz&FunctionResourceTemplate.from_functions&RGB D9RR\\=R=R  "KL L#^^**,EzzW..=== R-bjj)=|LM/ ="$44!wH!))#s3JT! /Z0@/AB z!6zlC67 (D (5DDOqqyyc*O D5EF5E #s+5E F$|3OP P 14 $$Z0(--2245 !  ""1%--1B1B1H1HH##A&++w/@/@/L/LL    !  ""1%--W5F5F5L5LL##A&++w/@/@/L/LL     #//#A # '(<'==vw '' 4..??lmxlyz   ..0  "**;7 %n%55bcnbop&1% .%N3"# @@@  @  @@ @2  $( "&#' $ $*.&*)-37Z Z Z  Z " Z  Z  Z !Z Z Z (Z $Z 'Z 1Z  "Z Z rmr)r(r]rczset[str])r>r]rczre.Pattern[str] | None)rKr]r(r]rczdict[str, str] | None)r(r]rQrurcr])6r __future__rr*rr"collections.abcrtypingrrrr urllib.parser r r mcp.typesmcpr r pydantic.json_schemarrrdocket.executionrrrpydanticrrrfastmcp.resources.baserrfastmcp.utilities.authorizationrfastmcp.utilities.componentsrfastmcp.utilities.json_schemarfastmcp.utilities.mimerfastmcp.utilities.tasksrrfastmcp.utilities.typesrr,rDrUrlrrrmr+rQs&" $9911'/*= <59978:"J$N-`^ '^ Bf /f rm