+ /**
+ * Closes the output stream of the download and moves the file to the final
+ * location.
+ *
+ * @param dccDownloadFinished
+ * The DCC download finished event
+ */
+ @Subscribe
+ public void dccDownloadFinished(DccDownloadFinished dccDownloadFinished) {
+
+ /* locate the correct download. */
+ 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.");
+ return;
+ }
+ Download download = requestedDownload.iterator().next();
+
+ try {
+ download.outputStream().close();
+ File file = new File(download.filename());
+ file.renameTo(new File(finalDirectory, download.pack().name()));
+ eventBus.post(new DownloadFinished(download));
+ dccReceivers.remove(dccDownloadFinished.dccReceiver());
+ 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);
+ }
+ }
+
+ /**
+ * Closes the output stream and notifies all listeners of the failure.
+ *
+ * @param dccDownloadFailed
+ * The DCC download failed event
+ */
+ @Subscribe
+ public void dccDownloadFailed(DccDownloadFailed dccDownloadFailed) {
+
+ /* locate the correct download. */
+ 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.");
+ return;
+ }
+ Download download = requestedDownload.iterator().next();
+
+ try {
+ Closeables.close(download.outputStream(), true);
+ eventBus.post(new DownloadFailed(download));
+ dccReceivers.remove(dccDownloadFailed.dccReceiver());
+ downloads.removeAll(download.pack().name());
+ } catch (IOException ioe1) {
+ /* swallow silently. */
+ }
+ }
+
+ @Subscribe
+ public void replyReceived(ReplyReceived replyReceived) {
+ logger.log(Level.FINEST, String.format("%s: %s", replyReceived.connection().hostname(), replyReceived.reply()));
+ }
+