import java.io.OutputStream;
import java.util.Collection;
import java.util.Collections;
+import java.util.Iterator;
import java.util.List;
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.event.ChannelLeft;
import net.pterodactylus.irc.event.ChannelMessageReceived;
import net.pterodactylus.irc.event.ClientQuit;
+import net.pterodactylus.irc.event.ConnectionClosed;
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.PrivateNoticeReceived;
import net.pterodactylus.irc.event.PrivateMessageReceived;
import net.pterodactylus.irc.util.MessageCleaner;
import net.pterodactylus.irc.util.RandomNickname;
import com.google.common.base.Optional;
import com.google.common.collect.HashBasedTable;
+import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
import com.google.common.io.Closeables;
-import com.google.common.util.concurrent.AbstractIdleService;
+import com.google.common.util.concurrent.AbstractExecutionThreadService;
import com.google.inject.Inject;
/**
*
* @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
*/
-public class Core extends AbstractIdleService {
+public class Core extends AbstractExecutionThreadService {
/** The logger. */
private static final Logger logger = Logger.getLogger(Core.class.getName());
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. */
}
@Override
+ protected void run() throws Exception {
+ while (isRunning()) {
+ try {
+ Thread.sleep(TimeUnit.MINUTES.toMillis(1));
+ } catch (InterruptedException ie1) {
+ /* ignore. */
+ }
+
+ /* find channels that should be monitored but are not. */
+ for (Channel channel : channels) {
+ if (joinedChannels.contains(channel)) {
+ continue;
+ }
+
+ connectNetwork(channel.network());
+ 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());
+ }
+ }
+ }
+ }
+
+ @Override
protected void shutDown() {
}
//
+ // 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
//
}
/**
+ * Remove all data stored for a network if the connection is closed.
+ *
+ * @param connectionClosed
+ * The connection closed event
+ */
+ @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)));
+
+ /* now remove the network. */
+ networkConnections.remove(network.get());
+ }
+
+ /**
* Shows a message when a channel was joined by us.
*
* @param channelJoined
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())));
+ }
}
/**
}
/**
+ * 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);
+ }
+
+ /**
* If a message on a channel is received, it is parsed for pack information
* with is then added to a bot.
*
}
/**
+ * Sends a message to all console when a notice was received.
+ *
+ * @param privateNoticeReceived
+ * The notice received event
+ */
+ @Subscribe
+ public void privateNoticeReceived(PrivateNoticeReceived privateNoticeReceived) {
+ Optional<Network> network = getNetwork(privateNoticeReceived.connection());
+ if (!network.isPresent()) {
+ return;
+ }
+
+ eventBus.post(new GenericMessage(String.format("Notice from %s (%s): %s", privateNoticeReceived.reply().source(), network.get(), privateNoticeReceived.text())));
+ }
+
+ /**
* Starts a DCC download.
*
* @param dccSendReceived
}
/* remove download. */
- downloads.remove(download);
+ downloads.remove(download.pack().name());
return;
}
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);
+ downloads.remove(download.pack().name());
return;
}
OutputStream outputStream = new FileOutputStream(outputFile, true);
file.renameTo(new File(finalDirectory, download.pack().name()));
eventBus.post(new DownloadFinished(download));
dccReceivers.remove(dccDownloadFinished.dccReceiver());
- downloads.remove(download);
+ downloads.remove(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);
Closeables.close(download.outputStream(), true);
eventBus.post(new DownloadFailed(download));
dccReceivers.remove(dccDownloadFailed.dccReceiver());
- downloads.remove(download);
+ downloads.remove(download.pack().name());
} catch (IOException ioe1) {
/* swallow silently. */
}
projects / xudocci.git / blobdiff