package net.pterodactylus.xdcc.core;
+import static java.lang.String.format;
+import static net.pterodactylus.irc.util.MessageCleaner.getDefaultInstance;
+import static net.pterodactylus.xdcc.data.Channel.TO_NETWORK;
import static net.pterodactylus.xdcc.data.Download.FILTER_RUNNING;
import java.io.File;
import java.util.Map;
import java.util.Map.Entry;
import java.util.concurrent.TimeUnit;
-import java.util.logging.Level;
-import java.util.logging.Logger;
import net.pterodactylus.irc.Connection;
import net.pterodactylus.irc.ConnectionBuilder;
import net.pterodactylus.irc.event.DccDownloadFailed;
import net.pterodactylus.irc.event.DccDownloadFinished;
import net.pterodactylus.irc.event.DccSendReceived;
+import net.pterodactylus.irc.event.KickedFromChannel;
import net.pterodactylus.irc.event.NicknameChanged;
import net.pterodactylus.irc.event.PrivateMessageReceived;
import net.pterodactylus.irc.event.PrivateNoticeReceived;
import net.pterodactylus.irc.event.ReplyReceived;
-import net.pterodactylus.irc.util.MessageCleaner;
import net.pterodactylus.irc.util.RandomNickname;
import net.pterodactylus.xdcc.core.event.BotAdded;
import net.pterodactylus.xdcc.core.event.CoreStarted;
import net.pterodactylus.xdcc.data.Pack;
import net.pterodactylus.xdcc.data.Server;
+import com.google.common.base.Function;
import com.google.common.base.Optional;
import com.google.common.base.Predicate;
import com.google.common.collect.FluentIterable;
import com.google.common.io.Closeables;
import com.google.common.util.concurrent.AbstractExecutionThreadService;
import com.google.inject.Inject;
+import org.apache.log4j.Logger;
/**
* The core of XDCC Downloader.
}
/**
+ * Returns all defined networks.
+ *
+ * @return All defined networks
+ */
+ public Collection<Network> networks() {
+ return FluentIterable.from(channels).transform(TO_NETWORK).toSet();
+ }
+
+ /**
+ * Returns all connected networks.
+ *
+ * @return All connected networks
+ */
+ public Collection<Network> connectedNetworks() {
+ return Lists.newArrayList(Optional.presentInstances(FluentIterable.from(networkConnections.values()).transform(new Function<Connection, Optional<Network>>() {
+ @Override
+ public Optional<Network> apply(Connection connection) {
+ return getNetwork(connection);
+ }
+ })));
+ }
+
+ /**
* Returns all configured channels. Due to various circumstances, configured
* channels might not actually be joined.
*
try {
connection.sendMessage(bot.name(), "XDCC SEND " + pack.id());
} catch (IOException ioe1) {
- logger.log(Level.WARNING, "Could not send message to bot!", ioe1);
+ logger.warn("Could not send message to bot!", ioe1);
+ }
+ }
+
+ /**
+ * Cancels the download of the given pack from the given bot.
+ *
+ * @param bot
+ * The bot the pack is being downloaded from
+ * @param pack
+ * The pack being downloaded
+ */
+ public void cancelDownload(Bot bot, Pack pack) {
+ Optional<Download> download = getDownload(pack, bot);
+ if (!download.isPresent()) {
+ return;
+ }
+
+ /* get connection. */
+ Connection connection = networkConnections.get(bot.network());
+ if (connection == null) {
+ /* request for unknown network? */
+ return;
+ }
+
+ /* stop the DCC receiver. */
+ if (download.get().dccReceiver() != null) {
+ download.get().dccReceiver().stop();
+ } else {
+ /* remove download if it hasn’t started yet. */
+ downloads.remove(pack.name(), download.get());
+ }
+
+ /* remove the request from the bot, too. */
+ try {
+ connection.sendMessage(bot.name(), String.format("XDCC %s", (download.get().dccReceiver() != null) ? "CANCEL" : "REMOVE"));
+ } catch (IOException ioe1) {
+ logger.warn(String.format("Could not cancel DCC from %s (%s)!", bot.name(), bot.network().name()), ioe1);
}
}
Connection connection = networkConnections.get(channel.network());
if (connection.established()) {
eventBus.post(new GenericMessage(String.format("Trying to join %s on %s.", channel.name(), channel.network().name())));
- connection.joinChannel(channel.name());
+ try {
+ connection.joinChannel(channel.name());
+ } catch (IOException ioe1) {
+ eventBus.post(new GenericMessage(String.format("Could not join %s on %s.", channel.name(), channel.network().name())));
+ }
}
}
}
/* found network? */
if (!network.isPresent()) {
+ eventBus.post(new GenericMessage(String.format("Connected to unknown network: %s", connectionEstablished.connection().hostname())));
return;
}
+ eventBus.post(new GenericMessage(String.format("Connected to network %s.", network.get().name())));
+
/* join all channels on this network. */
for (Channel channel : channels) {
if (channel.network().equals(network.get())) {
try {
+ eventBus.post(new GenericMessage(String.format("Trying to join %s on %s...", channel.name(), network.get().name())));
connectionEstablished.connection().joinChannel(channel.name());
} catch (IOException ioe1) {
- logger.log(Level.WARNING, String.format("Could not join %s on %s!", channel.name(), network.get().name()), ioe1);
+ logger.warn(String.format("Could not join %s on %s!", channel.name(), network.get().name()), ioe1);
}
}
}
* @param connectionFailed
* The connection failed event
*/
+ @Subscribe
public void connectionFailed(ConnectionFailed connectionFailed) {
removeConnection(connectionFailed.connection());
}
}
}
+ @Subscribe
+ public void channelNotJoined(ChannelNotJoined channelNotJoined) {
+ Optional<Network> network = getNetwork(channelNotJoined.connection());
+ if (!network.isPresent()) {
+ return;
+ }
+
+ eventBus.post(new GenericMessage(
+ format("Could not join %s/%s: %s", channelNotJoined.channel(),
+ network.get(), channelNotJoined.reason())));
+ }
+
/**
* Removes bots that leave a channel, or channels when it’s us that’s leaving.
*
return;
}
- Bot removedBot = networkBots.remove(network.get(), channelLeft.client().nick().get());
- if (removedBot != null) {
- eventBus.post(new GenericMessage(String.format("Bot %s (%s) was removed, %d packs removed.", removedBot.name(), removedBot.network().name(), removedBot.packs().size())));
+ networkBots.remove(network.get(), channelLeft.client().nick().get());
+ }
+
+ @Subscribe
+ public void kickedFromChannel(KickedFromChannel kickedFromChannel) {
+ Optional<Network> network = getNetwork(kickedFromChannel.connection());
+ if (!network.isPresent()) {
+ return;
+ }
+
+ /* have we been kicked? */
+ if (nicknameMatchesConnection(kickedFromChannel.connection(), kickedFromChannel.kickee())) {
+ eventBus.post(new GenericMessage(format(
+ "Kicked from %s/%s by %s: %s",
+ kickedFromChannel.channel(), network.get(),
+ kickedFromChannel.kicker(),
+ kickedFromChannel.reason().or("<unknown>")
+ )));
}
}
+ private boolean nicknameMatchesConnection(Connection connection, String nickname) {
+ return connection.nickname().equalsIgnoreCase(nickname);
+ }
+
/**
* Removes a client (which may be a bot) from the table of known bots.
*
return;
}
- Bot removedBot = networkBots.remove(network.get(), clientQuit.client().nick().get());
- if (removedBot != null) {
- eventBus.post(new GenericMessage(String.format("Bot %s (%s) was removed, %d packs removed.", removedBot.name(), removedBot.network().name(), removedBot.packs().size())));
- }
+ networkBots.remove(network.get(), clientQuit.client().nick().get());
}
/**
*/
@Subscribe
public void channelMessageReceived(ChannelMessageReceived channelMessageReceived) {
- String message = MessageCleaner.getDefaultInstance().clean(channelMessageReceived.message());
+ String message = getDefaultInstance().clean(channelMessageReceived.message());
if (!message.startsWith("#")) {
/* most probably not a pack announcement. */
return;
/* add pack. */
bot.addPack(pack.get());
- logger.fine(String.format("Bot %s now has %d packs.", bot, bot.packs().size()));
+ logger.debug(String.format("Bot %s now has %d packs.", bot, bot.packs().size()));
}
/**
File outputFile = new File(temporaryDirectory, dccAcceptReceived.filename());
if (outputFile.length() != dccAcceptReceived.position()) {
eventBus.post(new GenericError(String.format("Download %s from %s does not start at the right position!")));
- logger.log(Level.WARNING, String.format("Download %s from %s: have %d bytes but wants to resume from %d!", dccAcceptReceived.filename(), dccAcceptReceived.source(), outputFile.length(), dccAcceptReceived.position()));
+ logger.warn(String.format("Download %s from %s: have %d bytes but wants to resume from %d!", dccAcceptReceived.filename(), dccAcceptReceived.source(), outputFile.length(), dccAcceptReceived.position()));
downloads.removeAll(download.pack().name());
return;
Collection<Download> requestedDownload = FluentIterable.from(downloads.get(dccDownloadFinished.dccReceiver().filename())).filter(FILTER_RUNNING).toSet();
if (requestedDownload.isEmpty()) {
/* this seems wrong. */
- logger.warning("Download finished but could not be located.");
+ logger.warn("Download finished but could not be located.");
return;
}
Download download = requestedDownload.iterator().next();
downloads.removeAll(download.pack().name());
} catch (IOException ioe1) {
/* TODO - handle all the errors. */
- logger.log(Level.WARNING, String.format("Could not move file %s to directory %s.", download.filename(), finalDirectory), ioe1);
+ logger.warn(String.format("Could not move file %s to directory %s.", download.filename(), finalDirectory), ioe1);
}
}
Collection<Download> requestedDownload = FluentIterable.from(downloads.get(dccDownloadFailed.dccReceiver().filename())).filter(FILTER_RUNNING).toSet();
if (requestedDownload.isEmpty()) {
/* this seems wrong. */
- logger.warning("Download finished but could not be located.");
+ logger.warn("Download finished but could not be located.");
return;
}
Download download = requestedDownload.iterator().next();
@Subscribe
public void replyReceived(ReplyReceived replyReceived) {
- logger.log(Level.FINEST, String.format("%s: %s", replyReceived.connection().hostname(), replyReceived.reply()));
+ logger.trace(String.format("%s: %s", replyReceived.connection().hostname(), replyReceived.reply()));
}
//
//
/**
+ * Returns the download of the given pack from the given bot.
+ *
+ * @param pack
+ * The pack being downloaded
+ * @param bot
+ * The bot the pack is being downloaded from
+ * @return The download, or {@link Optional#absent()} if the download could not
+ * be found
+ */
+ private Optional<Download> getDownload(Pack pack, Bot bot) {
+ if (!downloads.containsKey(pack.name())) {
+ return Optional.absent();
+ }
+ for (Download download : Lists.newArrayList(downloads.get(pack.name()))) {
+ if (download.bot().equals(bot)) {
+ return Optional.of(download);
+ }
+ }
+ return Optional.absent();
+ }
+
+ /**
* Searches all current connections for the given connection, returning the
* associated network.
*
projects / xudocci.git / blobdiff