void testSaveHistoryTask()

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

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

  void testSaveHistoryTask() {
    var taskId = "taskId";
    var startTime = LocalDateTime.of(1986, Month.APRIL, 8, 12, 30);
    var request = createRequest(taskId, startTime);
    var topic = kafkaProperties.getTopics().get("bpm-history-task");

    kafkaTemplate.send(topic, request);

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