diff --git a/src/main/java/de/ozgcloud/nachrichten/postfach/muk/MukPostfachRemoteService.java b/src/main/java/de/ozgcloud/nachrichten/postfach/muk/MukPostfachRemoteService.java index e9879152ae6ee4c386f52925573a58d2edb6f108..4026df2676b3f782cf32fffa25a3daecafb0c04c 100644 --- a/src/main/java/de/ozgcloud/nachrichten/postfach/muk/MukPostfachRemoteService.java +++ b/src/main/java/de/ozgcloud/nachrichten/postfach/muk/MukPostfachRemoteService.java @@ -56,9 +56,7 @@ public class MukPostfachRemoteService implements PostfachRemoteService { @Override public Stream<PostfachNachricht> getAllMessages() { - LOG.warn("Loading of PostfachNachrichten disabled right now."); - return Stream.of(); - //return elsterTransferService.getAllMessages(); + return elsterTransferService.getAllMessages(); } @Override diff --git a/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java b/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java index eeeec4f97b073b1b235859ededd56657aac07491..835c37398b4584279a9218270c972c03bc9e511d 100644 --- a/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java +++ b/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java @@ -24,7 +24,6 @@ package de.ozgcloud.nachrichten.postfach.muk.transfer; import static de.ozgcloud.nachrichten.postfach.muk.transfer.MukPostfachMessageMapper.*; -import java.io.BufferedInputStream; import java.io.ByteArrayInputStream; import java.io.FileOutputStream; import java.io.IOException; @@ -47,7 +46,6 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.stereotype.Service; import de.ozgcloud.apilib.file.OzgCloudFile; -import de.ozgcloud.apilib.file.OzgCloudFileId; import de.ozgcloud.apilib.file.OzgCloudUploadFile; import de.ozgcloud.common.binaryfile.TempFileUtils; import de.ozgcloud.common.errorhandling.TechnicalException; @@ -199,8 +197,10 @@ public class ElsterTransferRemoteService { public Stream<PostfachNachricht> getAllMessages() { var antworten = loadAntworten(); - return antworten.getDatensaetze().stream() - .map(this::getAntwort).filter(nachricht -> nachricht.getVorgangId() != null); + /*return antworten.getDatensaetze().stream() + .map(this::getAntwort).filter(nachricht -> nachricht.getVorgangId() != null);*/ + LOG.warn("Saving of Antworten is disabled right now, returning an empty stream"); + return Stream.of(); } public AntwortDetailsList loadAntworten() { @@ -286,7 +286,7 @@ public class ElsterTransferRemoteService { } Optional<String> storeToOzgCloud(DownloadAnhangDetails downloadAnhangDetails, String vorgangId, ByteArrayInputStream dataIn) throws IOException { - OzgCloudFileId ozgCloudFileId; + /*OzgCloudFileId ozgCloudFileId; try (BufferedInputStream dataStream = new BufferedInputStream(dataIn)) { ozgCloudFileId = attachmentService.store(createOzgCloudUploadFile(downloadAnhangDetails, vorgangId), dataStream); @@ -297,6 +297,8 @@ public class ElsterTransferRemoteService { } LOG.error("Received no OzgCloudFileId when saving attachment {} to vorgangId {}", downloadAnhangDetails, vorgangId); + */ + LOG.warn("Saving attachment {} to vorgangId {} is disabled right now", downloadAnhangDetails, vorgangId); return Optional.empty(); } } diff --git a/src/test/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteServiceTest.java b/src/test/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteServiceTest.java index e3864d0d7b1545852234e5f0f1710745dab49fb6..444c06591a70391b0cd926aa5d32327c0cc71fd8 100644 --- a/src/test/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteServiceTest.java +++ b/src/test/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteServiceTest.java @@ -367,6 +367,7 @@ class ElsterTransferRemoteServiceTest { } @Test + @Disabled("Saving of Antworten is disabled right now") void shouldHavePostfachNachricht() { var antwortList = elsterTransferService.getAllMessages().toList(); @@ -375,61 +376,6 @@ class ElsterTransferRemoteServiceTest { } } - @Nested - class TestCreatingNachricht { - PostfachNachricht nachricht; - - @BeforeEach - void setUp() { - when(elsterTransferService.loadAntworten()).thenReturn(AntwortDetailsTestFactory.createAntwortDetailsList()); - when(postfachProperties.getReplySubjectPrefix()).thenReturn("Antwort"); - when(postfachProperties.getBody()).thenReturn("Body"); - nachricht = elsterTransferService.getAllMessages().toList().getFirst(); - } - /*PostfachNachricht.FIELD_VORGANG_ID, nachricht.getVorgangId(), - PostfachNachricht.FIELD_CREATED_AT, nachricht.getCreatedAt().format(DateTimeFormatter.ISO_DATE_TIME), - PostfachNachricht.FIELD_DIRECTION, nachricht.getDirection().name(), - PostfachNachricht.FIELD_REPLY_OPTION, nachricht.getReplyOption().name(), - PostfachNachricht.FIELD_SUBJECT, nachricht.getSubject(), - PostfachNachricht.FIELD_MAIL_BODY, nachricht.getMailBody(), - PostfachNachricht.FIELD_ATTACHMENTS, nachricht.getAttachments()));*/ - - @Test - void shouldHaveVorgangId() { - assertThat(nachricht.getVorgangId()).isNotNull(); - } - - @Test - void shouldHaveCreatedAt() { - assertThat(nachricht.getCreatedAt()).isNotNull(); - } - - @Test - void shouldHaveDirection() { - assertThat(nachricht.getDirection()).isEqualTo(PostfachNachricht.Direction.IN); - } - - @Test - void shouldHaveReplyOption() { - assertThat(nachricht.getReplyOption()).isNotNull(); - } - - @Test - void shouldHaveSubject() { - assertThat(nachricht.getSubject()).isNotNull(); - } - - @Test - void shouldHaveMailBody() { - assertThat(nachricht.getMailBody()).isNotNull(); - } - - @Test - void shouldHaveAttachments() { - assertThat(nachricht.getAttachments()).isNotNull(); - } - } - @Nested class TestExceptionHandling { byte[] data = "test data".getBytes(); @@ -508,7 +454,7 @@ class ElsterTransferRemoteServiceTest { class TestSaveFile { @Test void shouldExtractVorgangIdFromDateibezeichnung() throws IOException { - when(attachmentService.store(any(), any())).thenReturn(new OzgCloudFileId(UUID.randomUUID().toString())); + //when(attachmentService.store(any(), any())).thenReturn(new OzgCloudFileId(UUID.randomUUID().toString())); elsterTransferService.saveAnhang("Test,Data".getBytes(), AntwortDetailsTestFactory.createDownloadAnhangDetails(), null); @@ -517,11 +463,11 @@ class ElsterTransferRemoteServiceTest { @Test void shouldSaveAttachment() { - when(attachmentService.store(any(), any())).thenReturn(new OzgCloudFileId(UUID.randomUUID().toString())); + //when(attachmentService.store(any(), any())).thenReturn(new OzgCloudFileId(UUID.randomUUID().toString())); var fileIdOpt = elsterTransferService.saveAnhang("Test,Data".getBytes(), AntwortDetailsTestFactory.createDownloadAnhangDetails(), null); - assertThat(fileIdOpt).isPresent(); + assertThat(fileIdOpt).isNotPresent(); } } } \ No newline at end of file