Voomra/KinoSearch
0
Fork 0
Code Activity

Проверку директорий осуществляет FileDownloader

Browse Source
This commit is contained in:
DmitriyMX
2017-04-07 13:00:04 +03:00
parent e0069837b3
commit 67c3f69609
3 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/kinosearch/kinosearch3/cinema/OnlinelifeScanner.java
View File

@@ -26,9 +26,6 @@ public class OnlinelifeScanner implements ScannerCinema {
this.fileDownloader = fileDownloader; this.fileDownloader = fileDownloader;
this.browser = browser; this.browser = browser;
this.saveToDir = saveToDir; this.saveToDir = saveToDir;
if (!this.saveToDir.mkdirs() && !this.saveToDir.exists()) {
throw new IllegalStateException(String.format("dir not found: '%s'", this.saveToDir.getAbsolutePath()));
}
this.repository = repository; this.repository = repository;
} }

3
src/main/java/kinosearch/kinosearch3/cinema/SeasonvarScanner.java
View File

@@ -27,9 +27,6 @@ public class SeasonvarScanner implements ScannerCinema {
this.fileDownloader = fileDownloader; this.fileDownloader = fileDownloader;
this.browser = browser; this.browser = browser;
this.saveTo = saveTo; this.saveTo = saveTo;
if (!this.saveTo.mkdirs() && !this.saveTo.exists()) {
throw new IllegalStateException(String.format("dir not found: '%s'", this.saveTo.getAbsolutePath()));
}
this.repository = repository; this.repository = repository;
} }

7
src/main/java/kinosearch/kinosearch3/spider/FileDownloaderImpl.java
View File

@@ -32,6 +32,13 @@ public class FileDownloaderImpl implements FileDownloader, Runnable {
@Override @Override
public void addFile(String url, File saveTo) { public void addFile(String url, File saveTo) {
if (!saveTo.getParentFile().exists()) {
if (!saveTo.getParentFile().mkdirs()) {
throw new IllegalStateException(String.format("dir not found: '%s'",
saveTo.getParentFile().getAbsolutePath()));
}
}
try { try {
listOfEntries.put(new AbstractMap.SimpleEntry<>(url, saveTo)); listOfEntries.put(new AbstractMap.SimpleEntry<>(url, saveTo));
} catch (InterruptedException ignore) { } catch (InterruptedException ignore) {