package alphatunnel;

import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.CharBuffer;
import java.util.logging.Level;
import java.util.logging.Logger;

public class client extends Thread {
    private static CharBuffer buffer;

    public static PrintWriter toClient;
    public static InputStreamReader fromClient;

    @Override
    public void run() {
        try {
            Main.log("Waiting for a connection on port 1337...");
            ServerSocket tunnel = new ServerSocket(1337);
            Socket sock = tunnel.accept();
            Main.log("\tConnection established or timed out.");

            if (sock.isConnected()) {
                Main.log("\tConnection established, continue.");

                Main.log("Starting server thread...");
                Thread sConn = new server(); sConn.start();

                toClient = new PrintWriter(sock.getOutputStream(), true);
                fromClient = new InputStreamReader(sock.getInputStream());

                while (true) {
                    if (fromClient.ready()) {
                        fromClient.read(buffer);
                        Main.log("Client: " + buffer);
                        server.toServer.append(buffer);
                    }
                }
            } else
                Main.log("\tConnection NOT established, halt.");
        } catch (IOException ex) {
            Logger.getLogger(client.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}