in ddm-rrm-user-management/src/main/java/com/epam/digital/data/platform/management/users/service/UserImportServiceImpl.java [94:113]
public CephFileInfoDto getFileInfo(@NonNull SecurityContext securityContext) {
String username = userInfoService.createUsername(securityContext.getAccessToken());
try {
Set<String> keys = userImportCephService.getKeys(userImportFileBucket, StringUtils.EMPTY);
if (keys.isEmpty()) {
return new CephFileInfoDto();
}
return userImportCephService.getMetadata(userImportFileBucket, keys)
.stream()
.filter(cephObjectMetadata -> StringUtils.equals(
cephObjectMetadata.getUserMetadata().get(USERNAME), username))
.findFirst()
.map(cephObjectMetadata -> mapToDto(cephObjectMetadata.getUserMetadata()))
.orElse(new CephFileInfoDto());
} catch (Exception e) {
throw new CephInvocationException("Failed retrieve files info", e);
}
}