import net.pterodactylus.irc.event.ChannelMessageReceived;
import net.pterodactylus.irc.event.ClientQuit;
import net.pterodactylus.irc.event.ConnectionEstablished;
+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.NicknameChanged;
import net.pterodactylus.irc.event.PrivateMessageReceived;
import net.pterodactylus.irc.util.MessageCleaner;
import net.pterodactylus.irc.util.RandomNickname;
import net.pterodactylus.xdcc.core.event.DownloadFailed;
import net.pterodactylus.xdcc.core.event.DownloadFinished;
import net.pterodactylus.xdcc.core.event.DownloadStarted;
+import net.pterodactylus.xdcc.core.event.GenericError;
import net.pterodactylus.xdcc.core.event.GenericMessage;
import net.pterodactylus.xdcc.core.event.MessageReceived;
import net.pterodactylus.xdcc.data.Bot;
protected void startUp() {
for (Channel channel : channels) {
logger.info(String.format("Connecting to Channel %s on Network %s…", channel.name(), channel.network().name()));
- if (!networkConnections.containsKey(channel.network())) {
- /* select a random server. */
- List<Server> servers = Lists.newArrayList(channel.network().servers());
- Server server = servers.get((int) (Math.random() * servers.size()));
- Connection connection = new ConnectionBuilder(eventBus).connect(server.hostname()).port(server.unencryptedPorts().iterator().next()).build();
- connection.username(RandomNickname.get()).realName(RandomNickname.get());
- networkConnections.put(channel.network(), connection);
- connection.start();
- }
+ connectNetwork(channel.network());
}
/* notify listeners. */
}
//
+ // PRIVATE METHODS
+ //
+
+ /**
+ * Starts a new connection for the given network if no such connection exists
+ * already.
+ *
+ * @param network
+ * The network to connect to
+ */
+ private void connectNetwork(Network network) {
+ if (!networkConnections.containsKey(network)) {
+ /* select a random server. */
+ List<Server> servers = Lists.newArrayList(network.servers());
+ if (servers.isEmpty()) {
+ eventBus.post(new GenericError(String.format("Network %s does not have any servers.", network.name())));
+ return;
+ }
+ Server server = servers.get((int) (Math.random() * servers.size()));
+ Connection connection = new ConnectionBuilder(eventBus).connect(server.hostname()).port(server.unencryptedPorts().iterator().next()).build();
+ connection.username(RandomNickname.get()).realName(RandomNickname.get());
+ networkConnections.put(network, connection);
+ connection.start();
+ }
+ }
+
+ //
// EVENT HANDLERS
//
return;
}
- networkBots.remove(network.get(), channelLeft.client().nick().get());
+ 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())));
+ }
}
/**
return;
}
- networkBots.remove(network.get(), clientQuit.client().nick().get());
+ 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())));
+ }
+ }
+
+ /**
+ * If the nickname of a bit changes, remove it from the old name and store it
+ * under the new name.
+ *
+ * @param nicknameChanged
+ * The nickname changed event
+ */
+ @Subscribe
+ public void nicknameChanged(NicknameChanged nicknameChanged) {
+ Optional<Network> network = getNetwork(nicknameChanged.connection());
+ if (!network.isPresent()) {
+ return;
+ }
+
+ Bot bot = networkBots.remove(network.get(), nicknameChanged.client().nick().get());
+ if (bot == null) {
+ return;
+ }
+
+ networkBots.put(network.get(), nicknameChanged.newNickname(), bot);
}
/**
return;
}
- logger.info(String.format("Starting download of %s.", dccSendReceived.filename()));
+ /* check if the file already exists. */
+ File outputFile = new File(temporaryDirectory, dccSendReceived.filename());
+ if (outputFile.exists()) {
+ long existingFileSize = outputFile.length();
+
+ /* file already complete? */
+ if ((dccSendReceived.filesize() > -1) && (existingFileSize >= dccSendReceived.filesize())) {
+ /* file is apparently already complete. just move it. */
+ if (outputFile.renameTo(new File(finalDirectory, download.pack().name()))) {
+ eventBus.post(new GenericMessage(String.format("File %s already downloaded.", download.pack().name())));
+ } else {
+ eventBus.post(new GenericMessage(String.format("File %s already downloaded but not moved to %s.", download.pack().name(), finalDirectory)));
+ }
+
+ /* remove download. */
+ downloads.remove(download);
+ return;
+ }
+
+ /* file not complete yet, DCC resume it. */
+ try {
+ download.remoteAddress(dccSendReceived.inetAddress()).filesize(dccSendReceived.filesize());
+ dccSendReceived.connection().sendDccResume(dccSendReceived.source().nick().get(), dccSendReceived.filename(), dccSendReceived.port(), existingFileSize);
+ } catch (IOException ioe1) {
+ eventBus.post(new GenericError(String.format("Could not send DCC RESUME %s to %s (%s).", dccSendReceived.filename(), dccSendReceived.source().nick().get(), ioe1.getMessage())));
+ }
+
+ return;
+ }
+
+ /* file does not exist, start the download. */
try {
- File outputFile = new File(temporaryDirectory, dccSendReceived.filename());
OutputStream fileOutputStream = new FileOutputStream(outputFile);
DccReceiver dccReceiver = new DccReceiver(eventBus, dccSendReceived.inetAddress(), dccSendReceived.port(), dccSendReceived.filename(), dccSendReceived.filesize(), fileOutputStream);
download.filename(outputFile.getPath()).outputStream(fileOutputStream).dccReceiver(dccReceiver);
dccReceiver.start();
eventBus.post(new DownloadStarted(download));
} catch (FileNotFoundException fnfe1) {
- logger.log(Level.WARNING, "Could not open file for download!", fnfe1);
+ eventBus.post(new GenericError(String.format("Could not start download of %s from %s (%s).", dccSendReceived.filename(), dccSendReceived.source().nick().get(), fnfe1.getMessage())));
+ }
+ }
+
+ @Subscribe
+ public void dccAcceptReceived(DccAcceptReceived dccAcceptReceived) {
+ Optional<Network> network = getNetwork(dccAcceptReceived.connection());
+ if (!network.isPresent()) {
+ return;
+ }
+
+ Download download = downloads.get(dccAcceptReceived.filename());
+ if (download == null) {
+ /* unknown download, ignore. */
+ return;
+ }
+
+ try {
+ 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()));
+
+ downloads.remove(download);
+ return;
+ }
+ OutputStream outputStream = new FileOutputStream(outputFile, true);
+ DccReceiver dccReceiver = new DccReceiver(eventBus, download.remoteAddress(), dccAcceptReceived.port(), dccAcceptReceived.filename(), dccAcceptReceived.position(), download.filesize(), outputStream);
+ download.filename(outputFile.getPath()).outputStream(outputStream).dccReceiver(dccReceiver);
+ dccReceivers.add(dccReceiver);
+ dccReceiver.start();
+ eventBus.post(new DownloadStarted(download));
+ } catch (FileNotFoundException fnfe1) {
}
}