support bucket not config

Author: YangSen-qn

.gitignore

@@ -12,4 +12,4 @@ wheels/
 .env.dora
 .env.kodo
 
-mcp_server/test.py
+src/mcp_server/test.py

CHANGELOG.md

@@ -1,3 +1,6 @@
+# v1.1.0
+- 支持 Bucket 为空
+
 # v1.0.0
 
 - 支持 Kodo 服务

images/logo.png renamed to docs/images/logo.png

@@ -1,8 +1,12 @@
 [project]
 name = "qiniu-mcp-server"
-version = "1.0.0"
+version = "1.1.0"
 description = "A MCP server project of Qiniu."
 requires-python = ">=3.12"
+authors = [
+    { name = "Qiniu", email = "sdk@qiniu.com" },
+]
+keywords = ["qiniu", "mcp", "llm"]
 dependencies = [
     "aioboto3>=13.2.0",
     "fastjsonschema>=2.21.1",
@@ -18,8 +22,8 @@ dependencies = [
 requires = [ "hatchling",]
 build-backend = "hatchling.build"
 
-[tool.hatch.build.targets.wheel]
-packages = ["mcp_server"]
-
 [project.scripts]
 qiniu-mcp-server = "mcp_server:main"
+
+[tool.hatch.build.targets.wheel]
+packages = ["src/mcp_server"]

mcp_server/core/version/version.py

@@ -52,10 +52,6 @@ def load_config() -> Config:
         logger.error("QINIU_REGION_NAME is not configured")
         raise ValueError("QINIU_REGION_NAME is not configured")
 
-    if not config.buckets:
-        logger.error("QINIU_BUCKETS is not configured")
-        raise ValueError("QINIU_BUCKETS is not configured")
-
     logger.info(f"Configured   access_key: {config.access_key}")
     logger.info(f"Configured endpoint_url: {config.endpoint_url}")
     logger.info(f"Configured  region_name: {config.region_name}")

pyproject.toml

@@ -95,9 +95,9 @@ def get_object_url(
         return object_urls
 
     async def list_buckets(self, prefix: Optional[str] = None) -> List[dict]:
-        """
-        List S3 buckets using async client with pagination
-        """
+        if not self.config.buckets or len(self.config.buckets) == 0:
+            return []
+
         max_buckets = 50
 
         async with self.s3_session.client(
@@ -107,32 +107,22 @@ async def list_buckets(self, prefix: Optional[str] = None) -> List[dict]:
                 endpoint_url=self.config.endpoint_url,
                 region_name=self.config.region_name,
         ) as s3:
-            if self.config.buckets:
-                # If buckets are configured, only return those
-                response = await s3.list_buckets()
-                all_buckets = response.get("Buckets", [])
+            # If buckets are configured, only return those
+            response = await s3.list_buckets()
+            all_buckets = response.get("Buckets", [])
 
+            configured_bucket_list = [
+                bucket
+                for bucket in all_buckets
+                if bucket["Name"] in self.config.buckets
+            ]
+
+            if prefix:
                 configured_bucket_list = [
-                    bucket
-                    for bucket in all_buckets
-                    if bucket["Name"] in self.config.buckets
+                    b for b in configured_bucket_list if b["Name"] > prefix
                 ]
 
-                if prefix:
-                    configured_bucket_list = [
-                        b for b in configured_bucket_list if b["Name"] > prefix
-                    ]
-
-                return configured_bucket_list[:max_buckets]
-            else:
-                # Default behavior if no buckets configured
-                response = await s3.list_buckets()
-                buckets = response.get("Buckets", [])
-
-                if prefix:
-                    buckets = [b for b in buckets if b["Name"] > prefix]
-
-                return buckets[:max_buckets]
+            return configured_bucket_list[:max_buckets]
 
     async def list_objects(
             self, bucket: str, prefix: str = "", max_keys: int = 20, start_after: str = ""

mcp_server/README.md renamed to src/mcp_server/README.md

@@ -0,0 +1,2 @@
+
+VERSION = '1.1.0'

mcp_server/__init__.py renamed to src/mcp_server/__init__.py

@@ -7,7 +7,8 @@
 from typing import List, Dict, Callable, Optional, Union, Awaitable
 from dataclasses import dataclass
 from mcp import types
-from mcp_server import consts
+
+from .. import consts
 
 logger = logging.getLogger(consts.LOGGER_NAME)
 
@@ -36,8 +37,8 @@ def all_tools() -> List[types.Tool]:
 
 
 def register_tool(
-    meta: types.Tool,
-    func: Union[ToolFunc, AsyncToolFunc],
+        meta: types.Tool,
+        func: Union[ToolFunc, AsyncToolFunc],
 ) -> None:
     """注册工具，禁止重复名称"""
     name = meta.name