booklore-app/booklore
1
0
Fork 0
mirror of https://github.com/booklore-app/booklore.git synced 2026-02-18 00:17:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

Unregister paths on library delete

Browse Source
This commit is contained in:
aditya.chandel
2025-02-13 10:14:19 -07:00
parent 7378f25467
commit 4916ce0d9b
2 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
booklore-api/src/main/java/com/adityachandel/booklore/service/LibraryService.java
View File

@@ -6,7 +6,6 @@ import com.adityachandel.booklore.mapper.LibraryMapper;
import com.adityachandel.booklore.model.dto.Book;
import com.adityachandel.booklore.model.dto.Library;
import com.adityachandel.booklore.model.dto.LibraryPath;
import com.adityachandel.booklore.model.dto.Sort;
import com.adityachandel.booklore.model.dto.request.CreateLibraryRequest;
import com.adityachandel.booklore.model.entity.BookEntity;
import com.adityachandel.booklore.model.entity.LibraryEntity;
@@ -31,7 +30,6 @@ import java.util.Collections;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@Slf4j
@Service
@@ -108,7 +106,7 @@ public class LibraryService {
if (request.isWatch()) {
for (LibraryPathEntity pathEntity : savedLibrary.getLibraryPaths()) {
Path path = Paths.get(pathEntity.getPath());
monitoringService.registerPathWithLibraryId(path, libraryId);
monitoringService.registerPath(path, libraryId);
}
} else {
for (LibraryPathEntity pathEntity : savedLibrary.getLibraryPaths()) {
@@ -152,7 +150,7 @@ public class LibraryService {
if (request.isWatch()) {
for (LibraryPathEntity pathEntity : libraryEntity.getLibraryPaths()) {
Path path = Paths.get(pathEntity.getPath());
monitoringService.registerPathWithLibraryId(path, libraryId);
monitoringService.registerPath(path, libraryId);
}
}
@@ -196,10 +194,10 @@ public class LibraryService {
public void deleteLibrary(long id) {
LibraryEntity library = libraryRepository.findById(id).orElseThrow(() -> ApiError.LIBRARY_NOT_FOUND.createException(id));
/*library.getLibraryPaths().forEach(libraryPath -> {
library.getLibraryPaths().forEach(libraryPath -> {
Path path = Paths.get(libraryPath.getPath());
monitoringService.unregisterPath(path.toString());
});*/
});
Set<Long> bookIds = library.getBookEntities().stream().map(BookEntity::getId).collect(Collectors.toSet());
fileProcessingUtils.deleteBookCovers(bookIds);
libraryRepository.deleteById(id);

4
booklore-api/src/main/java/com/adityachandel/booklore/service/monitoring/MonitoringService.java
View File

@@ -45,14 +45,14 @@ public class MonitoringService {
library.getPaths().forEach(libraryPath -> {
Path path = Paths.get(libraryPath.getPath());
if (Files.isDirectory(path)) {
registerPathWithLibraryId(path, library.getId());
registerPath(path, library.getId());
}
});
});
log.info("Registered libraries for monitoring: {}", libraries.size());
}
public synchronized void registerPathWithLibraryId(Path path, Long libraryId) {
public synchronized void registerPath(Path path, Long libraryId) {
try {
if (monitoredPaths.add(path)) {
path.register(watchService,