ElwigData: Check zip file integrity

Elwig/App.xaml.cs

@@ -240,9 +240,9 @@ namespace Elwig {
             }
         }
 
-        public static void ReplaceDatabase(string filename) {
+        public static async Task ReplaceDatabase(string filename) {
             try {
-                ElwigData.ImportDatabase(filename);
+                await ElwigData.ImportDatabase(filename);
                 MessageBox.Show("Das Ersetzen war erfolgreich!\n\nBitte starten Sie Elwig neu!", "Datenbank ersetzen", MessageBoxButton.OK, MessageBoxImage.Information);
                 ForceShutdown = true;
                 Current.Shutdown();

Elwig/Elwig.csproj

@@ -35,6 +35,7 @@
     <PackageReference Include="RazorLight" Version="2.3.1" />
     <PackageReference Include="ScottPlot.WPF" Version="5.0.55" />
     <PackageReference Include="SQLitePCLRaw.bundle_e_sqlite3" Version="3.0.0" />
+    <PackageReference Include="System.IO.Hashing" Version="9.0.8" />
     <PackageReference Include="System.IO.Ports" Version="9.0.8" />
     <PackageReference Include="System.Text.Encoding.CodePages" Version="9.0.8" />
   </ItemGroup>

Elwig/Helpers/Export/ElwigData.cs

@@ -75,6 +75,7 @@ namespace Elwig.Helpers.Export {
                 foreach (var filename in filenames) {
                     // TODO read encrypted files
                     using var zip = ZipFile.Open(filename, ZipArchiveMode.Read);
+                    await zip.CheckIntegrity();
 
                     var version = zip.GetEntry("version");
                     using (var reader = new StreamReader(version!.Open(), Utils.UTF8)) {
@@ -370,11 +371,12 @@ namespace Elwig.Helpers.Export {
             }.Export(filename);
         }
 
-        public static void ImportDatabase(string filename) {
+        public static async Task ImportDatabase(string filename) {
             var oldName = Path.ChangeExtension(App.Config.DatabaseFile, ".old.sqlite3");
             var newName = Path.ChangeExtension(App.Config.DatabaseFile, ".new.sqlite3");
             try {
                 using (var zip = ZipFile.Open(filename, ZipArchiveMode.Read)) {
+                    await zip.CheckIntegrity();
                     var db = zip.GetEntry("database.sqlite3")!;
                     db.ExtractToFile(newName, true);
                 }

Elwig/Helpers/Extensions.cs

@@ -1,5 +1,7 @@
 using System;
 using System.IO;
+using System.IO.Compression;
+using System.IO.Hashing;
 using System.Net.Http;
 using System.Runtime.InteropServices;
 using System.Threading;
@@ -95,5 +97,16 @@ namespace Elwig.Helpers {
             await download.CopyToAsync(destination, 81920, relativeProgress, cancellationToken);
             progress.Report(100.0);
         }
+
+        public static async Task CheckIntegrity(this ZipArchive zip) {
+            var crc = new Crc32();
+            foreach (var entry in zip.Entries) {
+                crc.Reset();
+                using var stream = entry.Open();
+                await crc.AppendAsync(stream);
+                if (crc.GetCurrentHashAsUInt32() != entry.Crc32)
+                    throw new InvalidDataException($"CRC-32 mismatch in '{entry.FullName}'");
+            }
+        }
     }
 }

Elwig/Windows/MainWindow.xaml.cs

@@ -266,8 +266,8 @@ namespace Elwig.Windows {
                     if (res != MessageBoxResult.OK)
                         return;
 
-                    await App.MainDispatcher.BeginInvoke(() => {
+                    await App.MainDispatcher.BeginInvoke(async () => {
-                        App.ReplaceDatabase(filename);
+                        await App.ReplaceDatabase(filename);
                     });
                 } catch (HttpRequestException exc) {
                     MessageBox.Show("Eventuell Internetverbindung prüfen!\n\n" + exc.Message, "Datenbank herunterladen", MessageBoxButton.OK, MessageBoxImage.Error);