public Optional retrieve()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/FileService.java [54:77]


  public Optional<FileDataDto> retrieve(String instanceId, File file) {
    if (Objects.isNull(file)) {
      return Optional.empty();
    }
    log.info("Storing file '{}' from lowcode to data ceph bucket", file.getId());

    var lowcodeId = fileKeyProvider.generateKey(instanceId, file.getId());

    FileDataDto fileDataDto;
    try {
      fileDataDto = lowcodeFileDataStorageService.loadByKey(lowcodeId);
    } catch (FileNotFoundException ex) {
      log.warn("File not found ", ex);
      return Optional.empty();
    }

    var content = FileUtil.getContent(fileDataDto.getContent());
    FileUtil.validateChecksum(file, content);

    fileDataDto.setContent(new ByteArrayInputStream(content));
    datafactoryFileDataStorageService.save(file.getId(), fileDataDto);
    FileUtil.resetContent(fileDataDto.getContent());
    return Optional.of(fileDataDto);
  }