Merge pull request #1 from tofarr/fix-starlette-sse-endpoint

Fix handle_sse method to match Starlette route endpoint expectations

Author: tofarr

src/mcpm/router/router.py

@@ -614,17 +614,19 @@ async def get_sse_server_app(
         api_key = None if not self.router_config.auth_enabled else self.router_config.api_key
         sse = RouterSseTransport("/messages/", api_key=api_key)
 
-        async def handle_sse(request: Request) -> None:
-            async with sse.connect_sse(
-                request.scope,
-                request.receive,
-                request._send,  # noqa: SLF001
-            ) as (read_stream, write_stream):
-                await self.aggregated_server.run(
-                    read_stream,
-                    write_stream,
-                    self.aggregated_server.initialization_options,
-                )
+        async def handle_sse(request: Request):
+            async def app(scope: Scope, receive: Receive, send: Send) -> None:
+                async with sse.connect_sse(
+                    scope,
+                    receive,
+                    send,
+                ) as (read_stream, write_stream):
+                    await self.aggregated_server.run(
+                        read_stream,
+                        write_stream,
+                        self.aggregated_server.initialization_options,
+                    )
+            return app
 
         lifespan_handler: t.Optional[Lifespan[Starlette]] = None
         if include_lifespan: