Method _execute_mcp_auth_and_respond

python/copilot/session.py:2076–2127

Execute an MCP auth handler and respond via RPC.

(
        self,
        request: McpAuthRequest,
        handler: McpAuthHandler,
    )

                pass  # Connection lost or RPC error — nothing we can do

    async def _execute_mcp_auth_and_respond(
        self,
        request: McpAuthRequest,
        handler: McpAuthHandler,
    ) -> None:
        """Execute an MCP auth handler and respond via RPC."""
        request_id = request["requestId"]
        try:
            handler_start = time.perf_counter()
            maybe_result = handler(request, {"sessionId": self.session_id})
            if inspect.isawaitable(maybe_result):
                result = cast(McpAuthHandlerResult, await maybe_result)
            else:
                result = maybe_result
            log_timing(
                logger,
                logging.DEBUG,
                "CopilotSession._execute_mcp_auth_and_respond dispatch",
                handler_start,
                session_id=self.session_id,
                request_id=request_id,
            )

            if result and result.get("kind", "token") == "token":
                rpc_result = MCPOauthPendingRequestResponse(
                    kind=MCPOauthPendingRequestResponseKind.TOKEN,
                    access_token=result["accessToken"],
                    expires_in=result.get("expiresIn"),
                    token_type=result.get("tokenType"),
                )
            else:
                rpc_result = MCPOauthPendingRequestResponse(
                    kind=MCPOauthPendingRequestResponseKind.CANCELLED
                )
            await self.rpc.mcp.oauth.handle_pending_request(
                MCPOauthHandlePendingRequest(
                    request_id=request_id,
                    result=rpc_result,
                )
            )
        except Exception:
            try:
                await self.rpc.mcp.oauth.handle_pending_request(
                    MCPOauthHandlePendingRequest(
                        request_id=request_id,
                        result=MCPOauthPendingRequestResponse(
                            kind=MCPOauthPendingRequestResponseKind.CANCELLED
                        ),
                    )
                )
            except (JsonRpcError, ProcessExitedError, OSError):
                pass  # Connection lost or RPC error — nothing we can do

    async def _execute_command_and_respond(
        self,