public void testDataFactoryConnectorBatchCreateDelegate()

in ddm-bpm-extension/src/it/java/com/epam/digital/data/platform/bpms/extension/it/DataFactoryConnectorDelegateIT.java [280:332]
46 lines of code
1 McCabe index (conditional complexity)

  public void testDataFactoryConnectorBatchCreateDelegate() {
    digitalSignatureMockServer.addStubMapping(stubFor(
        post(urlPathEqualTo("/api/eseal/sign"))
            .withHeader("X-Access-Token", equalTo(validAccessToken))
            .withRequestBody(equalTo(
                "{\"data\":\"{\\\"data\\\":\\\"test data\\\",\\\"description\\\":\\\"some description\\\"}\"}"))
            .willReturn(aResponse().withHeader("Content-Type", "application/json").withStatus(200)
                .withBody("{\"signature\":\"signature\"}"))));

    dataFactoryMockServer.addStubMapping(
        stubFor(post(urlPathEqualTo("/mock-server/test"))
            .withHeader("X-Access-Token", equalTo(validAccessToken))
            .withHeader("X-Digital-Signature",
                matching("process/.*/task/test_token"))
            .withHeader("X-Digital-Signature-Derived",
                matching("lowcode_.*_system_signature_ceph_key_0"))
            .withRequestBody(
                equalTo("{\"data\":\"test data\",\"description\":\"some description\"}"))
            .willReturn(aResponse().withStatus(201))));

    digitalSignatureMockServer.addStubMapping(stubFor(
        post(urlPathEqualTo("/api/eseal/sign"))
            .withHeader("X-Access-Token", equalTo(validAccessToken))
            .withRequestBody(equalTo(
                "{\"data\":\"{\\\"data2\\\":\\\"test data2\\\",\\\"description2\\\":\\\"some description2\\\"}\"}"))
            .willReturn(aResponse().withHeader("Content-Type", "application/json").withStatus(200)
                .withBody("{\"signature\":\"signature2\"}"))));

    dataFactoryMockServer.addStubMapping(
        stubFor(post(urlPathEqualTo("/mock-server/test"))
            .withHeader("X-Access-Token", equalTo(validAccessToken))
            .withHeader("X-Digital-Signature",
                matching("process/.*/task/test_token"))
            .withHeader("X-Digital-Signature-Derived",
                matching("lowcode_.*_system_signature_ceph_key_1"))
            .withRequestBody(
                equalTo("{\"data2\":\"test data2\",\"description2\":\"some description2\"}"))
            .willReturn(aResponse().withStatus(201))));

    var processInstance = runtimeService
        .startProcessInstanceByKey("testDataFactoryConnectorBatchCreateDelegate_key");

    var cephKeyToken = formDataKeyProvider
        .generateKey("test_token", processInstance.getProcessInstanceId());
    formDataStorageService.putFormData(cephKeyToken, FormDataDto.builder().accessToken(validAccessToken)
        .data(new LinkedHashMap<>()).build());

    var taskId = taskService.createTaskQuery().taskDefinitionKey("waitConditionTask").singleResult()
        .getId();
    taskService.complete(taskId);

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