private FileDataDto getFileDataDto()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListener.java [250:260]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  private FileDataDto getFileDataDto(AsyncDataLoadRequest payload, String instanceId) {
    File derivedFile = payload.getDerivedFile();
    File file = payload.getFile();
    Optional<FileDataDto> fileDataDto = fileService.retrieve(instanceId, derivedFile);
    fileDataDto = fileDataDto.isEmpty() ? fileService.retrieve(instanceId, file) : fileDataDto;
    if (fileDataDto.isEmpty()) {
      throw new FileNotExistsException("Files not found in ceph bucket",
          List.of(file.getId(), derivedFile.getId()));
    }
    return fileDataDto.get();
  }