Merge pull request 'update logging' (#22) from impl/better-logging into main

Reviewed-on: #22

Patcher/PatchClient/PatchClient.csproj

@@ -4,8 +4,8 @@
     <TargetFramework>net8.0</TargetFramework>
     <IncludeNativeLibrariesForSelfExtract>true</IncludeNativeLibrariesForSelfExtract>
     <Nullable>enable</Nullable>
-    <AssemblyVersion>2.12.0</AssemblyVersion>
-    <FileVersion>2.12.0</FileVersion>
+    <AssemblyVersion>2.15.4</AssemblyVersion>
+    <FileVersion>2.15.4</FileVersion>
   </PropertyGroup>
   <ItemGroup>
     <AvaloniaResource Include="Assets\**" />

Patcher/PatchGenerator/PatchGenerator.csproj

@@ -4,8 +4,8 @@
     <TargetFramework>net8.0</TargetFramework>
     <IncludeNativeLibrariesForSelfExtract>true</IncludeNativeLibrariesForSelfExtract>
     <Nullable>enable</Nullable>
-    <AssemblyVersion>2.12.0</AssemblyVersion>
-    <FileVersion>2.12.0</FileVersion>
+    <AssemblyVersion>2.15.4</AssemblyVersion>
+    <FileVersion>2.15.4</FileVersion>
   </PropertyGroup>
 
   <ItemGroup>

Patcher/PatchGenerator/ViewModels/MainWindowViewModel.cs

@@ -23,7 +23,6 @@ namespace PatchGenerator.ViewModels
         {
             this.WhenActivated((CompositeDisposable disposables) =>
             {
-
                 if (genArgs != null && genArgs.ReadyToRun)
                 {
                     PatchGenInfo genInfo = new PatchGenInfo();
@@ -31,7 +30,8 @@ namespace PatchGenerator.ViewModels
                     genInfo.TargetFolderPath = genArgs.TargetFolderPath;
                     genInfo.SourceFolderPath = genArgs.SourceFolderPath;
                     genInfo.PatchName = genArgs.OutputFolderName;
-                    genInfo.AutoZip = genArgs.AutoZip;
+                    // issues with auto zip, but it's not really used anymore so just disabling for now
+                    genInfo.AutoZip = false;
                     genInfo.AutoClose = genArgs.AutoClose;
 
                     Router.Navigate.Execute(new PatchGenerationViewModel(this, genInfo));

Patcher/PatchGenerator/ViewModels/PatchGenerationViewModel.cs

@@ -14,9 +14,11 @@ using System.IO;
 using System.Reactive.Disposables;
 using System.Reflection;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 using System.Timers;
 using PatcherUtils.Model;
+using Timer = System.Timers.Timer;
 
 namespace PatchGenerator.ViewModels
 {
@@ -112,15 +114,17 @@ namespace PatchGenerator.ViewModels
                 patchGenStopwatch.Start();
 
                 var message = patcher.GeneratePatches();
-
-                if(message.ExitCode != PatcherExitCode.Success && generationInfo.AutoClose)
-                {
-                    Environment.Exit((int)message.ExitCode);
-                }
-
+                
                 patchGenStopwatch.Stop();
                 updateElapsedTimeTimer.Stop();
 
+                if(message.ExitCode != PatcherExitCode.Success && generationInfo.AutoClose)
+                {
+                    PatchLogger.LogInfo("Exiting: Auto close on failure");
+                    Environment.Exit((int)message.ExitCode);
+                }
+
+                PatchLogger.LogInfo("Printing summary info ...");
                 PrintSummary();
 
                 StringBuilder sb = new StringBuilder()
@@ -132,30 +136,33 @@ namespace PatchGenerator.ViewModels
                 ProgressMessage = sb.ToString();
 
                 File.Copy(LazyOperations.PatcherClientPath, $"{generationInfo.PatchName.FromCwd()}\\patcher.exe", true);
-
-                if (generationInfo.AutoZip)
-                {
-                    IndeterminateProgress = true;
-
-                    PatchItemCollection.Add(new PatchItem("Allowing Time for files to unlock ..."));
-
-                    System.Threading.Thread.Sleep(2000);
-
-                    PatchItemCollection.Add(new PatchItem("Zipping patcher ..."));
-
-                    ProgressMessage = "Zipping patcher";
-                    
-                    IndeterminateProgress = false;
-
-                    var progress = new Progress<int>(p =>
-                    {
-                        PatchPercent = p;
-                    });
-
-                    LazyOperations.CompressDirectory(generationInfo.PatchName.FromCwd(), $"{generationInfo.PatchName}.7z".FromCwd(), progress);
-
-                    PatchItemCollection.Add(new PatchItem("Done"));
-                }
+                
+                PatchLogger.LogInfo("Copied patcher.exe to output folder");
+                
+                // if (generationInfo.AutoZip)
+                // {
+                //     PatchLogger.LogInfo("AutoZipping");
+                //     IndeterminateProgress = true;
+                //
+                //     PatchItemCollection.Add(new PatchItem("Allowing Time for files to unlock ..."));
+                //
+                //     Thread.Sleep(2000);
+                //
+                //     PatchItemCollection.Add(new PatchItem("Zipping patcher ..."));
+                //
+                //     ProgressMessage = "Zipping patcher";
+                //     
+                //     IndeterminateProgress = false;
+                //
+                //     var progress = new Progress<int>(p =>
+                //     {
+                //         PatchPercent = p;
+                //     });
+                //
+                //     LazyOperations.CompressDirectory(generationInfo.PatchName.FromCwd(), $"{generationInfo.PatchName}.7z".FromCwd(), progress);
+                //
+                //     PatchItemCollection.Add(new PatchItem("Done"));
+                // }
 
                 if (generationInfo.AutoClose)
                 {

Patcher/PatchGenerator/Views/OptionsView.axaml

@@ -15,9 +15,10 @@
              Grid.Row="2" Grid.ColumnSpan="3"
              Watermark="Output Folder Name"
              />
-    
-    <CheckBox Content="Zip Generated Files" Grid.Row="4"
-              IsChecked="{Binding GenerationInfo.AutoZip}"/>
+      
+    <!-- UNRESOLVED ISSUES: disabling for now -->  
+    <!-- <CheckBox Content="Zip Generated Files" Grid.Row="4" -->
+    <!--           IsChecked="{Binding GenerationInfo.AutoZip}"/> -->
     
     <Button Content="Generate Patches" Grid.ColumnSpan="3" Grid.Row="4"
             HorizontalAlignment="Right"

Patcher/PatcherUtils/Helpers/XdeltaProcessHelper.cs

@@ -9,7 +9,7 @@ namespace PatcherUtils.Helpers;
 
 public class XdeltaProcessHelper
 {
-    private readonly int _timeout = (int)TimeSpan.FromMinutes(5).TotalMilliseconds;
+    private readonly int _timeout = (int)TimeSpan.FromMinutes(10).TotalMilliseconds;
     private string _args;
     private string _sourcePath;
     private string _deltaPath;

Patcher/PatcherUtils/LazyOperations.cs

@@ -2,7 +2,6 @@
 using PatcherUtils.Model;
 using System.IO;
 using System.Reflection;
-using Aki.Common.Utils;
 using SevenZip;
 
 namespace PatcherUtils
@@ -18,7 +17,7 @@ namespace PatcherUtils
         /// <summary>
         /// The folder that the patches will be stored in
         /// </summary>
-        public static string PatchFolder = "Aki_Patches";
+        public static string PatchFolder = "SPT_Patches";
 
         private static string SevenZDll = "7z.dll";
 
@@ -102,31 +101,44 @@ namespace PatcherUtils
 
         public static void CompressDirectory(string SourceDirectoryPath, string DestinationFilePath, IProgress<int> progress)
         {
-            var outputFile = new FileInfo(DestinationFilePath);
-            
-            SevenZipBase.SetLibraryPath(SevenZDllPath);
-            var compressor = new SevenZipCompressor()
+            try
             {
-                ArchiveFormat = OutArchiveFormat.SevenZip,
-                CompressionMethod = CompressionMethod.Lzma2,
-                CompressionLevel = CompressionLevel.Normal
-            };
+                PatchLogger.LogInfo($"Compressing: {SourceDirectoryPath}");
+                PatchLogger.LogInfo($"Output file: {DestinationFilePath}");
+                var outputFile = new FileInfo(DestinationFilePath);
+                SevenZipBase.SetLibraryPath(SevenZDllPath);
+                
+                PatchLogger.LogInfo($"7z.dll set: {SevenZDllPath}");
+                
+                var compressor = new SevenZipCompressor()
+                {
+                    ArchiveFormat = OutArchiveFormat.SevenZip,
+                    CompressionMethod = CompressionMethod.Lzma2,
+                    CompressionLevel = CompressionLevel.Normal,
+                    PreserveDirectoryRoot = true
+                };
 
-            compressor.Compressing += (_, args) =>
+                compressor.Compressing += (_, args) => { progress.Report(args.PercentDone); };
+
+                using var outputStream = outputFile.OpenWrite();
+
+                PatchLogger.LogInfo("Starting compression");
+                
+                compressor.CompressDirectory(SourceDirectoryPath, outputStream);
+                
+                PatchLogger.LogInfo("Compression complete");
+
+                outputFile.Refresh();
+
+                // failed to compress data
+                if (!outputFile.Exists || outputFile.Length == 0)
+                {
+                    PatchLogger.LogError("Failed to compress patcher");
+                }
+            }
+            catch (Exception ex)
             {
-                progress.Report(args.PercentDone);
-            };
-
-            using var outputStream = outputFile.OpenWrite();
-            
-            compressor.CompressDirectory(SourceDirectoryPath, outputStream);
-            
-            outputFile.Refresh();
-
-            // failed to compress data
-            if (!outputFile.Exists || outputFile.Length == 0)
-            {
-                Logger.LogError("Failed to compress patcher");
+                PatchLogger.LogException(ex);
             }
         }
 
@@ -140,7 +152,7 @@ namespace PatcherUtils
             if (dir.Exists)
             {
                 dir.Delete(true);
-                PatchLogger.LogInfo("Temp directory delted");
+                PatchLogger.LogInfo("Temp directory deleted");
             }
         }
     }

Patcher/PatcherUtils/PatchHelper.cs

@@ -1,12 +1,15 @@
 using PatchClient.Models;
 using PatcherUtils.Model;
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.IO;
 using System.Linq;
 using System.Security.Cryptography;
-using PatcherUtils.Helpers;
+using System.Threading;
+using System.Threading.Tasks;
+using PleOps.XdeltaSharp.Decoder;
 
 namespace PatcherUtils
 {
@@ -34,7 +37,8 @@ namespace PatcherUtils
         /// <remarks>Includes an array of <see cref="LineItem"/> with details for each type of patch</remarks>
         public event ProgressChangedHandler ProgressChanged;
 
-        protected virtual void RaiseProgressChanged(int progress, int total, string Message = "", params LineItem[] AdditionalLineItems)
+        protected virtual void RaiseProgressChanged(int progress, int total, string Message = "",
+            params LineItem[] AdditionalLineItems)
         {
             int percent = (int)Math.Floor((double)progress / total * 100);
 
@@ -79,6 +83,12 @@ namespace PatcherUtils
             var sourceInfo = new FileInfo(SourceFilePath);
             var targetInfo = new FileInfo(TargetFilePath);
 
+            // Return false if file size differs
+            if (sourceInfo.Length != targetInfo.Length)
+            {
+                return false;
+            }
+
             using (MD5 md5Service = MD5.Create())
             using (var sourceStream = File.OpenRead(SourceFilePath))
             using (var targetStream = File.OpenRead(TargetFilePath))
@@ -88,7 +98,8 @@ namespace PatcherUtils
 
                 bool matched = Enumerable.SequenceEqual(sourceHash, targetHash);
 
-                PatchLogger.LogInfo($"Hash Check: S({sourceInfo.Name}|{Convert.ToBase64String(sourceHash)}) - T({targetInfo.Name}|{Convert.ToBase64String(targetHash)}) - Match:{matched}");
+                PatchLogger.LogInfo(
+                    $"Hash Check: S({sourceInfo.Name}|{Convert.ToBase64String(sourceHash)}) - T({targetInfo.Name}|{Convert.ToBase64String(targetHash)}) - Match:{matched}");
 
                 return matched;
             }
@@ -103,37 +114,30 @@ namespace PatcherUtils
         {
             string decodedPath = SourceFilePath + ".decoded";
 
-            var xdeltaArgs = $"-d {(debugOutput ? "-v -v" : "")} -f -s";
-
-            var xdeltaHelper =
-                new XdeltaProcessHelper(xdeltaArgs, SourceFilePath, DeltaFilePath, decodedPath, debugOutput);
-
-            if (!xdeltaHelper.Run())
+            try
             {
-                return (false, "something went wrong during the xdelta3 process");
+                using var inputFile = new FileStream(SourceFilePath, FileMode.Open);
+                using var patchFile = new FileStream(DeltaFilePath, FileMode.Open);
+                using var decodedFile = new FileStream(decodedPath, FileMode.Create);
+                using var decoder = new Decoder(inputFile, patchFile, decodedFile);
+                decoder.Run();
+            }
+            catch (Exception ex)
+            {
+                PatchLogger.LogException(ex);
+                return (false, ex.Message);
             }
 
-            if (File.Exists(decodedPath))
+            try
             {
-                PatchLogger.LogInfo($"File delta decoded: {SourceFilePath}");
-
-                try
-                {
-                    File.Move(decodedPath, SourceFilePath, true);
-                    PatchLogger.LogInfo($"Delta applied: {DeltaFilePath}");
-                    return (true, "");
-                }
-                catch (Exception ex)
-                {
-                    PatchLogger.LogException(ex);
-                    return (false, ex.Message);
-                }
+                File.Move(decodedPath, SourceFilePath, true);
+                PatchLogger.LogInfo($"Delta applied: {DeltaFilePath}");
+                return (true, "");
             }
-            else
+            catch (Exception ex)
             {
-                string error = $"Failed to decode file delta: {SourceFilePath}";
-                PatchLogger.LogError(error);
-                return (false, error);
+                PatchLogger.LogException(ex);
+                return (false, ex.Message);
             }
         }
 
@@ -153,18 +157,18 @@ namespace PatcherUtils
             {
                 Directory.CreateDirectory(deltaPath.Replace(sourceFileInfo.Name + ".delta", ""));
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 PatchLogger.LogException(ex);
             }
 
             Process.Start(new ProcessStartInfo
-            {
-                FileName = LazyOperations.XDelta3Path,
-                Arguments = $"-0 -e -f -s \"{SourceFilePath}\" \"{TargetFilePath}\" \"{deltaPath}\"",
-                CreateNoWindow = true
-            })
-            .WaitForExit();
+                {
+                    FileName = LazyOperations.XDelta3Path,
+                    Arguments = $"-0 -e -f -S none -s \"{SourceFilePath}\" \"{TargetFilePath}\" \"{deltaPath}\"",
+                    CreateNoWindow = true
+                })
+                .WaitForExit();
 
             if (File.Exists(deltaPath))
             {
@@ -191,7 +195,7 @@ namespace PatcherUtils
             {
                 Directory.CreateDirectory(deltaPath.Replace(sourceFileInfo.Name + ".del", ""));
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 PatchLogger.LogException(ex);
             }
@@ -201,7 +205,7 @@ namespace PatcherUtils
                 File.Create(deltaPath);
                 PatchLogger.LogInfo($"File Created [DEL]: {deltaPath}");
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 PatchLogger.LogException(ex);
             }
@@ -222,7 +226,7 @@ namespace PatcherUtils
             {
                 Directory.CreateDirectory(deltaPath.Replace(targetSourceInfo.Name + ".new", ""));
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 PatchLogger.LogException(ex);
             }
@@ -232,7 +236,7 @@ namespace PatcherUtils
                 targetSourceInfo.CopyTo(deltaPath, true);
                 PatchLogger.LogInfo($"File Created [NEW]: {deltaPath}");
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 PatchLogger.LogException(ex);
             }
@@ -275,9 +279,11 @@ namespace PatcherUtils
 
             LazyOperations.ExtractResourcesToTempDir();
 
-            List<FileInfo> SourceFiles = sourceDir.GetFiles("*", SearchOption.AllDirectories).ToList();
+            List<FileInfo> sourceFiles = sourceDir.GetFiles("*", SearchOption.AllDirectories).ToList();
+            var targetFiles = targetDir.GetFiles("*", SearchOption.AllDirectories).ToList();
+            ConcurrentQueue<FileInfo> foundFilesQueue = new ConcurrentQueue<FileInfo>();
 
-            fileCountTotal = SourceFiles.Count;
+            fileCountTotal = targetFiles.Count;
 
             PatchLogger.LogInfo($"Total source files: {fileCountTotal}");
 
@@ -291,74 +297,101 @@ namespace PatcherUtils
 
             RaiseProgressChanged(0, fileCountTotal, "Generating deltas...");
 
-            foreach (FileInfo targetFile in targetDir.GetFiles("*", SearchOption.AllDirectories))
+            try
             {
-                //find a matching source file based on the relative path of the file
-                FileInfo sourceFile = SourceFiles.Find(f => f.FullName.Replace(sourceDir.FullName, "") == targetFile.FullName.Replace(targetDir.FullName, ""));
 
-                //if the target file doesn't exist in the source files, the target file needs to be added.
-                if (sourceFile == null)
+
+                Parallel.ForEach(targetFiles,
+                    new ParallelOptions() { MaxDegreeOfParallelism = 5 }, targetFile =>
+                    {
+                        //find a matching source file based on the relative path of the file
+                        FileInfo sourceFile = sourceFiles.Find(f =>
+                            f.FullName.Replace(sourceDir.FullName, "") ==
+                            targetFile.FullName.Replace(targetDir.FullName, ""));
+
+                        //if the target file doesn't exist in the source files, the target file needs to be added.
+                        if (sourceFile == null)
+                        {
+                            PatchLogger.LogInfo("::: Creating .new file :::");
+                            CreateNewFile(targetFile.FullName);
+
+                            newCount++;
+                            filesProcessed++;
+
+                            RaiseProgressChanged(filesProcessed, fileCountTotal,
+                                $"{targetFile.FullName.Replace(TargetFolder, "...")}.new", AdditionalInfo.ToArray());
+
+                            return;
+                        }
+
+                        string extension = "";
+
+                        // if a matching source file was found, check the file hashes and get the delta.
+                        // add it to the bag for removal later
+                        if (!CompareFileHashes(sourceFile.FullName, targetFile.FullName))
+                        {
+                            foundFilesQueue.Enqueue(sourceFile);
+                            PatchLogger.LogInfo("::: Creating .delta file :::");
+                            CreateDelta(sourceFile.FullName, targetFile.FullName);
+                            extension = ".delta";
+                            deltaCount++;
+                        }
+                        else
+                        {
+                            foundFilesQueue.Enqueue(sourceFile);
+                            PatchLogger.LogInfo("::: File Exists :::");
+                            existCount++;
+                        }
+
+                        filesProcessed++;
+
+                        AdditionalInfo[0].ItemValue = deltaCount;
+                        AdditionalInfo[1].ItemValue = newCount;
+                        AdditionalInfo[3].ItemValue = existCount;
+
+                        RaiseProgressChanged(filesProcessed, fileCountTotal,
+                            $"{targetFile.FullName.Replace(TargetFolder, "...")}{extension}", AdditionalInfo.ToArray());
+                    });
+            }
+            catch (Exception ex)
+            {
+                PatchLogger.LogException(ex);
+            }
+
+            // remove all queued files that were found in the source files list
+            PatchLogger.LogInfo(":: Updating Source List ::");
+            try
+            {
+                int processedQueueCount = 0;
+                int queueTotal = foundFilesQueue.Count;
+
+                foreach (var queuedFile in foundFilesQueue)
                 {
-                    PatchLogger.LogInfo("::: Creating .new file :::");
-                    CreateNewFile(targetFile.FullName);
-
-                    newCount++;
-                    filesProcessed++;
-
-                    RaiseProgressChanged(filesProcessed, fileCountTotal, $"{targetFile.FullName.Replace(TargetFolder, "...")}.new", AdditionalInfo.ToArray());
-
-                    continue;
+                    RaiseProgressChanged(processedQueueCount, queueTotal, $"Queued file removed: {queuedFile.Name}",
+                        AdditionalInfo.ToArray());
+                    sourceFiles.Remove(queuedFile);
                 }
-
-                string extension = "";
-
-                //if a matching source file was found, check the file hashes and get the delta.
-                if (!CompareFileHashes(sourceFile.FullName, targetFile.FullName))
-                {
-                    PatchLogger.LogInfo("::: Creating .delta file :::");
-                    CreateDelta(sourceFile.FullName, targetFile.FullName);
-                    extension = ".delta";
-                    deltaCount++;
-                }
-                else
-                {
-                    PatchLogger.LogInfo("::: File Exists :::");
-                    existCount++;
-                }
-
-                try
-                {
-                    SourceFiles.Remove(sourceFile);
-                }
-                catch(Exception ex)
-                {
-                    PatchLogger.LogException(ex);
-                }
-
-                filesProcessed++;
-
-                AdditionalInfo[0].ItemValue = deltaCount;
-                AdditionalInfo[1].ItemValue = newCount;
-                AdditionalInfo[3].ItemValue = existCount;
-
-                RaiseProgressChanged(filesProcessed, fileCountTotal, $"{targetFile.FullName.Replace(TargetFolder, "...")}{extension}", AdditionalInfo.ToArray());
+            }
+            catch (Exception ex)
+            {
+                PatchLogger.LogException(ex);
             }
 
             //Any remaining source files do not exist in the target folder and can be removed.
             //reset progress info
 
-            if (SourceFiles.Count == 0)
+            if (sourceFiles.Count == 0)
             {
                 PatchLogger.LogInfo("::: Patch Generation Complete :::");
 
                 return new PatchMessage("Generation Done", PatcherExitCode.Success);
             }
 
-            RaiseProgressChanged(0, SourceFiles.Count, "Processing .del files...");
+            RaiseProgressChanged(0, sourceFiles.Count, "Processing .del files...");
             filesProcessed = 0;
-            fileCountTotal = SourceFiles.Count;
+            fileCountTotal = sourceFiles.Count;
 
-            foreach (FileInfo delFile in SourceFiles)
+            foreach (FileInfo delFile in sourceFiles)
             {
                 PatchLogger.LogInfo("::: Creating .del file :::");
                 CreateDelFile(delFile.FullName);
@@ -368,7 +401,8 @@ namespace PatcherUtils
                 AdditionalInfo[2].ItemValue = delCount;
 
                 filesProcessed++;
-                RaiseProgressChanged(filesProcessed, fileCountTotal, $"{delFile.FullName.Replace(SourceFolder, "...")}.del", AdditionalInfo.ToArray());
+                RaiseProgressChanged(filesProcessed, fileCountTotal,
+                    $"{delFile.FullName.Replace(SourceFolder, "...")}.del", AdditionalInfo.ToArray());
             }
 
             PatchLogger.LogInfo("::: Patch Generation Complete :::");
@@ -398,7 +432,7 @@ namespace PatcherUtils
                 return new PatchMessage(message, PatcherExitCode.MissingDir);
             }
 
-            if(!deltaDir.Exists)
+            if (!deltaDir.Exists)
             {
                 string message = $"Could not find delta directory: {deltaDir.FullName}";
                 PatchLogger.LogError(message);
@@ -424,93 +458,143 @@ namespace PatcherUtils
                 new LineItem("Files to Delete", delCount)
             };
 
+            ConcurrentQueue<PatchMessage> errorsQueue = new ConcurrentQueue<PatchMessage>();
             filesProcessed = 0;
 
             fileCountTotal = deltaFiles.Count;
+            var patchingTokenSource = new CancellationTokenSource();
 
-            foreach (FileInfo deltaFile in deltaDir.GetFiles("*", SearchOption.AllDirectories))
+            try
             {
-                switch (deltaFile.Extension)
+
+
+                Parallel.ForEach(deltaDir.GetFiles("*", SearchOption.AllDirectories).ToList(),
+                    new ParallelOptions() { MaxDegreeOfParallelism = 5, CancellationToken = patchingTokenSource.Token },
+                    deltaFile =>
+                    {
+                        switch (deltaFile.Extension)
+                        {
+                            case ".delta":
+                            {
+                                //apply delta
+                                FileInfo sourceFile = SourceFiles.Find(f =>
+                                    f.FullName.Replace(sourceDir.FullName, "") == deltaFile.FullName
+                                        .Replace(deltaDir.FullName, "").Replace(".delta", ""));
+
+                                if (sourceFile == null)
+                                {
+                                    errorsQueue.Enqueue(new PatchMessage(
+                                        $"Failed to find matching source file for '{deltaFile.FullName}'",
+                                        PatcherExitCode.MissingFile));
+                                    patchingTokenSource.Cancel();
+                                    return;
+                                }
+
+                                PatchLogger.LogInfo("::: Applying Delta :::");
+                                var result = ApplyDelta(sourceFile.FullName, deltaFile.FullName);
+
+                                if (!result.Item1)
+                                {
+                                    errorsQueue.Enqueue(new PatchMessage(result.Item2, PatcherExitCode.PatchFailed));
+                                    patchingTokenSource.Cancel();
+                                    return;
+                                }
+
+                                deltaCount--;
+
+                                break;
+                            }
+                            case ".new":
+                            {
+                                //copy new file
+                                string destination = Path.Join(sourceDir.FullName,
+                                    deltaFile.FullName.Replace(deltaDir.FullName, "").Replace(".new", ""));
+
+                                PatchLogger.LogInfo("::: Adding New File :::");
+
+                                try
+                                {
+                                    Directory.CreateDirectory(Path.GetDirectoryName(destination));
+                                    File.Copy(deltaFile.FullName, destination, true);
+                                    PatchLogger.LogInfo($"File added: {destination}");
+                                }
+                                catch (Exception ex)
+                                {
+                                    PatchLogger.LogException(ex);
+                                    errorsQueue.Enqueue(new PatchMessage(ex.Message, PatcherExitCode.PatchFailed));
+                                    patchingTokenSource.Cancel();
+                                    return;
+                                }
+
+                                newCount--;
+
+                                break;
+                            }
+                            case ".del":
+                            {
+                                //remove unneeded file
+                                string delFilePath = Path.Join(sourceDir.FullName,
+                                    deltaFile.FullName.Replace(deltaDir.FullName, "").Replace(".del", ""));
+
+                                PatchLogger.LogInfo("::: Removing Uneeded File :::");
+
+                                try
+                                {
+                                    File.Delete(delFilePath);
+                                    PatchLogger.LogInfo($"File removed: {delFilePath}");
+                                }
+                                catch (Exception ex)
+                                {
+                                    PatchLogger.LogException(ex);
+                                    errorsQueue.Enqueue(new PatchMessage(ex.Message, PatcherExitCode.PatchFailed));
+                                    patchingTokenSource.Cancel();
+                                    return;
+                                }
+
+                                delCount--;
+
+                                break;
+                            }
+                        }
+
+                        AdditionalInfo[0].ItemValue = deltaCount;
+                        AdditionalInfo[1].ItemValue = newCount;
+                        AdditionalInfo[2].ItemValue = delCount;
+
+                        ++filesProcessed;
+                        RaiseProgressChanged(filesProcessed, fileCountTotal, deltaFile.Name, AdditionalInfo.ToArray());
+                    });
+            }
+            catch (Exception ex)
+            {
+                PatchLogger.LogException(ex);
+            }
+
+            if (errorsQueue.Count > 0)
+            {
+                PatchLogger.LogError($"Error queue entry count: {errorsQueue.Count}");
+                PatchLogger.LogError("Dequeuing errors");
+                
+                PatchMessage error = null;
+                
+                for (int i = 0; i < errorsQueue.Count; i++)
                 {
-                    case ".delta":
-                        {
-                            //apply delta
-                            FileInfo sourceFile = SourceFiles.Find(f => f.FullName.Replace(sourceDir.FullName, "") == deltaFile.FullName.Replace(deltaDir.FullName, "").Replace(".delta", ""));
-
-                            if (sourceFile == null)
-                            {
-                                return new PatchMessage($"Failed to find matching source file for '{deltaFile.FullName}'", PatcherExitCode.MissingFile);
-                            }
-
-                            PatchLogger.LogInfo("::: Applying Delta :::");
-                            var result = ApplyDelta(sourceFile.FullName, deltaFile.FullName);
-
-                            if(!result.Item1)
-                            {
-                                return new PatchMessage(result.Item2, PatcherExitCode.PatchFailed);
-                            }
-
-                            deltaCount--;
-
-                            break;
-                        }
-                    case ".new":
-                        {
-                            //copy new file
-                            string destination = Path.Join(sourceDir.FullName, deltaFile.FullName.Replace(deltaDir.FullName, "").Replace(".new", ""));
-
-                            PatchLogger.LogInfo("::: Adding New File :::");
-
-                            try
-                            {
-                                Directory.CreateDirectory(Path.GetDirectoryName(destination));
-                                File.Copy(deltaFile.FullName, destination, true);
-                                PatchLogger.LogInfo($"File added: {destination}");
-                            }
-                            catch(Exception ex)
-                            {
-                                PatchLogger.LogException(ex);
-                                return new PatchMessage(ex.Message, PatcherExitCode.PatchFailed);
-                            }
-
-                            newCount--;
-
-                            break;
-                        }
-                    case ".del":
-                        {
-                            //remove unneeded file
-                            string delFilePath = Path.Join(sourceDir.FullName, deltaFile.FullName.Replace(deltaDir.FullName, "").Replace(".del", ""));
-
-                            PatchLogger.LogInfo("::: Removing Uneeded File :::");
-
-                            try
-                            {
-                                File.Delete(delFilePath);
-                                PatchLogger.LogInfo($"File removed: {delFilePath}");
-                            }
-                            catch(Exception ex)
-                            {
-                                PatchLogger.LogException(ex);
-                                return new PatchMessage(ex.Message, PatcherExitCode.PatchFailed);
-                            }
-
-                            delCount--;
-
-                            break;
-                        }
+                    if (!errorsQueue.TryDequeue(out error))
+                    {
+                        return new PatchMessage(
+                            "Errors occurred during patching, but we couldn't dequeue them :(\n\nThere may be more information in the log",
+                            PatcherExitCode.PatchFailed);
+                    }
+                    
+                    PatchLogger.LogError(error.Message);
                 }
 
-                AdditionalInfo[0].ItemValue = deltaCount;
-                AdditionalInfo[1].ItemValue = newCount;
-                AdditionalInfo[2].ItemValue = delCount;
-
-                ++filesProcessed;
-                RaiseProgressChanged(filesProcessed, fileCountTotal, deltaFile.Name, AdditionalInfo.ToArray());
+                return error ?? new PatchMessage("Something went wrong :(", PatcherExitCode.PatchFailed);
             }
 
             PatchLogger.LogInfo("::: Patching Complete :::");
-            return new PatchMessage($"Patching Complete. You can delete the patcher.exe file.", PatcherExitCode.Success);
+            return new PatchMessage($"Patching Complete. You can delete the patcher.exe file.",
+                PatcherExitCode.Success);
         }
     }
-}
+}

Patcher/PatcherUtils/PatcherUtils.csproj

@@ -1,9 +1,9 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
     <TargetFramework>net8.0</TargetFramework>
-    <AssemblyVersion>2.11.0</AssemblyVersion>
-    <FileVersion>2.11.0</FileVersion>
+    <AssemblyVersion>2.15.3</AssemblyVersion>
+    <FileVersion>2.15.3</FileVersion>
   </PropertyGroup>
 
   <ItemGroup>
@@ -22,7 +22,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Squid-Box.SevenZipSharp" Version="1.6.1.23" />
+    <PackageReference Include="PleOps.XdeltaSharp" Version="1.3.0" />
+    <PackageReference Include="Squid-Box.SevenZipSharp" Version="1.6.2.24" />
   </ItemGroup>
 
 </Project>