X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fxdcc%2Fui%2Fstdin%2FCommandReader.java;h=56bfd33b0e02a6b1a59ee629309375f949e4d9a5;hb=7bbf28951def7e9124fb691d989de0131037b766;hp=381c519948e10b130fd0bb29bf221e2fc9e4cbd3;hpb=d616b16a772b4ac0c2bf8709e5f895f609581f84;p=xudocci.git

diff --git a/src/main/java/net/pterodactylus/xdcc/ui/stdin/CommandReader.java b/src/main/java/net/pterodactylus/xdcc/ui/stdin/CommandReader.java
index 381c519..56bfd33 100644
--- a/src/main/java/net/pterodactylus/xdcc/ui/stdin/CommandReader.java
+++ b/src/main/java/net/pterodactylus/xdcc/ui/stdin/CommandReader.java
@@ -39,6 +39,7 @@ import net.pterodactylus.xdcc.core.event.DownloadStarted;
 import net.pterodactylus.xdcc.core.event.GenericMessage;
 import net.pterodactylus.xdcc.core.event.MessageReceived;
 import net.pterodactylus.xdcc.data.Download;
+import net.pterodactylus.xdcc.util.io.DuplicateLineSuppressingWriter;
 
 import com.google.common.base.Joiner;
 import com.google.common.base.Optional;
@@ -62,6 +63,7 @@ public class CommandReader extends AbstractExecutionThreadService {
 
 	/** The writer to write the results to. */
 	private final Writer writer;
+	private final Collection<Download> failedDownloads;
 
 	/**
 	 * Creates a new command reader.
@@ -73,9 +75,10 @@ public class CommandReader extends AbstractExecutionThreadService {
 	 * @param writer
 	 * 		The write to write results to
 	 */
-	public CommandReader(Core core, Reader reader, Writer writer) {
+	public CommandReader(Core core, Reader reader, Writer writer, Collection<Download> failedDownloads) {
 		this.reader = new BufferedReader(reader);
-		this.writer = writer;
+		this.writer = new DuplicateLineSuppressingWriter(writer);
+		this.failedDownloads = failedDownloads;
 
 		/* initialize commands. */
 		ImmutableList.Builder<Command> commandBuilder = ImmutableList.builder();
@@ -86,6 +89,9 @@ public class CommandReader extends AbstractExecutionThreadService {
 		commandBuilder.add(new ListConnectionsCommand(core));
 		commandBuilder.add(new AbortDownloadCommand(core));
 		commandBuilder.add(new DisconnectCommand(core));
+		commandBuilder.add(new FailedDownloadsCommand(failedDownloads));
+		commandBuilder.add(new RestartCommand(core, failedDownloads));
+		commandBuilder.add(new ResearchCommand(core));
 		commands = commandBuilder.build();
 	}
 
@@ -165,6 +171,7 @@ public class CommandReader extends AbstractExecutionThreadService {
 	@Subscribe
 	public void downloadFailed(DownloadFailed downloadFailed) {
 		Download download = downloadFailed.download();
+		failedDownloads.add(download);
 		try {
 			writeLine(red(String.format("Download of %s (from %s, %s) has failed at %.1f%% and %s/s.", download.filename(), download.bot().name(), download.bot().network().name(), download.dccReceiver().progress() * 100.0 / download.dccReceiver().size(), f(download.dccReceiver().overallRate()))));
 		} catch (IOException ioe1) {