Revert "✨[Request] Abstract Storage SDK"

Author: Phinease

backend/database/attachment_db.py

@@ -165,7 +165,7 @@ def get_file_size_from_minio(object_name: str, bucket: Optional[str] = None) ->
     """
     Get file size by object name
     """
-    bucket = bucket or minio_client.storage_config.default_bucket
+    bucket = bucket or minio_client.default_bucket
     return minio_client.get_file_size(object_name, bucket)
 
 
@@ -207,7 +207,7 @@ def delete_file(object_name: str, bucket: Optional[str] = None) -> Dict[str, Any
         Dict[str, Any]: Delete result, containing success flag and error message (if any)
     """
     if not bucket:
-        bucket = minio_client.storage_config.default_bucket
+        bucket = minio_client.default_bucket
     success, result = minio_client.delete_file(object_name, bucket)
 
     response = {"success": success, "object_name": object_name}

backend/database/client.py

@@ -1,8 +1,12 @@
 import logging
+import os
 from contextlib import contextmanager
 from typing import Any, BinaryIO, Dict, List, Optional, Tuple
 
+import boto3
 import psycopg2
+from botocore.client import Config
+from botocore.exceptions import ClientError
 from sqlalchemy import create_engine
 from sqlalchemy.orm import class_mapper, sessionmaker
 
@@ -19,8 +23,6 @@
     POSTGRES_USER,
 )
 from database.db_models import TableBase
-from nexent.storage import create_storage_client_from_config, MinIOStorageConfig
-
 
 logger = logging.getLogger("database.client")
 
@@ -71,12 +73,6 @@ def clean_string_values(data: Dict[str, Any]) -> Dict[str, Any]:
 
 
 class MinioClient:
-    """
-    MinIO client wrapper using storage SDK
-    
-    This class maintains backward compatibility with the existing MinioClient interface
-    while using the new storage SDK under the hood.
-    """
     _instance: Optional['MinioClient'] = None
 
     def __new__(cls):
@@ -85,18 +81,39 @@ def __new__(cls):
         return cls._instance
 
     def __init__(self):
-        # Determine if endpoint uses HTTPS
-        secure = MINIO_ENDPOINT.startswith('https://') if MINIO_ENDPOINT else True
-        # Initialize storage client using SDK factory
-        self.storage_config = MinIOStorageConfig(
-            endpoint=MINIO_ENDPOINT,
-            access_key=MINIO_ACCESS_KEY,
-            secret_key=MINIO_SECRET_KEY,
-            region=MINIO_REGION,
-            default_bucket=MINIO_DEFAULT_BUCKET,
-            secure=secure
+        self.endpoint = MINIO_ENDPOINT
+        self.access_key = MINIO_ACCESS_KEY
+        self.secret_key = MINIO_SECRET_KEY
+        self.region = MINIO_REGION
+        self.default_bucket = MINIO_DEFAULT_BUCKET
+
+        # Initialize S3 client with proxy settings
+        self.client = boto3.client(
+            's3',
+            endpoint_url=self.endpoint,
+            aws_access_key_id=self.access_key,
+            aws_secret_access_key=self.secret_key,
+            region_name=self.region,
+            config=Config(
+                signature_version='s3v4',
+                proxies={
+                    'http': None,
+                    'https': None
+                }
+            )
         )
-        self._storage_client = create_storage_client_from_config(self.storage_config)
+
+        # Ensure default bucket exists
+        self._ensure_bucket_exists(self.default_bucket)
+
+    def _ensure_bucket_exists(self, bucket_name: str) -> None:
+        """Ensure bucket exists, create if it doesn't"""
+        try:
+            self.client.head_bucket(Bucket=bucket_name)
+        except ClientError:
+            # Bucket doesn't exist, create it
+            self.client.create_bucket(Bucket=bucket_name)
+            logger.info(f"Created bucket: {bucket_name}")
 
     def upload_file(
             self,
@@ -115,7 +132,16 @@ def upload_file(
         Returns:
             Tuple[bool, str]: (Success status, File URL or error message)
         """
-        return self._storage_client.upload_file(file_path, object_name, bucket)
+        bucket = bucket or self.default_bucket
+        if object_name is None:
+            object_name = os.path.basename(file_path)
+
+        try:
+            self.client.upload_file(file_path, bucket, object_name)
+            file_url = f"/{bucket}/{object_name}"
+            return True, file_url
+        except Exception as e:
+            return False, str(e)
 
     def upload_fileobj(self, file_obj: BinaryIO, object_name: str, bucket: Optional[str] = None) -> Tuple[bool, str]:
         """
@@ -129,7 +155,13 @@ def upload_fileobj(self, file_obj: BinaryIO, object_name: str, bucket: Optional[
         Returns:
             Tuple[bool, str]: (Success status, File URL or error message)
         """
-        return self._storage_client.upload_fileobj(file_obj, object_name, bucket)
+        bucket = bucket or self.default_bucket
+        try:
+            self.client.upload_fileobj(file_obj, bucket, object_name)
+            file_url = f"/{bucket}/{object_name}"
+            return True, file_url
+        except Exception as e:
+            return False, str(e)
 
     def download_file(self, object_name: str, file_path: str, bucket: Optional[str] = None) -> Tuple[bool, str]:
         """
@@ -143,7 +175,12 @@ def download_file(self, object_name: str, file_path: str, bucket: Optional[str]
         Returns:
             Tuple[bool, str]: (Success status, Success message or error message)
         """
-        return self._storage_client.download_file(object_name, file_path, bucket)
+        bucket = bucket or self.default_bucket
+        try:
+            self.client.download_file(bucket, object_name, file_path)
+            return True, f"File downloaded successfully to {file_path}"
+        except Exception as e:
+            return False, str(e)
 
     def get_file_url(self, object_name: str, bucket: Optional[str] = None, expires: int = 3600) -> Tuple[bool, str]:
         """
@@ -157,20 +194,23 @@ def get_file_url(self, object_name: str, bucket: Optional[str] = None, expires:
         Returns:
             Tuple[bool, str]: (Success status, Presigned URL or error message)
         """
-        return self._storage_client.get_file_url(object_name, bucket, expires)
+        bucket = bucket or self.default_bucket
+        try:
+            url = self.client.generate_presigned_url('get_object', Params={'Bucket': bucket, 'Key': object_name},
+                                                     ExpiresIn=expires)
+            return True, url
+        except Exception as e:
+            return False, str(e)
 
     def get_file_size(self, object_name: str, bucket: Optional[str] = None) -> int:
-        """
-        Get file size in bytes
-
-        Args:
-            object_name: Object name
-            bucket: Bucket name, if not specified use default bucket
-
-        Returns:
-            int: File size in bytes, 0 if file not found or error
-        """
-        return self._storage_client.get_file_size(object_name, bucket)
+        bucket = bucket or self.default_bucket
+        try:
+            response = self.client.head_object(Bucket=bucket, Key=object_name)
+            return int(response['ContentLength'])
+        except ClientError as e:
+            logger.error(
+                f"Get file size by objectname({object_name}) failed: {e}")
+            return 0
 
     def list_files(self, prefix: str = "", bucket: Optional[str] = None) -> List[dict]:
         """
@@ -183,7 +223,19 @@ def list_files(self, prefix: str = "", bucket: Optional[str] = None) -> List[dic
         Returns:
             List[dict]: List of file information
         """
-        return self._storage_client.list_files(prefix, bucket)
+        bucket = bucket or self.default_bucket
+        try:
+            response = self.client.list_objects_v2(
+                Bucket=bucket, Prefix=prefix)
+            files = []
+            if 'Contents' in response:
+                for obj in response['Contents']:
+                    files.append(
+                        {'key': obj['Key'], 'size': obj['Size'], 'last_modified': obj['LastModified']})
+            return files
+        except Exception as e:
+            logger.error(f"Error listing files: {str(e)}")
+            return []
 
     def delete_file(self, object_name: str, bucket: Optional[str] = None) -> Tuple[bool, str]:
         """
@@ -196,7 +248,12 @@ def delete_file(self, object_name: str, bucket: Optional[str] = None) -> Tuple[b
         Returns:
             Tuple[bool, str]: (Success status, Success message or error message)
         """
-        return self._storage_client.delete_file(object_name, bucket)
+        bucket = bucket or self.default_bucket
+        try:
+            self.client.delete_object(Bucket=bucket, Key=object_name)
+            return True, f"File {object_name} deleted successfully"
+        except Exception as e:
+            return False, str(e)
 
     def get_file_stream(self, object_name: str, bucket: Optional[str] = None) -> Tuple[bool, Any]:
         """
@@ -209,7 +266,12 @@ def get_file_stream(self, object_name: str, bucket: Optional[str] = None) -> Tup
         Returns:
             Tuple[bool, Any]: (Success status, File stream object or error message)
         """
-        return self._storage_client.get_file_stream(object_name, bucket)
+        bucket = bucket or self.default_bucket
+        try:
+            response = self.client.get_object(Bucket=bucket, Key=object_name)
+            return True, response['Body']
+        except Exception as e:
+            return False, str(e)
 
 
 # Create global database and MinIO client instances

backend/utils/document_vector_utils.py

@@ -595,10 +595,8 @@ def summarize_document(document_content: str, filename: str, language: str = LAN
                 {"role": MESSAGE_ROLE["USER"], "content": user_prompt}
             ]
 
-            # Call LLM, allow more tokens for generation
-            response = llm(messages, max_tokens=max_words * 2)
-            if not response or not response.content:
-                return ""
+            # Call LLM
+            response = llm(messages, max_tokens=max_words * 2)  # Allow more tokens for generation
             return response.content.strip()
         else:
             # Fallback to placeholder if no model configuration
@@ -677,8 +675,6 @@ def summarize_cluster(document_summaries: List[str], language: str = LANGUAGE["Z
 
             # Call LLM
             response = llm(messages, max_tokens=max_words * 2)  # Allow more tokens for generation
-            if not response or not response.content:
-                return ""
             return response.content.strip()
         else:
             # Fallback to placeholder if no model configuration

doc/docs/zh/opensource-memorial-wall.md

@@ -16,10 +16,6 @@
 请保持消息的礼貌和尊重，符合我们的行为准则。
 -->
 
-::: info lzysleep - 2025-11-7
-非常不错的项目，很适合快速上手搭建自己的Agent，赞赞赞！
-:::
-
 ::: info fishcat - 2025-10-31
 很好的项目，希望蒸蒸日上
 :::
@@ -304,44 +300,12 @@ Nexent功能如此之强大，给我很多帮助，感谢开发者！厉害
 
 ::: info niceman - 2025-10-29
 感谢 Nexent 让我踏上了开源之旅!希望能参加ict大赛长长见识。项目不错，给个star~ 
-:::
 
 ::：info XxHosxX - 2025-11-5
 希望参与ICT大赛以及Nexent平台提升自己的能力:)
-:::
 
 ::: tip Zwer1 - 2025-11-04
 感谢 Nexent 让我踏上了开源之旅！平台开发智能体的能力十分强大，希望能够学习到更多东西！
 :::
 
-::: tip Zwer1 - 2025-11-04
-想参加ICT创新赛
-:::
-
-::: tip Jackie - 2025-11-07
-期待能使用Nexent成为智能体开发大佬
-:::
-
-::: info xiaochenIpter - 2025-11-08
-希望能参加ict大赛可以学习到更多知识,感谢 Nexent 让我踏上了开源之旅！平台开发智能体的能力十分强大，希望能够学习到更多东西！
-:::
-
-::: info user - 2025-11-08
 "🎉 很高兴加入Nexent社区！作为新贡献者，我期待在代码优化、文档完善或测试反馈中尽一份力。#NexentCommunity 让我们一起构建更棒的项目！🚀"
-:::
-
-::: pxqn-xing - 2025-11-08
-感谢Nexent让我参与ICT大赛以提升自己的能力
-:::
-
-:::  QIYAN - 2025-11-09
-体验华为AI技术的一天
-:::
-
-::: tip qiyan111 - 2025-11-10
-想试下华为的智能体
-:::
-
-::：info XxHosxX - 2025-11-10
-自动创建agent的功能挺创新的，试过其他很多平台基本上都是只能通过一句描述语言优化提示词，很少有可以通过一句描述语言直接生成agent的功能，赞！
-:::

frontend/app/[locale]/chat/components/chatHeader.tsx

@@ -50,8 +50,8 @@ export function ChatHeader({ title, onRename }: ChatHeaderProps) {
   const inputRef = useRef<HTMLInputElement>(null);
   const { t } = useTranslation("common");
   const { currentLanguage, handleLanguageChange } = useLanguageSwitch();
-  const { user, isSpeedMode } = useAuth();
-  const isAdmin = isSpeedMode || user?.role === USER_ROLES.ADMIN;
+  const { user } = useAuth();
+  const isAdmin = user?.role === USER_ROLES.ADMIN;
 
   const goToModelSetup = () => {
     router.push(`/${currentLanguage}/setup/models`);