kKj*X\UddlmZddlZddlmZddlmZmZmZm Z m Z m Z ddl Z ddlZddlmZddl mZmZmZmZmZmZddl mZddlmZmZmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$dd l%m&Z&ddl'm(Z(m)Z)ddl*m+Z+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z2ddl3m4Z5dZ6erddl8m9Z9ddl:m;Z;ddlm?Z?m@Z@e&eAZBeegeCfZDdeEd<d)dZFd*dZGGddeZHGdde$Z d+ d,d ZI d+ d-d!ZJd"ZKd+d.d#ZLd+d/d$ZMd0d%ZNd+d1d&ZO d+ d2d'ZPddgZQd3d(ZRy#e7$rdZ6YwxYw)4) annotationsN)Callable) TYPE_CHECKING AnnotatedAnyClassVar TypeAliasoverload)validate_and_warn_tool_name)CallToolResult ContentBlockIcon TextContentToolAnnotations ToolExecution)Tool) BaseModelFieldmodel_validator)SkipJsonSchema)FastMCPDeprecationWarning) AuthCheck)FastMCPComponent) get_logger) TaskConfigTaskMeta)AudioFileImageNotSetNotSetT) PrefabApp) ComponentTF)Docket) Execution FunctionTool) ArgTransformTransformedToolr ToolResultSerializerTypect|trt|tr|nd}nt|tr t|}nd}|y|jj d}|dS|S)aResolve the effective ``by_alias`` setting for serializing *value*. Pydantic's low-level serialization helpers (``to_json``, ``to_jsonable_python``) default ``by_alias`` to ``True``, which silently ignores a model's ``serialize_by_alias`` config. When *value* is a Pydantic model we consult that config instead, falling back to ``True`` to preserve FastMCP's longstanding default of emitting aliases when no preference is declared. NTserialize_by_alias) isinstancetype issubclassr model_configget)valuemodel configureds c/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/fastmcp/tools/base.pyresolve_serialize_by_aliasr6Ase%#E954 E9 %U  }##''(<=J%45:5chtj|tt|j S)N)fallbackby_alias) pydantic_coreto_jsonstrr6decode)datas r5default_serializerr@Ys)   s%?%E  fhr7ceZdZUedZded<eddZded <edd Zded <ed d Zded< d dfd Z ddZ xZ S) ToolResultz*List of content blocks for the tool result) descriptionlist[ContentBlock]contentNz4Structured content matching the tool's output schema)defaultrCdict[str, Any] | Nonestructured_contentz)Runtime metadata about the tool executionmetaFzWhether this result represents a tool execution error. When True, it maps to CallToolResult.isError so the error is returned to the client rather than raised.boolis_errorc| | td||}t|}|trAt|tr t |}n%t|t rt t |} tj|t|}t|ts%tdt|jd|dt |E|||| y#tj$r}tjd|d}~wwxYw) Nz5Either content or structured_content must be provided)resultview)r2r:zCould not serialize structured content. If this is unexpected, set your tool's output_schema to None to disable automatic serialization: z/structured_content must be a dict or None. Got z: zA. Tools should wrap non-dict values based on their output_schema.)rErHrIrK) ValueError_convert_to_content _HAS_PREFABr- _PrefabApp_prefab_to_json_PrefabComponentr;to_jsonable_pythonr6PydanticSerializationErrorloggererrordictr.__name__super__init__)selfrErHrIrKconverted_contente __class__s r5r]zToolResult.__init__ps> ?19TU U _(G0C70S  )0*=)89K)L& 24DE)8"(:;*& %2%E%E,78JK&"0$7  23<<=R@R?UVVV %1  !;;  `ab`cd  s+ CD'DDc|j |jr7t|j|j|j|jS|j |jS|j|jfS)N)structuredContentrEisError_meta)rIrKr rHrEr^s r5 to_mcp_resultzToolResult.to_mcp_resultsl 99 DMM!"&"9"9  ii    " " *<< ||T4444r7)NNNF)rEzlist[ContentBlock] | Any | NonerHzdict[str, Any] | Any | NonerIrGrKrJ)returnzOlist[ContentBlock] | tuple[list[ContentBlock], dict[str, Any]] | CallToolResult) r[ __module__ __qualname__rrE__annotations__rHrIrKr]rg __classcell__ras@r5rBrB_s"'@#G 16"X1-#("M#D ,Hd48:>&* / 0/ 8/ $ /  / b5 X5r7rBc4eZdZUdZdZded<ded<dZded <dZd ed <dZd ed <dZ ded<dZ ded<dZ ded<e dd&dZ d'dZeddddddddeddddddd d(dZd)dZd*dZe d+ d,dZe d-dZ d+ d.dZd/dZddd  d0d!Zedeedeededdd" d1d#Zed2d$Zd3fd% ZxZS)4rz Internal tool registration info.toolz ClassVar[str] KEY_PREFIXzOAnnotated[dict[str, Any], Field(description='JSON schema for tool parameters')] parametersNzRAnnotated[dict[str, Any] | None, Field(description='JSON schema for tool output')] output_schemaz]Annotated[ToolAnnotations | None, Field(description='Additional annotations about the tool')]rz]Annotated[ToolExecution | None, Field(description='Task execution configuration (SEP-1686)')] executionzAnnotated[SkipJsonSchema[ToolResultSerializerType | None], Field(description='Deprecated. Return ToolResult from your tools for full control over serialization.')] serializerzAnnotated[SkipJsonSchema[AuthCheck | list[AuthCheck] | None], Field(description='Authorization checks for this tool', exclude=True)]authzkAnnotated[float | None, Field(description='Execution timeout in seconds. If None, no timeout is applied.')]timeoutafter)modec0t|j|S)zz&Tool.convert_result..YsM94 469)r:rErHzx-fastmcp-wrap-resultrMfastmcp wrap_resultT)rErHrI)r-rBrRrS_prefab_to_tool_result_get_fastmcp_app_namerUrQrtbytesrrr rrrlisttupleanyr;rVr6rWUnicodeDecodeErrorrZr1)r^ raw_valuerE structuredrs r5convert_resultzTool.convert_result8s i ,  )Z0-%:4%@)%56-I.%:4%@ &iDOOL i 'g. .    % y,"6">"E F9dUl3M9MMg. . /&99$>y$IJ    %*d+!'jQQg. .((,,-DE 9D*5*7B)mT23  IM  88:LM /g. . /s F%GGc Kywrrr^r task_metas r5_runz Tool._runss c Kywrrrs r5rz Tool._runzs &)rcKddlm}||d||d{}|r|S|j|d{S7!7w)a-Server entry point that handles task routing. This allows ANY Tool subclass to support background execution by setting task_config.mode to "supported" or "required". The server calls this method instead of run() directly. Args: arguments: Tool arguments task_meta: If provided, execute as background task and return CreateTaskResult. If None (default), execute synchronously and return ToolResult. Returns: ToolResult when task_meta is None. CreateTaskResult when task_meta is provided. Subclasses can override this to customize task routing behavior. For example, FastMCPProviderTool overrides to delegate to child middleware without submitting to Docket. r)check_background_taskro) component task_typerrN)fastmcp.server.tasks.routingrr)r^rrr task_results r5rz Tool._runsO2 G1    XXi((( )s>:><>>c|jjsy|j|j|jgy)z8Register this tool with docket for background execution.N)names)rrregisterrkey)r^dockets r5register_with_docketzTool.register_with_dockets1..0  3r7)fn_keytask_keyc~K|xs |j}|r||d<|j|fi||d{S7w)aeSchedule this tool for background execution via docket. Args: docket: The Docket instance arguments: Tool arguments fn_key: Function lookup key in Docket registry (defaults to self.key) task_key: Redis storage key for the result **kwargs: Additional kwargs passed to docket.add() rN)radd)r^rrrrkwargs lookup_keys r5 add_to_docketzTool.add_to_docketsE$'txx $F5M5ZVZZ 5f5i@@@@s 4=;=) rzr}rCrrrrrtrItransform_args transform_fnc jddlm} |j|}| j|| ||| ||||||  S)Nr)r)) rorrzr}rrCrrrrrtrI)fastmcp.tools.tool_transformr) _ensure_tool from_tool) rrorzr}rCrrrrrtrIrrr)s r5rzTool.from_toolsN A%(((%)##'!  r7ct|tr|Sddlm}ddlm}m}||}t||r|j||S|j|S)zCCoerce a callable into a Tool, respecting @tool decorator metadata.r)get_fastmcp_meta)r'ToolMeta)metadata)r-rfastmcp.decoratorsrrr'rr)rrorr'rfmetas r5rzTool._ensure_toolsS dD !K7F & eX &-<--dUC C  &&r7c,t|dddzS)Nro LocalProvider)zfastmcp.component.typezfastmcp.provider.type)r\get_span_attributes)r^ras r5rzTool.get_span_attributess#w*,&,%40   r7)rhr)rrrhr)"rzCallable[..., Any]rz str | Nonerzstr | int | Noner}rrCrrzlist[Icon] | Nonerset[str] | NonerzToolAnnotations | Nonerzlist[str] | Nonerrdict[str, Any] | NotSetT | NonertToolResultSerializerType | NonerIrGrzbool | TaskConfig | Nonervz float | Noneruz"AuthCheck | list[AuthCheck] | Nonerz bool | Nonerhr')rdict[str, Any]rhrB)rrrhrBr)rrrNonerhrB)rrrrrhzmcp.types.CreateTaskResult)rrrzTaskMeta | Nonerhz'ToolResult | mcp.types.CreateTaskResult)rr$rhr) rr$rrrrrrrrrhr%)roTool | Callable[..., Any]rzrr}str | NotSetT | NonerCrrrrz ToolAnnotations | NotSetT | NonerrrrtrrIrrzdict[str, ArgTransform] | NonerzCallable[..., Any] | Nonerhr))rorrhr)rhr)r[rirj__doc__rprkrrrrsrtrurvrr{r classmethodr rrrr rrrrrrrlrms@r5rrsc* &J &              '"# !! !F  $( "&#' $.2)-9?6:&*)- $37%)%( (  ( " (  (  ( !( ( ,( '( 7( 4( $( '( !( "1#( $#%( & '( ( T E9 v!   )!)) $ ))&*$)!$)#$) 1 $)L4"# AA"A  A  AA A.  &,,2 $8>9?6:069=26 '   $  *   6 7 4 . 7 0    B ' '  r7rc| ||St|S#t$r,}tjd|dYd}~t|Sd}~wwxYw)Nz!Error serializing tool result: %sT)exc_info) ExceptionrXwarningr@)rMrtr`s r5_serialize_with_fallbackrse f% % f %%  NN3    f %% s A AA c$t|tr|St|tr|jSt|tr|j St|t r|jSt|tr td|St|tr td|jdStdt||S#t$r2ddl }td|j|jdcYSwxYw)Ntextr.rzutf-8rascii)r-r rto_image_contentrto_audio_contentrto_resource_contentr=rrr>rbase64 b64encoder)rrtrs r5 _convert_to_single_content_blockr s$ % $$$&&$$$&&$''))$T22$ YFW1EF F F)A$ )S TT " Y F1A1A$1G1N1Nw1WX X Ys!C8DDz[Rendered Prefab UI]c> ddlm}||S#t$rYywxYw)z.es =fd:dL )frc3fK|])}t|ttztztz+ywr)r-r rrrrs r5rz&_convert_to_content..js' TVT:dL50584? @Vs/1rr) r-rrrallrr rr)rMrtrs r5rQrQXs ~ fte| -0DEE =f ==  TV TT   dL1 -T: >     V*B6:*V W XX s%Bcdddd}||vrLddl}|jjr tjd|dt d dd lm}t||Std td |)z2Deprecated re-exports for backwards compatibility.r'ParsedFunctionro)r'rrorNz Importing zX from fastmcp.tools.tool is deprecated. Import from fastmcp.tools.function_tool instead.) stacklevel) function_toolzmodule z has no attribute ) rsettingsdeprecation_warningswarningswarnr fastmcp.toolsrgetattrAttributeErrorr[)rzdeprecated_exportsrrs r5 __getattr__rxs'*  !!    0 0 MMTF#CD)   0}d++ 78,.@I JJr7)r2rrhrJ)r?rrhr=r)rMrrtrrhr=)rrrtrrhr )rrrhzCallable[..., str] | None)rrrrrhr)rorrhr)rrrrrhrB)rMrrtrrhrD)rzr=rhr)S __future__rr collections.abcrtypingrrrrr r mcp.typesmcpr;mcp.shared.tool_name_validationr r r rrrrrrpydanticrrrpydantic.json_schemarfastmcp.exceptionsrfastmcp.utilities.authorizationrfastmcp.utilities.componentsrfastmcp.utilities.loggingrfastmcp.utilities.tasksrrfastmcp.utilities.typesrrrr r! prefab_ui.appr"rSprefab_ui.components.baser#rUrRrrr$docket.executionr%rr'rr(r)r[rXr=r*rkr6r@rBrrrrrTrrrQ__all__rrr7r5r"s{"$G&66/859085GK*8J H '/ucz&:):60 R5R5jE E R @D &  &< & &$37U U/UU</  37Y Y/YY: < KSKsD!!D+*D+