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.ClientQuit;
import net.pterodactylus.irc.event.ConnectionClosed;
import net.pterodactylus.irc.event.ConnectionEstablished;
+import net.pterodactylus.irc.event.ConnectionFailed;
import net.pterodactylus.irc.event.DccAcceptReceived;
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.util.MessageCleaner;
+import net.pterodactylus.irc.event.ReplyReceived;
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 currently known connections.
+ *
+ * @return All currently known connections
+ */
+ public Collection<Connection> connections() {
+ return networkConnections.values();
+ }
+
+ /**
+ * 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);
+ }
+ }
+
+ /**
+ * Closes the given connection.
+ *
+ * @param connection
+ * The connection to close
+ */
+ public void closeConnection(Connection connection) {
+ try {
+ connection.close();
+ } catch (IOException ioe1) {
+ /* TODO */
}
}
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())));
+ }
}
}
}
}
}
+ /**
+ * Removes the given connection and all its channels and bots.
+ *
+ * @param connection
+ * The connection to remove
+ */
+ private void removeConnection(Connection connection) {
+ Optional<Network> network = getNetwork(connection);
+ if (!network.isPresent()) {
+ return;
+ }
+
+ /* find all channels that need to be removed. */
+ for (Collection<Channel> channels : ImmutableList.of(joinedChannels, extraChannels)) {
+ for (Iterator<Channel> channelIterator = channels.iterator(); channelIterator.hasNext(); ) {
+ Channel joinedChannel = channelIterator.next();
+ if (!joinedChannel.network().equals(network.get())) {
+ continue;
+ }
+
+ channelIterator.remove();
+ }
+ }
+
+ /* now remove all bots for that network. */
+ Map<String, Bot> bots = networkBots.row(network.get());
+ int botCount = bots.size();
+ int packCount = 0;
+ for (Bot bot : bots.values()) {
+ packCount += bot.packs().size();
+ }
+ bots.clear();
+ eventBus.post(new GenericMessage(String.format("Network %s disconnected, %d bots removed, %d packs removed.", network.get().name(), botCount, packCount)));
+
+ /* now remove the network. */
+ networkConnections.remove(network.get());
+ }
+
//
// EVENT HANDLERS
//
/* 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);
}
}
}
*/
@Subscribe
public void connectionClosed(ConnectionClosed connectionClosed) {
- Optional<Network> network = getNetwork(connectionClosed.connection());
- if (!network.isPresent()) {
- return;
- }
-
- /* find all channels that need to be removed. */
- for (Collection channels : ImmutableList.of(joinedChannels, extraChannels)) {
- for (Iterator<Channel> channelIterator = channels.iterator(); channelIterator.hasNext(); ) {
- Channel joinedChannel = channelIterator.next();
- if (!joinedChannel.network().equals(network.get())) {
- continue;
- }
-
- channelIterator.remove();
- }
- }
-
- /* now remove all bots for that network. */
- Map<String, Bot> bots = networkBots.row(network.get());
- int botCount = bots.size();
- int packCount = 0;
- for (Bot bot : bots.values()) {
- packCount += bot.packs().size();
- }
- bots.clear();
- eventBus.post(new GenericMessage(String.format("Network %s disconnected, %d bots removed, %d packs removed.", network.get().name(), botCount, packCount)));
+ removeConnection(connectionClosed.connection());
+ }
- /* now remove the network. */
- networkConnections.remove(network.get());
+ /**
+ * Remove all data stored for a network if the connection fails.
+ *
+ * @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.trace(String.format("%s: %s", replyReceived.connection().hostname(), replyReceived.reply()));
+ }
+
//
// PRIVATE METHODS
//
/**
+ * 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