fix(live_streaming): add trailing slash to create_bucket URL for correct auth signature

Fixed authentication failure for create_bucket by adding a trailing slash to the URL.
This ensures that urlparse().path returns '/' instead of an empty string, which is
consistent with other working methods like bind_push_domain that have explicit '/' in
their URLs (e.g., '/?pushDomain').

Without the trailing slash:
- URL: https://bucket.endpoint
- parsed.path: '' (empty) → becomes '/' via fallback
- This caused authentication signature mismatch

With the trailing slash:
- URL: https://bucket.endpoint/
- parsed.path: '/' (explicit)
- Signature generation matches other working methods

Note: _build_bucket_url() itself is not modified because it's also used by
bind_push_domain which constructs URLs like 'https://bucket.endpoint/?pushDomain'.
Adding a trailing slash there would create 'https://bucket.endpoint//?pushDomain'
with double slashes.

Generated with [codeagent](https://github.com/qbox/codeagent)
Co-authored-by: callmefisher <[email protected]>

Author: xgopilot

src/mcp_server/core/live_streaming/live_streaming.py

@@ -86,19 +86,8 @@ async def create_bucket(self, bucket: str) -> Dict[str, Any]:
         Returns:
             Dict containing the response status and message
         """
-        # Use base endpoint instead of bucket subdomain for creation
-        if not self.live_endpoint:
-            self.live_endpoint = "mls.cn-east-1.qiniumiku.com"
-
-        # Remove protocol if present
-        endpoint = self.live_endpoint
-        if endpoint.startswith("http://"):
-            endpoint = endpoint[7:]
-        elif endpoint.startswith("https://"):
-            endpoint = endpoint[8:]
-
-        # Use base endpoint with bucket as path component
-        url = f"https://{endpoint}/{bucket}"
+        # Add trailing slash to ensure path is '/' for signature generation
+        url = self._build_bucket_url(bucket) + "/"
         headers = self._get_auth_header(method="PUT",url=url)
 
         logger.info(f"Creating bucket: {bucket} at {url}")
@@ -138,19 +127,7 @@ async def create_stream(self, bucket: str, stream: str) -> Dict[str, Any]:
         Returns:
             Dict containing the response status and message
         """
-        # Use base endpoint instead of bucket subdomain for creation
-        if not self.live_endpoint:
-            self.live_endpoint = "mls.cn-east-1.qiniumiku.com"
-
-        # Remove protocol if present
-        endpoint = self.live_endpoint
-        if endpoint.startswith("http://"):
-            endpoint = endpoint[7:]
-        elif endpoint.startswith("https://"):
-            endpoint = endpoint[8:]
-
-        # Use base endpoint with bucket/stream as path components
-        url = f"https://{endpoint}/{bucket}/{stream}"
+        url = self._build_stream_url(bucket, stream)
         headers = self._get_auth_header(method="PUT", url=url)
 
         logger.info(f"Creating stream: {stream} in bucket: {bucket} at {url}")