o
$T%in, � @ s U d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
mZ ddlmZmZmZmZ z"ddlZddlmZ dd lmZ dd
lmZ dd lm Z m Z d Z W n e yl d
Z Y nw ddl m!Z!m"Z"m#Z#m$Z$ ddl%m&Z& ddl'm(Z(m)Z)m*Z*m+Z+ ddl,m-Z-m.Z.m/Z/m0Z0 ddl1m2Z2m3Z3m4Z4 ej5ej6dd� e�7d�Z8ed�Z9i a:de;d< da<de;d< dKd d �Z=dLd$d%�Z>dMd'd(�Z?dNd)d*�Z@d
d+�dOd1d2�ZAe9�B� dPd4d5��ZBe9�C� dQd9d:��ZCdRd<d=�ZDdNd>d?�ZEd@dA� ZFdSdTdHdI�ZGeHdJk�r
e�IeF� � dS dS )Uz�
pgtuner-mcp: PostgreSQL MCP Performance Tuning Server
This server implements a modular, extensible design pattern for PostgreSQL
performance tuning with HypoPG support for hypothetical index testing.
Supports both stdio and SSE MCP server modes.
� )� annotationsN)�Sequence)�Any)�Server)�EmbeddedResource� ImageContent� TextContent�Tool)�SseServerTransport)� Starlette)�Request)�Mount�RouteTF� )�
DbConnPool�
HypoPGService� IndexAdvisor� SqlDriver)� ToolHandler)�ActiveQueriesToolHandler�DatabaseHealthToolHandler�DatabaseSettingsToolHandler�WaitEventsToolHandler)�ExplainQueryToolHandler�HypoPGToolHandler�IndexAdvisorToolHandler�UnusedIndexesToolHandler)�AnalyzeQueryToolHandler�GetSlowQueriesToolHandler�TableStatsToolHandlerz4%(asctime)s - %(name)s - %(levelname)s - %(message)s)�level�format� pgtuner_mcpzdict[str, ToolHandler]�
tool_handlerszDbConnPool | None�db_pool� tool_handlerr �return�Nonec C s | t | j< t�d| j� �� dS )zy
Register a tool handler with the server.
Args:
tool_handler: The tool handler instance to register
zRegistered tool handler: N)r# �name�logger�info)r% � r+ �5/home/azureuser/pgtuner_mcp/src/pgtuner_mcp/server.py�add_tool_handlerM s
r- r( �str�ToolHandler | Nonec C s
t �| �S )z�
Retrieve a tool handler by name.
Args:
name: The name of the tool handler
Returns:
The tool handler instance or None if not found
)r# �get)r( r+ r+ r, �get_tool_handlerY s
r1 r c C s t du rtd��t S )z�
Get the global database connection pool.
Returns:
The database connection pool
Raises:
RuntimeError: If the database pool is not initialized
Nz(Database connection pool not initialized)r$ � RuntimeErrorr+ r+ r+ r, � get_db_poolf s r3 c C s� t � } t| �}t|�}t|�}tt|�� tt|�� tt|�� tt|�� tt ||�� tt
|�� tt |�� tt |�� tt
|�� tt|�� tt|�� t�dtt�� d�� dS )z�
Register all available tool handlers.
This function serves as the central registry for all tools.
New tool handlers should be added here for automatic registration.
z Registered z tool handlersN)r3 r r r r- r r r r r r r r r r r r) r* �lenr# )�pool�
sql_driver�hypopg_service�
index_advisorr+ r+ r, �register_all_toolsv s r9 ��debug�
mcp_serverr r; �boolr c sF t std��td��d� �fdd� }t|td |d
�td�jd �gd �S )z�
Create a Starlette application that can serve the provided mcp server with SSE.
Args:
mcp_server: The MCP server instance
debug: Whether to enable debug mode
Returns:
Starlette application instance
zKSSE dependencies not available. Install with: pip install starlette uvicornz
/messages/�requestr r& r' c � sl ��� | j| j| j�4 I d H �\}}� �||� �� �I d H W d �I d H d S 1 I d H s/w Y d S )N)� connect_sse�scope�receive�_send�run� create_initialization_options)r> � read_stream� write_stream�r< �sser+ r, �
handle_sse� s � � �.�z(create_starlette_app.<locals>.handle_ssez/sse)�endpoint)�app)r; �routesN)r> r r& r' )�
SSE_AVAILABLEr2 r
r r r
�handle_post_message)r< r; rI r+ rG r, �create_starlette_app� s
��rO �
list[Tool]c
� s` �zdd� t �� D �} t�dt| �� d�� | W S ty/ } z t�dt|�� �� � d}~ww )zn
List all available tools.
Returns:
List of Tool objects describing all registered tools
c S s g | ]}|� � �qS r+ )�get_tool_definition)�.0�handlerr+ r+ r, �
<listcomp>� s z list_tools.<locals>.<listcomp>zListed z available toolszError listing tools: N)r# �valuesr) r* r4 � Exception� exceptionr. )�tools�er+ r+ r, �
list_tools� s ���rZ � argumentsr �7Sequence[TextContent | ImageContent | EmbeddedResource]c
� s� �z9t |t�s td��t| �}|std| � ���t�d| � dt|�� �� �� |� |�I dH }t�d| � d�� |W S t
yt } z.t� d| � d t |�� �� t
�� }t�d
|� �� td d | � d
t |�� �d�gW Y d}~S d}~ww )a
Execute a tool with the provided arguments.
Args:
name: The name of the tool to execute
arguments: The arguments to pass to the tool
Returns:
Sequence of MCP content objects
Raises:
RuntimeError: If the tool execution fails
z Arguments must be a dictionaryzUnknown tool: zExecuting tool: z with arguments: NzTool z executed successfullyzError executing tool z: zFull traceback: �textzError executing tool 'z': )�typer] )�
isinstance�dictr2 r1 �
ValueErrorr) r* �list�keys�run_toolrV rW r. � traceback�
format_exc�errorr )r( r[ r% �resultrY �error_tracebackr+ r+ r, � call_tool� s, �
����rj � database_uric � s& �t | �at�� I dH t�d� dS )zm
Initialize the database connection pool.
Args:
database_uri: PostgreSQL connection URI
Nz1Database connection pool initialized successfully)r r$ �connectr) r* )rk r+ r+ r, �initialize_db_pool� s �rm c � s. �t durt �� I dH da t�d� dS dS )z0
Clean up the database connection pool.
Nz Database connection pool closed)r$ �closer) r* r+ r+ r+ r, �cleanup_db_pool s ��ro c
� s� �t jdd�} | jdddgddd� | jdd d
d � | jd td
dd� | jdddd� | jdddd � | �� }|jrHt�� �tj � t
�tj � zvzU|j pRt j
�d�}|sft
�d� tdtjd� t�d� t|�I dH t� t
�d |j� d �� t
�d tj� �� t
�d tt�� �� �� t |j|j |j |j�I dH W n t y� } z t
� d t!|�� �� � d}~ww W t"� I dH dS t"� I dH w )!z}
Main entry point for the pgtuner_mcp server.
Supports both stdio and SSE modes based on command line arguments.
zTpgtuner_mcp: PostgreSQL MCP Performance Tuning Server - supports stdio and SSE modes)� descriptionz--mode�stdiorH z#Server mode: stdio (default) or sse)�choices�default�helpz--host�0.0.0.0z1Host to bind to (SSE mode only, default: 0.0.0.0))rs rt z--port� z0Port to listen on (SSE mode only, default: 8080))r^ rs rt z--debug�
store_truezEnable debug mode)�actionrt z--database-urlNz7PostgreSQL connection URL (or use DATABASE_URI env var)� DATABASE_URIzUNo database URL provided. Set DATABASE_URI environment variable or use --database-urlz\Error: No database URL provided. Set DATABASE_URI environment variable or use --database-url)�filer z Starting pgtuner_mcp server in z mode...zPython version: zRegistered tools: zFailed to start server: )#�argparse�ArgumentParser� add_argument�int�
parse_argsr; �logging� getLogger�setLevel�DEBUGr) � database_url�os�environr0 rg �print�sys�stderr�exitrm r9 r* �mode�versionrb r# rc �
run_server�host�portrV rW r. ro )�parser�argsr� rY r+ r+ r, �main sp �������
�
��� r� ru rv r� r� r� r~ c
� s� �| dkr>t �d� ddlm} |� 4 I dH �\}}t�||t�� �I dH W d �I dH dS 1 I dH s7w Y dS | dkrutsHtd��t �d|� d |� d
�� t t|d �}t
j ||||rcd nd
d�}t
� |�} | �
� I dH dS td| � ���)a
Unified server runner that supports both stdio and SSE modes.
Args:
mode: Server mode ("stdio" or "sse")
host: Host to bind to (SSE mode only)
port: Port to listen on (SSE mode only)
debug: Whether to enable debug mode
rq zStarting stdio server...r )� stdio_serverNrH zVSSE mode requires additional dependencies. Install with: pip install starlette uvicornzStarting SSE server on �:z...r: r; r* )rK r� r� � log_levelzUnknown mode: )r) r* �mcp.server.stdior� rK rC rD rM r2 rO �uvicorn�Configr �servera )
r� r� r� r; r� rE rF �
starlette_app�config�serverr+ r+ r, r� ^ s6 �
�.��
�
r� �__main__)r% r r& r' )r( r. r& r/ )r& r )r& r' )r< r r; r= r& r )r& rP )r( r. r[ r r& r\ )rk r. r& r' )ru rv F)r� r. r� r. r� r~ r; r= )J�__doc__�
__future__r r{ �asyncior� r� r� re �collections.abcr �typingr �
mcp.serverr � mcp.typesr r r r r� �mcp.server.sser
�starlette.applicationsr �starlette.requestsr �starlette.routingr
r rM � ImportError�servicesr r r r �tools.toolhandlerr �tools.tools_healthr r r r �tools.tools_indexr r r r �tools.tools_performancer r r � basicConfig�INFOr� r) rK r# �__annotations__r$ r- r1 r3 r9 rO rZ rj rm ro r� r� �__name__rC r+ r+ r+ r, �<module> sf � �
%
.
K
2�
