use binary data

src/Infrastructure/BotSharp.Abstraction/Files/IFileStorageService.cs

@@ -63,7 +63,7 @@ public interface IFileStorageService
     #endregion
 
     #region Knowledge
-    bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvider, string fileId, string fileName, Stream stream);
+    bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvider, string fileId, string fileName, BinaryData fileData);
 
     /// <summary>
     /// Delete files in a knowledge collection. If fileId is null, remove all files in the collection.

src/Infrastructure/BotSharp.Core/Files/Services/Storage/LocalFileStorageService.KnowledgeBase.cs

@@ -5,7 +5,7 @@ namespace BotSharp.Core.Files.Services;
 
 public partial class LocalFileStorageService
 {
-    public bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvider, string fileId, string fileName, Stream stream)
+    public bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvider, string fileId, string fileName, BinaryData fileData)
     {
         if (string.IsNullOrWhiteSpace(collectionName)
             || string.IsNullOrWhiteSpace(vectorStoreProvider)
@@ -26,9 +26,9 @@ public bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvi
 
             var filePath = Path.Combine(dir, fileName);
             using var fs = new FileStream(filePath, FileMode.Create, FileAccess.Write);
-            stream.CopyTo(fs);
+            using var ds = fileData.ToStream();
+            ds.CopyTo(fs);
             fs.Flush();
-            fs.Close();
             return true;
         }
         catch (Exception ex)

src/Plugins/BotSharp.Plugin.KnowledgeBase/Services/KnowledgeService.Document.cs

@@ -208,11 +208,8 @@ private async Task<IEnumerable<string>> GetFileContent(string contentType, byte[
     private bool SaveDocument(string collectionName, string vectorStoreProvider, string fileId, string fileName, byte[] bytes)
     {
         var fileStoreage = _services.GetRequiredService<IFileStorageService>();
-        using var stream = new MemoryStream(bytes);
-        stream.Position = 0;
-
-        var saved = fileStoreage.SaveKnowledgeBaseFile(collectionName.CleanStr(), vectorStoreProvider.CleanStr(), fileId, fileName, stream);
-        stream.Close();
+        var data = BinaryData.FromBytes(bytes);
+        var saved = fileStoreage.SaveKnowledgeBaseFile(collectionName.CleanStr(), vectorStoreProvider.CleanStr(), fileId, fileName, data);
         return saved;
     }
 

src/Plugins/BotSharp.Plugin.TencentCos/Services/TencentCosService.KnowledgeBase.cs

@@ -4,7 +4,7 @@ namespace BotSharp.Plugin.TencentCos.Services;
 
 public partial class TencentCosService
 {
-    public bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvider, string fileId, string fileName, Stream stream)
+    public bool SaveKnowledgeBaseFile(string collectionName, string vectorStoreProvider, string fileId, string fileName, BinaryData fileData)
     {
         throw new NotImplementedException();
     }