Add build badge

Signed-off-by: Gitea <gitea@hopeless-cloud.xyz>

README.md

@@ -1,7 +1,20 @@
+[![status-badge](https://woodpecker.hopeless-cloud.xyz/api/badges/ProfessionalUwU/chksum/status.svg)](https://woodpecker.hopeless-cloud.xyz/ProfessionalUwU/chksum)
+
 # chksum
 
 Checksums every file under the current directory
 
+## Runtime dependency
+
+If you use version 2.0.0 or above you will need redis!
+
+```bash
+pacman -S redis && systemctl start redis
+```
+
+With this redis will be downloaded and started. 
+Don't forget to enable the service if you don't want to start it every time you run the program.
+
 ## Run Locally
 
 Clone the project
@@ -44,3 +57,18 @@ Run executable
 ```bash
 ./Chksum
 ```
+
+## Enabling verbose output for troubleshooting
+
+1. Open the file called chksum.cs with your editor of choice.
+2. At the top there will be the logger configuration which you can change. Should look like this.
+```cs
+private ILogger logger = new LoggerConfiguration()
+            .MinimumLevel.Debug()
+            .WriteTo.Console(restrictedToMinimumLevel: LogEventLevel.Error)
+            .WriteTo.File("chksum.log")
+            .CreateLogger();
+```
+3. Change the minimum level of the logger to Verbose.
+4. Compile the program
+5. Profit. Now you will be able to see how what the program is doing in detail.

src/Chksum/Chksum.csproj

@@ -18,6 +18,12 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.Data.Sqlite" Version="7.0.8" />
+    <PackageReference Include="MurmurHash.Net" Version="0.0.2" />
+    <PackageReference Include="Serilog" Version="3.0.1" />
+    <PackageReference Include="Serilog.Sinks.Console" Version="4.1.0" />
+    <PackageReference Include="Serilog.Sinks.File" Version="5.0.0" />
+    <PackageReference Include="StackExchange.Redis" Version="2.6.116" />
+    <PackageReference Include="Standart.Hash.xxHash" Version="4.0.5" />
   </ItemGroup>
 
 </Project>

src/Chksum/Program.cs

@@ -8,7 +8,7 @@ public class Program {
             Console.WriteLine("Please specify an option.");
             PrintAvailableOptions();
             return;
-        } else if (args.Length > 1 && args[0] != "compareDatabases") {
+        } else if (args.Length > 3) {
             Console.WriteLine("Too many options.");
             return;
         }
@@ -19,26 +19,41 @@ public class Program {
 
         utils.ExtractEmbeddedLibrary();
 
+        var option = args[0].ToLower();
+
         Console.ForegroundColor = ConsoleColor.Green;
-        switch (args[0]) {
+        switch (option) {
             case "checksum":
                 Console.WriteLine("Starting the checksum process.");
                 Console.ResetColor();
+                var hashAlgo = args[1].ToLower();
                 
-                utils.doTheThing();
+                if (hashAlgo.Equals("md5")) {
+                    utils.doTheThing(hashAlgo);
+                    break;
+                }
+                try {
+                    var bufferSize = int.Parse(args[2]);
+                    utils.doTheThing(hashAlgo, bufferSize);
+                } catch (FormatException) {
+                    Console.ForegroundColor = ConsoleColor.Red;
+                    Console.WriteLine("Buffer was not a valid integer value. Please specify a valid integer value for the buffer size");
+                    Console.ResetColor();
+                }
 
                 Console.ForegroundColor = ConsoleColor.Green;
                 Console.WriteLine("Checksum process finished");
                 break;
-            case "compareDatabases":
+            case "savetosqlite":
+                Console.ResetColor();
+                utils.saveToSqlite();
+                break;
+            case "comparedatabases":
                 Console.ResetColor();
 
                 utils.compareDatabases(args[1]);
                 break;
-            case "createDB":
-                utils.initializeDB();
-                break;
-            case "checkIfFileWasDeleted":
+            case "checkiffilewasdeleted":
                 Console.ResetColor();
                 utils.checkIfFileWasDeleted();
                 break;
@@ -57,16 +72,16 @@ public class Program {
 
     static void PrintAvailableOptions() {
         String[] options = {
-            "checksum",
-            "compareChecksums",
-            "createDB",
+            "checksum - MD5, Murmur and XxHash - Default buffer size is 4096",
+            "compareDatabases",
+            "saveToSqlite",
             "checkIfFileWasDeleted",
             "help"
         };
 
         Console.ResetColor();
         Console.WriteLine("usage: chksum [option] \nHere is a list of all available options:");
-        foreach (String option in options) {
+        foreach (var option in options) {
             Console.WriteLine("\t" + option);
         }
     }

src/Chksum/chksum.cs

@@ -2,24 +2,38 @@ using System.Collections.Concurrent;
 using System.Reflection;
 using System.Security.Cryptography;
 using Microsoft.Data.Sqlite;
+using Serilog;
+using Serilog.Events;
+using MurmurHash.Net;
+using Standart.Hash.xxHash;
+using StackExchange.Redis;
+
 namespace Chksum.Utils;
 public class ChksumUtils {
+    private ILogger logger = new LoggerConfiguration()
+            .MinimumLevel.Debug()
+            .WriteTo.Console(restrictedToMinimumLevel: LogEventLevel.Error)
+            .WriteTo.File("chksum.log")
+            .CreateLogger();
 
     private int getTotalFileCount() {
         int totalFileCount = Directory.GetFiles(Directory.GetCurrentDirectory(), "*", SearchOption.AllDirectories).Length;
-        return totalFileCount - 3; // Remove the program, datbase and library from the totalFileCount
+        logger.Debug("Total file count is {totalFileCount}", totalFileCount);
+        return totalFileCount - 4; // Remove the program, datbase, log and library from the totalFileCount
     }
 
     private string[] indexFiles() {
         string[] indexedFiles = Directory.GetFiles(Directory.GetCurrentDirectory(), "*", SearchOption.AllDirectories);
         string[] filesToExclude = { "Chksum", "chksum.db", "libe_sqlite3.so" };
         indexedFiles = indexedFiles.Where(file => !filesToExclude.Contains(Path.GetFileName(file))).ToArray();
+        logger.Information("All files were indexed");
         return indexedFiles;
     }
 
     public string DatabaseRoot { get; set; } = string.Empty;
     public void getBaseDir() {
         DatabaseRoot = AppDomain.CurrentDomain.BaseDirectory;
+        logger.Debug("DatabaseRoot is {DatabaseRoot}", DatabaseRoot);
     }
 
     public string libraryPath { get; set; } = string.Empty;
@@ -31,14 +45,17 @@ public class ChksumUtils {
                 byte[] buffer = new byte[resourceStream.Length];
                 resourceStream.Read(buffer, 0, buffer.Length);
                 File.WriteAllBytes(libraryPath, buffer);
+                logger.Debug("libe_sqlite3.so was successfully created");
             } else {
+                logger.Error("libe_sqlite3.so could not be loaded");
                 throw new Exception(libraryPath + " could not be loaded");
             }
         }
     }
 
-    public void initializeDB() {
+    private void initializeDB() {
         if (File.Exists("chksum.db")) {
+            logger.Information("A database already exits");
             return;
         }
 
@@ -57,6 +74,15 @@ public class ChksumUtils {
                 );
             ";
             command.ExecuteNonQuery();
+
+            var walCommand = connection.CreateCommand();
+            walCommand.CommandText =
+            @"
+                PRAGMA journal_mode = 'wal'
+            ";
+            walCommand.ExecuteNonQuery();
+
+            logger.Information("Database was successfully created");
         }
     }
 
@@ -68,12 +94,23 @@ public class ChksumUtils {
                 vacuum;
             ";
             command.ExecuteNonQuery();
+            logger.Debug("Database was successfully vacuumed");
         }
     }
 
+    private void UpdateProgressBar(int current, int total) {
+        var progress = (int)((double)current / total * 100);
+        string progressText = $"Progress: {progress}% [{current}/{total}]";
+
+        Console.Write("\r" + progressText.PadRight(Console.WindowWidth));
+    }
+
     private Dictionary<string, string> CalculateChecksums(string[] filenames) {
         ConcurrentDictionary<string, string> checksums = new ConcurrentDictionary<string, string>();
 
+        int totalFiles = filenames.Length;
+        int processedFiles = 0;
+
         Parallel.ForEach(filenames, (filename, state) => {
             using (var md5 = MD5.Create()) {
                 using (var stream = File.OpenRead(filename)) {
@@ -84,40 +121,171 @@ public class ChksumUtils {
                         checksums.TryAdd(filename, checksum);
                     }
                 }
+                Interlocked.Increment(ref processedFiles);
+                UpdateProgressBar(processedFiles, totalFiles);
             }
         });
 
         return new Dictionary<string, string>(checksums);
     }
 
-    public void doTheThing() {
-        using (var connection = new SqliteConnection("Data Source=" + DatabaseRoot + "chksum.db;Mode=ReadWrite")) {
+    private Dictionary<string, uint> CalculateChecksumsWithMurmur(string[] filenames, int userDefinedBufferSize) {
+        ConcurrentDictionary<string, uint> checksums = new ConcurrentDictionary<string, uint>();
+
+        int totalFiles = filenames.Length;
+        int processedFiles = 0;
+
+        Parallel.ForEach(filenames, (filename, state) => {
+                using (var stream = File.OpenRead(filename)) {
+                    var hash = CalculateMurmurHash32(stream, userDefinedBufferSize);
+                    lock (checksums) {
+                        checksums.TryAdd(filename, hash);
+                    }
+                Interlocked.Increment(ref processedFiles);
+                UpdateProgressBar(processedFiles, totalFiles);
+            }
+        });
+
+        return new Dictionary<string, uint>(checksums);
+    }
+
+    private uint CalculateMurmurHash32(Stream stream, int userDefinedBufferSize) {
+        int bufferSize = userDefinedBufferSize;
+        const uint seed = 123456U;
+        
+        var buffer = new byte[bufferSize];
+        uint hash = seed;
+
+        int bytesRead;
+        ReadOnlySpan<byte> span = buffer;
+
+        while ((bytesRead = stream.Read(buffer, 0, bufferSize)) > 0) {
+            hash = MurmurHash3.Hash32(bytes: span, seed: 123456U);
+        }
+        return hash;
+    }
+
+    private Dictionary<string, ulong> CalculateChecksumsWithXxHash3(string[] filenames, int userDefinedBufferSize) {
+        ConcurrentDictionary<string, ulong> checksums = new ConcurrentDictionary<string, ulong>();
+
+        int totalFiles = filenames.Length;
+        int processedFiles = 0;
+
+        Parallel.ForEach(filenames, (filename, state) => {
+            using (var stream = File.OpenRead(filename)) {
+                var hash = CalculateXxHash3(stream, userDefinedBufferSize);
+                checksums.TryAdd(filename, hash);
+            }
+            Interlocked.Increment(ref processedFiles);
+            UpdateProgressBar(processedFiles, totalFiles);
+        });
+
+        return new Dictionary<string, ulong>(checksums);
+    }
+
+    private ulong CalculateXxHash3(Stream stream, int userDefinedBufferSize) {
+        int bufferSize = userDefinedBufferSize;
+        const ulong seed = 123456U;
+
+        var buffer = new byte[bufferSize];
+        ulong hash = seed;
+        
+        int bytesRead;
+
+        while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) > 0) {
+            hash = xxHash3.ComputeHash(buffer, buffer.Length);
+        }
+
+        return hash;
+    }
+
+    public void doTheThing(string hashAlgo, int bufferSize = 4096) {
+
+        ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
+        IDatabase db = redis.GetDatabase();
+
         if (getTotalFileCount() < 1) {
+            logger.Information("There were no files to checksum");
             return;
         }
+
+        Dictionary<string, object> fileHashes;
+        Dictionary<string, ulong>  fileHashesXxHash3;
+        Dictionary<string, uint>  fileHashesMurmur;
+        Dictionary<string, string> fileHashesMD5;
+
+        switch (hashAlgo) {
+            case "md5":
+                fileHashesMD5 = CalculateChecksums(indexFiles());
+                fileHashes = fileHashesMD5.ToDictionary(kv => kv.Key, kv => (object)kv.Value);
+                break;
+            case "murmur":
+                fileHashesMurmur = CalculateChecksumsWithMurmur(indexFiles(), bufferSize);
+                fileHashes = fileHashesMurmur.ToDictionary(kv => kv.Key, kv => (object)kv.Value);
+                break;
+            case "xxhash":
+                fileHashesXxHash3 = CalculateChecksumsWithXxHash3(indexFiles(), bufferSize);
+                fileHashes = fileHashesXxHash3.ToDictionary(kv => kv.Key, kv => (object)kv.Value);
+                break;
+            default:
+                logger.Error("No valid hash algorithm was selected");
+                throw new Exception($"{hashAlgo} is not a valid option. Valid options are MD5, Murmur and XxHash");
+        }
+
+        logger.Information("All files were checksummed");
+
+        HashEntry[] hashEntries = fileHashes.Select(kv => new HashEntry(kv.Key, kv.Value.ToString())).ToArray();
+        string hashKey = "fileHashes";
+        db.HashSet(hashKey, hashEntries);
+        logger.Information("Dictionary inserted into Redis.");
+    }
+
+    public void saveToSqlite() {
+        initializeDB();
+
+        ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
+        IDatabase db = redis.GetDatabase();
+
+        HashEntry[] fileHashes = db.HashGetAll("fileHashes");
+        logger.Information("Retrived all values from redis");
+
+        using (var connection = new SqliteConnection("Data Source=" + DatabaseRoot + "chksum.db;Mode=ReadWrite")) {
             connection.Open();
-            Dictionary<string, string> fileHashes = CalculateChecksums(indexFiles());
 
             foreach (var file in fileHashes) {
-                string absolutePathToFile = file.Key;
-                string fileName = Path.GetFileName(absolutePathToFile);
-                string pathToFile = Path.GetRelativePath(DatabaseRoot, absolutePathToFile);
-                string fileHash = file.Value;
+                var absolutePathToFile = file.Name.ToString();
+                string fileName = Path.GetFileName(absolutePathToFile.ToString());
+                string pathToFile = Path.GetRelativePath(DatabaseRoot, absolutePathToFile.ToString());
+                var fileHash = file.Value.ToString();
 
-                if (checkIfFileMovedAndUpdatePathToFile(fileHash, fileName, pathToFile) == false && checkIfFileAlreadyExistsInDatabase(fileHash, fileName) == false) {
-                    var command = connection.CreateCommand();
-                    command.CommandText =
+                if (checkIfFileMovedAndUpdatePathToFile(fileHash, fileName, pathToFile) || checkIfFileAlreadyExistsInDatabase(fileHash, fileName)) {
+                    continue;
+                }
+
+                var InsertCommand = connection.CreateCommand();
+                InsertCommand.CommandText =
                 @"
                     INSERT INTO file (filehash, filename, pathtofile)
                     VALUES ($filehash, $filename, $pathtofile)
                 ";
-                    command.Parameters.AddWithValue("$filehash", fileHash);
-                    command.Parameters.AddWithValue("$filename", fileName);
-                    command.Parameters.AddWithValue("$pathtofile", pathToFile);
-                    command.ExecuteNonQuery();
+                InsertCommand.Parameters.AddWithValue("$filehash", fileHash);
+                InsertCommand.Parameters.AddWithValue("$filename", fileName);
+                InsertCommand.Parameters.AddWithValue("$pathtofile", pathToFile);
+                InsertCommand.ExecuteNonQuery();
+                logger.Verbose("{fileName} which is located at {pathToFile} relative to the database with the hash {fileHash} was successfully inserted into the database", fileName, pathToFile, fileHash);
             }
         }
+        logger.Information("All filehashes were successfully inserted into the database");
+        
+        var keys = db.Execute("KEYS", "*");
+        if (keys == null) {
+            logger.Error("No values found in redis");
+            return;
         }
+        foreach (var key in (RedisValue[])keys) {
+            db.KeyDelete((RedisKey)key.ToString());
+        }
+        logger.Information("Redis was successfully cleared of any remaining data");
     }
 
     private bool checkIfFileAlreadyExistsInDatabase(string fileHash, string pathToFile) {
@@ -141,9 +309,11 @@ public class ChksumUtils {
                     pathtofile = reader.GetString(1);
                 }
             }
+            logger.Verbose("{pathToFile} with the hash {fileHash} was successfully loaded", pathToFile, fileHash);
         }
 
         if (fileHash == filehash) {
+            logger.Verbose("File with filehash {filehash} already exists in the database", filehash);
             doesExist = true;
         }
         return doesExist;
@@ -181,16 +351,18 @@ public class ChksumUtils {
                 command2.Parameters.AddWithValue("$filehash", fileHash);
                 command2.ExecuteNonQuery();
 
-                Console.WriteLine("File moved or is a duplicate:");
-                Console.WriteLine($"\tfrom\t{pathToFile}");
-                Console.WriteLine($"\tto  \t{pathtofile}\n");
+                logger.Verbose("File moved or is a duplicate:\n\tfrom\t{pathToFile}\n\tto  \t{pathtofile}\n", pathToFile, pathtofile);
                 wasMoved = true;
             }
+            logger.Verbose("{fileName} which is located at {pathToFile} relative to the database with the hash {fileHash} was successfully checked", fileName, pathToFile, fileHash);
         }
         return wasMoved;
     }
 
     public void checkIfFileWasDeleted() {
+
+        saveToSqlite();
+
         string pathToFile = string.Empty;
 
         using (var connection = new SqliteConnection("Data Source=" + DatabaseRoot + "chksum.db;Mode=ReadWrite")) {
@@ -207,6 +379,7 @@ public class ChksumUtils {
                     pathToFile = reader.GetString(0);
                     
                     if (File.Exists(pathToFile)) {
+                        logger.Verbose("{pathToFile} exists", pathToFile);
                         continue;
                     }
                     var deleteCommand = connection.CreateCommand();
@@ -218,10 +391,10 @@ public class ChksumUtils {
                     deleteCommand.Parameters.AddWithValue("$pathtofile", pathToFile);
                     deleteCommand.ExecuteNonQuery();
 
-                    Console.WriteLine("File deleted:");
-                    Console.WriteLine($"\t{pathToFile}\n");
+                    logger.Information("File deleted:\n\t{pathToFile}", pathToFile);
                 }
             }
+            logger.Information("All deleted files were successfully removed from the database");
         }
     }
 
@@ -247,10 +420,19 @@ public class ChksumUtils {
             }
         }
 
+        logger.Debug("All filehashes were successfully retrived from the database");
         return filehashesFromDatabase;
     }
 
     public void compareDatabases(string filePathToOtherDatabase) {
+
+        saveToSqlite();
+
+        if (!File.Exists(filePathToOtherDatabase)) {
+            logger.Error("No database could be found at {filePathToOtherDatabase}", filePathToOtherDatabase);
+            throw new Exception("No database could be found at " + filePathToOtherDatabase);
+        }
+
         List<string> filesThatDoNotExistsInTheRemote = getFilehashesFromDatabase("Data Source=" + DatabaseRoot + "chksum.db;Mode=ReadOnly").Except(getFilehashesFromDatabase("Data Source=" + filePathToOtherDatabase + ";Mode=ReadOnly")).ToList();
 
         foreach (string file in filesThatDoNotExistsInTheRemote) {
@@ -272,13 +454,17 @@ public class ChksumUtils {
                         
                         Console.WriteLine("File not found in remote:");
                         Console.WriteLine($"\t{filename}\n");
+                        logger.Information("{filename} could not be found in the remote database", filename);
                     }
                 }
             }
         }
+        logger.Information("Compared both databases successfully");
     }
 
     public void cleanup() {
         File.Delete(libraryPath);
+        logger.Information("Successfully deleted libe_sqlite3.so");
+        Console.ResetColor();
     }
 }