Skip to content

Commit c6ffea0

Browse files
authored
Merge pull request #1181 from amvanbaren/bugfix/storage-local-usage
Always enqueue RemoveFileJobRequest
2 parents b70c680 + 0bc51cc commit c6ffea0

File tree

3 files changed

+3
-8
lines changed

3 files changed

+3
-8
lines changed

server/src/main/java/org/eclipse/openvsx/migration/GenerateKeyPairJobRequestHandler.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import org.springframework.stereotype.Component;
2121

2222
import static org.eclipse.openvsx.entities.FileResource.DOWNLOAD_SIG;
23-
import static org.eclipse.openvsx.entities.FileResource.STORAGE_LOCAL;
2423
import static org.eclipse.openvsx.entities.SignatureKeyPair.*;
2524

2625
@Component
@@ -85,8 +84,6 @@ private void enqueueCreateSignatureJob(ExtensionVersion extVersion) {
8584
}
8685

8786
private void enqueueDeleteSignatureJob(FileResource resource) {
88-
if(!resource.getStorageType().equals(STORAGE_LOCAL)) {
89-
scheduler.enqueue(new RemoveFileJobRequest(resource));
90-
}
87+
scheduler.enqueue(new RemoveFileJobRequest(resource));
9188
}
9289
}

server/src/main/java/org/eclipse/openvsx/repositories/FileResourceRepository.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,9 @@ public interface FileResourceRepository extends Repository<FileResource, Long> {
2929

3030
Streamable<FileResource> findByTypeAndStorageTypeAndNameIgnoreCaseIn(String type, String storageType, Collection<String> names);
3131

32-
void deleteByExtensionAndType(ExtensionVersion extVersion, String type);
33-
3432
void deleteByType(String type);
3533

3634
Streamable<FileResource> findByType(String type);
3735

38-
Streamable<FileResource> findByExtensionAndStorageTypeNot(ExtensionVersion extVersion, String storageType);
36+
Streamable<FileResource> findByExtension(ExtensionVersion extVersion);
3937
}

server/src/main/java/org/eclipse/openvsx/repositories/RepositoryService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ public LocalDateTime getOldestExtensionTimestamp() {
227227
}
228228

229229
public Streamable<FileResource> findFiles(ExtensionVersion extVersion) {
230-
return fileResourceRepo.findByExtensionAndStorageTypeNot(extVersion, STORAGE_LOCAL);
230+
return fileResourceRepo.findByExtension(extVersion);
231231
}
232232

233233
public void deleteFiles(ExtensionVersion extVersion) {

0 commit comments

Comments
 (0)