ChatClient.java

package assignment7;

import java.io.*;
import java.net.*;
import javafx.collections.FXCollections;
import javafx.collections.ObservableList;

public class ChatClient {
	public ObjectOutputStream writer;
	public ObjectInputStream objectInput;
	
	public Thread clientReaderThread;
	public Thread chatReaderThread;
	
	// for updating clientLobby
	public ObservableList<String> clientList = FXCollections.observableArrayList();
	public ObservableList<String> chatList = FXCollections.observableArrayList();
	
//	public ArrayList<String> activeChats = new ArrayList<String>();
	public ClientMain client;
	public int clientNum;
	
	public ChatClient(ClientMain client) {
		this.client = client;
		try {
			this.run();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public void run() throws Exception {
		setUpNetworking();
	}

	@SuppressWarnings("resource")
	private void setUpNetworking() throws Exception {		
		// establish connection with server
//		Socket sock = new Socket("169.254.61.84", 4242);
		Socket sock = new Socket("ec2-54-149-23-179.us-west-2.compute.amazonaws.com", 4242);
//		Socket sock = new Socket("ec2-54-187-25-160.us-west-2.compute.amazonaws.com", 4242);
		
		objectInput = new ObjectInputStream(sock.getInputStream());
		
		// writes output to socket from client -> server
		writer = new ObjectOutputStream(sock.getOutputStream());
		
		initMessage();
		
		// reads input from socket from server -> client
		clientReaderThread = new Thread(new ListUpdater(clientList));
		clientReaderThread.start();
		
		
		
		System.out.println("networking established");
	}
	
	public void initMessage() {
		ChatPacket cm = new ChatPacket("initMessage");
		cm.setMessage(client.username);
		writeCommand(cm);
	}
	
	public void addChat() {
		ChatPacket cm = new ChatPacket("startChat");
		writeCommand(cm);
	}
	
	public void joinChat(String chat) {
		ChatPacket cm = new ChatPacket("joinChat");
		cm.setMessage(chat);
		writeCommand(cm);
	}
	
	public void sendMessage(String message, String chat) {
		ChatPacket cm = new ChatPacket("sendMessage");
		cm.setMessage(message);
		cm.setChat(chat);
		writeCommand(cm);
	}
	
	public void joinPrivateChat(String clientName) {
		ChatPacket cm = new ChatPacket("joinPrivateChat");
		cm.setMessage(clientName);
		writeCommand(cm);
	}
	
	public void exitChat(String chat) {
		ChatPacket cm = new ChatPacket();
		cm.setCommand("exitChat");
		cm.setMessage(chat);
		writeCommand(cm);
	}
	
	public void exitPrivateChat(String clientName) {
		ChatPacket cm = new ChatPacket();
		cm.setCommand("exitPrivateChat");
		cm.setMessage(clientName);
		writeCommand(cm);
	}

	public void writeCommand(ChatPacket cm) {
		try {
			writer.writeObject(cm);
			writer.reset();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	class ListUpdater implements Runnable {
		ObservableList<String> list;
		
		public ListUpdater(ObservableList<String> list) {
			this.list = list;
		}

		@Override
		public void run() {
			ChatPacket message = null;
			
			// TODO Auto-generated method stub
			while (true) {
				synchronized(clientList) {
					try {
						while (((message = (ChatPacket) objectInput.readObject()) != null)) {
							System.out.println("from cc " + message.getMessage() + " " + message.getCommand() + " " +  message.getList());

							switch (message.getCommand()) {
								case "initMessage":
									clientNum = Integer.parseInt(message.getMessage());
									client.lobbyStage.setTitle("Client " + clientNum);
									break;
								case "groupChat":
									client.updateChat(message.getChat(), message.getMessage());
									break;
								case "privateChat":
									client.updatePrivateChat(message.getChat(), message.getMessage());
									break;
								case "joiningGroupChat":
									client.joiningGroupChat(message.getMessage());
									break;
								case "joiningPrivateChat":
									client.joiningPrivateChat(message.getChat(), message.getMessage());
									break;
								case "updateGroupClients":
									client.updateChatClients(message.getChat(), message.getList());
									break;
								case "updatePrivateClients":
									client.updatePrivateChatClients(message.getChat(), message.getList());
									break;
								case "updateLobbyChats":
									client.updateChatList(message.getList());
									break;
								case "updateLobbyClients":
									client.updateClientList(message.getList());
									break;
								case "exitedLobby":
									client.exitLobby();
									break;
								case "exitedPrivateChat":
									client.exitPrivateChat(message.getMessage());
									break;
							}
						}
					} catch (ClassNotFoundException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					} catch (IOException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					} catch (ClassCastException e) {
						System.out.println(message);
					}
				}
			}
		}
	}
}