From c09bf306265af11934dc941d893a304cbc1f0242 Mon Sep 17 00:00:00 2001
From: Wenjie Zhang <xerrors@163.com>
Date: Tue, 3 Feb 2026 02:35:56 +0800
Subject: [PATCH] =?UTF-8?q?feat(middleware):=20=E9=99=84=E4=BB=B6=E4=B8=AD?=
 =?UTF-8?q?=E9=97=B4=E4=BB=B6=E8=BF=81=E7=A7=BB=E8=87=B3=20MinIO=20?=
 =?UTF-8?q?=E5=AD=98=E5=82=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 使用 MinIOBackend 替代本地文件系统存储附件
- 优化 thread_id 获取逻辑，支持多种来源
- 保留原始文件名而非 file_id.md 格式
---
 src/agents/common/backends/minio_backend.py | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/src/agents/common/backends/minio_backend.py b/src/agents/common/backends/minio_backend.py
index 1661a74a..833b512d 100644
--- a/src/agents/common/backends/minio_backend.py
+++ b/src/agents/common/backends/minio_backend.py
@@ -210,7 +210,7 @@ class MinIOBackend(BackendProtocol):
             return f"Error reading {file_path}: {e}"
 
     def write(self, file_path: str, content: str) -> WriteResult:
-        """写入文件。
+        """写入文件（同步）。
 
         Args:
             file_path: 虚拟路径
@@ -240,6 +240,19 @@ class MinIOBackend(BackendProtocol):
             logger.error(f"MinIOBackend.write failed for {file_path}: {e}")
             return WriteResult(error=str(e))
 
+    async def awrite(self, file_path: str, content: str) -> WriteResult:
+        """异步写入文件。
+
+        Args:
+            file_path: 虚拟路径
+            content: 文件内容
+
+        Returns:
+            WriteResult
+        """
+        # 委托给同步 write 方法
+        return self.write(file_path, content)
+
     def edit(
         self,
         file_path: str,