Skip to content

Commit bbf88b8

Browse files
eugenbegiqieugenbegiqi
committed
[SELC-5434] : added some tests
1 parent 4370817 commit bbf88b8

File tree

1 file changed

+125
-5
lines changed

1 file changed

+125
-5
lines changed

‎apps/onboarding-ms/src/test/java/it/pagopa/selfcare/onboarding/service/AggregatesServiceDefaultTest.java

+125-5
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,13 @@
11
package it.pagopa.selfcare.onboarding.service;
22

3-
import com.fasterxml.jackson.databind.ObjectMapper;
43
import io.quarkus.test.InjectMock;
54
import io.quarkus.test.junit.QuarkusTest;
65
import io.quarkus.test.vertx.RunOnVertxContext;
76
import io.smallrye.mutiny.Uni;
87
import io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
98
import it.pagopa.selfcare.onboarding.exception.ResourceNotFoundException;
109
import it.pagopa.selfcare.onboarding.mapper.OnboardingMapper;
11-
import it.pagopa.selfcare.onboarding.model.VerifyAggregateResponse;
10+
import it.pagopa.selfcare.onboarding.model.*;
1211
import jakarta.inject.Inject;
1312
import org.eclipse.microprofile.rest.client.inject.RestClient;
1413
import org.junit.jupiter.api.Test;
@@ -20,10 +19,15 @@
2019
import org.openapi.quarkus.party_registry_proxy_json.model.UOResource;
2120

2221
import java.io.File;
23-
import java.io.IOException;
24-
import java.nio.file.Files;
22+
import java.util.ArrayList;
23+
import java.util.List;
24+
25+
import static org.junit.jupiter.api.Assertions.assertNotNull;
26+
import static org.mockito.ArgumentMatchers.any;
27+
import static org.mockito.Mockito.*;
28+
29+
import static org.junit.jupiter.api.Assertions.*;
2530

26-
import static org.mockito.Mockito.when;
2731

