Fixed duplicate insertions into the filtered database.

Backend/Handler/ContentFilter.cs

@@ -1,6 +1,5 @@
 using System.Collections.Concurrent;
 using System.Diagnostics;
-using System.Text;
 using Backend.Helper;
 using Models.Handler;
 using Models.Model.Backend;
@@ -15,18 +14,18 @@ public class ContentFilter
     private readonly string _getDomainPort443;
     private bool _stop;
     private int _timeOut;
-    private string _basePath;
+    private readonly string _basePath;
     
     public ContentFilter(ConcurrentQueue<QueueItem> queue, DbHandler dbHandler, string basePath)
     {
         _queue = queue;
         _dbHandler = dbHandler;
         _basePath = basePath;
-
+        
         _getDomainPort80 = $"{basePath}/Backend/Scripts/GetDomainNamePort80.sh";
         _getDomainPort443 = $"{basePath}/Backend/Scripts/GetDomainNamePort443.sh";
         
-        SetTimeout(60000);
+        SetTimeout(3000);
     }
     
     public void SetTimeout(int timeOut)
@@ -39,6 +38,7 @@ public class ContentFilter
         WaitHandle[] waitHandles = new WaitHandle[1];
         EventWaitHandle handle = new(false, EventResetMode.ManualReset);
         waitHandles[0] = handle;
+        
         Thread f = new (Filter!);
         f.Start(handle);
         
@@ -229,12 +229,11 @@ public class ContentFilter
         Process proc = new();
         proc.StartInfo = new()
         {
-            FileName = fileName,
-            Arguments = $"{ip}",
+            FileName = "/bin/bash",
+            Arguments = $"{fileName} {ip} {_basePath}/Backend/Scripts/{port}Header.txt",
             UseShellExecute = false,
             RedirectStandardOutput = false,
             RedirectStandardError = false,
-            RedirectStandardInput = false,
             CreateNoWindow = true
         };
         

Backend/Handler/ThreadHandler.cs

@@ -51,7 +51,7 @@ public class ThreadHandler
     {
         Thread.Sleep(10000); // Let the database handler instantiate and warm up first.
         
-        WaitHandle[] wait = _ipScanner.Start(2);
+        WaitHandle[] wait = _ipScanner.Start(64);
         
         WaitHandle.WaitAll(wait);
         
@@ -78,7 +78,7 @@ public class ThreadHandler
     
     private void StartDiscardedDbHandler()
     {
-        WaitHandle[] wait = _dbHandler.Start(2);
+        WaitHandle[] wait = _dbHandler.Start(4);
         
         WaitHandle.WaitAll(wait);