/*
 * Copyright (c) 1995, 2008, Oracle and/or its affiliates. All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 *   - Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 *
 *   - Redistributions in binary form must reproduce the above copyright
 *     notice, this list of conditions and the following disclaimer in the
 *     documentation and/or other materials provided with the distribution.
 *
 *   - Neither the name of Oracle or the names of its
 *     contributors may be used to endorse or promote products derived
 *     from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
 * IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
 * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
 * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR
 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

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

//import KnockKnockServer.receiver;

public class KnockKnockServer {

    public static void main(String[] args) throws IOException {

        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(4444);
        } catch (IOException e) {
            System.err.println("Could not listen on port: 4444.");
            System.exit(1);
        }

        Socket clientSocket = null;
        try {
            clientSocket = serverSocket.accept();

            // KnockKnockServer newServer = new KnockKnockServer(); //SO-code
            // KnockKnockServer.receiver receiv = newServer.new
            // receiver(clientSocket);//SO-code
            // receiv.run(); //SO-code

        }  catch (SocketException e) {
            System.err.println("SocketException /!!!!.");
            System.exit(1);
        }
           catch (IOException e) {
            System.err.println("Accept failed.");
            System.exit(1);
        }

        /*
         * try { //new code KnockKnockServer newS = new KnockKnockServer();
         * KnockKnockServer.receiver receiv = newS.new receiver(clientSocket);
         * receiv.run(); } catch(IOException e) {
         * System.err.println("Accept failed."); System.exit(1); }
         */

        PrintWriter out;
        BufferedReader in;
        try {
            out = new PrintWriter(clientSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(
                    clientSocket.getInputStream()));
            String inputLine, outputLine;
            KnockKnockProtocol kkp = new KnockKnockProtocol();

            outputLine = kkp.processInput(null);
            out.println(outputLine);

            while ((inputLine = in.readLine()) != null) {
                outputLine = kkp.processInput(inputLine);
                out.println(outputLine);
                if (outputLine.equals("Bye."))
                    break;


                out.close();
                in.close();
                clientSocket.close();
                serverSocket.close();

            }
        } catch (SocketException e1) {
            System.out.println(" Socet exprssion");
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }

        catch (Exception e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }



        // Socket clientSocket = null;
/*      try {  commnted out 1238PM
            // clientSocket = serverSocket.accept();

            KnockKnockServer newServer = new KnockKnockServer(); // SO-code
            KnockKnockServer.receiver receive = newServer.new receiver(
                    clientSocket);// SO-code
            receive.run(); // SO-code

        } catch (IOException e) {
            System.err.println("NEW Accept failed.");
            System.exit(1);
        }*/

    }// end main



    // new code from SO
    public class receiver extends Thread {

        public boolean heartbeatmessage = false;

        Socket clientSocket = new Socket("localhost ", 4444);
        PrintWriter out; // =new PrintWriter(clientSocket.getOutputStream());

        public receiver(Socket clientsocket) throws IOException {
            clientSocket = clientsocket;
            out = new PrintWriter(clientSocket.getOutputStream(), true);
        }

        public void run() {

            while (true) {
                if (heartbeatmessage) {
                    try {
                        Thread.sleep(1000);
                        out.println("heartbeat");
                    } catch (InterruptedException e) {
                        System.out.println(" other side die");
                    }
                } else {
                    break;
                }

            }
        }
    }

    // </new code>

}