package httpserver;

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

public class HttpServerThread extends Thread {
    private Socket socket = null;
    private RequestHandler handler = null;
    private long connectionCounter;

    public HttpServerThread(Socket socket, RequestHandler handler, long connectionCounter) {
        super("HttpServerThread");
        this.socket = socket;
        this.handler = handler;
        this.connectionCounter = connectionCounter;
    }

    private void cleanUp() throws IOException {
        this.socket.close();
    }

    private void outputRequest(HttpRequest request) {
        System.out.println(request.toString());

        for (String headerName: request.getHeaderNames()) {
            String header = request.getHeader(headerName);
            System.out.println(String.format("%1s: %2s", headerName, header));
        }
    }

    public void run() {
        try {
            // Add a few extra seconds.
            socket.setSoTimeout((HttpServer.DEFAULT_TIMEOUT + 5) * 1000 );

            OutputStream socketOut = socket.getOutputStream();
            BufferedReader socketIn = new BufferedReader(
                    new InputStreamReader(socket.getInputStream()));

            HttpRequest request = null;
            HttpResponse response = null;

            do {
                try {
                    request = HttpRequest.fromReader(socketIn);
                    response = handler.handle(request);
                } catch (HttpError he) {
                    response = new StatusResponse(he.status);
                } catch (NoRequestException | java.net.SocketTimeoutException nre) {
                    // No request found, send no response and close the connection.
                    response = null;
                } catch (RuntimeException re) {
                    HttpStatus serverError = HttpStatus.ServerError();
                    serverError.setDetail(re.toString());
                    response = new StatusResponse(serverError);
                    re.printStackTrace();
                }

                if (response != null) {
                    response.write(socketOut);
                    socketOut.flush();
                    // Log request to stdout
                    System.out.println(
                        String.format("[%1$5d][%2$s][%3$s]",
                            connectionCounter, request.toString(), response.toString()
                    ));
                }

            } while (response != null && response.isPersistent());

            // Clean up
            socketOut.close();
            socketIn.close();
            socket.close();

        } catch (java.net.SocketException se) {
            se.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}