From a6693d9d226c3bb2afa28bd12b6633b018c07b8f Mon Sep 17 00:00:00 2001 From: Elliot Williams Date: Sat, 30 May 2026 05:23:22 +0000 Subject: [PATCH] Fix typos found by codespell: requestor -> requester, Implementors -> Implementers --- src/mcp/server/auth/provider.py | 4 ++-- src/mcp/server/sse.py | 4 ++-- src/mcp/server/streamable_http_manager.py | 8 ++++---- src/mcp/types/_types.py | 2 +- 4 files changed, 9 insertions(+), 9 deletions(-) diff --git a/src/mcp/server/auth/provider.py b/src/mcp/server/auth/provider.py index 4ce1137575..03fc0fe919 100644 --- a/src/mcp/server/auth/provider.py +++ b/src/mcp/server/auth/provider.py @@ -111,7 +111,7 @@ class OAuthAuthorizationServerProvider(Protocol, Generic[AuthorizationCodeT, Ref async def get_client(self, client_id: str) -> OAuthClientInformationFull | None: """Retrieves client information by client ID. - Implementors MAY raise NotImplementedError if dynamic client registration is + Implementers MAY raise NotImplementedError if dynamic client registration is disabled in ClientRegistrationOptions. Args: @@ -124,7 +124,7 @@ async def get_client(self, client_id: str) -> OAuthClientInformationFull | None: async def register_client(self, client_info: OAuthClientInformationFull) -> None: """Saves client information as part of registering it. - Implementors MAY raise NotImplementedError if dynamic client registration is + Implementers MAY raise NotImplementedError if dynamic client registration is disabled in ClientRegistrationOptions. Args: diff --git a/src/mcp/server/sse.py b/src/mcp/server/sse.py index 05e948332b..ba1eba5c80 100644 --- a/src/mcp/server/sse.py +++ b/src/mcp/server/sse.py @@ -232,8 +232,8 @@ async def handle_post_message(self, scope: Scope, receive: Receive, send: Send) return await response(scope, receive, send) user = scope.get("user") - requestor = authorization_context(user) if isinstance(user, AuthenticatedUser) else None - if requestor != self._session_owners.get(session_id): + requester = authorization_context(user) if isinstance(user, AuthenticatedUser) else None + if requester != self._session_owners.get(session_id): # A session can only be used with the credential that created it. # Respond exactly as if the session did not exist. logger.warning("Rejecting message for session %s: credential does not match", session_id) diff --git a/src/mcp/server/streamable_http_manager.py b/src/mcp/server/streamable_http_manager.py index 81350a8f24..363a999d5e 100644 --- a/src/mcp/server/streamable_http_manager.py +++ b/src/mcp/server/streamable_http_manager.py @@ -197,12 +197,12 @@ async def _handle_stateful_request(self, scope: Scope, receive: Receive, send: S request_mcp_session_id = request.headers.get(MCP_SESSION_ID_HEADER) user = scope.get("user") - requestor = authorization_context(user) if isinstance(user, AuthenticatedUser) else None + requester = authorization_context(user) if isinstance(user, AuthenticatedUser) else None # Existing session case if request_mcp_session_id is not None and request_mcp_session_id in self._server_instances: transport = self._server_instances[request_mcp_session_id] - if requestor != self._session_owners.get(request_mcp_session_id): + if requester != self._session_owners.get(request_mcp_session_id): # A session can only be used with the credential that created # it. Respond exactly as if the session did not exist. logger.warning( @@ -240,8 +240,8 @@ async def _handle_stateful_request(self, scope: Scope, receive: Receive, send: S ) assert http_transport.mcp_session_id is not None - if requestor is not None: - self._session_owners[http_transport.mcp_session_id] = requestor + if requester is not None: + self._session_owners[http_transport.mcp_session_id] = requester self._server_instances[http_transport.mcp_session_id] = http_transport logger.info(f"Created new transport with session ID: {new_session_id}") diff --git a/src/mcp/types/_types.py b/src/mcp/types/_types.py index 9005d253af..2af50518ea 100644 --- a/src/mcp/types/_types.py +++ b/src/mcp/types/_types.py @@ -534,7 +534,7 @@ class TaskStatusNotificationParams(NotificationParams, Task): class TaskStatusNotification(Notification[TaskStatusNotificationParams, Literal["notifications/tasks/status"]]): - """An optional notification from the receiver to the requestor, informing them that a task's status has changed. + """An optional notification from the receiver to the requester, informing them that a task's status has changed. Receivers are not required to send these notifications. """