)`ik dZddlmZddlmZmZmZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZddlmZdd lmZmZdd lmZdd lmZdd lmZmZdd lmZm Z ddl!m"Z"GddeZ#eddZ$e ej%ej&fej'ze(zZ)Gddeej*ej+ej&ej%ej'fZ,dS)a ServerSession Module This module provides the ServerSession class, which manages communication between the server and client in the MCP (Model Context Protocol) framework. It is most commonly used in MCP servers to interact with the client. Common usage pattern: ``` server = Server(name) @server.call_tool() async def handle_tool_call(ctx: RequestContext, arguments: dict[str, Any]) -> Any: # Check client capabilities before proceeding if ctx.session.check_client_capability( types.ClientCapabilities(experimental={"advanced_tools": dict()}) ): # Perform advanced tool operations result = await perform_advanced_tool_operation(arguments) else: # Fall back to basic tool operations result = await perform_basic_tool_operation(arguments) return result @server.list_prompts() async def handle_list_prompts(ctx: RequestContext) -> list[types.Prompt]: # Access session for any necessary checks or operations if ctx.session.client_params: # Customize prompts based on client initialization parameters return generate_custom_prompts(ctx.session.client_params) else: return default_prompts ``` The ServerSession class is typically used internally by the Server class and should not be instantiated directly by users of the MCP framework. )Enum)AnyTypeVaroverloadN)MemoryObjectReceiveStreamMemoryObjectSendStream)AnyUrl)!ExperimentalServerSessionFeatures)InitializationOptions)validate_sampling_tools!validate_tool_use_result_messages)check_tasks_capability)RELATED_TASK_METADATA_KEY)ServerMessageMetadataSessionMessage) BaseSessionRequestResponder)SUPPORTED_PROTOCOL_VERSIONSceZdZdZdZdZdS)InitializationStateN)__name__ __module__ __qualname__NotInitialized Initializing Initializedf/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/mcp/server/session.pyrr>sNLKKKr!rServerSessionT ServerSession)boundceZdZUejZeed<dZej dzed<dZ e dzed< dFde e ezdee ded ed df fd Zed ej dzfd Zed e fd Zdejd efdZdGfd ZdeejejffdZdejd dfdZ dHdejde de!dzdej"dzd df dZ#de$d dfdZ%e&dddddddddd de'ej(de)de!dzd ej*dzd!e+dzd"e'e!dzd#e,e!e fdzd$ej-dzd%dd&ej.dzdej"dzd ej/fd'Z0e&ddddddddd(de'ej(de)de!dzd ej*dzd!e+dzd"e'e!dzd#e,e!e fdzd$ej-dzd%e'ej1d&ej.dzdej"dzd ej2fd)Z0dddddddddd de'ej(de)de!dzd ej*dzd!e+dzd"e'e!dzd#e,e!e fdzd$ej-dzd%e'ej1dzd&ej.dzdej"dzd ej/ej2zfd*Z0d ej3fd+Z4 dId,e!d-ej5dej"dzd ej6fd.Z7 dId,e!d-ej5dej"dzd ej6fd/Z8 dId,e!d0e!d1e!dej"dzd ej6f d2Z9d ej:fd3Z; dJd4e!e)zd5e+d6e+dzd,e!dzde!dzd df d7ZdGd:Z? dId1e!dej"dzd dfd;Z@ dHd,e!d-ej5dZC dId,e!d0e!d1e!dz(ServerSession.__init__..hsT5Y5`5`5b5br!)super__init__types ClientRequestClientNotificationrrr_initialization_state _init_optionsanyiocreate_memory_object_streamServerRequestResponder_incoming_message_stream_writerr2 _exit_stackpush_async_callback)r5r*r+r,r- __class__s` r"r8zServerSession.__init__Xs lE4GIabbb/8 `  + +>Q>` "*UZUv "V V V R,d.R ,,-b-b-b-bcccccr!c|jSr1)r(r4s r" client_paramszServerSession.client_paramsjs ""r!cF|jt||_|jS)uExperimental APIs for server→client task operations. WARNING: These APIs are experimental and may change without notice. )r)r r4s r" experimentalzServerSession.experimentalns&  & .*KD*Q*QD '**r! capabilityc|jdS|jj}|j#|jdS|jjr|jjsdS|j=|jdS|jj|jjdS|jj|jjdS|j |jdS|jE|jdS|j D]"\}}||jvs|j||krdS#|j %|j dSt|j |j sdSdS)z3Check if the client supports a specific capability.NFT) r( capabilitiesroots listChangedsamplingcontexttools elicitationrHitemstasksr)r5rI client_capsexp_key exp_values r"check_client_capabilityz%ServerSession.check_client_capabilityxs[   &5)6   ' (u+ K4E4Q u   *#+u"*6;;O;W;_u"(49M9S9[u  ! -+2I2Q5  " .'/u&0&=&C&C&E&E ! !"+":::k>VW^>_cl>l>l 55?m   ' (u)**:K,M/3/A/M*.*<*B ,","," .2-?-L   $.A-L***-8."$$$$$%-1D1PPP&'\]]]QPsB+C::C>C> notificationcKtjd{V|jtjdx\t j|_dS |jt jkrtddS)Nr z8Received notification before initialization was complete) r>lowlevel checkpointrfr9InitializedNotificationrrr<rq)r5rts r"_received_notificationz$ServerSession._received_notificationsn''))))))))).00000-@-L***1-1D1PPP&'abbbQPr!leveldataloggerrelated_request_idc K|tjtjtj||||d{VdS)z Send a log message notification.)rzr{r|r\N)send_notificationr9ServerNotificationLoggingMessageNotification LoggingMessageNotificationParams)r5rzr{r|r}s r"send_log_messagezServerSession.send_log_messages$$  $0 A#!%      r!uric K|tjtjtj|d{VdS)z%Send a resource updated notification.)rr\N)rr9rResourceUpdatedNotification!ResourceUpdatedNotificationParams)r5rs r"send_resource_updatedz#ServerSession.send_resource_updateds|$$  $1 BsKKK             r!) system_promptinclude_context temperaturestop_sequencesmetadatamodel_preferencesrP tool_choicer}messages max_tokensrrrrrrrPrc  KdS)z0Overload: Without tools, returns single content.Nr r5rrrrrrrrrPrr}s r"create_messagezServerSession.create_message " r!)rrrrrrrr}c  KdS)z4Overload: With tools, returns array-capable content.Nr rs r"rzServerSession.create_messagerr!c K|jr |jjnd} t| | | t|t jt jt j||||||||| |  } t| }| (| | tj |d{VS| | tj |d{VS)aSend a sampling/create_message request. Args: messages: The conversation messages to send. max_tokens: Maximum number of tokens to generate. system_prompt: Optional system prompt. include_context: Optional context inclusion setting. Should only be set to "thisServer" or "allServers" if the client has sampling.context capability. temperature: Optional sampling temperature. stop_sequences: Optional stop sequences. metadata: Optional metadata to pass through to the LLM provider. model_preferences: Optional model selection preferences. tools: Optional list of tools the LLM can use during sampling. Requires client to have sampling.tools capability. tool_choice: Optional control over tool usage behavior. Requires client to have sampling.tools capability. related_request_id: Optional ID of a related request. Returns: The sampling result from the client. Raises: McpError: If tools are provided but client doesn't support them. ValueError: If tool_use or tool_result message structure is invalid. N) r systemPromptincludeContextr maxTokens stopSequencesrmodelPreferencesrP toolChoicer\r})re result_typer) r(rKr r r9 ServerRequestCreateMessageRequestCreateMessageRequestParamsr send_requestCreateMessageResultWithToolsCreateMessageResult)r5rrrrrrrrrPrr}rTre metadata_objs r"rzServerSession.create_messagesGR;?:MWd)66SW  UK@@@)(333%  &7%!.#2 +("0%%6*         -@RSSS   **!>%+  &&1!'         r!cK|tjtjtjd{VS)zSend a roots/list request.N)rr9rListRootsRequestListRootsResultr4s r" list_rootszServerSession.list_roots^sY&&   6 8 8 9 9  !         r!messagerequestedSchemac@K||||d{VS)aSend a form mode elicitation/create request. Args: message: The message to present to the user requestedSchema: Schema defining the expected response structure related_request_id: Optional ID of the request that triggered this elicitation Returns: The client's response Note: This method is deprecated in favor of elicit_form(). It remains for backward compatibility but new code should use elicit_form(). N) elicit_formr5rrr}s r"elicitzServerSession.elicites3(%%g@RSSSSSSSSSr!c K|tjtjtj||tjt |d{VS)agSend a form mode elicitation/create request. Args: message: The message to present to the user requestedSchema: Schema defining the expected response structure related_request_id: Optional ID of the request that triggered this elicitation Returns: The client's response with form data )rrr\rrN)rr9r ElicitRequestElicitRequestFormParams ElicitResultrrs r"rzServerSession.elicit_form{s &&  # 8 '(7    *>PQQQ'         r!urlelicitation_idc K|tjtjtj|||tjt |d{VS)akSend a URL mode elicitation/create request. This directs the user to an external URL for out-of-band interactions like OAuth flows, credential collection, or payment processing. Args: message: Human-readable explanation of why the interaction is needed url: The URL the user should navigate to elicitation_id: Unique identifier for tracking this elicitation related_request_id: Optional ID of the request that triggered this elicitation Returns: The client's response indicating acceptance, decline, or cancellation rr elicitationIdr\rrN)rr9rrElicitRequestURLParamsrr)r5rrrr}s r" elicit_urlzServerSession.elicit_urls*&&  # 7 '&4    *>PQQQ'         r!cK|tjtjtjd{VS)zSend a ping request.N)rr9rrp EmptyResultr4s r" send_pingzServerSession.send_pingsY&&   1 3 3 4 4           r!progress_tokenprogresstotalc K|tjtjtj|||||d{VdS)zSend a progress notification.) progressTokenrrrr\N)rr9rProgressNotificationProgressNotificationParams)r5rrrrr}s r"send_progress_notificationz(ServerSession.send_progress_notifications$$  $* ;&4!)# '       r!cK|tjtjd{VdS)z*Send a resource list changed notification.N)rr9rResourceListChangedNotificationr4s r"send_resource_list_changedz(ServerSession.send_resource_list_changedsF$$U%=e>c>e>e%f%fgggggggggggr!cK|tjtjd{VdS)z&Send a tool list changed notification.N)rr9rToolListChangedNotificationr4s r"send_tool_list_changedz$ServerSession.send_tool_list_changedsF$$U%=e>_>a>a%b%bcccccccccccr!cK|tjtjd{VdS)z(Send a prompt list changed notification.N)rr9rPromptListChangedNotificationr4s r"send_prompt_list_changedz&ServerSession.send_prompt_list_changedsF$$U%=e>a>c>c%d%deeeeeeeeeeer!c K|tjtjtj||d{VdS)aSend an elicitation completion notification. This should be sent when a URL mode elicitation has been completed out-of-band to inform the client that it may retry any requests that were waiting for this elicitation. Args: elicitation_id: The unique identifier of the completed elicitation related_request_id: Optional ID of the request that triggered this )rr\N)rr9rElicitCompleteNotification ElicitCompleteNotificationParams)r5rr}s r"send_elicit_completez"ServerSession.send_elicit_completes$$  $0 AP^___               r!related_task_idtaskcttj|||}|ddd}|@d|vri|d<tj|d|dt<|rd |d t |n|j}||xjd z c_tjd |d |S)aBuild a form mode elicitation request without sending it. Args: message: The message to present to the user requestedSchema: Schema defining the expected response structure related_task_id: If provided, adds io.modelcontextprotocol/related-task metadata task: If provided, makes this a task-augmented request Returns: A JSONRPCRequest ready to be sent or queued )rrrTjsonby_aliasmode exclude_noneN_metataskIdrtask--r2.0elicitation/createjsonrpcidmethodr])r9r model_dumpRelatedTaskMetadatarr _request_idJSONRPCRequest)r5rrrrr] params_data request_ids r"_build_elicit_form_requestz(ServerSession._build_elicit_form_requests$.+    ''FQU'VV   &k))') G$>C>W&???j$j''  !: ;@Od;_;;r&zz;;;TXTd  "    !  #'     r!cttj|||}|ddd}|@d|vri|d<tj|d|dt<|rd |d t |n|j}||xjd z c_tjd |d |S)aBuild a URL mode elicitation request without sending it. Args: message: Human-readable explanation of why the interaction is needed url: The URL the user should navigate to elicitation_id: Unique identifier for tracking this elicitation related_task_id: If provided, adds io.modelcontextprotocol/related-task metadata Returns: A JSONRPCRequest ready to be sent or queued rTrrNrrrrrrrrr)r9rrrrrrr)r5rrrrr]rrs r"_build_elicit_url_requestz'ServerSession._build_elicit_url_request*s$-(    ''FQU'VV   &k))') G$>C>W&???j$j''  !: ;@Od;_;;r&zz;;;TXTd  "    !  #'     r!) rrrrrrrPrrrc tj||||||||| | |  } | ddd}| @d|vri|d<tj| d|dt<| rd | d t | n|j}| |xjd z c_tjd |d |S)aBuild a sampling/createMessage request without sending it. Args: messages: The conversation messages to send max_tokens: Maximum number of tokens to generate system_prompt: Optional system prompt include_context: Optional context inclusion setting temperature: Optional sampling temperature stop_sequences: Optional stop sequences metadata: Optional metadata to pass through to the LLM provider model_preferences: Optional model selection preferences tools: Optional list of tools the LLM can use during sampling tool_choice: Optional control over tool usage behavior related_task_id: If provided, adds io.modelcontextprotocol/related-task metadata task: If provided, makes this a task-augmented request Returns: A JSONRPCRequest ready to be sent or queued ) rrrrrrrrrPrrTrrNrrrrrrrzsampling/createMessager)r9rrrrrrr)r5rrrrrrrrrPrrrr]rrs r"_build_create_message_requestz+ServerSession._build_create_message_requestWsF1&*# (."    ''FQU'VV   &k))') G$>C>W&???j$j''  !: ;@Od;_;;r&zz;;;TXTd  "    !  #+     r!cJK|j|d{VdS)aSend a raw session message. This is primarily used by TaskResultHandler to deliver queued messages (elicitation/sampling requests) to the client during task execution. WARNING: This is a low-level experimental method that may change without notice. Prefer using higher-level methods like send_notification() or send_request() for normal operations. Args: message: The session message to send N) _write_streamsend)r5rs r" send_messagezServerSession.send_messages7 %%g...........r!reqcJK|j|d{VdSr1)rAr)r5rs r"_handle_incomingzServerSession._handle_incomings5277<<<<<<<<<<anyio.lowlevelanyio.streams.memoryrrpydanticr mcp.typesr9(mcp.server.experimental.session_featuresr mcp.server.modelsr mcp.server.validationr r *mcp.shared.experimental.tasks.capabilitiesr%mcp.shared.experimental.tasks.helpersrmcp.shared.messagerrmcp.shared.sessionrrmcp.shared.versionrrr#r:rir;rr@rrr$r r!r"r!s%%N)))))))))) RRRRRRRRVVVVVV333333\\\\\\\\MMMMMMKKKKKKDDDDDDDD;:::::$ )AAAU(%*<<=@XX[dd h 4h 4h 4h 4h 4        "h 4h 4h 4h 4h 4r!