Prevent duplicate record to be inserted

2024-04-01 21:10:21 -05:00 · 2024-04-01 21:10:21 -05:00 · 601b64b50a
parent 8cc9776a0f
commit 601b64b50a
1 changed files with 7 additions and 0 deletions
--- a/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationStorage.cs
+++ b/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationStorage.cs
@ -38,6 +38,13 @@ public class ConversationStorage : IConversationStorage
        var db = _services.GetRequiredService<IBotSharpRepository>();
        var dialogElements = new List<DialogElement>();

+        // Prevent duplicate record to be inserted
+        var dialogs = db.GetConversationDialogs(conversationId);
+        if (dialogs.Any(x => x.MetaData.MessageId == dialog.MessageId && x.Content == dialog.Content))
+        {
+            return;
+        }
+
        if (dialog.Role == AgentRole.Function)
        {
            var meta = new DialogMetaData