import java.io.Console;

import java.io.IOException;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.net.Socket;

/*

This thread is responsible for reading user's input and send it to the server.

It runs in an infinite loop until the user types 'bye' to quit.

*/

public class WriteThread extends Thread {

private PrintWriter writer;

private Socket socket;

private ChatClient client;

public WriteThread(Socket socket, ChatClient client) {

this.socket = socket;

this.client = client;

try {

OutputStream output = socket.getOutputStream();

writer = new PrintWriter(output, true);

} catch (IOException ex) {

System.out.println("Error getting output stream: " + ex.getMessage());

ex.printStackTrace();

}

}

public void run() {

//System.console() used to read inout from the user

Console console = System.console();

//console.readLine() used to prompt the user to enter their name and

// messages to send to the server

String userName = console.readLine("\nEnter your name: ");

client.setUserName(userName);

writer.println(userName);

String text;

do {

text = console.readLine("[" + userName + "]: ");

// writer.println is used to send the user's name and message to

// the server

writer.println(text);

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

try {

socket.close();

} catch (IOException ex) {

System.out.println("Error writing to server: " + ex.getMessage());

}

}

}