Merge pull request 'feature/SQlite' (#1) from feature/SQlite into main

Reviewed-on: #1

src/Chksum/Program.cs

@@ -8,7 +8,7 @@ public class Program {
             Console.WriteLine("Please specify an option.");
             PrintAvailableOptions();
             return;
-        } else if (args.Length > 1) {
+        } else if (args.Length > 1 && args[0] != "compareDatabases") {
             Console.WriteLine("Too many options.");
             return;
         }
@@ -30,11 +30,10 @@ public class Program {
                 Console.ForegroundColor = ConsoleColor.Green;
                 Console.WriteLine("Checksum process finished");
                 break;
-            case "compareChecksums":
-                Console.WriteLine("Comparing all md5 checksum files. If there is none, creating one.");
+            case "compareDatabases":
                 Console.ResetColor();
 
-                utils.compareChecksums();
+                utils.compareDatabases(args[1]);
                 break;
             case "createDB":
                 utils.initializeDB();

src/Chksum/chksum.cs

@@ -208,38 +208,57 @@ public class ChksumUtils {
         }
     }
 
-    public void compareChecksums() { // reuse for database comparison
-        foreach (var directory in Directory.GetDirectories(Directory.GetCurrentDirectory())) {
-            Directory.SetCurrentDirectory(directory); // Set new root
-            if (getFileCount() >= 1) {
-                DirectoryInfo dir = new DirectoryInfo(Directory.GetCurrentDirectory());
-                FileInfo[] files = dir.GetFiles();
-                // files.ToList().ForEach(i => Console.WriteLine(i.ToString())); // Print all files in files array
-                foreach (FileInfo file in files) {
-                    string fileName = file.Name;
-                    string fileNameWithoutExtension = Path.GetFileNameWithoutExtension(fileName);
-                    string checksumFile = Directory.GetCurrentDirectory() + "/" + fileNameWithoutExtension + ".md5";
-                    string fileMd5Checksum = fileNameWithoutExtension + ".md5";
-                    if (File.Exists(fileMd5Checksum)) {
-                        string newFileChecksum = CalculateMD5(fileName) + "  " + fileName;
-                        string existingFileChecksum = File.ReadAllText(fileMd5Checksum);
-                        string newFileName = newFileChecksum.Substring(34);
-                        string existingFileName = existingFileChecksum.Substring(34);
-                        if (newFileChecksum.Equals(existingFileChecksum)) {
-                            Console.WriteLine(newFileName + " and " + existingFileName + " are the same.");
-                        } else {
-                            Console.WriteLine(newFileName + " and " + existingFileName + " are not the same.");
-                            Console.WriteLine("The checksum of " + newFileName + " is " + newFileChecksum);
-                            Console.WriteLine("The checksum of the already exting file " + existingFileName + " is " + existingFileChecksum);
-                            // TODO Tell the user to check which file is the correct one
-                        }
-                    } else {
-                        File.AppendAllText(checksumFile, CalculateMD5(fileName) + "  " + fileName);
-                        Console.WriteLine("Calculated checksum for: " + checksumFile);
+    private List<string> getFilehashesFromDatabase(string connectionString) {
+        List<string> filehashesFromDatabase = new List<string>();
+
+        using (var connection = new SqliteConnection(connectionString)) {
+            string filehash = string.Empty;
+            
+            connection.Open();
+
+            var selectCommand = connection.CreateCommand();
+            selectCommand.CommandText =
+            @"
+                Select filehash FROM file
+            ";
+
+            using (var reader = selectCommand.ExecuteReader()) {
+                while (reader.Read()) {
+                    filehash = reader.GetString(0);
+                    filehashesFromDatabase.Add(filehash);
+                }
+            }
+        }
+
+        return filehashesFromDatabase;
+    }
+
+    public void compareDatabases(string filePathToOtherDatabase) {
+        List<string> filesThatDoNotExistsInTheRemote = getFilehashesFromDatabase("Data Source=" + DatabaseRoot + "chksum.db;Mode=ReadOnly").Except(getFilehashesFromDatabase("Data Source=" + filePathToOtherDatabase + ";Mode=ReadOnly")).ToList();
+        //List<string> filesThatDoNotExistsInTheOrigin = filehashesOfRemoteDatabase.Except(filehashesOfOriginDatabase).ToList();
+
+        foreach (string file in filesThatDoNotExistsInTheRemote) {
+            using (var connection = new SqliteConnection("Data Source=" + DatabaseRoot + "chksum.db;Mode=ReadOnly")) {
+                string filename = string.Empty;
+                
+                connection.Open();
+
+                var selectCommand = connection.CreateCommand();
+                selectCommand.CommandText =
+                @"
+                    Select filename FROM file WHERE filehash = $filehash
+                ";
+                selectCommand.Parameters.AddWithValue("$filehash", file);
+
+                using (var reader = selectCommand.ExecuteReader()) {
+                    while (reader.Read()) {
+                        filename = reader.GetString(0);
+                        
+                        Console.WriteLine("File not found in remote:");
+                        Console.WriteLine($"\t{filename}\n");
                     }
                 }
             }
-            compareChecksums();
         }
     }