2832
@QuarkusTest
2933
public class AggregatesServiceDefaultTest {
@@ -100,4 +104,120 @@ void validateSendAggregates(){
100104
.assertCompleted();
101105
}
102106

107+
108+
@Test
109+
void testValidateAppIoAggregatesCsv() {
110+
111+
File file = new File("src/test/resources/aggregates-appio.csv");
112+
113+
CsvAggregateAppIo csvAggregate = new CsvAggregateAppIo();
114+
csvAggregate.setSubunitType("AOO");
115+
csvAggregate.setSubunitCode("AOO_CODE");
116+
117+
List<CsvAggregateAppIo> csvAggregateList = new ArrayList<>();
118+
csvAggregateList.add(csvAggregate);
119+
120+
AggregatesCsvResponse aggregatesCsvResponse = aggregatesServiceDefault.readItemsFromCsv(file, CsvAggregateAppIo.class);
121+
when(aooApi.findByUnicodeUsingGET("1437190414", null)).thenReturn(Uni.createFrom().item(new AOOResource()));
122+
when(institutionApi.findInstitutionUsingGET("00297110389", null, null)).thenReturn(Uni.createFrom().item(new InstitutionResource()));
123+
124+
Uni<VerifyAggregateResponse> result = aggregatesServiceDefault.validateAppIoAggregatesCsv(file);
125+
126+
VerifyAggregateResponse verifyAggregateResponse = result.await().indefinitely();
127+
assertNotNull(verifyAggregateResponse);
128+
assertNotNull(aggregatesCsvResponse.getValidAggregates());
129+
130+
assertTrue(!aggregatesCsvResponse.getCsvAggregateList().isEmpty());
131+
assertTrue(aggregatesCsvResponse.getRowErrorList().isEmpty());
132+
133+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getAddress());
134+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getCity());
135+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getPec());
136+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getDescription());
137+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getRowNumber());
138+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getSubunitCode());
139+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getTaxCode());
140+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getProvince());
141+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getSubunitType());
142+
assertNotNull(((CsvAggregateAppIo) aggregatesCsvResponse.getCsvAggregateList().get(0)).getVatNumber());
143+
144+
verify(aooApi,times(0)).findByUnicodeUsingGET("1437190414", null);
145+
verify(institutionApi,times(0)).findInstitutionUsingGET("00297110389", null, null);
146+
147+
}
148+
149+
@Test
150+
void testValidateSendAggregatesCsv() {
151+
152+
File file = new File("src/test/resources/aggregates-send.csv");
153+
154+
CsvAggregateSend csvAggregate = new CsvAggregateSend();
155+
csvAggregate.setSubunitType("AOO");
156+
csvAggregate.setSubunitCode("AOO_CODE");
157+
158+
List<CsvAggregateSend> csvAggregateList = new ArrayList<>();
159+
csvAggregateList.add(csvAggregate);
160+
161+
AggregatesCsvResponse aggregatesCsvResponse = aggregatesServiceDefault.readItemsFromCsv(file, CsvAggregateSend.class);
162+
when(aooApi.findByUnicodeUsingGET("1437190414", null)).thenReturn(Uni.createFrom().item(new AOOResource()));
163+
when(institutionApi.findInstitutionUsingGET("00297110389", null, null)).thenReturn(Uni.createFrom().item(new InstitutionResource()));
164+
when(uoApi.findByUnicodeUsingGET1("4551120274", null)).thenReturn(Uni.createFrom().item(new UOResource()));
165+
166+
Uni<VerifyAggregateResponse> result = aggregatesServiceDefault.validateAppIoAggregatesCsv(file);
167+
168+
VerifyAggregateResponse verifyAggregateResponse = result.await().indefinitely();
169+
assertNotNull(verifyAggregateResponse);
170+
assertNotNull(aggregatesCsvResponse.getValidAggregates());
171+
172+
assertTrue(!aggregatesCsvResponse.getCsvAggregateList().isEmpty());
173+
assertTrue(aggregatesCsvResponse.getRowErrorList().isEmpty());
174+
175+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getAddress());
176+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getCity());
177+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getPec());
178+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getDescription());
179+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getRowNumber());
180+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getSubunitCode());
181+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getTaxCode());
182+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getProvince());
183+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getSubunitType());
184+
assertNotNull(((CsvAggregateSend) aggregatesCsvResponse.getCsvAggregateList().get(0)).getVatNumber());
185+
186+
verify(aooApi,times(0)).findByUnicodeUsingGET("1437190414", null);
187+
verify(institutionApi,times(0)).findInstitutionUsingGET("00297110389", null, null);
188+
verify(uoApi,times(0)).findByUnicodeUsingGET1("4551120274", null);
189+
190+
}
191+
192+
@Test
193+
void testValidatePagoPaAggregatesCsv() {
194+
195+
File file = new File("src/test/resources/aggregates-pagopa.csv");
196+
197+
CsvAggregatePagoPa csvAggregate = new CsvAggregatePagoPa();
198+
199+
List<CsvAggregatePagoPa> csvAggregateList = new ArrayList<>();
200+
csvAggregateList.add(csvAggregate);
201+
202+
AggregatesCsvResponse aggregatesCsvResponse = aggregatesServiceDefault.readItemsFromCsv(file, CsvAggregatePagoPa.class);
203+
Uni<VerifyAggregateResponse> result = aggregatesServiceDefault.validateAppIoAggregatesCsv(file);
204+
205+
VerifyAggregateResponse verifyAggregateResponse = result.await().indefinitely();
206+
assertNotNull(verifyAggregateResponse);
207+
assertNotNull(aggregatesCsvResponse.getValidAggregates());
208+
209+
assertTrue(!aggregatesCsvResponse.getCsvAggregateList().isEmpty());
210+
assertTrue(aggregatesCsvResponse.getRowErrorList().isEmpty());
211+
212+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getAddress());
213+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getCity());
214+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getPec());
215+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getDescription());
216+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getRowNumber());
217+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getTaxCode());
218+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getProvince());
219+
assertNotNull(((CsvAggregatePagoPa) aggregatesCsvResponse.getCsvAggregateList().get(0)).getVatNumber());
220+
221+
}
222+
103223
}

0 commit comments

Comments
 (0)