Voomra/Project-Mirror
0
Fork 0
Code Issues 2 Releases Activity

refactoring

Browse Source
This commit is contained in:
DmitriyMX
2022-05-07 20:04:30 +03:00
parent 07eb599f12
commit b79ae4f76b
1 changed files with 19 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
mirror-core/src/main/java/ru/di9/mirror/core/handler/MavenHandler.java
View File

@@ -23,25 +23,30 @@ public class MavenHandler {
return optionalInputStream return optionalInputStream
.map(inputStream -> new GetFileResponse(fileName, inputStream)); .map(inputStream -> new GetFileResponse(fileName, inputStream));
} else { } else {
for (ExternalMavenService externalMavenService : externalMavenServices) { return findInMirrors(path, fileName);
final String nameForStore = "/" + externalMavenService.getId() + "/" + path; }
}
optionalInputStream = minioService.get(nameForStore); private Optional<GetFileResponse> findInMirrors(String path, String fileName) {
if (optionalInputStream.isPresent()) { Optional<InputStream> result;
return optionalInputStream for (ExternalMavenService externalMavenService : externalMavenServices) {
final String nameForStore = "/" + externalMavenService.getId() + "/" + path;
result = minioService.get(nameForStore);
if (result.isPresent()) {
return result
.map(inputStream -> new GetFileResponse(fileName, inputStream));
} else {
result = externalMavenService.getFile(path);
if (result.isPresent()) {
minioService.put(nameForStore, result.get());
return minioService.get(nameForStore)
.map(inputStream -> new GetFileResponse(fileName, inputStream)); .map(inputStream -> new GetFileResponse(fileName, inputStream));
} else {
optionalInputStream = externalMavenService.getFile(path);
if (optionalInputStream.isPresent()) {
minioService.put(nameForStore, optionalInputStream.get());
return minioService.get(nameForStore)
.map(inputStream -> new GetFileResponse(fileName, inputStream));
}
} }
} }
return Optional.empty();
} }
return Optional.empty();
} }
public void putFile(String path, InputStream inputStream) { public void putFile(String path, InputStream inputStream) {