void testSavingHistoryProcessInstance()

in src/it/java/com/epam/digital/data/platform/bphistory/persistence/listener/HistoryProcessInstanceListenerIT.java [37:52]

• 14 lines of code
• 1 McCabe index (conditional complexity)

  void testSavingHistoryProcessInstance() {
    var processId = "processId";
    var startTime = LocalDateTime.of(1986, Month.APRIL, 8, 12, 30);
    var topic = kafkaProperties.getTopics().get("bpm-history-process");
    var request = createHistoryProcess(processId, startTime);

    kafkaTemplate.send(topic, request);

    await().atMost(Durations.TEN_SECONDS).untilAsserted(() -> {
      var savedTask = repository.findById(processId);
      assertThat(savedTask).isNotEmpty();
      var historyTask = savedTask.get();
      assertThat(historyTask.getProcessInstanceId()).isEqualTo(processId);
      assertThat(historyTask.getStartTime()).isEqualTo(startTime);
    });
  }