add Android client

1 files changed, 240 insertions, 0 deletions

diff --git a/android/VulpIRC/src/main/java/net/brokenfox/vulpirc/Connection.java b/android/VulpIRC/src/main/java/net/brokenfox/vulpirc/Connection.java
new file mode 100644
index 0000000..845717c
--- /dev/null
+++ b/android/VulpIRC/src/main/java/net/brokenfox/vulpirc/Connection.java
@@ -0,0 +1,240 @@
+package net.brokenfox.vulpirc;
+
+import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
+import java.util.ArrayList;
+
+/**
+ * Created by ninji on 1/30/14.
+ */
+public class Connection implements BaseConn.BaseConnListener {
+	private static Connection mInstance = new Connection();
+	public static Connection get() { return mInstance; }
+
+
+
+	private BaseConn mBaseConn = new BaseConn();
+	private Connection() {
+		mBaseConn.setListener(this);
+
+		statusWindow.id = -1;
+		statusWindow.title = "Status";
+	}
+
+	// Listener junk
+	public interface ConnectionListener {
+		void handleWindowsUpdated();
+	}
+
+	private ArrayList<ConnectionListener> mListeners = new ArrayList<ConnectionListener>();
+	public void registerListener(ConnectionListener l) {
+		mListeners.add(l);
+	}
+
+	public void deregisterListener(ConnectionListener l) {
+		mListeners.remove(l);
+	}
+
+
+
+	private ArrayList<LoginStateListener> mLoginStateListeners = new ArrayList<LoginStateListener>();
+	public interface LoginStateListener {
+		void handleLoginStateChanged();
+	}
+	public void registerLoginStateListener(LoginStateListener l) {
+		mLoginStateListeners.add(l);
+	}
+	public void deregisterLoginStateListener(LoginStateListener l) {
+		mLoginStateListeners.remove(l);
+	}
+
+
+	// Connection control
+	public void connect(String hostname, int port, boolean useTls, String username, String password) {
+		clearLoginError();
+		mBaseConn.initiateConnection(hostname, port, useTls, username, password);
+	}
+	public void breakConn() {
+		mBaseConn.requestDisconnection();
+	}
+	public void disconnect() {
+		mBaseConn.requestEndSession();
+	}
+
+	public BaseConn.SocketState getSocketState() {
+		return mBaseConn.getSocketState();
+	}
+	public boolean getSessionActive() {
+		return mBaseConn.getSessionActive();
+	}
+
+	private String mLoginError = null;
+	public String getLoginError() {
+		return mLoginError;
+	}
+	public void clearLoginError() {
+		mLoginError = null;
+	}
+
+
+	// BaseConn handlers
+	@Override
+	public void handleSessionStarted() {
+		statusWindow.pushMessage("Session started!");
+
+		for (LoginStateListener l : mLoginStateListeners)
+			l.handleLoginStateChanged();
+
+		windows.clear();
+		for (ConnectionListener l : mListeners)
+			l.handleWindowsUpdated();
+	}
+
+	@Override
+	public void handleSessionEnded() {
+		statusWindow.pushMessage("Session ended!");
+
+		for (LoginStateListener l : mLoginStateListeners)
+			l.handleLoginStateChanged();
+	}
+
+	@Override
+	public void handleSocketStateChanged() {
+		for (LoginStateListener l : mLoginStateListeners)
+			l.handleLoginStateChanged();
+	}
+
+	@Override
+	public void handleLoginError(String error) {
+		mLoginError = error;
+	}
+
+	@Override
+	public void handlePacketReceived(int type, byte[] data) {
+		//statusWindow.pushMessage("Packet received! " + type + " " + data.length);
+
+		ByteBuffer p = ByteBuffer.wrap(data);
+		p.order(ByteOrder.LITTLE_ENDIAN);
+
+		if (type == 1) {
+
+			statusWindow.pushMessage(Util.readStringFromBuffer(p));
+
+		} else if (type == 0x100) {
+			// Add windows!
+			int windowCount = p.getInt();
+			if (windowCount <= 0)
+				return;
+
+			for (int i = 0; i < windowCount; i++) {
+				int windowType = p.getInt();
+
+				WindowData w;
+				if (windowType == 2)
+					w = new ChannelData();
+				else
+					w = new WindowData();
+
+				w.processInitialSync(p);
+
+				windows.add(w);
+			}
+
+			for (ConnectionListener l : mListeners)
+				l.handleWindowsUpdated();
+
+		} else if (type == 0x101) {
+			// Remove windows
+			int windowCount = p.getInt();
+			if (windowCount <= 0)
+				return;
+
+			for (int i = 0; i < windowCount; i++) {
+				int windowID = p.getInt();
+				for (int j = 0; j < windows.size(); j++) {
+					if (windows.get(j).id == windowID) {
+						windows.remove(j);
+						break;
+					}
+				}
+
+				if ((mActiveWindow != null) && (mActiveWindow.id == windowID))
+					mActiveWindow = null;
+			}
+
+			for (ConnectionListener l : mListeners)
+				l.handleWindowsUpdated();
+
+		} else if (type == 0x102) {
+			// Add message to window
+			int windowID = p.getInt();
+			byte priority = p.get();
+			String message = Util.readStringFromBuffer(p);
+
+			WindowData w = findWindowByID(windowID);
+			if (w != null) {
+				w.pushMessage(message);
+
+				if (priority > w.unreadLevel && w != mActiveWindow)
+					w.setUnreadLevel(priority);
+			}
+
+		} else if (type == 0x103) {
+			// Rename window
+			int windowID = p.getInt();
+			String newTitle = Util.readStringFromBuffer(p);
+
+			WindowData w = findWindowByID(windowID);
+			if (w != null)
+				w.setTitle(newTitle);
+
+		} else if ((type >= 0x120) && (type < 0x124)) {
+			// Channel packets
+			int windowID = p.getInt();
+			WindowData w = findWindowByID(windowID);
+
+			if (w != null && w instanceof ChannelData) {
+				((ChannelData)w).processChannelPacket(type, p);
+			}
+		}
+	}
+
+	public WindowData findWindowByID(int id) {
+		if (id == -1)
+			return statusWindow;
+
+		for (WindowData w : windows)
+			if (w.id == id)
+				return w;
+
+		return null;
+	}
+
+	@Override
+	public void handleStatusMessage(String message) {
+		statusWindow.pushMessage(message);
+	}
+
+
+
+	public void sendPacket(int type, byte[] data) {
+		mBaseConn.sendPacket(type, data);
+	}
+
+
+	// Windows.
+	public WindowData statusWindow = new WindowData();
+	public ArrayList<WindowData> windows = new ArrayList<WindowData>();
+	private WindowData mActiveWindow = null;
+
+	public void notifyWindowsUpdated() {
+		for (ConnectionListener l : mListeners)
+			l.handleWindowsUpdated();
+	}
+
+	public WindowData getActiveWindow() { return mActiveWindow; }
+	public void setActiveWindow(WindowData w) {
+		mActiveWindow = w;
+		w.setUnreadLevel(0);
+	}
+}