diff options
author | Christof Rabensteiner <christof.rabensteiner@iaik.tugraz.at> | 2019-05-13 14:02:42 +0200 |
---|---|---|
committer | Christof Rabensteiner <christof.rabensteiner@iaik.tugraz.at> | 2019-05-13 14:02:42 +0200 |
commit | f4af4f437ff79cb6e2a35fdfe87e8d952a70b685 (patch) | |
tree | 4108bf08dab953e11e6ff44233552d73d8ff26e2 /src/test/java | |
parent | 2f45b2f1366b7152391979c778e36402eb237b03 (diff) | |
download | moa-zs-f4af4f437ff79cb6e2a35fdfe87e8d952a70b685.tar.gz moa-zs-f4af4f437ff79cb6e2a35fdfe87e8d952a70b685.tar.bz2 moa-zs-f4af4f437ff79cb6e2a35fdfe87e8d952a70b685.zip |
Add Unit Tests for DeliveryPipeline
- Refactor: Move TnvzClient in sub package
- Autowire all parameters instead of each parameter individually
Diffstat (limited to 'src/test/java')
-rw-r--r-- | src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java | 211 |
1 files changed, 211 insertions, 0 deletions
diff --git a/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java b/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java new file mode 100644 index 0000000..f394a63 --- /dev/null +++ b/src/test/java/at/gv/egiz/moazs/SameThreadDeliveryPipelineTest.java @@ -0,0 +1,211 @@ +package at.gv.egiz.moazs; + +import at.gv.egiz.moazs.pipeline.DeliveryPipeline; +import at.gv.egiz.moazs.pipeline.SameThreadDeliveryPipeline; +import at.gv.egiz.moazs.repository.DeliveryRepository; +import at.gv.egiz.moazs.scheme.Mzs2MsgConverter; +import at.gv.egiz.moazs.tnvz.TnvzClient; +import at.gv.zustellung.app2mzs.xsd.DeliveryRequestType; +import at.gv.zustellung.msg.xsd.DeliveryRequestStatusType; +import at.gv.zustellung.msg.xsd.MetaData; +import at.gv.zustellung.tnvz.xsd.MimeTypeList; +import at.gv.zustellung.tnvz.xsd.PersonResultType; +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.Mock; +import org.mockito.junit.MockitoJUnitRunner; + +import java.util.List; + +import static at.gv.zustellung.app2mzs.xsd.ConfigType.configTypeBuilder; +import static at.gv.zustellung.app2mzs.xsd.DeliveryRequestType.Payload; +import static at.gv.zustellung.app2mzs.xsd.DeliveryRequestType.Payload.payloadBuilder; +import static at.gv.zustellung.app2mzs.xsd.DeliveryRequestType.deliveryRequestTypeBuilder; +import static at.gv.zustellung.msg.xsd.DeliveryRequestStatusType.Success.successBuilder; +import static at.gv.zustellung.msg.xsd.DeliveryRequestStatusType.deliveryRequestStatusTypeBuilder; +import static at.gv.zustellung.msg.xsd.ErrorInfoType.errorInfoTypeBuilder; +import static at.gv.zustellung.msg.xsd.MetaData.metaDataBuilder; +import static at.gv.zustellung.tnvz.xsd.MimeTypeList.mimeTypeListBuilder; +import static at.gv.zustellung.tnvz.xsd.PersonResultSuccessType.personResultSuccessTypeBuilder; +import static at.gv.zustellung.tnvz.xsd.PersonResultType.Error.errorBuilder; +import static at.gv.zustellung.tnvz.xsd.PersonResultType.personResultTypeBuilder; +import static java.util.Optional.of; +import static java.util.stream.Collectors.toList; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.Mockito.*; + +@RunWith(MockitoJUnitRunner.class) +public class SameThreadDeliveryPipelineTest { + + @Mock + private DeliveryRepository repository; + + @Mock + private TnvzClient tnvzClient; + + @Mock + private MsgClient msgClient; + + @Mock + private Mzs2MsgConverter converter; + + + private DeliveryPipeline pipeline; + + @Before + public void setup() { + pipeline = new SameThreadDeliveryPipeline(repository, tnvzClient, converter, msgClient); + } + + @Test + public void executePipelineWithoutTnvzRequest() { + var appDeliveryId = "no-tnvz-request"; + var status = setupMocks(appDeliveryId, false, List.of(), List.of("*/*")); + + pipeline.processRequest(appDeliveryId); + + verifyZeroInteractions(tnvzClient); + verify(repository).add(status); + } + + @Test(expected = MoaZSException.class) + public void rejectDeliveryWhenReceiverIsNotAddressable() { + var appDeliveryId = "not-addressable"; + setupMocks(appDeliveryId, true, List.of(), List.of("*/*")); + when(tnvzClient.queryPerson(any(), any())).thenReturn(setupTnvzError()); + + pipeline.processRequest(appDeliveryId); + + verify(tnvzClient).queryPerson(any(), any()); + } + + @Test + public void acceptWildcardMimeType() { + var appDeliveryId = "wild-card-mimetype"; + List<String> acceptedTypes = List.of("*/*"); + List<String> attachedTypes = List.of("pdf", "xml", "html", "random/attachedtype"); + var status = setupMocks(appDeliveryId, true, attachedTypes, acceptedTypes); + + pipeline.processRequest(appDeliveryId); + + verify(tnvzClient).queryPerson(any(), any()); + verify(repository).add(status); + } + + @Test(expected = MoaZSException.class) + public void rejectMismatchedMimeTypes() { + var appDeliveryId = "mismatched-mimetype"; + List<String> acceptedTypes = List.of("xml"); + List<String> attachedTypes = List.of("pdf", "xml", "html", "random/attachedtype"); + setupMocks(appDeliveryId, true, attachedTypes, acceptedTypes); + + pipeline.processRequest(appDeliveryId); + + verify(tnvzClient).queryPerson(any(), any()); + } + + @Test + public void acceptSpecificMimeType() { + var appDeliveryId = "specific-mimetype"; + List<String> acceptedTypes = List.of("pdf", "xml", "html"); + List<String> attachedTypes = List.of("pdf", "xml"); + var status = setupMocks(appDeliveryId, true, attachedTypes, acceptedTypes); + + pipeline.processRequest(appDeliveryId); + + verify(tnvzClient).queryPerson(any(), any()); + verify(repository).add(status); + } + + private DeliveryRequestStatusType setupMocks(String appDeliveryId, boolean tnvzRequest, + List<String> attachedTypes, List<String> acceptedTypes) { + + var mzsRequest = setupMzsRequest(appDeliveryId, tnvzRequest, attachedTypes); + var msgRequest = setupMsgRequest(appDeliveryId); + var status = setupStatus(appDeliveryId); + when(repository.getDeliveryRequest(appDeliveryId)).thenReturn(of(mzsRequest)); + when(tnvzClient.queryPerson(any(), any())).thenReturn(setupTnvzSuccess(acceptedTypes)); + when(converter.convert(eq(mzsRequest) )).thenReturn(msgRequest); + when(converter.convert(eq(mzsRequest), any())).thenReturn(msgRequest); + when(msgClient.send(msgRequest)).thenReturn(status); + + return status; + + } + + private PersonResultType setupTnvzError() { + + var info = errorInfoTypeBuilder() + .withCode("400") + .withText("Person Not Found") + .build(); + + var error = errorBuilder() + .withErrorInfo(info) + .build(); + + return personResultTypeBuilder() + .withError(error) + .build(); + } + + private PersonResultType setupTnvzSuccess(List<String> mimeTypes) { + + var success = personResultSuccessTypeBuilder() + .withMimeTypeList(setupMimeTypeList(mimeTypes)) + .build(); + + return personResultTypeBuilder() + .withSuccess(success) + .build(); + } + + private DeliveryRequestStatusType setupStatus(String appDeliveryId) { + + var success = successBuilder() + .withAppDeliveryID(appDeliveryId) + .build(); + + return deliveryRequestStatusTypeBuilder() + .withSuccess(success) + .build(); + + } + + private DeliveryRequestType setupMzsRequest(String appDeliveryId, boolean tnvzRequest, List<String> mimeTypes) { + + var config = configTypeBuilder() + .withPerformQueryPersonRequest(tnvzRequest) + .build(); + + return deliveryRequestTypeBuilder() + .withMetaData(setupMetaData(appDeliveryId)) + .withConfig(config) + .withPayload(setupPayload(mimeTypes)) + .build(); + } + + private List<Payload> setupPayload(List<String> mimeTypes) { + return mimeTypes.stream() + .map((mtype) -> payloadBuilder().withMIMEType(mtype).build()) + .collect(toList()); + } + + private MimeTypeList setupMimeTypeList(List<String> mimeTypes) { + return mimeTypeListBuilder().withMimeType(mimeTypes).build(); + } + + private at.gv.zustellung.msg.xsd.DeliveryRequestType setupMsgRequest(String appDeliveryId) { + return at.gv.zustellung.msg.xsd.DeliveryRequestType.deliveryRequestTypeBuilder() + .withMetaData(setupMetaData(appDeliveryId)) + .build(); + } + + private MetaData setupMetaData(String appDeliveryId) { + return metaDataBuilder() + .withAppDeliveryID(appDeliveryId) + .build(); + } + +} |