public void shouldPutTaskFormDataToCeph()

in ddm-bpm-extension/src/it/java/com/epam/digital/data/platform/bpms/extension/it/CephJavaDelegatesIT.java [70:97]

21 lines of code
1 McCabe index (conditional complexity)


  public void shouldPutTaskFormDataToCeph() {
    var content = Spin.JSON("{\"name\":\"value ek\"}");

    Map<String, Object> vars = ImmutableMap.of("formData", Variables.objectValue(content, true));
    var processInstance = runtimeService
        .startProcessInstanceByKey("testCephFormDataDelegates_key", "key", vars);

    var expectedCephKey = formDataKeyProvider.generateKey("userTask",
        processInstance.getProcessInstanceId());

    var data = formDataStorageService.getFormData(expectedCephKey);
    assertThat(data).isNotEmpty();
    assertThat(data.get().getData().get("name")).isEqualTo("value ek");

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

    BpmnAwareTests.assertThat(processInstance).isEnded();

    var resultVariables = historyService.createHistoricVariableInstanceQuery()
        .processInstanceId(processInstance.getId()).list().stream()
        .filter(historicVariableInstance -> Objects.nonNull(historicVariableInstance.getValue()))
        .collect(toMap(HistoricVariableInstance::getName, HistoricVariableInstance::getValue,
            (o1, o2) -> o1));

    assertThat(resultVariables).doesNotContainKey("formDataOutput");
  }