Fix constructor.

[xudocci.git] / src / main / java / net / pterodactylus / xdcc / core / Core.java

diff --git a/src/main/java/net/pterodactylus/xdcc/core/Core.java b/src/main/java/net/pterodactylus/xdcc/core/Core.java
index 607246c..39dc3ad 100644 (file)
--- a/src/main/java/net/pterodactylus/xdcc/core/Core.java
+++ b/src/main/java/net/pterodactylus/xdcc/core/Core.java
@@ -220,6 +220,25 @@ public class Core extends AbstractExecutionThreadService {
                        return;
                }
 
+               /* check if we are already downloading the file? */
+               if (downloads.containsKey(pack.name())) {
+                       Collection<Download> packDownloads = downloads.get(pack.name());
+                       Collection<Download> runningDownloads = FluentIterable.from(packDownloads).filter(FILTER_RUNNING).toSet();
+                       if (!runningDownloads.isEmpty()) {
+                               Download download = runningDownloads.iterator().next();
+                               eventBus.post(new GenericMessage(String.format("File %s is already downloading from %s (%s).", pack.name(), download.bot().name(), download.bot().network().name())));
+                               return;
+                       }
+                       StringBuilder bots = new StringBuilder();
+                       for (Download download : packDownloads) {
+                               if (bots.length() > 0) {
+                                       bots.append(", ");
+                               }
+                               bots.append(download.bot().name()).append(" (").append(download.bot().network().name()).append(')');
+                       }
+                       eventBus.post(new GenericMessage(String.format("File %s is already requested from %d bots (%s).", pack.name(), packDownloads.size(), bots.toString())));
+               }
+
                Download download = new Download(bot, pack);
                downloads.put(pack.name(), download);
 
@@ -515,7 +534,7 @@ public class Core extends AbstractExecutionThreadService {
                Bot bot;
                synchronized (networkBots) {
                        if (!networkBots.contains(network.get(), channelMessageReceived.source().nick().get())) {
-                               bot = new Bot(network.get()).name(channelMessageReceived.source().nick().get());
+                               bot = new Bot(network.get(), channelMessageReceived.source().nick().get());
                                networkBots.put(network.get(), channelMessageReceived.source().nick().get(), bot);
                                eventBus.post(new BotAdded(bot));
                        } else {