void processFileCleanupMessage()

in digital-document-service/src/it/java/com/epam/digital/data/platform/dgtldcmnt/listener/kafka/FileCleanerListenerIT.java [50:64]

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

  void processFileCleanupMessage() {
    var processInstanceId = UUID.randomUUID().toString();
    var fileId = UUID.randomUUID().toString();
    var fileCephKey = String.format("process/%s/%s", processInstanceId, fileId);
    var fileInputStream = new StringInputStream("some file content");
    cephService.put(bucket, fileCephKey, "text/plain", Map.of(), fileInputStream);

    var dto = new FileStorageCleanupDto(processInstanceId);
    kafkaTemplate.send(topic, dto);

    await()
        .atMost(10, TimeUnit.SECONDS)
        .pollDelay(100, TimeUnit.MILLISECONDS)
        .untilAsserted(() -> Assertions.assertThat(cephService.get(bucket, fileCephKey)).isEmpty());
  }