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);
}