Mangrana
/
SonarrQueueFixer
1
0
Fork 0
Code Releases Activity

introduce FailedImportFixer

This commit is contained in:
Xavier Fontanet 2024-05-19 14:27:26 +02:00
parent a36e09ec98
commit dc73030822
2 changed files with 33 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/tv/mangrana/worker/FailedImportFixer.java Normal file
View File

@ -0,0 +1,22 @@
package tv.mangrana.worker;
import tv.mangrana.sonarr.api.schema.queue.Record;
public class FailedImportFixer {
private final String elementTitle;
private final Record queueRecord;
private FailedImportFixer(String elementTitle, Record queueRecord) {
this.elementTitle = elementTitle;
this.queueRecord = queueRecord;
}
static FailedImportFixer of(String elementTitle, Record queueRecord) {
return new FailedImportFixer(elementTitle, queueRecord);
}
void fix() {
System.out.printf("fixing: %s%n",elementTitle);
System.out.printf(">> located in: %s%n%n",queueRecord.getOutputPath());
}
}

14
src/main/java/tv/mangrana/worker/QueueFixer.java
View File

@ -33,8 +33,16 @@ public class QueueFixer {
private void fixFailedImports(List<Record> recordsWithImportFailure) { private void fixFailedImports(List<Record> recordsWithImportFailure) {
Map<String, Record> recordsByTitle = new HashMap<>(); Map<String, Record> recordsByTitle = new HashMap<>();
for (var record : recordsWithImportFailure) recordsWithImportFailure.forEach(record ->
recordsByTitle.putIfAbsent(record.getTitle(), record); recordsByTitle.putIfAbsent(record.getTitle(), record));
System.out.println(recordsByTitle.keySet());
recordsByTitle.entrySet().forEach(this::fixFailedImport);
} }
private void fixFailedImport(Map.Entry<String, Record> recordEntry) {
FailedImportFixer
.of(recordEntry.getKey(), recordEntry.getValue())
.fix();
}
} }