import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import java.util.concurrent.atomic.AtomicInteger;

/*

* Individual ServerThread listens for the client to tell it what command to run, then

* runs that command and sends the output of that command to the client

*

*/

public class ServerThread extends Thread {

Socket client = null;

PrintWriter output;

BufferedReader input;

public ServerThread(Socket client) {

this.client = client;

}

public void run() {

System.out.print("Accepted connection. ");

try {

// open a new PrintWriter and BufferedReader on the socket

output = new PrintWriter(client.getOutputStream(), true);

input = new BufferedReader(new InputStreamReader(client.getInputStream()));

System.out.print("Reader and writer created. ");

String inString;

// read the command from the client

while ((inString = input.readLine()) == null);

System.out.println("Read command " + inString);

// run the command using CommandExecutor and get its output

String outString = CommandExecutor.run(inString);

System.out.println("Server sending result to client");

// send the result of the command to the client

output.println(outString);

}

catch (IOException e) {

e.printStackTrace();

}

finally {

// close the connection to the client

try {

client.close();

}

catch (IOException e) {

e.printStackTrace();

}

System.out.println("Output closed.");

}

}

}