import java.io.*;

import java.net.Socket;

/*

This thread handles connection for each connected client, so the server can handle

multiple clients at the same time.

*/

public class UserThread extends Thread {

private Socket socket;

private ChatServer server;

private PrintWriter writer;

public UserThread(Socket socket, ChatServer server) {

this.socket = socket;

this.server = server;

}

public void run() {

try {

InputStream input = socket.getInputStream();

BufferedReader reader = new BufferedReader(new InputStreamReader(input));

OutputStream output = socket.getOutputStream();

writer = new PrintWriter(output, true);

printUsers();

String userName = reader.readLine();

server.addUserName(userName);

String serverMessage = "New user connected: " + userName;

server.broadcast(serverMessage, this);

//sends message to all connected clients

String clientMessage;

do {

clientMessage = reader.readLine();

serverMessage = "[" + userName + "]: " + clientMessage;

server.broadcast(serverMessage, this);

} while (!clientMessage.equals("bye"));

server.removeUser(userName, this);

socket.close();

serverMessage = userName + " has quit.";

server.broadcast(serverMessage, this);

} catch (IOException ex) {

System.out.println("Error in UserThread: " + ex.getMessage());

ex.printStackTrace();

/*

This is often useful for debugging purposes, as it allows you to see

the sequence of method calls that led to the exception being thrown.

*/

}

}

/*

Sends a list of online users to the newly connected user.

*/

void printUsers() {

if (server.hasUsers()) {

writer.println("Connected users: " + server.getUserNames());

} else {

writer.println("No users connected");

}

}

/*

Sends a message to the client.

*/

void sendMessage(String message) {

writer.println(message);

}

}