1 files changed, 114 insertions, 0 deletions
diff --git a/src/jrummikub/control/network/ConnectionControl.java b/src/jrummikub/control/network/ConnectionControl.java
new file mode 100644
index 0000000..9777853
--- /dev/null
+++ b/src/jrummikub/control/network/ConnectionControl.java
@@ -0,0 +1,114 @@
+package jrummikub.control.network;
+
+import javax.swing.SwingUtilities;
+
+import jrummikub.util.Event;
+import jrummikub.util.IEvent;
+import jrummikub.util.LoginData;
+
+import org.jivesoftware.smack.Connection;
+import org.jivesoftware.smack.XMPPConnection;
+import org.jivesoftware.smack.XMPPException;
+import org.jivesoftware.smack.packet.XMPPError;
+import org.jivesoftware.smack.packet.XMPPError.Type;
+import org.jivesoftware.smackx.muc.MultiUserChat;
+
+class ConnectionControl {
+	private final LoginData loginData;
+	private volatile Connection connection;
+	private volatile MultiUserChat muc;
+
+	private Event connectedEvent = new Event();
+	private Event connectionFailedEvent = new Event();
+
+	ConnectionControl(LoginData loginData) {
+		this.loginData = loginData;
+	}
+
+	void connect() {
+		new Thread(new ConnectRunner()).start();
+	}
+
+	void disconnect() {
+		connectedEvent = new Event();
+		connectionFailedEvent = new Event();
+		new Thread(new DisconnectRunner()).start();
+
+	}
+
+	IEvent getConnectedEvent() {
+		return connectedEvent;
+	}
+
+	IEvent getConnectionFailedEvent() {
+		return connectionFailedEvent;
+	}
+
+	private static void emitLater(final Event event) {
+		SwingUtilities.invokeLater(new Runnable() {
+			@Override
+			public void run() {
+				event.emit();
+			}
+		});
+	}
+
+	private class ConnectRunner implements Runnable {
+		@Override
+		public void run() {
+			synchronized (ConnectionControl.this) {
+				connection = new XMPPConnection(loginData.getServerName());
+				try {
+					connection.connect();
+					connection.login(loginData.getUserName(),
+							loginData.getPassword(), "JRummikub");
+					muc = new MultiUserChat(connection,
+							loginData.getChannelName());
+
+					String nickname = loginData.getUserName();
+					// Loop until a unused nickname is found
+					while (true) {
+						try {
+							muc.join(nickname);
+							break; // Join was successful, break the loop
+						} catch (XMPPException e) {
+							XMPPError error = e.getXMPPError();
+							if (error.getType() == Type.CANCEL
+									&& error.getCode() == 409) {
+								// There was a conflict, try again with another
+								// nickname
+								nickname += "_";
+								continue;
+							} else {
+								// An unknown error has occurred, cancel connect
+								throw e;
+							}
+						}
+					}
+
+					emitLater(connectedEvent);
+				} catch (XMPPException e) {
+					connection.disconnect();
+					connection = null;
+
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+
+					emitLater(connectionFailedEvent);
+				}
+			}
+		}
+	}
+
+	private class DisconnectRunner implements Runnable {
+		@Override
+		public void run() {
+			synchronized (ConnectionControl.this) {
+				if (connection != null) {
+					connection.disconnect();
+					connection = null;
+				}
+			}
+		}
+	}
+}