X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fxdcc%2Fcore%2FCore.java;h=ff7a4e161730b75777a1a072e508bef7d369a8e9;hb=99f3d9c7383ea129c79e0d2c6b35189fa874d892;hp=98bd1588b679f1ecaa1f3427b53af2a57cccf5ec;hpb=1bfd1f9819b117291679aa292f11a84cf98f9774;p=xudocci.git diff --git a/src/main/java/net/pterodactylus/xdcc/core/Core.java b/src/main/java/net/pterodactylus/xdcc/core/Core.java index 98bd158..ff7a4e1 100644 --- a/src/main/java/net/pterodactylus/xdcc/core/Core.java +++ b/src/main/java/net/pterodactylus/xdcc/core/Core.java @@ -892,33 +892,28 @@ public class Core extends AbstractExecutionThreadService { if (!network.isPresent()) { return; } - eventBus.post(new GenericMessage("a")); Set openDownloads = downloads.values().stream() .filter(download -> download.bot().name().equalsIgnoreCase(dccSendReceived.source().nick().orNull())) .filter(download -> download.dccReceiver() == null) .collect(toSet()); - eventBus.post(new GenericMessage("b")); if (openDownloads.isEmpty()) { /* I don't think we requested this. */ eventBus.post(new GenericMessage(format("Ignoring offer for %s, no open download from %s.", dccSendReceived.filename(), dccSendReceived.source()))); return; } - eventBus.post(new GenericMessage("c")); /* check if it’s already downloading. */ if (downloads.values().stream().anyMatch(download -> Objects.equals(download.filename(), dccSendReceived.filename()) && download.dccReceiver() != null)) { eventBus.post(new GenericMessage(format("Ignoring offer for %s, it’s already being downloaded.", dccSendReceived.filename()))); return; } - eventBus.post(new GenericMessage("d")); Download download = openDownloads.stream() .filter(it -> Objects.equals(it.filename(), dccSendReceived.filename())) .findFirst() .orElse(openDownloads.iterator().next()); - eventBus.post(new GenericMessage("e")); eventBus.post(new GenericMessage(format("Downloading %s from %s as %s.", dccSendReceived.filename(), dccSendReceived.source(), download.pack().name()))); /* check if the file already exists. */