Resolve 5602 bulk export would fail if type parameter is not provided (#5605)
* default _type to all resource types in the patient compartment for patient type&instance level bulk export * parametrized test so that it calls both type and instance level * added change log and spotless check * resolved code review comments
This commit is contained in:
parent
6a370c60cb
commit
6e1a56d520
|
@ -0,0 +1,5 @@
|
||||||
|
---
|
||||||
|
type: fix
|
||||||
|
issue: 5602
|
||||||
|
title: "Previously, instance-level Patient Bulk Export batch job would fail if the `_type` parameter was empty. This is
|
||||||
|
now fixed and `_type` will default to all resource types in the Patient Compartment plus Device."
|
|
@ -29,6 +29,7 @@ import ca.uhn.fhir.rest.server.tenant.UrlBaseTenantIdentificationStrategy;
|
||||||
import ca.uhn.fhir.test.utilities.HttpClientExtension;
|
import ca.uhn.fhir.test.utilities.HttpClientExtension;
|
||||||
import ca.uhn.fhir.test.utilities.server.RestfulServerExtension;
|
import ca.uhn.fhir.test.utilities.server.RestfulServerExtension;
|
||||||
import ca.uhn.fhir.util.JsonUtil;
|
import ca.uhn.fhir.util.JsonUtil;
|
||||||
|
import ca.uhn.fhir.util.SearchParameterUtil;
|
||||||
import ca.uhn.fhir.util.UrlUtil;
|
import ca.uhn.fhir.util.UrlUtil;
|
||||||
import com.google.common.base.Charsets;
|
import com.google.common.base.Charsets;
|
||||||
import org.apache.commons.io.IOUtils;
|
import org.apache.commons.io.IOUtils;
|
||||||
|
@ -49,6 +50,7 @@ import org.junit.jupiter.params.ParameterizedTest;
|
||||||
import org.junit.jupiter.params.provider.Arguments;
|
import org.junit.jupiter.params.provider.Arguments;
|
||||||
import org.junit.jupiter.params.provider.CsvSource;
|
import org.junit.jupiter.params.provider.CsvSource;
|
||||||
import org.junit.jupiter.params.provider.MethodSource;
|
import org.junit.jupiter.params.provider.MethodSource;
|
||||||
|
import org.junit.jupiter.params.provider.ValueSource;
|
||||||
import org.mockito.ArgumentCaptor;
|
import org.mockito.ArgumentCaptor;
|
||||||
import org.mockito.InjectMocks;
|
import org.mockito.InjectMocks;
|
||||||
import org.mockito.Mock;
|
import org.mockito.Mock;
|
||||||
|
@ -60,13 +62,16 @@ import org.slf4j.LoggerFactory;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.nio.charset.StandardCharsets;
|
import java.nio.charset.StandardCharsets;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
|
import java.util.HashSet;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
import java.util.stream.Stream;
|
import java.util.stream.Stream;
|
||||||
|
|
||||||
import static org.hamcrest.MatcherAssert.assertThat;
|
import static org.hamcrest.MatcherAssert.assertThat;
|
||||||
|
import static org.hamcrest.Matchers.arrayContainingInAnyOrder;
|
||||||
import static org.hamcrest.Matchers.contains;
|
import static org.hamcrest.Matchers.contains;
|
||||||
import static org.hamcrest.Matchers.containsInAnyOrder;
|
import static org.hamcrest.Matchers.containsInAnyOrder;
|
||||||
import static org.hamcrest.Matchers.containsString;
|
import static org.hamcrest.Matchers.containsString;
|
||||||
|
@ -799,8 +804,9 @@ public class BulkDataExportProviderTest {
|
||||||
assertThat(bp.getFilters(), containsInAnyOrder("Patient?gender=male", "Patient?gender=female"));
|
assertThat(bp.getFilters(), containsInAnyOrder("Patient?gender=male", "Patient?gender=female"));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@ParameterizedTest
|
||||||
public void testInitiateBulkExportOnPatient_noTypeParam_addsTypeBeforeBulkExport() throws IOException {
|
@ValueSource(strings = {"/Patient/" + ProviderConstants.OPERATION_EXPORT, "/Patient/p1/" + ProviderConstants.OPERATION_EXPORT})
|
||||||
|
public void testInitiateBulkExportOnPatient_noTypeParam_addsTypeBeforeBulkExport(String mode) throws IOException {
|
||||||
// when
|
// when
|
||||||
when(myJobCoordinator.startInstance(isNotNull(), any()))
|
when(myJobCoordinator.startInstance(isNotNull(), any()))
|
||||||
.thenReturn(createJobStartResponse());
|
.thenReturn(createJobStartResponse());
|
||||||
|
@ -809,7 +815,7 @@ public class BulkDataExportProviderTest {
|
||||||
input.addParameter(JpaConstants.PARAM_EXPORT_OUTPUT_FORMAT, new StringType(Constants.CT_FHIR_NDJSON));
|
input.addParameter(JpaConstants.PARAM_EXPORT_OUTPUT_FORMAT, new StringType(Constants.CT_FHIR_NDJSON));
|
||||||
|
|
||||||
// call
|
// call
|
||||||
HttpPost post = new HttpPost(myServer.getBaseUrl() + "/Patient/" + ProviderConstants.OPERATION_EXPORT);
|
HttpPost post = new HttpPost(myServer.getBaseUrl() + mode);
|
||||||
post.addHeader(Constants.HEADER_PREFER, Constants.HEADER_PREFER_RESPOND_ASYNC);
|
post.addHeader(Constants.HEADER_PREFER, Constants.HEADER_PREFER_RESPOND_ASYNC);
|
||||||
post.setEntity(new ResourceEntity(myCtx, input));
|
post.setEntity(new ResourceEntity(myCtx, input));
|
||||||
ourLog.info("Request: {}", post);
|
ourLog.info("Request: {}", post);
|
||||||
|
@ -820,9 +826,12 @@ public class BulkDataExportProviderTest {
|
||||||
assertEquals(myServer.getBaseUrl() + "/$export-poll-status?_jobId=" + A_JOB_ID, response.getFirstHeader(Constants.HEADER_CONTENT_LOCATION).getValue());
|
assertEquals(myServer.getBaseUrl() + "/$export-poll-status?_jobId=" + A_JOB_ID, response.getFirstHeader(Constants.HEADER_CONTENT_LOCATION).getValue());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// verify
|
||||||
|
Set<String> expectedResourceTypes = new HashSet<>(SearchParameterUtil.getAllResourceTypesThatAreInPatientCompartment(myCtx));
|
||||||
|
expectedResourceTypes.add("Device");
|
||||||
BulkExportJobParameters bp = verifyJobStartAndReturnParameters();
|
BulkExportJobParameters bp = verifyJobStartAndReturnParameters();
|
||||||
assertEquals(Constants.CT_FHIR_NDJSON, bp.getOutputFormat());
|
assertEquals(Constants.CT_FHIR_NDJSON, bp.getOutputFormat());
|
||||||
assertThat(bp.getResourceTypes(), containsInAnyOrder("Patient"));
|
assertThat(bp.getResourceTypes(), containsInAnyOrder(expectedResourceTypes.toArray()));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
|
@ -647,8 +647,8 @@ public class BulkDataExportProvider {
|
||||||
List<IPrimitiveType<String>> theTypePostFetchFilterUrl) {
|
List<IPrimitiveType<String>> theTypePostFetchFilterUrl) {
|
||||||
IPrimitiveType<String> type = theType;
|
IPrimitiveType<String> type = theType;
|
||||||
if (type == null) {
|
if (type == null) {
|
||||||
// Type is optional, but the job requires it
|
// set type to all patient compartment resources if it is null
|
||||||
type = new StringDt("Patient");
|
type = new StringDt(String.join(",", getPatientCompartmentResources()));
|
||||||
}
|
}
|
||||||
BulkExportJobParameters BulkExportJobParameters = buildBulkExportJobParameters(
|
BulkExportJobParameters BulkExportJobParameters = buildBulkExportJobParameters(
|
||||||
theOutputFormat,
|
theOutputFormat,
|
||||||
|
@ -673,9 +673,14 @@ public class BulkDataExportProvider {
|
||||||
IPrimitiveType<String> theExportIdentifier,
|
IPrimitiveType<String> theExportIdentifier,
|
||||||
IIdType thePatientId,
|
IIdType thePatientId,
|
||||||
List<IPrimitiveType<String>> theTypePostFetchFilterUrl) {
|
List<IPrimitiveType<String>> theTypePostFetchFilterUrl) {
|
||||||
|
IPrimitiveType<String> type = theType;
|
||||||
|
if (type == null) {
|
||||||
|
// set type to all patient compartment resources if it is null
|
||||||
|
type = new StringDt(String.join(",", getPatientCompartmentResources()));
|
||||||
|
}
|
||||||
BulkExportJobParameters BulkExportJobParameters = buildBulkExportJobParameters(
|
BulkExportJobParameters BulkExportJobParameters = buildBulkExportJobParameters(
|
||||||
theOutputFormat,
|
theOutputFormat,
|
||||||
theType,
|
type,
|
||||||
theSince,
|
theSince,
|
||||||
theTypeFilter,
|
theTypeFilter,
|
||||||
theExportIdentifier,
|
theExportIdentifier,
|
||||||
|
|
Loading…
Reference in New Issue