diff --git a/DysonNetwork.Sphere/Storage/Handlers/MessageReadReceiptFlushHandler.cs b/DysonNetwork.Sphere/Storage/Handlers/MessageReadReceiptFlushHandler.cs index f5011b9..d9af8e5 100644 --- a/DysonNetwork.Sphere/Storage/Handlers/MessageReadReceiptFlushHandler.cs +++ b/DysonNetwork.Sphere/Storage/Handlers/MessageReadReceiptFlushHandler.cs @@ -22,7 +22,10 @@ public class MessageReadReceiptFlushHandler(IServiceProvider serviceProvider) : using var scope = serviceProvider.CreateScope(); var db = scope.ServiceProvider.GetRequiredService(); - await db.BulkInsertAsync(distinctItems, config => config.ConflictOption = ConflictOption.Ignore); + await db.BulkInsertAsync(distinctItems, config => { + config.ConflictOption = ConflictOption.Ignore; + config.UpdateByProperties = [nameof(MessageReadReceipt.MessageId), nameof(MessageReadReceipt.SenderId)]; + }); } }