Damn Vulnerable Model Context Protocol (DVMCP)

o J-�gJ�@sVdd
lm
Z
mZ
ddlmZ
ddlmZ
ddlmZm Z
ddl mZ
Gdd�d�ZdS) �)�FastMCP�Context)
�SseServerTransport)
� Starlette)�Mount�Route)
�FastAPIc@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd S) �SseCompatibleMcpServercCst|
�
|_
||_t�|_dS)
N)r�mcp�portr�app)�self�namer�r�5/home/ubuntu/damn-vulnerable-mcs/common/sse_server.py�__init__ s


zSseCompatibleMcpServer.__init__c

Cs|j�
d
|���
dS)z'Mount the SSE server to the FastAPI app�
/N)r�mount�create_sse_server)
r rrr�mount_sse_serversz'SseCompatibleMcpServer.mount_sse_serverc
s:td
�
�
��
fdd�}
t
d|
d�td�
jd�g}t|d�
S) zHCreate a Starlette app that handles SSE connections and message handlingz /messages/c
 �sx�
�
�|j
|j|j�4IdH� }
�jj�|
d
|
d�jj���IdH
Wd�IdH
dS1IdHs5w



Y
dS)Nr
�
)�connect_sse�scope�receive�_sendr �_mcp_server�run�create_initialization_options)�request�streams�r � transportrr� handle_sses�

�

�.�z<SseCompatibleMcpServer.create_sse_server.<locals>.handle_sse�/sse)
�endpointz /messages)
r)
�routes)rrr�handle_post_messager)r r"r%rr rrs 
� z(SseCompatibleMcpServer.create_sse_serverc
Cs^d
dl}
t
d|jj�d��

t
d�

t
d|j���

t
d|j�d��

|
j|jd |jd �
dS)zRun the server with uvicornr
Nz Starting z MCP ServerzKConnect to this server using an MCP client (e.g., Claude Desktop or Cursor)z#Server running at http://localhost:z+SSE endpoint available at http://localhost:r#z0.0.0.0)�hostr)�uvicorn�printr rrrr)r r(rrrr(s




zSseCompatibleMcpServer.runN)�__name__� __module__�__qualname__rrrrrrrrr s 
r N) �mcp.server.fastmcprr�mcp.server.sser�starlette.applicationsr�starlette.routingrr�fastapirr rrrr�<module>
s