Merge pull request #1255 from yileicn/master

optimize CreateNewConversation use async method

Author: yileicn

src/Infrastructure/BotSharp.Abstraction/Repositories/IBotSharpRepository.cs

@@ -127,7 +127,7 @@ bool DeleteAgentCodeScripts(string agentId, List<AgentCodeScript>? scripts = nul
     #endregion
 
     #region Conversation
-    void CreateNewConversation(Conversation conversation)
+    Task CreateNewConversation(Conversation conversation)
         => throw new NotImplementedException();
     bool DeleteConversations(IEnumerable<string> conversationIds)
         => throw new NotImplementedException();

src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.cs

@@ -112,7 +112,7 @@ public async Task<Conversation> NewConversation(Conversation sess)
         record.Tags = sess.Tags;
         record.Title = string.IsNullOrEmpty(record.Title) ? "New Conversation" : record.Title;
 
-        db.CreateNewConversation(record);
+        await db.CreateNewConversation(record);
 
         var hooks = _services.GetHooks<IConversationHook>(record.AgentId);
 

src/Infrastructure/BotSharp.Core/Repository/FileRepository/FileRepository.Conversation.cs

@@ -8,7 +8,7 @@ public partial class FileRepository
     private static readonly object _dialogLock = new object();
     private static readonly object _stateLock = new object();
 
-    public void CreateNewConversation(Conversation conversation)
+    public async Task CreateNewConversation(Conversation conversation)
     {
         var utcNow = DateTime.UtcNow;
         conversation.CreatedTime = utcNow;
@@ -24,31 +24,31 @@ public void CreateNewConversation(Conversation conversation)
         var convFile = Path.Combine(dir, CONVERSATION_FILE);
         if (!File.Exists(convFile))
         {
-            File.WriteAllText(convFile, JsonSerializer.Serialize(conversation, _options));
+            await File.WriteAllTextAsync(convFile, JsonSerializer.Serialize(conversation, _options));
         }
 
         var dialogFile = Path.Combine(dir, DIALOG_FILE);
         if (!File.Exists(dialogFile))
         {
-            File.WriteAllText(dialogFile, "[]");
+            await File.WriteAllTextAsync(dialogFile, "[]");
         }
 
         var stateFile = Path.Combine(dir, STATE_FILE);
         if (!File.Exists(stateFile))
         {
-            File.WriteAllText(stateFile, "[]");
+            await File.WriteAllTextAsync(stateFile, "[]");
         }
 
         var latestStateFile = Path.Combine(dir, CONV_LATEST_STATE_FILE);
         if (!File.Exists(latestStateFile))
         {
-            File.WriteAllText(latestStateFile, "{}");
+            await File.WriteAllTextAsync(latestStateFile, "{}");
         }
 
         var breakpointFile = Path.Combine(dir, BREAKPOINT_FILE);
         if (!File.Exists(breakpointFile))
         {
-            File.WriteAllText(breakpointFile, "[]");
+            await File.WriteAllTextAsync(breakpointFile, "[]");
         }
     }
 

src/Plugins/BotSharp.Plugin.MongoStorage/Repository/MongoRepository.Conversation.cs

@@ -6,7 +6,7 @@ namespace BotSharp.Plugin.MongoStorage.Repository;
 
 public partial class MongoRepository
 {
-    public void CreateNewConversation(Conversation conversation)
+    public async Task CreateNewConversation(Conversation conversation)
     {
         if (conversation == null) return;
 
@@ -49,9 +49,17 @@ public void CreateNewConversation(Conversation conversation)
             UpdatedTime = utcNow
         };
 
-        _dc.Conversations.InsertOne(convDoc);
-        _dc.ConversationDialogs.InsertOne(dialogDoc);
-        _dc.ConversationStates.InsertOne(stateDoc);
+        try
+        {
+            await _dc.Conversations.InsertOneAsync(convDoc);
+            await _dc.ConversationDialogs.InsertOneAsync(dialogDoc);
+            await _dc.ConversationStates.InsertOneAsync(stateDoc);
+        }
+        catch (MongoWriteException ex) when (ex.WriteError?.Code == 11000)
+        {
+            //11000  duplicate key error
+            return;
+        }
     }
 
     public bool DeleteConversations(IEnumerable<string> conversationIds)