dev add cold storage
Test Workflow / test (push) Has been cancelled

This commit is contained in:
2026-04-23 14:11:05 +07:00
parent 04506f4b42
commit 71aa8ee01a
3 changed files with 6 additions and 9 deletions
@@ -261,7 +261,6 @@ public class ApiController {
}
return ResponseEntity.ok(response);
} catch(IllegalArgumentException e) {
log.error("Error with file extensions : {}", e.getMessage(), e);
return ResponseEntity.ok().body(new BaseResponse(MessageCode.FILE_FOR_SEARCH_NOT_VALID.getCode(),
@@ -287,7 +286,7 @@ public class ApiController {
return results;
}
File file = new File(fileEntity.getFilePath());
File file = cloudStorageService.readFileFromStorageByPath(fileEntity.getFilePath());
FileProtector.Type type = "document".equals(fileEntity.getMimeType()) ?
FileProtector.Type.DOC : FileProtector.Type.AUDIO;
@@ -124,7 +124,9 @@ public class FileSimilarityService {
List<Long> userIds = new ArrayList<>();
if (company != null) {
userIds.addAll(company.getUsers().stream().map(User::getId).toList());
userIds.addAll(company.getUsers().stream()
.map(User::getId)
.toList());
} else {
userIds.add(userId);
}
@@ -132,16 +134,10 @@ public class FileSimilarityService {
List<FileEntity> fileEntityList = fileEntityRepository.findByMimeTypeAndUserIds(mimeType, userIds);
for (FileEntity file : fileEntityList) {
// if (file.getProtectedFilePath() == null) continue;
// File existingFile = cloudStorageService.readFileFromStorageByPath(file.getFilePath());
// File newFile = new File(path);
// if (existingFile.length() == newFile.length()) {
if (!file.getStatus().name().equals(FileStatus.TEMP.name()) &&
calculateFileHash(file.getFilePath(), true).equals(hash)) {
return file;
}
// }
}
return null;
@@ -217,6 +213,7 @@ public class FileSimilarityService {
}
byte[] hashBytes = digest.digest();
return Base64.getEncoder().encodeToString(hashBytes);
}
@@ -198,6 +198,7 @@ public class CloudStorageService {
try {
ResponseBytes<GetObjectResponse> responseBytes = s3Client.getObjectAsBytes(objectRequest);
return responseBytes.asByteArray();
} catch (Exception e) {
log.error("Failed to read file from S3: {}", filePath, e);