We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 95b44fb commit 8c0c485Copy full SHA for 8c0c485
src/mcp/client/sse.py
@@ -73,7 +73,15 @@ async def sse_reader(
73
logger.debug(f"Received SSE event: {sse.event}")
74
match sse.event:
75
case "endpoint":
76
- endpoint_url = urljoin(url, sse.data)
+ # endpoint_url = urljoin(url, sse.data)
77
+
78
+ parsed_url = urlparse(url)
79
+ if parsed_url.path.endswith('/'):
80
+ base_url = url
81
+ else:
82
+ base_path = '/'.join(parsed_url.path.split('/')[:-1]) + '/'
83
+ base_url = f"{parsed_url.scheme}://{parsed_url.netloc}{base_path}"
84
+ endpoint_url = urljoin(base_url, sse.data.lstrip('/'))
85
logger.debug(f"Received endpoint URL: {endpoint_url}")
86
87
url_parsed = urlparse(url)
0 commit comments