refactor: replace mcp.types as types to from mcp import types (#1986)
This commit is contained in:
parent
4fc49c62bd
commit
1a8c14a5b8
46 changed files with 66 additions and 73 deletions
22
README.md
22
README.md
|
|
@ -682,7 +682,7 @@ The Context object provides the following capabilities:
|
|||
- `ctx.session` - Access to the underlying session for advanced communication (see [Session Properties and Methods](#session-properties-and-methods))
|
||||
- `ctx.request_context` - Access to request-specific data and lifespan resources (see [Request Context Properties](#request-context-properties))
|
||||
- `await ctx.debug(message)` - Send debug log message
|
||||
- `await ctx.info(message)` - Send info log message
|
||||
- `await ctx.info(message)` - Send info log message
|
||||
- `await ctx.warning(message)` - Send warning log message
|
||||
- `await ctx.error(message)` - Send error log message
|
||||
- `await ctx.log(level, message, logger_name=None)` - Send log with custom level
|
||||
|
|
@ -1110,13 +1110,13 @@ The session object accessible via `ctx.session` provides advanced control over c
|
|||
async def notify_data_update(resource_uri: str, ctx: Context) -> str:
|
||||
"""Update data and notify clients of the change."""
|
||||
# Perform data update logic here
|
||||
|
||||
|
||||
# Notify clients that this specific resource changed
|
||||
await ctx.session.send_resource_updated(AnyUrl(resource_uri))
|
||||
|
||||
|
||||
# If this affects the overall resource list, notify about that too
|
||||
await ctx.session.send_resource_list_changed()
|
||||
|
||||
|
||||
return f"Updated {resource_uri} and notified clients"
|
||||
```
|
||||
|
||||
|
|
@ -1145,11 +1145,11 @@ def query_with_config(query: str, ctx: Context) -> str:
|
|||
"""Execute a query using shared database and configuration."""
|
||||
# Access typed lifespan context
|
||||
app_ctx: AppContext = ctx.request_context.lifespan_context
|
||||
|
||||
|
||||
# Use shared resources
|
||||
connection = app_ctx.db
|
||||
settings = app_ctx.config
|
||||
|
||||
|
||||
# Execute query with configuration
|
||||
result = connection.execute(query, timeout=settings.query_timeout)
|
||||
return str(result)
|
||||
|
|
@ -1644,7 +1644,7 @@ from contextlib import asynccontextmanager
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -1758,7 +1758,7 @@ uv run examples/snippets/servers/lowlevel/basic.py
|
|||
import asyncio
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -1837,7 +1837,7 @@ import asyncio
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -1939,7 +1939,7 @@ import asyncio
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -2012,7 +2012,7 @@ For servers that need to handle large datasets, the low-level server provides pa
|
|||
```python
|
||||
"""Example of implementing pagination with MCP server decorators."""
|
||||
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
|
||||
# Initialize the server
|
||||
|
|
|
|||
22
README.v2.md
22
README.v2.md
|
|
@ -683,7 +683,7 @@ The Context object provides the following capabilities:
|
|||
- `ctx.session` - Access to the underlying session for advanced communication (see [Session Properties and Methods](#session-properties-and-methods))
|
||||
- `ctx.request_context` - Access to request-specific data and lifespan resources (see [Request Context Properties](#request-context-properties))
|
||||
- `await ctx.debug(message)` - Send debug log message
|
||||
- `await ctx.info(message)` - Send info log message
|
||||
- `await ctx.info(message)` - Send info log message
|
||||
- `await ctx.warning(message)` - Send warning log message
|
||||
- `await ctx.error(message)` - Send error log message
|
||||
- `await ctx.log(level, message, logger_name=None)` - Send log with custom level
|
||||
|
|
@ -1111,13 +1111,13 @@ The session object accessible via `ctx.session` provides advanced control over c
|
|||
async def notify_data_update(resource_uri: str, ctx: Context) -> str:
|
||||
"""Update data and notify clients of the change."""
|
||||
# Perform data update logic here
|
||||
|
||||
|
||||
# Notify clients that this specific resource changed
|
||||
await ctx.session.send_resource_updated(AnyUrl(resource_uri))
|
||||
|
||||
|
||||
# If this affects the overall resource list, notify about that too
|
||||
await ctx.session.send_resource_list_changed()
|
||||
|
||||
|
||||
return f"Updated {resource_uri} and notified clients"
|
||||
```
|
||||
|
||||
|
|
@ -1146,11 +1146,11 @@ def query_with_config(query: str, ctx: Context) -> str:
|
|||
"""Execute a query using shared database and configuration."""
|
||||
# Access typed lifespan context
|
||||
app_ctx: AppContext = ctx.request_context.lifespan_context
|
||||
|
||||
|
||||
# Use shared resources
|
||||
connection = app_ctx.db
|
||||
settings = app_ctx.config
|
||||
|
||||
|
||||
# Execute query with configuration
|
||||
result = connection.execute(query, timeout=settings.query_timeout)
|
||||
return str(result)
|
||||
|
|
@ -1645,7 +1645,7 @@ from contextlib import asynccontextmanager
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -1759,7 +1759,7 @@ uv run examples/snippets/servers/lowlevel/basic.py
|
|||
import asyncio
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -1838,7 +1838,7 @@ import asyncio
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -1940,7 +1940,7 @@ import asyncio
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
@ -2013,7 +2013,7 @@ For servers that need to handle large datasets, the low-level server provides pa
|
|||
```python
|
||||
"""Example of implementing pagination with MCP server decorators."""
|
||||
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
|
||||
# Initialize the server
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ from typing import Any
|
|||
|
||||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from starlette.requests import Request
|
||||
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from starlette.requests import Request
|
||||
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.server.lowlevel.helper_types import ReadResourceContents
|
||||
from starlette.requests import Request
|
||||
|
|
|
|||
|
|
@ -5,8 +5,8 @@ from typing import Any
|
|||
|
||||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
import uvicorn
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.server.streamable_http_manager import StreamableHTTPSessionManager
|
||||
from starlette.applications import Starlette
|
||||
|
|
|
|||
|
|
@ -5,7 +5,7 @@ from typing import Any
|
|||
|
||||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.server.streamable_http_manager import StreamableHTTPSessionManager
|
||||
from starlette.applications import Starlette
|
||||
|
|
|
|||
|
|
@ -11,8 +11,8 @@ from contextlib import asynccontextmanager
|
|||
from typing import Any
|
||||
|
||||
import click
|
||||
import mcp.types as types
|
||||
import uvicorn
|
||||
from mcp import types
|
||||
from mcp.server.experimental.task_context import ServerTaskContext
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.server.streamable_http_manager import StreamableHTTPSessionManager
|
||||
|
|
|
|||
|
|
@ -6,8 +6,8 @@ from typing import Any
|
|||
|
||||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
import uvicorn
|
||||
from mcp import types
|
||||
from mcp.server.experimental.task_context import ServerTaskContext
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.server.streamable_http_manager import StreamableHTTPSessionManager
|
||||
|
|
|
|||
|
|
@ -2,7 +2,7 @@ from typing import Any
|
|||
|
||||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.shared._httpx_utils import create_mcp_http_client
|
||||
from starlette.requests import Request
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@ from typing import Any
|
|||
|
||||
import anyio
|
||||
import click
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
from mcp.server.streamable_http_manager import StreamableHTTPSessionManager
|
||||
from starlette.applications import Starlette
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ from datetime import datetime
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
|
|||
|
|
@ -5,7 +5,7 @@ uv run examples/snippets/servers/lowlevel/basic.py
|
|||
import asyncio
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ import asyncio
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
|
|||
|
|
@ -7,7 +7,7 @@ from contextlib import asynccontextmanager
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ import asyncio
|
|||
from typing import Any
|
||||
|
||||
import mcp.server.stdio
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import NotificationOptions, Server
|
||||
from mcp.server.models import InitializationOptions
|
||||
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
"""Example of implementing pagination with MCP server decorators."""
|
||||
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.server.lowlevel import Server
|
||||
|
||||
# Initialize the server
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ from urllib.parse import urlparse
|
|||
import anyio
|
||||
from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream
|
||||
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.client.session import ClientSession
|
||||
from mcp.client.sse import sse_client
|
||||
from mcp.client.stdio import StdioServerParameters, stdio_client
|
||||
|
|
|
|||
|
|
@ -18,7 +18,7 @@ from typing import TYPE_CHECKING, Protocol
|
|||
|
||||
from pydantic import TypeAdapter
|
||||
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.shared._context import RequestContext
|
||||
from mcp.shared.session import RequestResponder
|
||||
|
||||
|
|
|
|||
|
|
@ -26,7 +26,7 @@ Example:
|
|||
from collections.abc import AsyncIterator
|
||||
from typing import TYPE_CHECKING, Any, TypeVar
|
||||
|
||||
import mcp.types as types
|
||||
from mcp import types
|
||||
from mcp.shared.experimental.tasks.polling import poll_until_terminal
|
||||
from mcp.types._types import RequestParamsMeta
|
||||
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show more
Loading…
Reference in a new issue