refactor: 调整插件测试目录结构

将 docker 目录移动至 src/providers/docker_test

.github/workflows/docker-test.yml

@@ -47,7 +47,7 @@ jobs:
       - name: Build and Publish
         uses: docker/build-push-action@v6
         with:
-          context: ./docker
+          context: ./src/providers/docker_test
           push: ${{ github.event_name != 'pull_request' }}
           tags: ${{ steps.metadata.outputs.tags }}
           labels: ${{ steps.metadata.outputs.labels }}

src/providers/docker_test/__init__.py

@@ -0,0 +1,104 @@
+import json
+from typing import Any
+
+import docker
+from pydantic import BaseModel, Field, field_validator, model_validator
+from pydantic_core import PydanticCustomError
+
+from src.providers.constants import DOCKER_IMAGES
+
+
+class Metadata(BaseModel):
+    """插件元数据"""
+
+    name: str
+    desc: str
+    homepage: str
+    type: str | None = None
+    supported_adapters: list[str] | None = None
+
+    @model_validator(mode="before")
+    @classmethod
+    def model_validator(cls, data: dict[str, Any]):
+        if data.get("desc") is None:
+            data["desc"] = data.get("description")
+        return data
+
+    @field_validator("supported_adapters", mode="before")
+    @classmethod
+    def supported_adapters_validator(cls, v: list[str] | str | None):
+        if isinstance(v, str):
+            try:
+                v = json.loads(v)
+            except json.JSONDecodeError:
+                raise PydanticCustomError("json_type", "JSON 格式不合法")
+
+        return v
+
+
+class DockerTestResult(BaseModel):
+    """Docker 测试结果"""
+
+    run: bool  # 是否运行
+    load: bool  # 是否加载成功
+    version: str | None = None
+    config: str = ""
+    # 测试环境 python==3.10 pytest==6.2.5 nonebot2==2.0.0a1 ...
+    test_env: str = Field(default="unknown")
+    metadata: Metadata | None
+    outputs: list[str]
+
+    @field_validator("metadata", mode="before")
+    @classmethod
+    def metadata_validator(cls, v: Any):
+        if v:
+            return v
+        return None
+
+    @field_validator("config", mode="before")
+    @classmethod
+    def config_validator(cls, v: str | None):
+        return v or ""
+
+
+class DockerPluginTest:
+    def __init__(
+        self, docker_images: str, project_link: str, module_name: str, config: str = ""
+    ):
+        self.docker_images = docker_images
+        self.project_link = project_link
+        self.module_name = module_name
+        self.config = config
+
+    @property
+    def key(self) -> str:
+        """插件的标识符
+
+        project_link:module_name
+        例：nonebot-plugin-test:nonebot_plugin_test
+        """
+        return f"{self.project_link}:{self.module_name}"
+
+    async def run(self, version: str) -> DockerTestResult:
+        """运行 Docker 容器测试插件
+
+        Args:
+            version (str): 对应的 Python 版本
+
+        Returns:
+            DockerTestResult: 测试结果
+        """
+        image_name = DOCKER_IMAGES.format(version)
+        # 连接 Docker 环境
+        client = docker.DockerClient(base_url="unix://var/run/docker.sock")
+
+        # 运行 Docker 容器，捕获输出。 容器内运行的代码拥有超时设限，此处无需设置超时
+        output = client.containers.run(
+            image_name,
+            environment={"PLUGIN_INFO": self.key, "PLUGIN_CONFIG": self.config},
+            detach=False,
+        ).decode()
+
+        data = json.loads(output)
+        data["test_env"] = f"python=={version}"
+        return DockerTestResult(**data)

docker/plugin_test.py → src/providers/docker_test/plugin_test.py

@@ -276,7 +276,7 @@ async def run(self):
 
         return self._run, self._lines_output
 
-    async def command(self, cmd: str, timeout: int = 300) -> tuple[bool, str, str]:  # noqa: ASYNC109
+    async def command(self, cmd: str, timeout: int = 300) -> tuple[bool, str, str]:
         """执行命令
 
         Args:
@@ -286,14 +286,14 @@ async def command(self, cmd: str, timeout: int = 300) -> tuple[bool, str, str]:
         Returns:
             tuple[bool, str, str]: 命令执行返回值，标准输出，标准错误
         """
+        proc = await create_subprocess_shell(
+            cmd,
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE,
+            cwd=self.path,
+            env=self.env,
+        )
         try:
-            proc = await create_subprocess_shell(
-                cmd,
-                stdout=subprocess.PIPE,
-                stderr=subprocess.PIPE,
-                cwd=self.path,
-                env=self.env,
-            )
             stdout, stderr = await asyncio.wait_for(proc.communicate(), timeout)
             code = proc.returncode
         except TimeoutError: