Improved AddRange for MessageRepositorySQLite - now works as a transa…

…ction
GlitchedPolygons · Aug 7, 2019 · af6e0b4 · af6e0b4
1 parent f7e3c9e
commit af6e0b4
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Services/Convos/MessageRepositorySQLite.cs b/src/Services/Convos/MessageRepositorySQLite.cs
@@ -300,6 +300,7 @@ public async Task<bool> AddRange(IEnumerable<Message> messages)
             string sql = $"INSERT OR IGNORE INTO \"{tableName}\" VALUES (@Id, @SenderId, @SenderName, @TimestampUTC, @Body)";
 
             using (var dbcon = OpenConnection())
+            using (var t = dbcon.BeginTransaction())
             {
                 success = await dbcon.ExecuteAsync(sql, messages.Where(m => m.Id.NotNullNotEmpty()).Select(m => new
                 {
@@ -308,7 +309,12 @@ public async Task<bool> AddRange(IEnumerable<Message> messages)
                     SenderName = m.SenderName,
                     TimestampUTC = m.TimestampUTC.ToUnixTimeMilliseconds(),
                     Body = m.Body,
-                })) > 0;
+                }), t) > 0;
+
+                if (success)
+                {
+                    t.Commit();
+                }
             }
 
             return success;