From 4ef3c7d2a39ef4f0d7d9beaae898c6c9398ba664 Mon Sep 17 00:00:00 2001
From: Vitalii Mikhailov <personal@aragas.org>
Date: Sat, 24 Feb 2024 23:21:59 +0200
Subject: [PATCH] Fix

---
 src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs b/src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs
index e5d345c..6726603 100644
--- a/src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs
+++ b/src/BUTR.CrashReportServer/Services/DatabaseMigrator.cs
@@ -38,22 +38,22 @@ protected override async Task ExecuteAsync(CancellationToken ct)
         var idDataCount = sqlite.Set<IdEntity>().Count();
         for (var i = 0; i < idDataCount % take; i+= take)
         {
-            var data = await sqlite.Set<IdEntity>().Skip(i * take).Take(take).ToArrayAsync(ct);
+            var data = await sqlite.Set<IdEntity>().OrderBy(x => x.FileId).Skip(i * take).Take(take).ToArrayAsync(ct);
             await postgres.Set<IdEntity>().AddRangeAsync(data, ct);
         }
         
         var fileDataCount = sqlite.Set<FileEntity>().Count();
         for (var i = 0; i < fileDataCount % take; i+= take)
         {
-            var data = await sqlite.Set<FileEntity>().Skip(i * take).Take(take).ToArrayAsync(ct);
+            var data = await sqlite.Set<FileEntity>().OrderBy(x => x.Id.FileId).Skip(i * take).Take(take).ToArrayAsync(ct);
             await postgres.Set<FileEntity>().AddRangeAsync(data, ct);
         }
         
         var jsonDataCount = sqlite.Set<OldJsonEntity>().Count();
         for (var i = 0; i < jsonDataCount % take; i+= take)
         {
-            var data = await sqlite.Set<OldJsonEntity>().Skip(i * take).Take(take).AsAsyncEnumerable()
-                .SelectAwait(async (x) => new JsonEntity
+            var data = await sqlite.Set<OldJsonEntity>().OrderBy(x => x.Id.FileId).Skip(i * take).Take(take).AsAsyncEnumerable()
+                .SelectAwait(async x => new JsonEntity
                 {
                     Id = x.Id,
                     CrashReport = await new StreamReader(await _compressor.DecompressAsync(x.CrashReportCompressed, ct)).ReadToEndAsync(ct),