kKj$(ddlmZddlmZddlmZmZmZmZm Z m Z ddl m Z ddl mZmZddlmZmZddlmZddlmZer dd lmZdd lmZed e ZGd de dZddZddZddZGddeZ y)) annotations)Sequence) TYPE_CHECKING AnnotatedAnyClassVar TypedDictcast)Icon)BeforeValidatorField)SelfTypeVar TaskConfig)FastMCPBaseModel)Docket) ExecutionT)defaultc,eZdZUded<ded<ded<y) FastMCPMetaz list[str]tagsstrversionversionsN)__name__ __module__ __qualname____annotations__m/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/fastmcp/utilities/components.pyrrs O Lr"rF)totalc|siSdD]5}|j|}t|ts%tt|cSiS)zExtract FastMCP metadata from a component's meta dict. Handles both the current `fastmcp` namespace and the legacy `_fastmcp` namespace for compatibility with older FastMCP servers. )fastmcp_fastmcp)get isinstancedictr r)metakeymetadatas r#get_fastmcp_metadatar.sA  &88C= h % X. .' Ir"cT| tSt|tr|St|S)z@Convert a sequence to a set, defaulting to an empty set if None.)setr)) maybe_sets r#_convert_set_default_noner2+s)u )S! y>r"c|yt|trtd|t|ttt fs$tdt |jd|t|}d|vrtd||S)zCoerce version to string, accepting int, float, or str. Raises TypeError for non-scalar types (list, dict, set, etc.). Raises ValueError if version contains '@' (used as key delimiter). Nz3Version must be a string, int, or float, got bool: z-Version must be a string, int, or float, got z: @z;Version string cannot contain '@' (used as key delimiter): ) r)bool TypeErrorrintfloattyper ValueError)vrs r#_coerce_versionr<4s  y!TMaUSTT a#sE* +;DGzFastMCPComponent.zs jk&Br")rQz_Annotated[TaskConfig, Field(description='Background task execution configuration (SEP-1686).')] task_configc@|jr|jd|S|S)zConstruct the lookup key for this component type. Args: identifier: The raw identifier (name for tools/prompts, uri for resources) Returns: A prefixed key like "tool:name" or "resource:uri" :)r@)rI identifiers r#make_keyzFastMCPComponent.make_key|s' >>nn%Qzl3 3r"cb|j|j}|d|jxsdS)aThe globally unique lookup key for this component. Format: "{key_prefix}:{identifier}@{version}" or "{key_prefix}:{identifier}@" e.g. "tool:my_tool@v2", "tool:my_tool@", "resource:file://x.txt@" The @ suffix is ALWAYS present to enable unambiguous parsing of keys (URIs may contain @ characters, so we always include the delimiter). Subclasses should override this to use their specific identifier. Base implementation uses name. Prefer `.key` over ad-hoc `name or uri or uri_template` logic for any cross-component identity work (dedupe, grouping, collision detection, lookup tables). It encodes type, identifier, and version, so variants of the same component don't falsely collide with each other, and cross-type identifiers (e.g. a tool and a resource both named "foo") can't clash. r4r?)r[rMr)selfbase_keys r#r,zFastMCPComponent.keys1(==+1T\\/R011r"c|jrt|jni}dt|ji}|j|j|d<|j dx}ct |ts td|jDcic]\}}|jdr||}}}tt||z}||d<|Scc}}w)a8Get the meta information about the component. Returns a dict that always includes a `fastmcp` key containing: - `tags`: sorted list of component tags - `version`: component version (only if set) Internal keys (prefixed with `_`) are stripped from the fastmcp namespace. rrr&zmeta['fastmcp'] must be a dict_) r+r*sortedrrr(r)r6items startswithr r)r]r+ fastmcp_meta upstream_metakr;public_upstreams r#get_metazFastMCPComponent.get_metas#'))tDII%+VDII->$? << #&*llL #"XXi0 0M =mT2 @AA"/!4!4!6!6Aall3>O1!6  _|-KLL&Y s C1Cct|t|uryt|t|sy|j|jk(S)NF)r9r) model_dump)r]others r#__eq__zFastMCPComponent.__eq__sA :T%[ (%d, E$4$4$666r"cBd|jg}|jr|jd|j|jd|jd|j d|j g|jjddj|dS) Nzname=zversion=ztitle=z description=ztags=(z, )) rMrappendextendrOrLrrKrjoin)r]partss r#__repr__zFastMCPComponent.__repr__s &' << LL8DLL#34 5 't//23 {#  ..))*!DIIe,<+=Q??r"c4td|jd)z6Removed in 3.0. Use server.enable(keys=[...]) instead.zHComponent.enable() was removed in FastMCP 3.0. Use server.enable(keys=[' ']) instead.NotImplementedErrorr,r]s r#enablezFastMCPComponent.enables$!((,z ?  r"c4td|jd)z7Removed in 3.0. Use server.disable(keys=[...]) instead.zJComponent.disable() was removed in FastMCP 3.0. Use server.disable(keys=['rvrwrys r#disablezFastMCPComponent.disables%!))- , @  r"c"|jS)zCreate a copy of the component.) model_copyrys r#copyzFastMCPComponent.copys  r"cy)zRegister this component with docket for background execution. No-ops if task_config.mode is "forbidden". Subclasses override to register their callable (self.run, self.read, self.render, or self.fn). Nr!)r]dockets r#register_with_docketz%FastMCPComponent.register_with_docketsr"c|S)u&Validate and coerce task arguments before any task state is created. Called by ``submit_to_docket`` up front, so invalid inputs raise before the task's Redis metadata and initial status notification exist — otherwise a coercion failure during queueing would orphan a task the client has already observed. The base implementation is a no-op; components that splat arguments into a typed Python callable (e.g. ``FunctionTool``) override this to mirror the synchronous validation path. r!)r] argumentss r#coerce_task_argumentsz&FastMCPComponent.coerce_task_argumentss r"cK|jjs0td|jjd|j dt |jjdw)aSchedule this component for background execution via docket. Subclasses override this to handle their specific calling conventions: - Tool: add_to_docket(docket, arguments: dict, **kwargs) - Resource: add_to_docket(docket, **kwargs) - ResourceTemplate: add_to_docket(docket, params: dict, **kwargs) - Prompt: add_to_docket(docket, arguments: dict | None, **kwargs) The **kwargs are passed through to docket.add() (e.g., key=task_key). z Cannot add z 'z)' to docket: task execution not supportedz# does not implement add_to_docket())rWsupports_tasks RuntimeErrorrKrrMrx)r]rargsrJs r# add_to_docketzFastMCPComponent.add_to_docketss..0dnn556b D/0 "~~&&''J K  sA-A/cd|jiS)z{Return span attributes for telemetry. Subclasses should call super() and merge their specific attributes. zfastmcp.component.key)r,rys r#get_span_attributesz$FastMCPComponent.get_span_attributess (22r")rJrreturnNone)rZrrr)rr)rdict[str, Any])rkobjectrr5)rr)rr)rrrr)rrrr)rrrrrJrrr) rrr__doc__r@r rEr rMrrOrLrPr0rr+rW classmethodr[propertyr,rhrlrtrzr|rrrrr __classcell__)rKs@r#r>r>JsdS "J " 0D#HMKHG D FE:$7K %^ E MR-MD I#("H#D  BCD   22,87 @  !    %( 47  ,3r"r>N)r+rRrr)r1zset[T] | Sequence[T] | Nonerzset[T])r;zstr | int | float | NonerrN)! __future__rcollections.abcrtypingrrrrr r mcp.typesr pydanticr r typing_extensionsrrfastmcp.utilities.tasksrfastmcp.utilities.typesrrrdocket.executionrrrr.r2r<r>r!r"r#rsa"$KK++.4* C)5 ",I3'I3r"