refactor: add problem to rejection (planning#1950))

integration-tests/src/test/java/dev/fitko/fitconnect/integrationtests/SubscriberClientIT.java

@@ -7,6 +7,7 @@ import dev.fitko.fitconnect.api.domain.model.event.EventState;
 import dev.fitko.fitconnect.api.domain.model.event.Status;
 import dev.fitko.fitconnect.api.domain.model.event.problems.data.DataEncryptionIssue;
 import dev.fitko.fitconnect.api.domain.model.event.problems.data.IncorrectDataAuthenticationTag;
+import dev.fitko.fitconnect.api.domain.model.event.problems.other.TechnicalError;
 import dev.fitko.fitconnect.api.domain.model.event.problems.submission.InvalidEventLog;
 import dev.fitko.fitconnect.api.domain.model.submission.ServiceType;
 import dev.fitko.fitconnect.api.domain.model.submission.SubmissionForPickup;
@@ -370,7 +371,7 @@ public class SubscriberClientIT extends IntegrationTestBase {
         final UUID destinationId = UUID.fromString(System.getenv("TEST_DESTINATION_ID"));
 
         // ensure destination is empty
-        subscriberClient.getAvailableSubmissionsForDestination(destinationId).forEach(s -> subscriberClient.rejectSubmission(s, List.of()));
+        subscriberClient.getAvailableSubmissionsForDestination(destinationId).forEach(s -> subscriberClient.rejectSubmission(s, List.of(new TechnicalError())));
         assertThat(subscriberClient.getAvailableSubmissionsForDestination(destinationId), hasSize(0));
 
         final var submission = SendableSubmission.Builder()
@@ -384,7 +385,7 @@ public class SubscriberClientIT extends IntegrationTestBase {
                 senderClient.send(submission);
                 // create some distance between submission dates
                 Thread.sleep(1000);
-            } catch (InterruptedException e) {
+            } catch (final InterruptedException e) {
                 throw new RuntimeException(e);
             }
         });
@@ -426,10 +427,10 @@ public class SubscriberClientIT extends IntegrationTestBase {
 
         IntStream.range(0, 10).mapToObj(i -> submission).forEach(senderClient::send);
 
-        ExecutorService es = Executors.newCachedThreadPool();
+        final ExecutorService es = Executors.newCachedThreadPool();
         final SubscriberClient subscriberClient = ClientFactory.createSubscriberClient(config);
 
-        for (SubmissionForPickup submissionForPickup : subscriberClient.getAvailableSubmissionsForDestination(submission.getDestinationId())) {
+        for (final SubmissionForPickup submissionForPickup : subscriberClient.getAvailableSubmissionsForDestination(submission.getDestinationId())) {
             es.execute(new SubscriberRunner(subscriberClient, submissionForPickup, "Thread-" + submissionForPickup.getSubmissionId()));
         }
 
@@ -443,7 +444,7 @@ public class SubscriberClientIT extends IntegrationTestBase {
         private final SubmissionForPickup submissionForPickup;
         private final String threadName;
 
-        SubscriberRunner(SubscriberClient subscriberClient, SubmissionForPickup submissionForPickup, String threadName) {
+        SubscriberRunner(final SubscriberClient subscriberClient, final SubmissionForPickup submissionForPickup, final String threadName) {
             this.subscriberClient = subscriberClient;
             this.submissionForPickup = submissionForPickup;
             this.threadName = threadName;