public void testDataFactoryConnectorBatchReadDelegate()

in ddm-bpm-extension/src/it/java/com/epam/digital/data/platform/bpms/extension/it/DataFactoryConnectorDelegateIT.java [410:435]

22 lines of code
1 McCabe index (conditional complexity)


  public void testDataFactoryConnectorBatchReadDelegate() {
    String chemResearchId = "7074945f-e088-446b-8c28-325aca4f423f";
    String physResearchId = "0b3c9f55-ba50-4d87-970a-bfbb8e31adeb";

    dataFactoryMockServer.addStubMapping(
        stubFor(get(urlPathEqualTo(String.format("/mock-server/research/%s", chemResearchId)))
            .withHeader("Content-Type", equalTo("application/json"))
            .withHeader("X-Source-System", equalTo("Low-code Platform"))
            .withHeader("X-Source-Application", equalTo("ddm-bpm-extension"))
            .willReturn(aResponse().withStatus(200)
                .withBody(convertJsonToString("/json/researchResponseChem.json")))));

    dataFactoryMockServer.addStubMapping(
        stubFor(get(urlPathEqualTo(String.format("/mock-server/research/%s", physResearchId)))
            .withHeader("Content-Type", equalTo("application/json"))
            .withHeader("X-Source-System", equalTo("Low-code Platform"))
            .withHeader("X-Source-Application", equalTo("ddm-bpm-extension"))
            .willReturn(aResponse().withStatus(200)
                .withBody(convertJsonToString("/json/researchResponsePhys.json")))));

    var processInstance = runtimeService
        .startProcessInstanceByKey("test-batch-read",
            Map.of("resourceIds", List.of(chemResearchId, physResearchId)));

    BpmnAwareTests.assertThat(processInstance).isEnded();
  }