package apz.pirichat.client;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.IOException;
import java.net.Socket;
import apz.pirichat.shared.PiriSocket;
import apz.pirichat.shared.ChatMessage;

/*
    Client.java

    The PiriSale client executable
*/

public class Client
{
    public static void main(String[] args) throws Exception
    {
        BufferedReader userInput = new BufferedReader(new InputStreamReader(System.in));
        System.out.print("Welcome to PiriChat!\n\n");
        System.out.print("Please enter IP address of server to connect to:");
        String serverAddress = userInput.readLine();
        System.out.println("Connecting....");
        Socket socket = new Socket(serverAddress, 9999);
        System.out.println("Connected!");
        PiriSocket piriSocket = new PiriSocket(socket);
        piriSocket.sendMessage(new ChatMessage("*", "*", "init"));
        System.out.println("Connected!zz");
        // Create our two threads
        InputThread inputThread = new InputThread(userInput, piriSocket);
        RecieveThread recieveThread = new RecieveThread(piriSocket);
        // Run our threads
        inputThread.start();
        recieveThread.start();
    }

    public static void messageRecieved(ChatMessage chatMessage)
    {
        System.out.println(chatMessage.getMessage());
    }
}