import java.net.*;
import java.io.*;

public class ChatClient extends Thread {
  private Chatter chatter = null;
  private PrintWriter out = null;
  private BufferedReader in = null;

  public ChatClient(Chatter chatter) {
    this.chatter = chatter;
  }

  public void connect(String host, int port) {
    try {
      Socket socket= new Socket(host, port);
      in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      out = new PrintWriter(socket.getOutputStream(), true);
    } catch (IOException ioe) {
      System.out.println("COULD NOT CONNECT: "+ ioe);
    }
    start();
  }

  public void run() {
    while(true) {
      try {
        String tmp = in.readLine();
        chatter.receive(tmp);
      } catch(Exception e) {
        System.out.println("Exception generated: " + e);
      } 
    }
  }

  public void send(String message) {
    out.println(message);
  }
}