Bugfixes in worker management

Description

Resolves #136 (closed) and #107 (closed).

Changes

Solves #136 (closed) by running report generator in a separate thread and #107 (closed) by checking if submissions have a CPM token.

Test and Review

Fixed a faulty test checking for a wrong date.

To be filled in by the reviewers

• All of the methods are commented to expectation

• The methods are tested to satisfaction

• There are no unnecessary files present in the MR

• The continuous integration has no problems with the MR

• The MR is filled in as requested (including labels, milestones, and reviewers)

• The documentation is up-to-date

• All nullable parameters are marked as such

core/src/main/java/nl/tudelft/ewi/auta/core/communication/MessageReceiver.java

@@ -7,6 +7,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
+import nl.tudelft.ewi.auta.common.threads.Threads;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -58,22 +59,30 @@ public class MessageReceiver {
      */
     private transient boolean running = true;
 
+    /**
+     * The Thread wrapper.
+     */
+    private transient Threads threads;
+
     /**
      * Initializes a ReportReceiver for receiving worker reports.
      * @param pool the current worker pool
      * @param jump a jump instance
      * @param resultsProcessor the results processor to pass finished jobs to
      * @param settings the global settings of the core
+     * @param threads the Thread wrapper
      */
     @Autowired
     public MessageReceiver(final WorkerPool pool,
                            final Jump jump,
                            final ResultsProcessor resultsProcessor,
-                           final GlobalSettings settings) {
+                           final GlobalSettings settings,
+                           final Threads threads) {
         this.pool = pool;
         this.jump = jump;
         this.resultsProcessor = resultsProcessor;
         this.settings = settings;
+        this.threads = threads;
     }
 
     /**
@@ -156,7 +165,8 @@ public class MessageReceiver {
             this.processControl(worker, msg);
         } else {
             final var results = new Results(msg);
-            this.resultsProcessor.process(results);
+
+            this.threads.asThread(() -> this.resultsProcessor.process(results)).start();
 
             this.pool.dismiss(worker);