public void testDataFactoryConnectorBatchCreateDelegateV2CsvUpload()

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

29 lines of code
1 McCabe index (conditional complexity)


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

    dataFactoryMockServer.addStubMapping(
        stubFor(post(urlPathEqualTo("/mock-server/test/csv"))
            .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"))
            .withRequestBody(
                equalTo("{\"id\":\"dataId\",\"checksum\":\"dataChecksum\"}"))
            .willReturn(aResponse().withStatus(201))));

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

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

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

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